Skip to content

Commit

Permalink
resolved prettier issue
Browse files Browse the repository at this point in the history
Signed-off-by: Rinkal Bhojani <rinkal.bhojani@ayanworks.com>
  • Loading branch information
RinkalBhojani committed Dec 17, 2024
1 parent 64ab6a6 commit d7db235
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions src/transport/SocketDockInboundTransport.ts
Original file line number Diff line number Diff line change
Expand Up @@ -44,14 +44,14 @@ export class SocketDockInboundTransport implements InboundTransport {

try {
const socketId = this.activeConnections[connectionId]
agent.config.logger.debug(`activeConnections transport session : ${ socketId} ${connectionId}`)
agent.config.logger.debug(`activeConnections transport session : ${socketId} ${connectionId}`)
const sendUrl = req.body.meta.send
const requestMimeType = req.headers['content-type'] as string
const session = new SocketDockTransportSession(socketId, res, sendUrl, requestMimeType)
const message = req.body.message
const encryptedMessage = JSON.parse(message)

agent.config.logger.debug(`Session value for transport session : ${ session.id}`)
agent.config.logger.debug(`Session value for transport session : ${session.id}`)

agent.events.emit<AgentMessageReceivedEvent>(agent.context, {
type: AgentEventTypes.AgentMessageReceived,
Expand All @@ -70,15 +70,15 @@ export class SocketDockInboundTransport implements InboundTransport {
this.app.post('/disconnect', async (req, res) => {
agent.config.logger.info('SocketDockInboundTransport.disconnect')
const transportService = agent.dependencyManager.resolve(TransportService)
const { connection_id } = req.body
const { connection_id } = req.body
if (!connection_id) {
throw new Error('ConnectionId is not sent from socketDock server')
}

delete this.activeConnections[connection_id]
const session = transportService.findSessionById(connection_id)
agent.config.logger.debug(`Got session from transportService ${session?.id}`)
if(session) {
if (session) {
transportService.removeSession(session)
}

Expand Down

0 comments on commit d7db235

Please sign in to comment.