@aries-framework/node
Advanced tools
Comparing version 0.1.0-alpha.253 to 0.1.0-alpha.254
@@ -1,7 +0,10 @@ | ||
import type { InboundTransporter, Agent, TransportSession, WireMessage } from '@aries-framework/core'; | ||
/// <reference types="node" /> | ||
import type { InboundTransport, Agent, TransportSession, WireMessage } from '@aries-framework/core'; | ||
import type { Express, Request, Response } from 'express'; | ||
export declare class HttpInboundTransport implements InboundTransporter { | ||
import type { Server } from 'http'; | ||
export declare class HttpInboundTransport implements InboundTransport { | ||
readonly app: Express; | ||
private port; | ||
private server?; | ||
private _server?; | ||
get server(): Server | undefined; | ||
constructor({ app, port }: { | ||
@@ -8,0 +11,0 @@ app?: Express; |
@@ -35,8 +35,10 @@ "use strict"; | ||
} | ||
get server() { | ||
return this._server; | ||
} | ||
async start(agent) { | ||
const transportService = agent.injectionContainer.resolve(core_1.TransportService); | ||
const config = agent.injectionContainer.resolve(core_1.AgentConfig); | ||
config.logger.debug(`Starting HTTP inbound transporter`, { | ||
config.logger.debug(`Starting HTTP inbound transport`, { | ||
port: this.port, | ||
endpoint: config.getEndpoint(), | ||
}); | ||
@@ -62,7 +64,7 @@ this.app.post('/', async (req, res) => { | ||
}); | ||
this.server = this.app.listen(this.port); | ||
this._server = this.app.listen(this.port); | ||
} | ||
async stop() { | ||
var _a; | ||
(_a = this.server) === null || _a === void 0 ? void 0 : _a.close(); | ||
(_a = this._server) === null || _a === void 0 ? void 0 : _a.close(); | ||
} | ||
@@ -69,0 +71,0 @@ } |
@@ -1,4 +0,4 @@ | ||
import type { Agent, InboundTransporter, TransportSession, WireMessage } from '@aries-framework/core'; | ||
import type { Agent, InboundTransport, TransportSession, WireMessage } from '@aries-framework/core'; | ||
import WebSocket, { Server } from 'ws'; | ||
export declare class WsInboundTransport implements InboundTransporter { | ||
export declare class WsInboundTransport implements InboundTransport { | ||
private socketServer; | ||
@@ -5,0 +5,0 @@ private logger; |
@@ -35,4 +35,5 @@ "use strict"; | ||
this.logger = config.logger; | ||
this.logger.debug(`Starting HTTP inbound transporter`, { | ||
endpoint: config.getEndpoint(), | ||
const wsEndpoint = config.endpoints.find((e) => e.startsWith('ws')); | ||
this.logger.debug(`Starting WS inbound transport`, { | ||
endpoint: wsEndpoint, | ||
}); | ||
@@ -39,0 +40,0 @@ this.socketServer.on('connection', (socket) => { |
@@ -5,3 +5,3 @@ { | ||
"types": "build/index", | ||
"version": "0.1.0-alpha.253+895f7d0", | ||
"version": "0.1.0-alpha.254+56cb9f2", | ||
"files": [ | ||
@@ -27,3 +27,3 @@ "build" | ||
"dependencies": { | ||
"@aries-framework/core": "0.1.0-alpha.253+895f7d0", | ||
"@aries-framework/core": "0.1.0-alpha.254+56cb9f2", | ||
"express": "^4.17.1", | ||
@@ -42,3 +42,3 @@ "indy-sdk": "^1.16.0-dev-1634", | ||
}, | ||
"gitHead": "895f7d084287f99221c9492a25fed58191868edd" | ||
"gitHead": "56cb9f2202deb83b3c133905f21651bfefcb63f7" | ||
} |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Manifest confusion
Supply chain riskThis package has inconsistent metadata. This could be malicious or caused by an error when publishing the package.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Manifest confusion
Supply chain riskThis package has inconsistent metadata. This could be malicious or caused by an error when publishing the package.
Found 1 instance in 1 package
32062
325