diff --git a/src/Center/Center.ts b/src/Center/Center.ts index 31490b4..1cb6bce 100644 --- a/src/Center/Center.ts +++ b/src/Center/Center.ts @@ -1,6 +1,5 @@ import EventEmitter from "events"; import {ClientEvents} from "../Client/ClientEvents"; -import ClientStatus from "../Client/ClientStatus"; import {Job} from "../Job/Job"; import {JobEvents} from "../Job/JobEvents"; import Logger from "../Logger"; @@ -134,19 +133,24 @@ export class Center implements SmppSession { } close(): Promise { - throw new Error("NEBI"); + return new Promise((resolve, reject) => { + this.logger.log1(`Center-${this._id} closing...`); + this.server.close(); + this.status = CenterStatus.WAITING_CONNECTION; + resolve(); + }); } getDefaultMultipleJob(): Job { - throw new Error("NEBI"); + return this.getDefaultSingleJob(); } getDefaultSingleJob(): Job { - throw new Error("NEBI"); + return this.defaultSingleJob; } getId(): number { - throw new Error("NEBI"); + return this.id; } sendMultiple(job: Job): Promise { @@ -220,11 +224,11 @@ export class Center implements SmppSession { } setDefaultMultipleJob(job: Job): void { - throw new Error("NEBI"); + this.defaultMultipleJob = job; } setDefaultSingleJob(job: Job): void { - throw new Error("NEBI"); + this.defaultSingleJob = job; } private validateSessions(reject: (reason?: any) => void) { @@ -297,8 +301,6 @@ export class Center implements SmppSession { } private eventAnyPdu(pdu: any): void { - console.log("eventAnyPdu"); - // console.log(pdu); this.eventEmitter.emit(CenterEvents.ANY_PDU, pdu); } } \ No newline at end of file diff --git a/src/main.ts b/src/main.ts index d84ba9c..6b6b102 100644 --- a/src/main.ts +++ b/src/main.ts @@ -60,12 +60,13 @@ async function main() { let center: Center = new Center(0, 7000, "test", "test"); setTimeout(() => { - center.sendMultiple(new Job(new PDU("deliver_sm", { - source_addr: "1234567890", - destination_addr: "1234567890", - short_message: "Hello World" - }), 100, 100)); - }, 10000); + // center.sendMultiple(new Job(new PDU("deliver_sm", { + // source_addr: "1234567890", + // destination_addr: "1234567890", + // short_message: "Hello World" + // }), 100, 100)); + center.close(); + }, 1000); } main();