saqut
/
MWSE
1
1
Fork 0
Code Issues 10 Pull Requests Packages Projects 2 Releases 1 Wiki Activity

IPPressure sync bug fixed

This commit is contained in:
Abdussamed 2023-04-16 13:44:16 +03:00
parent 9ae492b318
commit fd414cc225
1 changed files with 7 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
Source/Services/IPPressure.js
View File

@ -1,9 +1,5 @@
const { Client } = require("../Client"); const { Client } = require("../Client");
let {addService, addListener} = require("../WebSocket.js"); let {addService, addListener} = require("../WebSocket.js");
let {
randomBytes
} = require("node:crypto");
const { slog } = require("../IPC");
class APNumber{ class APNumber{
/** /**
@ -36,12 +32,12 @@ class APNumber{
*/ */
static release(num) static release(num)
{ {
APNumber.busyNumbers.delete(num);
process.send({ process.send({
type: 'AP_NUMBER/RELEASE', type: 'AP_NUMBER/RELEASE',
uuid: APNumber.busyNumbers.get(num).id, uuid: APNumber.busyNumbers.get(num).id,
value: num value: num
}) })
APNumber.busyNumbers.delete(num);
} }
static whois(num){ static whois(num){
return APNumber.busyNumbers.get(num)?.id; return APNumber.busyNumbers.get(num)?.id;
@ -392,8 +388,8 @@ process.on('message',({type, uuid, value}) => {
if(client) if(client)
{ {
client.APNumber = value; client.APNumber = value;
client.sync('APNumber');
} }
break;
} }
case "AP_NUMBER/RELEASE":{ case "AP_NUMBER/RELEASE":{
console.log("S",process.pid, 'IPPressure SYNCED') console.log("S",process.pid, 'IPPressure SYNCED')
@ -402,8 +398,8 @@ process.on('message',({type, uuid, value}) => {
if(client) if(client)
{ {
client.APNumber = void 0; client.APNumber = void 0;
client.sync('APNumber');
} }
break;
} }
case "AP_SHORTCODE/LOCK":{ case "AP_SHORTCODE/LOCK":{
console.log("S",process.pid, 'IPPressure SYNCED') console.log("S",process.pid, 'IPPressure SYNCED')
@ -412,8 +408,8 @@ process.on('message',({type, uuid, value}) => {
if(client) if(client)
{ {
client.APShortCode = value; client.APShortCode = value;
client.sync('APShortCode');
} }
break;
} }
case "AP_SHORTCODE/RELEASE":{ case "AP_SHORTCODE/RELEASE":{
console.log("S",process.pid, 'IPPressure SYNCED') console.log("S",process.pid, 'IPPressure SYNCED')
@ -422,8 +418,8 @@ process.on('message',({type, uuid, value}) => {
if(client) if(client)
{ {
client.APShortCode = void 0; client.APShortCode = void 0;
client.sync('APShortCode');
} }
break;
} }
case "AP_IPADDRESS/LOCK":{ case "AP_IPADDRESS/LOCK":{
console.log("S",process.pid, 'IPPressure SYNCED') console.log("S",process.pid, 'IPPressure SYNCED')
@ -432,8 +428,8 @@ process.on('message',({type, uuid, value}) => {
if(client) if(client)
{ {
client.APIPAddress = value; client.APIPAddress = value;
client.sync('APIPAddress');
} }
break;
} }
case "AP_IPADDRESS/RELEASE":{ case "AP_IPADDRESS/RELEASE":{
console.log("S",process.pid, 'IPPressure SYNCED') console.log("S",process.pid, 'IPPressure SYNCED')
@ -442,8 +438,8 @@ process.on('message',({type, uuid, value}) => {
if(client) if(client)
{ {
client.APIPAddress = void 0; client.APIPAddress = void 0;
client.sync('APIPAddress');
} }
break;
} }
} }
}) })