Lineas activas e insertar cada una

packages/sim-objenious-cron/config/intranetPostgresConfig.ts

@@ -0,0 +1,20 @@
+/**
+ * Cliente de postgres para la intranet. Se usa solo porque hace falta para el 
+ * volcado de datos, si se usa en mas partes algo estás haciendo mal.
+ */
+
+import { Pool } from 'pg';
+import { PgClient } from 'sim-shared/infrastructure/PgClient.js'
+import { env } from './env/index.js';
+
+export const pgPoolIntranet = new Pool({
+  user: env.POSTGRES_USER,
+  host: env.POSTGRES_HOST,
+  database: "intranet",
+  password: env.POSTGRES_PASSWORD,
+  port: Number(env.POSTGRES_PORT) || 5432,
+});
+
+export const postgrClientIntranet = new PgClient({
+  pool: pgPoolIntranet
+}) 

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

@@ -0,0 +1,73 @@
+import { PoolClient } from "pg";
+import { CreateObjeniousLineDTO } from "sim-shared/domain/objeniousLine.js";
+import { PgClient } from "sim-shared/infrastructure/PgClient.js";
+
+export class ObjeniousLinesRepository {
+  constructor(
+    private pgClient: PgClient
+  ) {
+  }
+
+  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
+        ) VALUES (
+            $1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15, $16
+        ) 
+        ON CONFLICT (simId) 
+        DO UPDATE SET 
+            iccid = EXCLUDED.iccid,
+            msisdn = EXCLUDED.msisdn,
+            imei = EXCLUDED.imei,
+            imeiChangeDate = EXCLUDED.imeiChangeDate,
+            offerCode = EXCLUDED.offerCode,
+            status = EXCLUDED.status,
+            preactivationDate = EXCLUDED.preactivationDate,
+            activationDate = EXCLUDED.activationDate,
+            commercialStatus = EXCLUDED.commercialStatus,
+            commercialStatusDate = EXCLUDED.commercialStatusDate,
+            billingStatus = EXCLUDED.billingStatus,
+            billingStatusChangeDate = EXCLUDED.billingStatusChangeDate,
+            billingActivationDate = EXCLUDED.billingActivationDate,
+            raw = EXCLUDED.raw
+        RETURNING id;
+    `;
+
+    const values = [
+      data.simId,
+      data.iccid,
+      data.msisdn,
+      data.imei,
+      data.imeiChangeDate,
+      data.offerCode,
+      data.status,
+      data.preactivationDate,
+      data.activationDate,
+      data.commercialStatus,
+      data.commercialStatusDate,
+      data.billingStatus,
+      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
+    ];
+
+    let client: PoolClient | undefined = undefined;
+    try {
+      client = await this.pgClient.connect();
+      const res = await client.query(query, values);
+      return res.rows[0].id;
+    } catch (err) {
+      console.error('Error en la inserción:', err);
+      throw err;
+    } finally {
+      if (client != undefined) {
+        client.release()
+      }
+    }
+  }
+}

packages/sim-objenious-cron/tasks/check_objenious_request.ts

@@ -54,6 +54,7 @@ export class CheckObjeniousRequests {
   /**
    * Para una lista de operaciones **con mass_action_id** se comprueba si han tenido alguna actualizacion
    * Devuelve el numero de operaciones comprobadas.
+   * TODO: Esto va en un repositorio
    */
   private async getMassActionsStatus(requestList: ObjeniousOperation[]) {
     if (requestList.length == 0) return 0;

packages/sim-objenious-cron/tasks/volcado_lineas.ts

@@ -0,0 +1,68 @@
+import { ObjeniousLine, ObjeniousLineResponse } from "sim-shared/domain/objeniousLine.js";
+import { tryCatch, Result } from "sim-shared/domain/Result.js";
+import { HttpClient } from "sim-shared/infrastructure/HTTPClient.js";
+
+const MAX_PAGE_SIZE = 1000
+
+export class VolcadoLineas {
+  constructor(
+    private readonly httpClient: HttpClient
+  ) {
+  }
+
+  /**
+  * Mover al repo
+  */
+  private async getLinesByStatus(args?: {
+    pageSize?: number,
+    pageNumber?: number,
+    status?: string
+  }): Promise<Result<string, ObjeniousLine[]>> {
+
+    const path = "/lines"
+    const pageSize = args?.pageSize ?? MAX_PAGE_SIZE;
+    const status = args?.status ?? null;
+    let currentPage = args?.pageNumber ?? 0;
+    let totalPages = 1;
+    let allLines: ObjeniousLine[] = []
+
+    const loadNextLine = async () => {
+      const nextPage = await tryCatch<ObjeniousLineResponse>(this.httpClient.client.get(path, {
+        params: {
+          simStatus: status,
+          pageSize: pageSize,
+          pageNumber: currentPage
+        }
+      }))
+      if (nextPage.error != undefined) {
+        return {
+          error: nextPage.error.msg.message
+        }
+      }
+
+      // Se aumenta para la siguiente ejecucion
+      currentPage = nextPage.data.pageNumber + 1
+      allLines = [...allLines, ...nextPage.data.content]
+      totalPages = nextPage.data.totalPages
+    }
+
+    // El inicio se ejecuta siempre
+    await loadNextLine()
+
+    // Copia para evitar bucles infinitos por error de la api
+    const maxPages = totalPages
+
+    for (let i = currentPage; i < maxPages; i++) {
+      await loadNextLine()
+    }
+
+    return {
+      data: allLines
+    }
+  }
+
+  public async loadLines() {
+
+  }
+
+}