diff --git a/src/PersistentPromise.ts b/src/PersistentPromise.ts index dc7d8c9..b7b2f59 100644 --- a/src/PersistentPromise.ts +++ b/src/PersistentPromise.ts @@ -11,10 +11,6 @@ export default class PersistentPromise { }); } - getPromise(): Promise { - return this.promise; - } - resolve(value?: any): void { if (this.promiseResolve) { this.promiseResolve(value); diff --git a/src/SmppSession.ts b/src/SmppSession.ts index 83edca9..96dc08c 100644 --- a/src/SmppSession.ts +++ b/src/SmppSession.ts @@ -22,7 +22,7 @@ export abstract class SmppSession { readonly counterUpdateTimer: any = new NanoTimer(); readonly MESSAGE_SEND_UPDATE_DELAY: number = Number(process.env.MESSAGE_SEND_UPDATE_DELAY) || 500; - constructor() { + protected constructor() { this.eventEmitter.on(this.EVENT.STATE_CHANGED, () => this.updateWs(this.EVENT.STATE_CHANGED)); this.eventEmitter.on(this.EVENT.STATUS_CHANGED, () => this.updateWs(this.EVENT.STATUS_CHANGED)); this.eventEmitter.on(this.EVENT.ANY_PDU, (pdu: any) => this.updateWs(this.EVENT.ANY_PDU, [pdu])); diff --git a/src/main.ts b/src/main.ts index ee96143..1e4bddf 100644 --- a/src/main.ts +++ b/src/main.ts @@ -8,7 +8,6 @@ import {PduProcessor} from "./PDUProcessor/PduProcessor"; import {WSServer} from "./WS/WSServer"; const {PDU} = require("smpp"); -// TODO: Add support for encodings let logger = new Logger("main"); @@ -17,7 +16,9 @@ PduProcessor.addProcessor(EchoPduProcessor); let clientManager: ClientSessionManager = new ClientSessionManager(); let centerManager: CenterSessionManager = new CenterSessionManager(); - +// TODO: Add support for encodings +// TODO: Fix reading and writing processors +// TODO: Try creating multiple entries with the same arg let wss: WSServer = new WSServer([clientManager, centerManager]); let httpServer: HttpServer = new HttpServer(clientManager, centerManager);