TCORE-242 Refactor and Test Network Everynet Plugin for Monorepo

package.json

@@ -39,7 +39,9 @@
     "zod": "3.23.8",
     "systeminformation": "5.23.5",
     "express": "4.21.1",
-    "qs": "6.10.1"
+    "qs": "6.10.1",
+    "async": "3.2.6",
+    "body-parser": "2.0.1"
   },
   "devDependencies": {
     "@biomejs/biome": "1.9.3",
@@ -52,6 +54,8 @@
     "@types/uuid": "10.0.0",
     "@types/express": "5.0.0",
     "@types/axios": "0.14.0",
+    "@types/async": "3.2.24",
+    "@types/ms": "0.7.34",
     "concurrently": "9.0.1",
     "esbuild": "0.24.0",
     "jest": "29.7.0",

plugins/mqtt/package.json

@@ -13,11 +13,8 @@
     "permissions": ["device", "action", "device-data"]
   },
   "dependencies": {
-    "async": "3.2.6",
     "mqtt-connection": "4.1.0"
   },
   "devDependencies": {
-    "@types/async": "3.2.24",
-    "@types/ms": "0.7.34"
   }
 }

plugins/mysql/src/Database/index.ts

@@ -101,6 +101,7 @@ function setupConnections(config: Config) {
     port: config.main_read_port,
     user: config.main_user,
     password: config.main_password,
+    timezone: "local",
   };
 
   const mainOptions: IConnectionOptions = {

plugins/mysql/src/Providers/Device/getDeviceInfo.ts

@@ -33,7 +33,7 @@ async function getDeviceInfo(deviceID: TGenericID): Promise<IDevice | null> {
       response.created_at = new Date(response.created_at);
     }
     if (response.encoder_stack) {
-      response.encoder_stack = JSON.parse(JSON.stringify(response.encoder_stack));
+      response.encoder_stack = JSON.parse(response.encoder_stack);
     }
   }
 

plugins/mysql/src/Providers/Device/getDeviceList.ts

@@ -61,7 +61,7 @@ async function getDeviceList(
       item.tags = JSON.parse(JSON.stringify(item.tags));
     }
     if (item.encoder_stack) {
-      item.encoder_stack = JSON.parse(JSON.stringify(item.encoder_stack));
+      item.encoder_stack = JSON.parse(item.encoder_stack);
     }
     if (item.last_input) {
       item.last_input = new Date(item.last_input);

standalone-plugins/network-actility/README.md → plugins/network-actility/README.md

@@ -57,6 +57,8 @@ In order for the integration to properly identify the device, you must add a tag
 * **Tag key**: serial
 * **Tag value**: copy the Device EUI in the value of the tag.
 
+For TagoCore to interpret the payload sent by Actility, you need to go to the device and select the Encoder Stack as Actility LoRaWAN.
+
 ---
 # Action type: Send downlink to the device
 This integration also add a new action which you can use the send downlink to the device. Such as select as type of the action when setting up new actions.

plugins/network-actility/package.json

@@ -0,0 +1,20 @@
+{
+  "name": "@tago-io/tcore-plugin-network-actility",
+  "version": "0.7.0",
+  "private": false,
+  "main": "./src/index.ts",
+  "type": "module",
+  "tcore": {
+    "name": "Actility LoRaWAN",
+    "short_description": "Adds support for Actility LoRaWAN",
+    "full_description": "./README.md",
+    "icon": "./assets/icon.png",
+    "cluster": true,
+    "types": ["service", "encoder", "action-type"],
+    "permissions": ["device", "action", "device-data"]
+  },
+  "dependencies": {
+    "lora-packet": "0.9.2"
+  },
+  "devDependencies": {}
+}

standalone-plugins/network-actility/src/Services/downlink.ts → plugins/network-actility/src/Services/downlink.ts

@@ -1,11 +1,11 @@
-import crypto from "crypto";
+import crypto from "node:crypto";
 import { core } from "@tago-io/tcore-sdk";
-import axios, { AxiosRequestConfig } from "axios";
-import { Request, Response } from "express";
+import axios, { type AxiosRequestConfig } from "axios";
+import type { Request, Response } from "express";
 import { DateTime } from "luxon";
-import sendResponse from "../lib/sendResponse";
-import { IConfigParam } from "../types";
-import { getDevice } from "./uplink";
+import sendResponse from "../lib/sendResponse.ts";
+import type { IConfigParam } from "../types.ts";
+import { getDevice } from "./uplink.ts";
 
 interface IDownlinkBuild {
   url: string;
@@ -56,24 +56,40 @@ interface IClassAConfig {
  * @param classAConfig - optinal parameter sent by Actlity for class A devices
  * @returns {void}
  */
-async function downlinkService(config: IConfigParam, req: Request, res: Response, classAConfig: IClassAConfig = {}) {
-  const authorization = req.headers["Authorization"] || req.headers["authorization"];
+async function downlinkService(
+  config: IConfigParam,
+  req: Request,
+  res: Response,
+  classAConfig: IClassAConfig = {},
+) {
+  const authorization = req.headers.Authorization || req.headers.authorization;
   if (!authorization || authorization !== config.authorization_code) {
-    console.error(`[Network Server] Request refused, authentication is invalid: ${authorization}`);
-    return sendResponse(res, { body: "Invalid authorization header", status: 401 });
+    console.error(
+      `[Network Server] Request refused, authentication is invalid: ${authorization}`,
+    );
+    return sendResponse(res, {
+      body: "Invalid authorization header",
+      status: 401,
+    });
   }
 
   const body = <IDownlinkParams>req.body;
 
   const device = await getDevice(body.device);
   if (!body.device) {
-    return sendResponse(res, { body: "Missing device paramater with device eui as value", status: 400 });
+    return sendResponse(res, {
+      body: "Missing device paramater with device eui as value",
+      status: 400,
+    });
   }
   if (!body.port) {
     return sendResponse(res, { body: "Missing port paramater", status: 400 });
   }
   if (!body.payload) {
-    return sendResponse(res, { body: "Missing payload paramater with hexadecimal value", status: 400 });
+    return sendResponse(res, {
+      body: "Missing payload paramater with hexadecimal value",
+      status: 400,
+    });
   }
 
   if (!classAConfig?.fcntdn || !classAConfig?.as_id) {
@@ -83,15 +99,21 @@ async function downlinkService(config: IConfigParam, req: Request, res: Response
     const fctdnParam = deviceParams.find((param) => param.key === "fctdn");
 
     if (!asIDParam || !fctdnParam) {
-      return sendResponse(res, { body: "Invalid authorization header", status: 401 });
+      return sendResponse(res, {
+        body: "Invalid authorization header",
+        status: 401,
+      });
     }
 
     classAConfig.fcntdn = Number(fctdnParam.value as string);
     classAConfig.as_id = asIDParam.value as string;
   }
 
   const deveui = String(device).toUpperCase();
-  const time = DateTime.utc().setZone("America/Sao_Paulo").plus({ seconds: 5 }).toFormat("YYYY-MM-DDTHH:mm:ss.SZ");
+  const time = DateTime.utc()
+    .setZone("America/Sao_Paulo")
+    .plus({ seconds: 5 })
+    .toFormat("YYYY-MM-DDTHH:mm:ss.SZ");
   const tokenString = `DevEUI=${deveui}&FPort=${body.port}&FCntDn=${classAConfig.fcntdn}&Payload=${
     body.payload
   }&AS_ID=${classAConfig.as_id}&Time=${time}${config.tunnel_key.toLowerCase()}`;
@@ -117,12 +139,18 @@ async function downlinkService(config: IConfigParam, req: Request, res: Response
 
   await sendDownlink(downlinkBuild)
     .then(() => {
-      return sendResponse(res, { body: { status: true, message: "Downlink successfully sent" }, status: 201 });
+      return sendResponse(res, {
+        body: { status: true, message: "Downlink successfully sent" },
+        status: 201,
+      });
     })
     .catch((e) => {
-      return sendResponse(res, { body: JSON.stringify(e.response.data), status: e.response.status });
+      return sendResponse(res, {
+        body: JSON.stringify(e.response.data),
+        status: e.response.status,
+      });
     });
 }
 
 export default downlinkService;
-export { IClassAConfig, IDownlinkParams };
+export type { IClassAConfig, IDownlinkParams };

standalone-plugins/network-everynet/src/Services/downlinkAction.ts → plugins/network-actility/src/Services/downlinkAction.ts

@@ -1,11 +1,11 @@
 import { core } from "@tago-io/tcore-sdk";
-import { IDeviceData } from "@tago-io/tcore-sdk/build/Types";
-import { IConfigParam } from "../types";
-import downlinkService, { IDownlinkParams } from "./downlink";
+import type { IDeviceData } from "@tago-io/tcore-sdk/Types";
+import type { IConfigParam } from "../types.ts";
+import downlinkService, { type IDownlinkParams } from "./downlink.ts";
 
 class ResMockup {
   _status = 200;
-  json(body: {}) {
+  json(body: any) {
     if (this._status >= 400) {
       console.error(body);
     }
@@ -32,18 +32,29 @@ async function downlinkAction(
   pluginConfig: IConfigParam,
   actionID: string,
   actionSettings: IDownlinkParams,
-  dataList: IDeviceData
+  dataList: IDeviceData,
 ) {
   const action = await core.getActionInfo(actionID);
 
   if (Array.isArray(dataList) && dataList[0].variable) {
     // eslint-disable-next-line @typescript-eslint/no-explicit-any
-    const variables = action.trigger.conditions.map((condition: any) => condition.variable);
+    const variables = action.trigger.conditions.map(
+      (condition: any) => condition.variable,
+    );
     const data = dataList.find((item) => variables.includes(item.variable));
 
-    actionSettings.payload = actionSettings.payload.replace(/\$VALUE\$/g, data.value);
-    actionSettings.payload = actionSettings.payload.replace(/\$VARIABLE\$/g, data.variable);
-    actionSettings.payload = actionSettings.payload.replace(/\$SERIE\$/g, data.serie);
+    actionSettings.payload = actionSettings.payload.replace(
+      /\$VALUE\$/g,
+      data.value,
+    );
+    actionSettings.payload = actionSettings.payload.replace(
+      /\$VARIABLE\$/g,
+      data.variable,
+    );
+    actionSettings.payload = actionSettings.payload.replace(
+      /\$SERIE\$/g,
+      data.serie,
+    );
 
     if (actionSettings.device.toLowerCase() === "$device_id$") {
       const deviceInfo = await core.getDeviceInfo(data.origin);

standalone-plugins/network-actility/src/Services/parser.ts → plugins/network-actility/src/Services/parser.ts

@@ -1,5 +1,5 @@
-import toTagoFormat, { IDeviceDataLatLng } from "../lib/toTagoFormat";
-import { IPayloadParamsActility } from "./uplink";
+import toTagoFormat, { type IDeviceDataLatLng } from "../lib/toTagoFormat.ts";
+import type { IPayloadParamsActility } from "./uplink.ts";
 
 /**
  * Decode data from Actility
@@ -9,7 +9,9 @@ import { IPayloadParamsActility } from "./uplink";
  */
 // eslint-disable-next-line @typescript-eslint/no-explicit-any
 export default async function parser(
-  payload: Partial<IPayloadParamsActility["DevEUI_uplink"]> & { payload?: string }
+  payload: Partial<IPayloadParamsActility["DevEUI_uplink"]> & {
+    payload?: string;
+  },
 ): Promise<IDeviceDataLatLng[]> {
   if (Array.isArray(payload)) {
     return payload;
@@ -23,19 +25,21 @@ export default async function parser(
   const serie = String(new Date().getTime());
   if (payload.payload_hex) {
     payload.payload = payload.payload_hex;
-    delete payload.payload_hex;
+    payload.payload_hex = undefined;
   }
-  delete payload.CustomerData;
-  delete payload.CustomerID;
-  delete payload.Lrrs;
-  delete payload.DevAddr;
-  delete payload.AppSKey;
-  delete payload.DynamicClass;
-  delete payload.InstantPER;
-  delete payload.MeanPER;
+  payload.CustomerData = undefined;
+  payload.CustomerID = undefined;
+  payload.Lrrs = undefined;
+  payload.DevAddr = undefined;
+  payload.AppSKey = undefined;
+  payload.DynamicClass = undefined;
+  payload.InstantPER = undefined;
+  payload.MeanPER = undefined;
 
   let result = toTagoFormat(payload, serie);
-  result = result.filter((x) => !x.location || (x.location.lat !== 0 && x.location.lng !== 0));
+  result = result.filter(
+    (x) => !x.location || (x.location.lat !== 0 && x.location.lng !== 0),
+  );
 
   return result;
 }