require("dotenv").config({ path: ".env" });
require("events").EventEmitter.prototype._maxListeners = 30;
const morgan = require("morgan");
// 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;
// end for gps-tracking

// start for normal http request
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 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);

		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;

				// 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");
			}
		}

		// 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 });
			}
		}

		// 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);
			}

			/**
			 * 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");
/**
 * 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

		// save connections
		c.id = nanoid();

		c.pipe(c);

		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"),
			};

			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;

					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.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.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

					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;

					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.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.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;
					}

					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");

					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", () => {});

		// 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("<?xml version=\"1.0\"?>\n");
		// c.write("<!DOCTYPE cross-domain-policy SYSTEM \"http://www.macromedia.com/xml/dtds/cross-domain-policy.dtd\">\n");
		// c.write("<cross-domain-policy>\n");
		// c.write("<allow-access-from domain=\"*\" to-ports=\"*\"/>\n");
		// c.write("</cross-domain-policy>\n");
		// c.end();

		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(morgan("combined"));
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();
});
// 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);
});
// end for normal http request

// start for gps-tracking UDP ONLY
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"));

	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"),
	};

	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;

			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("close", function () {
	console.log("udp socket is closed !");
});
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