dave/smsgw-tester
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix center status

Browse Source
This commit is contained in:
David Majdandžić
2023-04-06 19:05:26 +02:00
parent 00750ba862
commit 577bca0c5c
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/Center/Center.ts
View File

@@ -113,7 +113,7 @@ export default class Center extends SmppSession {
let count = job.count || 1; let count = job.count || 1;
let interval = 1 / (job.perSecond || 1); let interval = 1 / (job.perSecond || 1);
this.setStatus(3); this.setStatus(4);
this.sendTimer.setInterval(() => { this.sendTimer.setInterval(() => {
if (count > 0 && counter >= count) { if (count > 0 && counter >= count) {
this.cancelSendInterval(); this.cancelSendInterval();
@@ -130,7 +130,7 @@ export default class Center extends SmppSession {
this.server = smpp.createServer({}, this.eventSessionConnected.bind(this)); this.server = smpp.createServer({}, this.eventSessionConnected.bind(this));
this.server.on('error', this.eventServerError.bind(this)); this.server.on('error', this.eventServerError.bind(this));
this.doListen(); this.doListen();
this.setStatus(0); this.setStatus(1);
} }
close(): Promise<void> { close(): Promise<void> {
@@ -140,7 +140,7 @@ export default class Center extends SmppSession {
this.sessions.forEach((session: any) => { this.sessions.forEach((session: any) => {
session.close(); session.close();
}); });
this.setStatus(0); this.setStatus(1);
resolve(); resolve();
}); });
} }
@@ -163,11 +163,11 @@ export default class Center extends SmppSession {
updateStatus(): void { updateStatus(): void {
if (this.sessions.length > 0) { if (this.sessions.length > 0) {
this.setStatus(2); this.setStatus(3);
} else if (this.pendingSessions.length > 0) { } else if (this.pendingSessions.length > 0) {
this.setStatus(1); this.setStatus(2);
} else { } else {
this.setStatus(0); this.setStatus(1);
} }
} }
@@ -206,6 +206,7 @@ export default class Center extends SmppSession {
private eventServerError(): void { private eventServerError(): void {
this.logger.log1(`Center tried listening on port which is already in use, retrying in ${PORT_RELISTEN_DELAY}`); this.logger.log1(`Center tried listening on port which is already in use, retrying in ${PORT_RELISTEN_DELAY}`);
this.setStatus(0);
setTimeout(this.doListen.bind(this), PORT_RELISTEN_DELAY); setTimeout(this.doListen.bind(this), PORT_RELISTEN_DELAY);
} }