Skip to content

Commit

Permalink
fix:resolved comments
Browse files Browse the repository at this point in the history
Signed-off-by: pallavicoder <[email protected]>
  • Loading branch information
pallavighule committed Dec 4, 2024
1 parent 85c8c6b commit 8b221d1
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 6 deletions.
2 changes: 1 addition & 1 deletion src/agent.ts
Original file line number Diff line number Diff line change
Expand Up @@ -113,7 +113,7 @@ export async function createAgent() {
agent.registerInboundTransport(wsInboundTransport)
agent.registerOutboundTransport(wsOutboundTransport)
} else {
agent.registerInboundTransport(new SocketDockInboundTransport(app, logger, agent))
agent.registerInboundTransport(new SocketDockInboundTransport(app, logger))
}

// Added health check endpoint
Expand Down
8 changes: 3 additions & 5 deletions src/transport/SocketDockInboundTransport.ts
Original file line number Diff line number Diff line change
Expand Up @@ -6,16 +6,14 @@ import { WebSocketTransportSession } from './SocketDockTransportSession'
export class SocketDockInboundTransport implements InboundTransport {
private app: Express
private logger: Logger
private agent: Agent
private active_connections: Record<string, unknown> = {}
private active_connections: Record<string, string> = {}

constructor(app: Express, logger: Logger, agent: Agent) {
constructor(app: Express, logger: Logger) {
this.app = app
this.logger = logger
this.agent = agent
}

async start(agent: Agent<any>): Promise<void> {
public async start(agent: Agent<any>) {
this.app.post('/connect', async (req, res) => {
this.logger.info('SocketDockInboundTransport.connect')
const sendUrl = req.body.meta.send
Expand Down

0 comments on commit 8b221d1

Please sign in to comment.