From 5c147562b3c6954f2d2dee084247e089d973b344 Mon Sep 17 00:00:00 2001
From: Owaise Imdad <owaiseimdad@gmail.com>
Date: Tue, 29 Jul 2025 00:17:34 +0530
Subject: [PATCH] Added net to be returned from api in backend for infra.

---
 server/db/models/HardwareCheck.js             | 19 +++++
 .../db/mongo/modules/monitorModuleQueries.js  | 82 +++++++++++++++++++
 .../service/infrastructure/statusService.js   |  3 +-
 3 files changed, 103 insertions(+), 1 deletion(-)

diff --git a/server/db/models/HardwareCheck.js b/server/db/models/HardwareCheck.js
index bda9f693c..f29df2dbc 100755
--- a/server/db/models/HardwareCheck.js
+++ b/server/db/models/HardwareCheck.js
@@ -40,6 +40,20 @@ const captureSchema = mongoose.Schema({
 	mode: { type: String, default: "" },
 });
 
+const networkInterfaceSchema = mongoose.Schema({
+	name: { type: String, required: true },
+	bytes_sent: { type: Number, default: 0 },
+	bytes_recv: { type: Number, default: 0 },
+	packets_sent: { type: Number, default: 0 },
+	packets_recv: { type: Number, default: 0 },
+	err_in: { type: Number, default: 0 },
+	err_out: { type: Number, default: 0 },
+	drop_in: { type: Number, default: 0 },
+	drop_out: { type: Number, default: 0 },
+	fifo_in: { type: Number, default: 0 },
+	fifo_out: { type: Number, default: 0 },
+});
+
 const HardwareCheckSchema = mongoose.Schema(
 	{
 		...BaseCheckSchema.obj,
@@ -69,6 +83,11 @@ const HardwareCheckSchema = mongoose.Schema(
 			type: captureSchema,
 			default: () => ({}),
 		},
+
+		net: {
+			type: [networkInterfaceSchema],
+			default: () => [],
+		},
 	},
 	{ timestamps: true }
 );
diff --git a/server/db/mongo/modules/monitorModuleQueries.js b/server/db/mongo/modules/monitorModuleQueries.js
index d96e128fa..56c9a794b 100755
--- a/server/db/mongo/modules/monitorModuleQueries.js
+++ b/server/db/mongo/modules/monitorModuleQueries.js
@@ -220,6 +220,7 @@ const buildHardwareDetailsPipeline = (monitor, dates, dateString) => {
 							diskCount: {
 								$size: "$disk",
 							},
+							netCount: { $size: "$net" },
 						},
 					},
 					{
@@ -227,6 +228,7 @@ const buildHardwareDetailsPipeline = (monitor, dates, dateString) => {
 							from: "hardwarechecks",
 							let: {
 								diskCount: "$diskCount",
+								netCount: "$netCount",
 							},
 							pipeline: [
 								{
@@ -258,6 +260,9 @@ const buildHardwareDetailsPipeline = (monitor, dates, dateString) => {
 										disks: {
 											$push: "$disk",
 										},
+										net: {
+											$push: "$net",
+										},
 									},
 								},
 								{
@@ -371,6 +376,83 @@ const buildHardwareDetailsPipeline = (monitor, dates, dateString) => {
 												},
 											},
 										},
+										net: {
+											$map: {
+												input: { $range: [0, "$$netCount"] },
+												as: "netIndex",
+												in: {
+													name: {
+														$concat: ["net", { $toString: "$$netIndex" }],
+													},
+													bytesSent: {
+														$avg: {
+															$map: {
+																input: "$net",
+																as: "netArray",
+																in: {
+																	$arrayElemAt: ["$$netArray.bytes_sent", "$$netIndex"],
+																},
+															},
+														},
+													},
+													bytesRecv: {
+														$avg: {
+															$map: {
+																input: "$net",
+																as: "netArray",
+																in: {
+																	$arrayElemAt: ["$$netArray.bytes_recv", "$$netIndex"],
+																},
+															},
+														},
+													},
+													packetsSent: {
+														$avg: {
+															$map: {
+																input: "$net",
+																as: "netArray",
+																in: {
+																	$arrayElemAt: ["$$netArray.packets_sent", "$$netIndex"],
+																},
+															},
+														},
+													},
+													packetsRecv: {
+														$avg: {
+															$map: {
+																input: "$net",
+																as: "netArray",
+																in: {
+																	$arrayElemAt: ["$$netArray.packets_recv", "$$netIndex"],
+																},
+															},
+														},
+													},
+													errIn: {
+														$avg: {
+															$map: {
+																input: "$net",
+																as: "netArray",
+																in: {
+																	$arrayElemAt: ["$$netArray.errin", "$$netIndex"],
+																},
+															},
+														},
+													},
+													errOut: {
+														$avg: {
+															$map: {
+																input: "$net",
+																as: "netArray",
+																in: {
+																	$arrayElemAt: ["$$netArray.errout", "$$netIndex"],
+																},
+															},
+														},
+													},
+												},
+											},
+										},
 									},
 								},
 							],
diff --git a/server/service/infrastructure/statusService.js b/server/service/infrastructure/statusService.js
index 1c91a407c..0967d3d46 100755
--- a/server/service/infrastructure/statusService.js
+++ b/server/service/infrastructure/statusService.js
@@ -232,7 +232,7 @@ class StatusService {
 		}
 
 		if (type === "hardware") {
-			const { cpu, memory, disk, host } = payload?.data ?? {};
+			const { cpu, memory, disk, host, net } = payload?.data ?? {};
 			const { errors } = payload?.errors ?? [];
 			check.cpu = cpu ?? {};
 			check.memory = memory ?? {};
@@ -240,6 +240,7 @@ class StatusService {
 			check.host = host ?? {};
 			check.errors = errors ?? [];
 			check.capture = payload?.capture ?? {};
+			check.net = net ?? {};
 		}
 		return check;
 	};