diff --git a/app.js b/app.js index 1754c87..31486f3 100644 --- a/app.js +++ b/app.js @@ -1,567 +1,568 @@ -require('dotenv').config({ path: '.env' }); -require('events').EventEmitter.prototype._maxListeners = 30; +require("dotenv").config({ path: ".env" }); +require("events").EventEmitter.prototype._maxListeners = 30; // start for gps-tracking -const net = require('net'); -const dgram = require('dgram'); -const crc = require('crc'); -const moment = require('moment'); -const LibDevice = require('./library/LibDevice'); -const GpsTracksModels = require('./models/GpsTracksModels'); -const ZoneModels = require('./models/ZoneModels'); -const VhcModels = require('./models/VhcModels'); -const LibMail = require('./library/LibMail'); -const LibHelper = require('./library/LibHelper'); -const nanoid = require('nanoid').nanoid; +const net = require("net"); +const dgram = require("dgram"); +const crc = require("crc"); +const moment = require("moment"); +const LibDevice = require("./library/LibDevice"); +const GpsTracksModels = require("./models/GpsTracksModels"); +const ZoneModels = require("./models/ZoneModels"); +const VhcModels = require("./models/VhcModels"); +const LibMail = require("./library/LibMail"); +const LibHelper = require("./library/LibHelper"); +const nanoid = require("nanoid").nanoid; // end for gps-tracking // start for normal http request -const express = require('express'); -const LibBullAdapter = require('./library/LibBullAdapter'); -const routes = require('./routes/routes'); +const express = require("express"); +// const LibBullAdapter = require('./library/LibBullAdapter'); +const routes = require("./routes/routes"); // const routes = require('./routes/routes_without_scheduler'); const app = express(); // end for normal http request // start for logging -const LibWinston = require('./library/LibWinston'); +const LibWinston = require("./library/LibWinston"); -const logName = 'libUdp'; +const logName = "libUdp"; const Logger = LibWinston.initialize(logName); // end for logging // start commit / log message from gps async function commitMessage(now, logDevice) { - try { - // don't log - if (!logDevice.original_hex) { - return false; - } - // in the future don't log to db if device_id not found in vhc - const vhc = await VhcModels.getVhcByDeviceId(logDevice.device_id); - const lastTrack = await GpsTracksModels.get2LastLocByDeviceId(logDevice.device_id); + try { + // don't log + if (!logDevice.original_hex) { + return false; + } + // in the future don't log to db if device_id not found in vhc + const vhc = await VhcModels.getVhcByDeviceId(logDevice.device_id); + const lastTrack = await GpsTracksModels.get2LastLocByDeviceId(logDevice.device_id); - if (['heartbeat', 'alarm'].includes(logDevice.action)) { - // set engine stts moving,idling,stopped - if (logDevice.ignition == GpsTracksModels.STTS_IGNITION_HIGH) { - if (logDevice.speed) { - logDevice.stts_engine = GpsTracksModels.STTS_EN_MOVING; - } else { - if (lastTrack.length > 0) { - const checkLastHeartbeat = await GpsTracksModels.getLastHeartbeatToDeterminIdling(logDevice.device_id, lastTrack[0].crt, now); - if (checkLastHeartbeat.length >= 3) { - logDevice.stts_engine = GpsTracksModels.STTS_EN_IDLING; - } else { - logDevice.stts_engine = lastTrack[0].stts_engine; - } - } - } - } else { - logDevice.stts_engine = GpsTracksModels.STTS_EN_STOPING; - } - } - // get last ignition, stts_engine, stts_alarm, stts_charge, stts_acc, stts_volt, stts_switch - if (['location'].includes(logDevice.action)) { - // get last ignition - const lastHeartbeatOrAlarm = await GpsTracksModels.get2LastHeartbeatOrAlarm(logDevice.device_id); - if (lastHeartbeatOrAlarm.length > 0) { - logDevice.ignition = lastHeartbeatOrAlarm[0].ignition; - logDevice.stts_gps = lastHeartbeatOrAlarm[0].stts_gps; - logDevice.stts_gsm = lastHeartbeatOrAlarm[0].stts_gsm; - } else { - logDevice.ignition = lastHeartbeatOrAlarm[0].ignition; - logDevice.stts_gps = lastHeartbeatOrAlarm[0].stts_gps; - logDevice.stts_gsm = lastHeartbeatOrAlarm[0].stts_gsm; - } - // set engine stts moving,idling,stopped - if (logDevice.ignition == GpsTracksModels.STTS_IGNITION_HIGH) { - if (logDevice.speed) { - logDevice.stts_engine = GpsTracksModels.STTS_EN_MOVING; - } else { - if (lastTrack.length > 0) { - const checkLastHeartbeat = await GpsTracksModels.getLastHeartbeatToDeterminIdling(logDevice.device_id, lastTrack[0].crt, now); - if (checkLastHeartbeat.length >= 3) { - logDevice.stts_engine = GpsTracksModels.STTS_EN_IDLING; - } else { - logDevice.stts_engine = lastTrack[0].stts_engine; - } - } - } - // get stts_alarm, stts_charge, stts_acc, stts_volt, stts_switch - } else { - logDevice.stts_engine = GpsTracksModels.STTS_EN_STOPING; - } - logDevice.stts_oil_electricity = lastHeartbeatOrAlarm[0].stts_oil_electricity; - logDevice.stts_alarm = lastHeartbeatOrAlarm[0].stts_alarm; - logDevice.stts_charge = lastHeartbeatOrAlarm[0].stts_charge; - logDevice.stts_acc = lastHeartbeatOrAlarm[0].stts_acc; - logDevice.stts_volt = lastHeartbeatOrAlarm[0].stts_volt; - logDevice.stts_switch = lastHeartbeatOrAlarm[0].stts_switch; - } + if (["heartbeat", "alarm"].includes(logDevice.action)) { + // set engine stts moving,idling,stopped + if (logDevice.ignition == GpsTracksModels.STTS_IGNITION_HIGH) { + if (logDevice.speed) { + logDevice.stts_engine = GpsTracksModels.STTS_EN_MOVING; + } else { + if (lastTrack.length > 0) { + const checkLastHeartbeat = await GpsTracksModels.getLastHeartbeatToDeterminIdling(logDevice.device_id, lastTrack[0].crt, now); + if (checkLastHeartbeat.length >= 3) { + logDevice.stts_engine = GpsTracksModels.STTS_EN_IDLING; + } else { + logDevice.stts_engine = lastTrack[0].stts_engine; + } + } + } + } else { + logDevice.stts_engine = GpsTracksModels.STTS_EN_STOPING; + } + } + // get last ignition, stts_engine, stts_alarm, stts_charge, stts_acc, stts_volt, stts_switch + if (["location"].includes(logDevice.action)) { + // get last ignition + const lastHeartbeatOrAlarm = await GpsTracksModels.get2LastHeartbeatOrAlarm(logDevice.device_id); + if (lastHeartbeatOrAlarm.length > 0) { + logDevice.ignition = lastHeartbeatOrAlarm[0].ignition; + logDevice.stts_gps = lastHeartbeatOrAlarm[0].stts_gps; + logDevice.stts_gsm = lastHeartbeatOrAlarm[0].stts_gsm; + } else { + logDevice.ignition = lastHeartbeatOrAlarm[0].ignition; + logDevice.stts_gps = lastHeartbeatOrAlarm[0].stts_gps; + logDevice.stts_gsm = lastHeartbeatOrAlarm[0].stts_gsm; + } + // set engine stts moving,idling,stopped + if (logDevice.ignition == GpsTracksModels.STTS_IGNITION_HIGH) { + if (logDevice.speed) { + logDevice.stts_engine = GpsTracksModels.STTS_EN_MOVING; + } else { + if (lastTrack.length > 0) { + const checkLastHeartbeat = await GpsTracksModels.getLastHeartbeatToDeterminIdling(logDevice.device_id, lastTrack[0].crt, now); + if (checkLastHeartbeat.length >= 3) { + logDevice.stts_engine = GpsTracksModels.STTS_EN_IDLING; + } else { + logDevice.stts_engine = lastTrack[0].stts_engine; + } + } + } + // get stts_alarm, stts_charge, stts_acc, stts_volt, stts_switch + } else { + logDevice.stts_engine = GpsTracksModels.STTS_EN_STOPING; + } + logDevice.stts_oil_electricity = lastHeartbeatOrAlarm[0].stts_oil_electricity; + logDevice.stts_alarm = lastHeartbeatOrAlarm[0].stts_alarm; + logDevice.stts_charge = lastHeartbeatOrAlarm[0].stts_charge; + logDevice.stts_acc = lastHeartbeatOrAlarm[0].stts_acc; + logDevice.stts_volt = lastHeartbeatOrAlarm[0].stts_volt; + logDevice.stts_switch = lastHeartbeatOrAlarm[0].stts_switch; + } - // sekarang heartbeat diinject data lokasi juga dari lokasi terakhir - if (['heartbeat'].includes(logDevice.action)) { - if (lastTrack.length > 0) { - logDevice.latitude = lastTrack[0].latitude; - logDevice.longitude = lastTrack[0].longitude; - logDevice.speed = lastTrack[0].speed; - logDevice.orientation = lastTrack[0].orientation; - if (logDevice.latitude) { - logDevice.stts_reverse_geo = GpsTracksModels.STTS_REVERSE_GEO_NOT; - } - - logDevice.length_gps = lastTrack[0].length_gps; - logDevice.pos_stlt_gps = lastTrack[0].pos_stlt_gps; - logDevice.pos_type_gps = lastTrack[0].pos_type_gps; - logDevice.is_pos_gps = lastTrack[0].is_pos_gps; + // sekarang heartbeat diinject data lokasi juga dari lokasi terakhir + if (["heartbeat"].includes(logDevice.action)) { + if (lastTrack.length > 0) { + logDevice.latitude = lastTrack[0].latitude; + logDevice.longitude = lastTrack[0].longitude; + logDevice.speed = lastTrack[0].speed; + logDevice.orientation = lastTrack[0].orientation; + if (logDevice.latitude) { + logDevice.stts_reverse_geo = GpsTracksModels.STTS_REVERSE_GEO_NOT; + } - // jika gapengen dimunculin di last movement - // logDevice.crt = lastTrack[0].crt; - // logDevice.crt_format = lastTrack[0].crt_format; - // logDevice.crt_d = lastTrack[0].crt_d; - // logDevice.crt_d_format = lastTrack[0].crt_d_format; - // jika pengen di munculin di last movement - logDevice.crt = now; - logDevice.crt_format = moment.unix(now).format('YYYY-MM-DD HH:mm:ss'); - logDevice.crt_d = now; - logDevice.crt_d_format = moment.unix(now).format('YYYY-MM-DD HH:mm:ss'); - } - } + logDevice.length_gps = lastTrack[0].length_gps; + logDevice.pos_stlt_gps = lastTrack[0].pos_stlt_gps; + logDevice.pos_type_gps = lastTrack[0].pos_type_gps; + logDevice.is_pos_gps = lastTrack[0].is_pos_gps; - // count milleage - if (logDevice.latitude != null && logDevice.longitude != null && lastTrack.length > 0) { - const distance = LibHelper.haversineGreatCircleDistance(lastTrack[0].latitude, lastTrack[0].longitude, logDevice.latitude, logDevice.longitude, LibHelper.EARTH_RADIUS_KM); - const distance_km = LibHelper.kmToKm(distance, 100000000); - // console.log(`GPS TRACKER UP LOCATION => device_id:${logDevice.device_id} vhc_id:${(vhc[0]) ? vhc[0].vid : 0}, distance_km:${distance_km}`); - // validasi jika lebih dari 3km, ga disimpan - if (distance_km >= 3) { - GpsTracksModels.bundleCreate2(logDevice, logDevice); // jika tidak disimpan malah jadi bug, jadi akan update lokasi terus dengan kalkulasi jarak sebelumnya jadi makan lama makin lebar, mending disimpen terus milleagenya jadi 0 aja - return false; - } - logDevice.pre_milleage = distance_km; - logDevice.sum_milleage = (lastTrack[0].sum_milleage + logDevice.pre_milleage).toFixed(8); - if (vhc.length > 0) { - logDevice.vhc_id = (vhc[0]) ? vhc[0].vid : 0; - if (lastTrack[0].vhc_id == logDevice.vhc_id) { - logDevice.vhc_milleage = (lastTrack[0].vhc_milleage + logDevice.pre_milleage).toFixed(8); - } else { - logDevice.vhc_milleage = ((vhc[0]) ? vhc[0].sum_milleage : 0 + logDevice.pre_milleage).toFixed(8); - } - VhcModels.update((vhc[0]) ? vhc[0].vid : 0, { sum_milleage: logDevice.vhc_milleage }); - } - } + // jika gapengen dimunculin di last movement + // logDevice.crt = lastTrack[0].crt; + // logDevice.crt_format = lastTrack[0].crt_format; + // logDevice.crt_d = lastTrack[0].crt_d; + // logDevice.crt_d_format = lastTrack[0].crt_d_format; + // jika pengen di munculin di last movement + logDevice.crt = now; + logDevice.crt_format = moment.unix(now).format("YYYY-MM-DD HH:mm:ss"); + logDevice.crt_d = now; + logDevice.crt_d_format = moment.unix(now).format("YYYY-MM-DD HH:mm:ss"); + } + } - // truck zoning spawn - if (logDevice.latitude != null && logDevice.longitude != null) { // && vhc.length > 0 - // log tracking - const currTrack = await GpsTracksModels.bundleCreate2(logDevice, logDevice); - // console.log('GT06 HAS LOCATION AND CHECK ZONE'); - const inCircle = await ZoneModels.getInCircle(logDevice.latitude, logDevice.longitude); - const inShape = await ZoneModels.getInShape(logDevice.latitude, logDevice.longitude); - const insideSpawnZone = []; - for (let zone of inCircle) { - insideSpawnZone.push(zone); - } - for (let zone of inShape) { - insideSpawnZone.push(zone); - } + // count milleage + if (logDevice.latitude != null && logDevice.longitude != null && lastTrack.length > 0) { + const distance = LibHelper.haversineGreatCircleDistance(lastTrack[0].latitude, lastTrack[0].longitude, logDevice.latitude, logDevice.longitude, LibHelper.EARTH_RADIUS_KM); + const distance_km = LibHelper.kmToKm(distance, 100000000); + // console.log(`GPS TRACKER UP LOCATION => device_id:${logDevice.device_id} vhc_id:${(vhc[0]) ? vhc[0].vid : 0}, distance_km:${distance_km}`); + // validasi jika lebih dari 3km, ga disimpan + if (distance_km >= 3) { + GpsTracksModels.bundleCreate2(logDevice, logDevice); // jika tidak disimpan malah jadi bug, jadi akan update lokasi terus dengan kalkulasi jarak sebelumnya jadi makan lama makin lebar, mending disimpen terus milleagenya jadi 0 aja + return false; + } + logDevice.pre_milleage = distance_km; + logDevice.sum_milleage = (lastTrack[0].sum_milleage + logDevice.pre_milleage).toFixed(8); + if (vhc.length > 0) { + logDevice.vhc_id = vhc[0] ? vhc[0].vid : 0; + if (lastTrack[0].vhc_id == logDevice.vhc_id) { + logDevice.vhc_milleage = (lastTrack[0].vhc_milleage + logDevice.pre_milleage).toFixed(8); + } else { + logDevice.vhc_milleage = (vhc[0] ? vhc[0].sum_milleage : 0 + logDevice.pre_milleage).toFixed(8); + } + VhcModels.update(vhc[0] ? vhc[0].vid : 0, { sum_milleage: logDevice.vhc_milleage }); + } + } - /** - * get lastSpawn desc index 0, where leave_at = 0 - * kalo gaada create, dengan isi field enter_at aja, kalo ada didalam zona - * kalo ada update, dengan isi field leave_at aja, kalo udah diluar zona - */ - const lastSpawn = await GpsTracksModels.listSpawnZone({ - source: GpsTracksModels.SOURCE_GPS_TRACKER, - device_id: logDevice.device_id, - vhc_id: (vhc[0]) ? vhc[0].vid : 0, - leave_at_d: 0, - order_by: 'ORDER BY id DESC', - limit: 1, - }); + // truck zoning spawn + if (logDevice.latitude != null && logDevice.longitude != null) { + // && vhc.length > 0 + // log tracking + const currTrack = await GpsTracksModels.bundleCreate2(logDevice, logDevice); + // console.log('GT06 HAS LOCATION AND CHECK ZONE'); + const inCircle = await ZoneModels.getInCircle(logDevice.latitude, logDevice.longitude); + const inShape = await ZoneModels.getInShape(logDevice.latitude, logDevice.longitude); + const insideSpawnZone = []; + for (let zone of inCircle) { + insideSpawnZone.push(zone); + } + for (let zone of inShape) { + insideSpawnZone.push(zone); + } - if (lastSpawn.length > 0) { - let is_leave_zone = 1; - for (const insideZone of insideSpawnZone) { - if (insideZone.zid === lastSpawn[0].zone_id) is_leave_zone = 0; - } - if (is_leave_zone === 1 && lastSpawn[0].device_id == logDevice.device_id) { - GpsTracksModels.updt2SpawnZone({ - leave_lat: logDevice.latitude, - leave_lng: logDevice.longitude, - leave_at_d: logDevice.crt_d || now, - leave_at_d_format: moment.unix(logDevice.crt_d || now).format('YYYY-MM-DD HH:mm:ss'), - leave_at_s: now, - leave_at_s_format: moment.unix(now).format('YYYY-MM-DD HH:mm:ss'), - updt: now, - updt_format: moment.unix(now).format('YYYY-MM-DD HH:mm:ss'), - }, lastSpawn[0].id); - } - } else { - for (let zone of insideSpawnZone) { - let mailData = { - pic_name: zone.pic_name, - pic_mail: zone.pic_mail, - z_name: zone.name, - z_type_name: zone.type_name, - z_workflow_name: zone.workflow_type_name, - shiptocode: zone.shiptocode, - z_fulladdress: zone.fulladdress, - v_nopol: ((vhc[0]) ? vhc[0].nopol1 : 0 || '') + ((vhc[0]) ? vhc[0].nopol2 : 0 || '') + ((vhc[0]) ? vhc[0].nopol3 : 0 || ''), - da_name: (vhc[0]) ? vhc[0].da_name : 0 || '', - da_phone: '+' + ((vhc[0]) ? vhc[0].da_phone_code : 0 || '') + ((vhc[0]) ? vhc[0].da_phone : 0 || ''), - }; - // LibMail.sendVhcSpawnZoneMail(`${(vhc[0]) ? vhc[0].nopol1 : 0 || ''}${(vhc[0]) ? vhc[0].nopol2 : 0 || ''}${(vhc[0]) ? vhc[0].nopol3 : 0 || ''} entering zone ${mailData.z_name}`, mailData.pic_mail, mailData); - - if (logDevice.device_id === '0865784052395871') console.log(1234567890); - GpsTracksModels.create2SpawnZone({ - device_id: logDevice.device_id, - master_id: Number(currTrack.result.insertId), - enter_lat: logDevice.latitude, - enter_lng: logDevice.longitude, - enter_at_d: logDevice.crt_d || now, - enter_at_d_format: moment.unix(logDevice.crt_d || now).format('YYYY-MM-DD HH:mm:ss'), - enter_at_s: now, - enter_at_s_format: moment.unix(now).format('YYYY-MM-DD HH:mm:ss'), - zone_id: zone.zid, - zone_name: zone.name, - vhc_id: (vhc[0]) ? vhc[0].vid : 0, - source: GpsTracksModels.SOURCE_GPS_TRACKER, - crt: now, - crt_format: moment.unix(now).format('YYYY-MM-DD HH:mm:ss'), - }); - if (logDevice.device_id === '0865784052395871') console.log('DISINI'); - } - } - } else { - // log tracking - GpsTracksModels.bundleCreate2(logDevice, logDevice); - } - } catch (e) { - console.error(e); - } + /** + * get lastSpawn desc index 0, where leave_at = 0 + * kalo gaada create, dengan isi field enter_at aja, kalo ada didalam zona + * kalo ada update, dengan isi field leave_at aja, kalo udah diluar zona + */ + const lastSpawn = await GpsTracksModels.listSpawnZone({ + source: GpsTracksModels.SOURCE_GPS_TRACKER, + device_id: logDevice.device_id, + vhc_id: vhc[0] ? vhc[0].vid : 0, + leave_at_d: 0, + order_by: "ORDER BY id DESC", + limit: 1, + }); + + if (lastSpawn.length > 0) { + let is_leave_zone = 1; + for (const insideZone of insideSpawnZone) { + if (insideZone.zid === lastSpawn[0].zone_id) is_leave_zone = 0; + } + if (is_leave_zone === 1 && lastSpawn[0].device_id == logDevice.device_id) { + GpsTracksModels.updt2SpawnZone( + { + leave_lat: logDevice.latitude, + leave_lng: logDevice.longitude, + leave_at_d: logDevice.crt_d || now, + leave_at_d_format: moment.unix(logDevice.crt_d || now).format("YYYY-MM-DD HH:mm:ss"), + leave_at_s: now, + leave_at_s_format: moment.unix(now).format("YYYY-MM-DD HH:mm:ss"), + updt: now, + updt_format: moment.unix(now).format("YYYY-MM-DD HH:mm:ss"), + }, + lastSpawn[0].id + ); + } + } else { + for (let zone of insideSpawnZone) { + let mailData = { + pic_name: zone.pic_name, + pic_mail: zone.pic_mail, + z_name: zone.name, + z_type_name: zone.type_name, + z_workflow_name: zone.workflow_type_name, + shiptocode: zone.shiptocode, + z_fulladdress: zone.fulladdress, + v_nopol: (vhc[0] ? vhc[0].nopol1 : 0 || "") + (vhc[0] ? vhc[0].nopol2 : 0 || "") + (vhc[0] ? vhc[0].nopol3 : 0 || ""), + da_name: vhc[0] ? vhc[0].da_name : 0 || "", + da_phone: "+" + (vhc[0] ? vhc[0].da_phone_code : 0 || "") + (vhc[0] ? vhc[0].da_phone : 0 || ""), + }; + // LibMail.sendVhcSpawnZoneMail(`${(vhc[0]) ? vhc[0].nopol1 : 0 || ''}${(vhc[0]) ? vhc[0].nopol2 : 0 || ''}${(vhc[0]) ? vhc[0].nopol3 : 0 || ''} entering zone ${mailData.z_name}`, mailData.pic_mail, mailData); + + if (logDevice.device_id === "0865784052395871") console.log(1234567890); + GpsTracksModels.create2SpawnZone({ + device_id: logDevice.device_id, + master_id: Number(currTrack.result.insertId), + enter_lat: logDevice.latitude, + enter_lng: logDevice.longitude, + enter_at_d: logDevice.crt_d || now, + enter_at_d_format: moment.unix(logDevice.crt_d || now).format("YYYY-MM-DD HH:mm:ss"), + enter_at_s: now, + enter_at_s_format: moment.unix(now).format("YYYY-MM-DD HH:mm:ss"), + zone_id: zone.zid, + zone_name: zone.name, + vhc_id: vhc[0] ? vhc[0].vid : 0, + source: GpsTracksModels.SOURCE_GPS_TRACKER, + crt: now, + crt_format: moment.unix(now).format("YYYY-MM-DD HH:mm:ss"), + }); + if (logDevice.device_id === "0865784052395871") console.log("DISINI"); + } + } + } else { + // log tracking + GpsTracksModels.bundleCreate2(logDevice, logDevice); + } + } catch (e) { + console.error(e); + } } // end commit / log message from gps // start for gps-tracking TCP ONLY const devices = []; -const netConn = require('./config/netConn'); +const netConn = require("./config/netConn"); /** * uniquely identify a socket with Node.js * https://stackoverflow.com/questions/6805432/how-to-uniquely-identify-a-socket-with-node-js */ -net.createServer({ - allowHalfOpen: true, -}, function (c) { // c mean connection +net.createServer( + { + allowHalfOpen: true, + }, + function (c) { + // c mean connection - // save connections - c.id = nanoid(); + // save connections + c.id = nanoid(); - c.pipe(c); + c.pipe(c); - c.on('data', async (buffer_req) => { - const now = moment().unix(); - const me = LibDevice.identifyProtocolFromBuffer(buffer_req); - // console.log('app ', buffer_req); + c.on("data", async (buffer_req) => { + const now = moment().unix(); + const me = LibDevice.identifyProtocolFromBuffer(buffer_req); + // console.log('app ', buffer_req); - const logDevice = { - original_hex: me.ori_string, - protocol: (me.protocol_name == 'unknown') ? null : me.protocol_name, - action: null, - device_id: null, - latitude: null, - longitude: null, - speed: null, - orientation: 0, - ignition: 0, - stts_engine: 0, - stts_gps: 0, - length_gps: 0, - pos_stlt_gps: 0, - pos_type_gps: 0, - is_pos_gps: 0, - stts_gsm: 0, - stts_oil_electricity: 0, - stts_alarm: 0, - stts_charge: 0, - stts_acc: 0, - stts_volt: 0, - stts_switch: 0, - stts_reverse_geo: 0, - pre_milleage: 0, - source: GpsTracksModels.SOURCE_GPS_TRACKER, - vhc_id: 0, - drv_id: 0, - crt: now, - crt_format: moment.unix(now).format('YYYY-MM-DD HH:mm:ss'), - crt_d: 0, - crt_d_format: null, - crt_s: now, - crt_s_format: moment.unix(now).format('YYYY-MM-DD HH:mm:ss'), - }; + const logDevice = { + original_hex: me.ori_string, + protocol: me.protocol_name == "unknown" ? null : me.protocol_name, + action: null, + device_id: null, + latitude: null, + longitude: null, + speed: null, + orientation: 0, + ignition: 0, + stts_engine: 0, + stts_gps: 0, + length_gps: 0, + pos_stlt_gps: 0, + pos_type_gps: 0, + is_pos_gps: 0, + stts_gsm: 0, + stts_oil_electricity: 0, + stts_alarm: 0, + stts_charge: 0, + stts_acc: 0, + stts_volt: 0, + stts_switch: 0, + stts_reverse_geo: 0, + pre_milleage: 0, + source: GpsTracksModels.SOURCE_GPS_TRACKER, + vhc_id: 0, + drv_id: 0, + crt: now, + crt_format: moment.unix(now).format("YYYY-MM-DD HH:mm:ss"), + crt_d: 0, + crt_d_format: null, + crt_s: now, + crt_s_format: moment.unix(now).format("YYYY-MM-DD HH:mm:ss"), + }; - if (me.protocol_name == 'gt06') { - // const act = LibDevice.gt06Action(me, device.device_id || null); - let dvc_id = devices[c.id]; - const act = LibDevice.gt06Action(me, dvc_id || null); + if (me.protocol_name == "gt06") { + // const act = LibDevice.gt06Action(me, device.device_id || null); + let dvc_id = devices[c.id]; + const act = LibDevice.gt06Action(me, dvc_id || null); - if (act.action_type == 'login') { - logDevice.action = act.action_type; - logDevice.device_id = act.device_id; + if (act.action_type == "login") { + logDevice.action = act.action_type; + logDevice.device_id = act.device_id; - devices[c.id] = act.device_id; - netConn[act.device_id] = c; - if (typeof act.buffer_resp != 'undefined') { - c.write(act.buffer_resp); - } - } - else if (act.action_type == 'location') { - logDevice.action = act.action_type; - logDevice.device_id = act.device_id; + devices[c.id] = act.device_id; + netConn[act.device_id] = c; + if (typeof act.buffer_resp != "undefined") { + c.write(act.buffer_resp); + } + } else if (act.action_type == "location") { + logDevice.action = act.action_type; + logDevice.device_id = act.device_id; - logDevice.latitude = act.gps_data.latitude || null; - logDevice.longitude = act.gps_data.longitude || null; - logDevice.speed = act.gps_data.speed; - logDevice.orientation = act.gps_data.orientation; - if (logDevice.latitude) { - logDevice.stts_reverse_geo = GpsTracksModels.STTS_REVERSE_GEO_NOT; - } + logDevice.latitude = act.gps_data.latitude || null; + logDevice.longitude = act.gps_data.longitude || null; + logDevice.speed = act.gps_data.speed; + logDevice.orientation = act.gps_data.orientation; + if (logDevice.latitude) { + logDevice.stts_reverse_geo = GpsTracksModels.STTS_REVERSE_GEO_NOT; + } - logDevice.length_gps = act.gps_data.quantity_pos_satellites_c; - logDevice.pos_stlt_gps = act.gps_data.quantity_pos_satellites_b; - logDevice.pos_type_gps = (Number(act.gps_data.realtime_dif_gps) === 0) ? GpsTracksModels.STTS_POS_TYPE_GPS_RLTM : GpsTracksModels.STTS_POS_TYPE_GPS_DIFF; - logDevice.is_pos_gps = (Number(act.gps_data.positioning_gps)) ? GpsTracksModels.STTS_IS_POS_GPS_HAS : GpsTracksModels.STTS_IS_POS_GPS_NOT; + logDevice.length_gps = act.gps_data.quantity_pos_satellites_c; + logDevice.pos_stlt_gps = act.gps_data.quantity_pos_satellites_b; + logDevice.pos_type_gps = Number(act.gps_data.realtime_dif_gps) === 0 ? GpsTracksModels.STTS_POS_TYPE_GPS_RLTM : GpsTracksModels.STTS_POS_TYPE_GPS_DIFF; + logDevice.is_pos_gps = Number(act.gps_data.positioning_gps) ? GpsTracksModels.STTS_IS_POS_GPS_HAS : GpsTracksModels.STTS_IS_POS_GPS_NOT; - logDevice.crt = moment(act.gps_data.date).unix(); - logDevice.crt_format = moment(act.gps_data.date).format('YYYY-MM-DD HH:mm:ss'); - logDevice.crt_d = moment(act.gps_data.date).unix(); - logDevice.crt_d_format = moment(act.gps_data.date).format('YYYY-MM-DD HH:mm:ss'); - } - else if (act.action_type == 'heartbeat') { - logDevice.action = act.action_type; - logDevice.device_id = act.device_id; + logDevice.crt = moment(act.gps_data.date).unix(); + logDevice.crt_format = moment(act.gps_data.date).format("YYYY-MM-DD HH:mm:ss"); + logDevice.crt_d = moment(act.gps_data.date).unix(); + logDevice.crt_d_format = moment(act.gps_data.date).format("YYYY-MM-DD HH:mm:ss"); + } else if (act.action_type == "heartbeat") { + logDevice.action = act.action_type; + logDevice.device_id = act.device_id; - logDevice.ignition = Number(act.stts_data.terminal_info.acc) ? GpsTracksModels.STTS_IGNITION_HIGH : GpsTracksModels.STTS_IGNITION_LOW; - logDevice.stts_gps = (act.stts_data.terminal_info.gps_tracking) ? GpsTracksModels.STTS_GPS_ON : GpsTracksModels.STTS_GPS_OFF; // 1=>on, 2=>off - logDevice.stts_gsm = Number(act.stts_data.gsm_signal_strength) + 1; // 1=>no signal, n>1=>get signal + logDevice.ignition = Number(act.stts_data.terminal_info.acc) ? GpsTracksModels.STTS_IGNITION_HIGH : GpsTracksModels.STTS_IGNITION_LOW; + logDevice.stts_gps = act.stts_data.terminal_info.gps_tracking ? GpsTracksModels.STTS_GPS_ON : GpsTracksModels.STTS_GPS_OFF; // 1=>on, 2=>off + logDevice.stts_gsm = Number(act.stts_data.gsm_signal_strength) + 1; // 1=>no signal, n>1=>get signal - logDevice.stts_oil_electricity = (Number(act.stts_data.terminal_info.oil_electricity) === 0) ? GpsTracksModels.STTS_OIL_ELECTRIC_ON : GpsTracksModels.STTS_OIL_ELECTRIC_OFF; // 1=>on, 2=>off + logDevice.stts_oil_electricity = Number(act.stts_data.terminal_info.oil_electricity) === 0 ? GpsTracksModels.STTS_OIL_ELECTRIC_ON : GpsTracksModels.STTS_OIL_ELECTRIC_OFF; // 1=>on, 2=>off - let stts_alarm = Number(act.stts_data.terminal_info.stts); - if (stts_alarm == 0) { - logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_NORMAL; - } else if (stts_alarm == 1) { - logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_SHOCK; - } else if (stts_alarm == 2) { - logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_POWER_CUT; - } else if (stts_alarm == 3) { - logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_LOW_BATTERY; - } else if (stts_alarm == 4) { - logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_SOS; - } + let stts_alarm = Number(act.stts_data.terminal_info.stts); + if (stts_alarm == 0) { + logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_NORMAL; + } else if (stts_alarm == 1) { + logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_SHOCK; + } else if (stts_alarm == 2) { + logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_POWER_CUT; + } else if (stts_alarm == 3) { + logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_LOW_BATTERY; + } else if (stts_alarm == 4) { + logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_SOS; + } - logDevice.stts_charge = Number(act.stts_data.terminal_info.charge) ? GpsTracksModels.STTS_CHARGE_ON : GpsTracksModels.STTS_CHARGE_OFF; - logDevice.stts_acc = Number(act.stts_data.terminal_info.acc) ? GpsTracksModels.STTS_ACC_HIGH : GpsTracksModels.STTS_ACC_LOW; - logDevice.stts_switch = Number(act.stts_data.terminal_info.is_active) ? GpsTracksModels.STTS_SWITCH_ON : GpsTracksModels.STTS_SWITCH_OFF; - logDevice.stts_volt = Number(act.stts_data.voltage_level) + 1; + logDevice.stts_charge = Number(act.stts_data.terminal_info.charge) ? GpsTracksModels.STTS_CHARGE_ON : GpsTracksModels.STTS_CHARGE_OFF; + logDevice.stts_acc = Number(act.stts_data.terminal_info.acc) ? GpsTracksModels.STTS_ACC_HIGH : GpsTracksModels.STTS_ACC_LOW; + logDevice.stts_switch = Number(act.stts_data.terminal_info.is_active) ? GpsTracksModels.STTS_SWITCH_ON : GpsTracksModels.STTS_SWITCH_OFF; + logDevice.stts_volt = Number(act.stts_data.voltage_level) + 1; - if (typeof act.buffer_resp != 'undefined') { - c.write(act.buffer_resp); - } - } - else if (act.action_type == 'alarm') { - logDevice.action = act.action_type; - logDevice.device_id = act.device_id; + if (typeof act.buffer_resp != "undefined") { + c.write(act.buffer_resp); + } + } else if (act.action_type == "alarm") { + logDevice.action = act.action_type; + logDevice.device_id = act.device_id; - logDevice.latitude = act.gps_data.latitude || null; - logDevice.longitude = act.gps_data.longitude || null; - logDevice.speed = act.gps_data.speed; - logDevice.orientation = act.gps_data.orientation; - if (logDevice.latitude) { - logDevice.stts_reverse_geo = GpsTracksModels.STTS_REVERSE_GEO_NOT; - } + logDevice.latitude = act.gps_data.latitude || null; + logDevice.longitude = act.gps_data.longitude || null; + logDevice.speed = act.gps_data.speed; + logDevice.orientation = act.gps_data.orientation; + if (logDevice.latitude) { + logDevice.stts_reverse_geo = GpsTracksModels.STTS_REVERSE_GEO_NOT; + } - logDevice.length_gps = act.gps_data.quantity_pos_satellites_c; - logDevice.pos_stlt_gps = act.gps_data.quantity_pos_satellites_b; - logDevice.pos_type_gps = (Number(act.gps_data.realtime_dif_gps) === 0) ? GpsTracksModels.STTS_POS_TYPE_GPS_RLTM : GpsTracksModels.STTS_POS_TYPE_GPS_DIFF; - logDevice.is_pos_gps = (Number(act.gps_data.positioning_gps)) ? GpsTracksModels.STTS_IS_POS_GPS_HAS : GpsTracksModels.STTS_IS_POS_GPS_NOT; + logDevice.length_gps = act.gps_data.quantity_pos_satellites_c; + logDevice.pos_stlt_gps = act.gps_data.quantity_pos_satellites_b; + logDevice.pos_type_gps = Number(act.gps_data.realtime_dif_gps) === 0 ? GpsTracksModels.STTS_POS_TYPE_GPS_RLTM : GpsTracksModels.STTS_POS_TYPE_GPS_DIFF; + logDevice.is_pos_gps = Number(act.gps_data.positioning_gps) ? GpsTracksModels.STTS_IS_POS_GPS_HAS : GpsTracksModels.STTS_IS_POS_GPS_NOT; - logDevice.ignition = Number(act.stts_data.terminal_info.acc) ? GpsTracksModels.STTS_IGNITION_HIGH : GpsTracksModels.STTS_IGNITION_LOW; - logDevice.stts_gps = (act.stts_data.terminal_info.gps_tracking) ? GpsTracksModels.STTS_GPS_ON : GpsTracksModels.STTS_GPS_OFF; // 1=>on, 2=>off - logDevice.stts_gsm = Number(act.stts_data.gsm_signal_strength) + 1; // 1=>no signal, n>1=>get signal + logDevice.ignition = Number(act.stts_data.terminal_info.acc) ? GpsTracksModels.STTS_IGNITION_HIGH : GpsTracksModels.STTS_IGNITION_LOW; + logDevice.stts_gps = act.stts_data.terminal_info.gps_tracking ? GpsTracksModels.STTS_GPS_ON : GpsTracksModels.STTS_GPS_OFF; // 1=>on, 2=>off + logDevice.stts_gsm = Number(act.stts_data.gsm_signal_strength) + 1; // 1=>no signal, n>1=>get signal - logDevice.stts_oil_electricity = (Number(act.stts_data.terminal_info.oil_electricity) === 0) ? GpsTracksModels.STTS_OIL_ELECTRIC_ON : GpsTracksModels.STTS_OIL_ELECTRIC_OFF; // 1=>on, 2=>off + logDevice.stts_oil_electricity = Number(act.stts_data.terminal_info.oil_electricity) === 0 ? GpsTracksModels.STTS_OIL_ELECTRIC_ON : GpsTracksModels.STTS_OIL_ELECTRIC_OFF; // 1=>on, 2=>off - let stts_alarm = Number(act.stts_data.terminal_info.stts); - if (stts_alarm == 0) { - logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_NORMAL; - } else if (stts_alarm == 1) { - logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_SHOCK; - } else if (stts_alarm == 2) { - logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_POWER_CUT; - } else if (stts_alarm == 3) { - logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_LOW_BATTERY; - } else if (stts_alarm == 4) { - logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_SOS; - } + let stts_alarm = Number(act.stts_data.terminal_info.stts); + if (stts_alarm == 0) { + logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_NORMAL; + } else if (stts_alarm == 1) { + logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_SHOCK; + } else if (stts_alarm == 2) { + logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_POWER_CUT; + } else if (stts_alarm == 3) { + logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_LOW_BATTERY; + } else if (stts_alarm == 4) { + logDevice.stts_alarm = GpsTracksModels.STTS_ALARM_SOS; + } - logDevice.stts_charge = Number(act.stts_data.terminal_info.charge) ? GpsTracksModels.STTS_CHARGE_ON : GpsTracksModels.STTS_CHARGE_OFF; - logDevice.stts_acc = Number(act.stts_data.terminal_info.acc) ? GpsTracksModels.STTS_ACC_HIGH : GpsTracksModels.STTS_ACC_LOW; - logDevice.stts_switch = Number(act.stts_data.terminal_info.is_active) ? GpsTracksModels.STTS_SWITCH_ON : GpsTracksModels.STTS_SWITCH_OFF; - logDevice.stts_volt = Number(act.stts_data.voltage_level) + 1; + logDevice.stts_charge = Number(act.stts_data.terminal_info.charge) ? GpsTracksModels.STTS_CHARGE_ON : GpsTracksModels.STTS_CHARGE_OFF; + logDevice.stts_acc = Number(act.stts_data.terminal_info.acc) ? GpsTracksModels.STTS_ACC_HIGH : GpsTracksModels.STTS_ACC_LOW; + logDevice.stts_switch = Number(act.stts_data.terminal_info.is_active) ? GpsTracksModels.STTS_SWITCH_ON : GpsTracksModels.STTS_SWITCH_OFF; + logDevice.stts_volt = Number(act.stts_data.voltage_level) + 1; - logDevice.crt = moment(act.gps_data.date).unix(); - logDevice.crt_format = moment(act.gps_data.date).format('YYYY-MM-DD HH:mm:ss'); - logDevice.crt_d = moment(act.gps_data.date).unix(); - logDevice.crt_d_format = moment(act.gps_data.date).format('YYYY-MM-DD HH:mm:ss'); + logDevice.crt = moment(act.gps_data.date).unix(); + logDevice.crt_format = moment(act.gps_data.date).format("YYYY-MM-DD HH:mm:ss"); + logDevice.crt_d = moment(act.gps_data.date).unix(); + logDevice.crt_d_format = moment(act.gps_data.date).format("YYYY-MM-DD HH:mm:ss"); - if (typeof act.buffer_resp != 'undefined') { - c.write(act.buffer_resp); - } - } - // act.action_type == 'other' - else { - logDevice.action = act.action_type; - logDevice.device_id = act.device_id; - } - } + if (typeof act.buffer_resp != "undefined") { + c.write(act.buffer_resp); + } + } + // act.action_type == 'other' + else { + logDevice.action = act.action_type; + logDevice.device_id = act.device_id; + } + } - commitMessage(now, logDevice); - }); - c.on('end', () => { - }); - c.on('close', () => { - }); + commitMessage(now, logDevice); + }); + c.on("end", () => {}); + c.on("close", () => {}); - // unused - c.on('drain', (a) => { - console.log('client drain', a); - }); - c.on('error', (a) => { - console.error('client error', a); - }); - c.on('lookup', (a) => { - console.log('client lookup', a); - }); - c.on('ready', (a) => { - console.log('client ready', a); - }); - c.on('timeout', (a) => { - console.log('client timeout', a); - }); + // unused + c.on("drain", (a) => { + console.log("client drain", a); + }); + c.on("error", (a) => { + console.error("client error", a); + }); + c.on("lookup", (a) => { + console.log("client lookup", a); + }); + c.on("ready", (a) => { + console.log("client ready", a); + }); + c.on("timeout", (a) => { + console.log("client timeout", a); + }); - // not work for gps tracker - // https://stackoverflow.com/questions/17245881/how-do-i-debug-error-econnreset-in-node-js - // c.write("\n"); - // c.write("\n"); - // c.write("\n"); - // c.write("\n"); - // c.write("\n"); - // c.end(); + // not work for gps tracker + // https://stackoverflow.com/questions/17245881/how-do-i-debug-error-econnreset-in-node-js + // c.write("\n"); + // c.write("\n"); + // c.write("\n"); + // c.write("\n"); + // c.write("\n"); + // c.end(); - c.pipe(c); -}).listen(process.env.PORT, () => { - console.log('Server gps tracker running at port ' + process.env.PORT); + c.pipe(c); + } +).listen(process.env.PORT, () => { + console.log("Server gps tracker running at port " + process.env.PORT); }); // end for gps-tracking TCP ONLY // start for normal http request -app.use(express.json({ limit: '10mb' })); // parsing application/json -app.use(express.urlencoded({ extended: true, limit: '10mb' })); // parsing application/x-www-form-urlencoded +app.use(express.json({ limit: "10mb" })); // parsing application/json +app.use(express.urlencoded({ extended: true, limit: "10mb" })); // parsing application/x-www-form-urlencoded app.use(async function (req, res, next) { - // set control allowed headers - res.header('Access-Control-Allow-Origin', '*'); - res.header('Access-Control-Allow-Methods', 'OPTIONS,GET,HEAD,PUT,PATCH,POST,DELETE'); - res.header('Access-Control-Allow-Headers', 'Accept, Authorization, Content-Type, X-Requested-With, Range, x-api-key, x-forwarded-for'); - next(); + // set control allowed headers + res.header("Access-Control-Allow-Origin", "*"); + res.header("Access-Control-Allow-Methods", "OPTIONS,GET,HEAD,PUT,PATCH,POST,DELETE"); + res.header("Access-Control-Allow-Headers", "Accept, Authorization, Content-Type, X-Requested-With, Range, x-api-key, x-forwarded-for"); + next(); }); -app.use(process.env.PATH_URL + '/bull/monitor', LibBullAdapter.getRouter()); +app.use(process.env.PATH_URL + "/bull/monitor", LibBullAdapter.getRouter()); routes.use(app); app.listen(process.env.PORT_EXPRESS, () => { - console.log('Express server running at port ' + process.env.PORT_EXPRESS); + console.log("Express server running at port " + process.env.PORT_EXPRESS); }); // end for normal http request // start for gps-tracking UDP ONLY -const udp = dgram.createSocket('udp4'); +const udp = dgram.createSocket("udp4"); const devices1 = []; -udp.on('message', (msg, rinfo) => { - const buffer_req = Buffer.from(msg, 'utf8'); - console.log('20203', buffer_req); - console.log('20203', rinfo); - Logger.log('info', buffer_req.toString('hex')); +udp.on("message", (msg, rinfo) => { + const buffer_req = Buffer.from(msg, "utf8"); + console.log("20203", buffer_req); + console.log("20203", rinfo); + Logger.log("info", buffer_req.toString("hex")); - const now = moment().unix(); - const me = LibDevice.identifyProtocolFromBuffer(buffer_req, {isEelinkCustom: 1}); - console.log('port 20203 ', me); + const now = moment().unix(); + const me = LibDevice.identifyProtocolFromBuffer(buffer_req, { isEelinkCustom: 1 }); + console.log("port 20203 ", me); - const logDevice = { - original_hex: me.ori_buffer, - protocol: (me.protocol_name == 'unknown') ? null : me.protocol_name, - action: null, - device_id: null, - latitude: null, - longitude: null, - speed: null, - orientation: 0, - ignition: 0, - stts_engine: 0, - stts_gps: 0, - length_gps: 0, - pos_stlt_gps: 0, - pos_type_gps: 0, - is_pos_gps: 0, - stts_gsm: 0, - stts_oil_electricity: 0, - stts_alarm: 0, - stts_charge: 0, - stts_acc: 0, - stts_volt: 0, - stts_switch: 0, - stts_reverse_geo: 0, - pre_milleage: 0, - source: GpsTracksModels.SOURCE_GPS_TRACKER, - crt: now, - crt_format: moment.unix(now).format('YYYY-MM-DD HH:mm:ss'), - crt_d: 0, - crt_d_format: null, - crt_s: now, - crt_s_format: moment.unix(now).format('YYYY-MM-DD HH:mm:ss'), - }; + const logDevice = { + original_hex: me.ori_buffer, + protocol: me.protocol_name == "unknown" ? null : me.protocol_name, + action: null, + device_id: null, + latitude: null, + longitude: null, + speed: null, + orientation: 0, + ignition: 0, + stts_engine: 0, + stts_gps: 0, + length_gps: 0, + pos_stlt_gps: 0, + pos_type_gps: 0, + is_pos_gps: 0, + stts_gsm: 0, + stts_oil_electricity: 0, + stts_alarm: 0, + stts_charge: 0, + stts_acc: 0, + stts_volt: 0, + stts_switch: 0, + stts_reverse_geo: 0, + pre_milleage: 0, + source: GpsTracksModels.SOURCE_GPS_TRACKER, + crt: now, + crt_format: moment.unix(now).format("YYYY-MM-DD HH:mm:ss"), + crt_d: 0, + crt_d_format: null, + crt_s: now, + crt_s_format: moment.unix(now).format("YYYY-MM-DD HH:mm:ss"), + }; - if (me.protocol_name === 'eelinkCustom') { - let dvc_id = devices1[`${rinfo.address}:${rinfo.port}`]; - const act = LibDevice.eelinkCustomAction(me, dvc_id || null); - console.log('act 20203', act); + if (me.protocol_name === "eelinkCustom") { + let dvc_id = devices1[`${rinfo.address}:${rinfo.port}`]; + const act = LibDevice.eelinkCustomAction(me, dvc_id || null); + console.log("act 20203", act); - if (act.action_type == 'exist_data') { - logDevice.action = act.action_type; - logDevice.device_id = act.device_id; + if (act.action_type == "exist_data") { + logDevice.action = act.action_type; + logDevice.device_id = act.device_id; - devices1[`${rinfo.address}:${rinfo.port}`] = act.device_id; - if (typeof act.buffer_resp != 'undefined') { - udp.send(act.buffer_resp, 0, act.buffer_resp.length, rinfo.port, rinfo.address, function(err, bytes) { - if (err) throw err; - console.log('UDP message sent to ' + rinfo.address +':'+ rinfo.port); - console.log('20203', bytes); - }); - } - - - } - } + devices1[`${rinfo.address}:${rinfo.port}`] = act.device_id; + if (typeof act.buffer_resp != "undefined") { + udp.send(act.buffer_resp, 0, act.buffer_resp.length, rinfo.port, rinfo.address, function (err, bytes) { + if (err) throw err; + console.log("UDP message sent to " + rinfo.address + ":" + rinfo.port); + console.log("20203", bytes); + }); + } + } + } }); -udp.on('error', (err) => { - console.log(`udp error:\n${err.stack}`); - udp.close(); +udp.on("error", (err) => { + console.log(`udp error:\n${err.stack}`); + udp.close(); }); -udp.on('close',function(){ - console.log('udp socket is closed !'); +udp.on("close", function () { + console.log("udp socket is closed !"); }); -udp.on('listening', () => { - const address = udp.address(); - console.log(`udp listening ${address.address}:${address.port}`); +udp.on("listening", () => { + const address = udp.address(); + console.log(`udp listening ${address.address}:${address.port}`); }); udp.bind(process.env.PORT_UDP); -// end for gps-tracking UDP ONLY \ No newline at end of file +// end for gps-tracking UDP ONLY