changes on masterConnectedSlaveList

src/controllers/installationController.js

@@ -1228,6 +1228,68 @@ exports.createMasterSlaveData = async (req, reply) => {
   }
 };
 
+exports.masterConnectedSlaveList = async (req, reply) => {
+  try {
+    const { connectedTo } = req.params;
+
+    // Step 1: Get master device details
+    const master = await Insensors.findOne({ hardwareId: connectedTo, type: 'master' }).lean();
+    if (!master) {
+      return reply.status(404).send({
+        success: false,
+        message: "Master device not found"
+      });
+    }
+
+    // Step 2: Get tank metadata for master
+    const tankDetails = await Tank.findOne({ hardwareId: connectedTo }, { tankLocation: 1, typeOfWater: 1 }).lean();
+
+    // Step 3: Get slave tanks connected to master
+    const slaveTanks = await Insensors.find({ connected_to: connectedTo, type: 'slave' }).lean();
+    const slaveCount = slaveTanks.length;
+
+    // Step 4: Get latest IotData for master
+    const latestIotData = await IotData.findOne({ hardwareId: connectedTo }).sort({ date: -1 }).lean();
+
+    // Step 5: Prepare master object for response
+    const masterResponse = {
+      ...master,
+      isMaster: true,
+      tankLocation: tankDetails?.tankLocation || null,
+      typeOfWater: tankDetails?.typeOfWater || null,
+      tankHeight: null // Master doesn't have individual tankHeight
+    };
+
+    // Step 6: Process each slave
+    const processedSlaves = slaveTanks.map(slave => {
+      const matchingTankData = latestIotData?.tanks?.find(t => t.tankhardwareId === slave.hardwareId);
+
+      return {
+        ...slave,
+        isMaster: false,
+        tankHeight: matchingTankData?.tankHeight ?? null
+      };
+    });
+
+    // Step 7: Combine master and slaves into one array
+    const combinedData = [masterResponse, ...processedSlaves];
+
+    return reply.send({
+      success: true,
+      connectedSlaveCount: slaveCount,
+      data: combinedData
+    });
+
+  } catch (error) {
+    console.error("Error fetching master connected slave data:", error);
+    return reply.status(500).send({
+      success: false,
+      message: "Internal Server Error"
+    });
+  }
+};
+
+
 // exports.masterConnectedSlaveList = async (req, reply) => {
 //   try {
 //     const { connectedTo } = req.params;
@@ -1303,60 +1365,60 @@ exports.createMasterSlaveData = async (req, reply) => {
 
 
 
-exports.masterConnectedSlaveList = async (req, reply) => {
+// exports.masterConnectedSlaveList = async (req, reply) => {
-  try {
+//   try {
-    const { connectedTo } = req.params;
+//     const { connectedTo } = req.params;
 
-    // Step 1: Get master details
+//     // Step 1: Get master details
-    const master = await Insensors.findOne({ hardwareId: connectedTo, type: 'master' }).lean();
+//     const master = await Insensors.findOne({ hardwareId: connectedTo, type: 'master' }).lean();
-    if (!master) {
+//     if (!master) {
-      return reply.status(404).send({
+//       return reply.status(404).send({
-        success: false,
+//         success: false,
-        message: "Master device not found"
+//         message: "Master device not found"
-      });
+//       });
-    }
+//     }
 
-    // Step 2: Get slave tanks connected to master
+//     // Step 2: Get slave tanks connected to master
-    const slaveTanks = await Insensors.find({ connected_to: connectedTo, type: 'slave' }).lean();
+//     const slaveTanks = await Insensors.find({ connected_to: connectedTo, type: 'slave' }).lean();
-    const slaveCount = slaveTanks.length;
+//     const slaveCount = slaveTanks.length;
 
-    // Step 3: Get Tank metadata for master
+//     // Step 3: Get Tank metadata for master
-    const tankDetails = await Tank.findOne({ hardwareId: connectedTo }, { tankLocation: 1, typeOfWater: 1 }).lean();
+//     const tankDetails = await Tank.findOne({ hardwareId: connectedTo }, { tankLocation: 1, typeOfWater: 1 }).lean();
 
-    // Step 4: Get latest IotData for master
+//     // Step 4: Get latest IotData for master
-    const latestIotData = await IotData.findOne({ hardwareId: connectedTo }).sort({ date: -1 }).lean();
+//     const latestIotData = await IotData.findOne({ hardwareId: connectedTo }).sort({ date: -1 }).lean();
 
-    // Step 5: Process slaves
+//     // Step 5: Process slaves
-    const processedSlaves = slaveTanks.map(slave => {
+//     const processedSlaves = slaveTanks.map(slave => {
-      const matchingTankData = latestIotData?.tanks?.find(tank => tank.tankhardwareId === slave.hardwareId);
+//       const matchingTankData = latestIotData?.tanks?.find(tank => tank.tankhardwareId === slave.hardwareId);
-      return {
+//       return {
-        ...slave,
+//         ...slave,
-        tankHeight: matchingTankData?.tankHeight ?? null
+//         tankHeight: matchingTankData?.tankHeight ?? null
-      };
+//       };
-    });
+//     });
 
-    // Step 6: Prepare full master object
+//     // Step 6: Prepare full master object
-    const masterResponse = {
+//     const masterResponse = {
-      ...master,
+//       ...master,
-      tankLocation: tankDetails?.tankLocation || null,
+//       tankLocation: tankDetails?.tankLocation || null,
-      typeOfWater: tankDetails?.typeOfWater || null
+//       typeOfWater: tankDetails?.typeOfWater || null
-    };
+//     };
 
-    return reply.send({
+//     return reply.send({
-      success: true,
+//       success: true,
-      master: masterResponse,
+//       master: masterResponse,
-      connectedSlaveCount: slaveCount,
+//       connectedSlaveCount: slaveCount,
-      slaves: processedSlaves
+//       slaves: processedSlaves
-    });
+//     });
 
-  } catch (error) {
+//   } catch (error) {
-    console.error("Error fetching master connected slave data:", error);
+//     console.error("Error fetching master connected slave data:", error);
-    return reply.status(500).send({
+//     return reply.status(500).send({
-      success: false,
+//       success: false,
-      message: "Internal Server Error"
+//       message: "Internal Server Error"
-    });
+//     });
-  }
+//   }
-};
+// };