Repositorio de lineas funciona

packages/sim-objenious-cron/infranstructure/ObjeniousLinesRepository.ts

@@ -8,15 +8,38 @@ export class ObjeniousLinesRepository {
   ) {
   }
 
+  private generateLineHash(data: CreateObjeniousLineDTO) {
+    try {
+      const lineStr = JSON.stringify(data)
+      return lineStr
+    } catch (e) {
+      console.error("[x] Error generando el hash de la linea", data)
+      return undefined
+    }
+  }
+
   public async insertOrUpdate(data: CreateObjeniousLineDTO) {
     const query = `
         INSERT INTO objenious_lines (
-            simId, iccid, msisdn, imei, imeiChangeDate, 
-            offerCode, status, preactivationDate, activationDate, 
-            commercialStatus, commercialStatusDate, billingStatus, 
-            billingStatusChangeDate, billingActivationDate, createDate, raw
+            simId,
+            iccid,
+            msisdn,
+            imei,
+            imeiChangeDate, 
+            offerCode,
+            status,
+            preactivationDate,
+            activationDate, 
+            commercialStatus,
+            commercialStatusDate,
+            billingStatus, 
+            billingStatusChangeDate,
+            billingActivationDate,
+            createDate,
+            raw,
+            hash
         ) VALUES (
-            $1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15, $16
+            $1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15, $16, $17
         ) 
         ON CONFLICT (simId) 
         DO UPDATE SET 
@@ -33,10 +56,19 @@ export class ObjeniousLinesRepository {
             billingStatus = EXCLUDED.billingStatus,
             billingStatusChangeDate = EXCLUDED.billingStatusChangeDate,
             billingActivationDate = EXCLUDED.billingActivationDate,
-            raw = EXCLUDED.raw
+            raw = EXCLUDED.raw,
+            hash = EXCLUDED.hash
+        WHERE objenious_lines.hash IS DISTINCT FROM EXCLUDED.hash
         RETURNING id;
     `;
 
+    const lineHash = this.generateLineHash(data)
+
+    if (lineHash == undefined) {
+      console.error("[x] Ignorando linea ", data)
+      return;
+    }
+
     const values = [
       data.simId,
       data.iccid,
@@ -53,14 +85,15 @@ export class ObjeniousLinesRepository {
       data.billingStatusChangeDate,
       data.billingActivationDate,
       data.createDate || new Date(), // Default a ahora si no viene
-      JSON.stringify(data.raw)       // El driver de pg requiere string o el objeto directo para JSONB
+      JSON.stringify(data.raw),       // El driver de pg requiere string o el objeto directo para JSONB
+      lineHash
     ];
 
     let client: PoolClient | undefined = undefined;
     try {
       client = await this.pgClient.connect();
-      const res = await client.query(query, values);
-      return res.rows[0].id;
+      const res = await client.query<{ id: number }>(query, values);
+      return res.rows[0];
     } catch (err) {
       console.error('Error en la inserción:', err);
       throw err;