From 8b9fe0b72d04342df0f03399783163c890ca3cbf Mon Sep 17 00:00:00 2001
From: subash-rumsan <subhash.parajuli@rumsan.net>
Date: Tue, 9 Dec 2025 16:47:28 +0545
Subject: [PATCH] fix: update saveDataInGFH function to update or create base
 on stationName and riverGuageId

---
 packages/gfh-adapter/src/gfh.service.ts | 14 ++++++--------
 1 file changed, 6 insertions(+), 8 deletions(-)

diff --git a/packages/gfh-adapter/src/gfh.service.ts b/packages/gfh-adapter/src/gfh.service.ts
index 566e28e..b739f78 100644
--- a/packages/gfh-adapter/src/gfh.service.ts
+++ b/packages/gfh-adapter/src/gfh.service.ts
@@ -27,19 +27,17 @@ export class GfhService {
                   equals: payload.info.stationName,
                 },
               },
-              {
-                info: {
-                  path: ["info", "forecastDate"],
-                  equals: payload.info.forecastDate,
-                },
-              },
             ],
+            info: {
+              path: ["info", "riverGaugeId"],
+              equals: payload.info.riverGaugeId,
+            },
           },
         });
 
         if (existingRecord) {
           this.logger.log(
-            `Updating existing record with new data for ${payload?.info?.stationName}`
+            `Updating existing record with new data for ${payload?.info?.riverGaugeId} and ${payload?.info?.stationName}`
           );
           return await tx.sourcesData.update({
             where: { id: existingRecord.id },
@@ -52,7 +50,7 @@ export class GfhService {
           });
         } else {
           this.logger.log(
-            `Creating new record for ${payload?.info?.stationName}`
+            `Creating new record for ${payload?.info?.riverGaugeId} and ${payload?.info?.stationName}`
           );
           return await tx.sourcesData.create({
             data: {