Implement various getters and setters

This commit is contained in:
David Majdandžić
2023-03-28 20:12:11 +02:00
parent 5f32eb127d
commit 9c0de4ef3c
2 changed files with 18 additions and 15 deletions

View File

@@ -1,6 +1,5 @@
import EventEmitter from "events"; import EventEmitter from "events";
import {ClientEvents} from "../Client/ClientEvents"; import {ClientEvents} from "../Client/ClientEvents";
import ClientStatus from "../Client/ClientStatus";
import {Job} from "../Job/Job"; import {Job} from "../Job/Job";
import {JobEvents} from "../Job/JobEvents"; import {JobEvents} from "../Job/JobEvents";
import Logger from "../Logger"; import Logger from "../Logger";
@@ -134,19 +133,24 @@ export class Center implements SmppSession {
} }
close(): Promise<void> { close(): Promise<void> {
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 { getDefaultMultipleJob(): Job {
throw new Error("NEBI"); return this.getDefaultSingleJob();
} }
getDefaultSingleJob(): Job { getDefaultSingleJob(): Job {
throw new Error("NEBI"); return this.defaultSingleJob;
} }
getId(): number { getId(): number {
throw new Error("NEBI"); return this.id;
} }
sendMultiple(job: Job): Promise<void> { sendMultiple(job: Job): Promise<void> {
@@ -220,11 +224,11 @@ export class Center implements SmppSession {
} }
setDefaultMultipleJob(job: Job): void { setDefaultMultipleJob(job: Job): void {
throw new Error("NEBI"); this.defaultMultipleJob = job;
} }
setDefaultSingleJob(job: Job): void { setDefaultSingleJob(job: Job): void {
throw new Error("NEBI"); this.defaultSingleJob = job;
} }
private validateSessions(reject: (reason?: any) => void) { private validateSessions(reject: (reason?: any) => void) {
@@ -297,8 +301,6 @@ export class Center implements SmppSession {
} }
private eventAnyPdu(pdu: any): void { private eventAnyPdu(pdu: any): void {
console.log("eventAnyPdu");
// console.log(pdu);
this.eventEmitter.emit(CenterEvents.ANY_PDU, pdu); this.eventEmitter.emit(CenterEvents.ANY_PDU, pdu);
} }
} }

View File

@@ -60,12 +60,13 @@ async function main() {
let center: Center = new Center(0, 7000, "test", "test"); let center: Center = new Center(0, 7000, "test", "test");
setTimeout(() => { setTimeout(() => {
center.sendMultiple(new Job(new PDU("deliver_sm", { // center.sendMultiple(new Job(new PDU("deliver_sm", {
source_addr: "1234567890", // source_addr: "1234567890",
destination_addr: "1234567890", // destination_addr: "1234567890",
short_message: "Hello World" // short_message: "Hello World"
}), 100, 100)); // }), 100, 100));
}, 10000); center.close();
}, 1000);
} }
main(); main();