From c416114c502ee96f6fdcc7c6879e6d720c7fb028 Mon Sep 17 00:00:00 2001
From: Alvar San Martin <alvarsanmartin@savefamilygps.com>
Date: Tue, 24 Feb 2026 12:44:19 +0100
Subject: [PATCH] Arrglos por el cambio de nombre

---
 packages/sim-consumidor-objenious/index.ts     |  4 ++--
 .../config/postgreConfig.ts                    | 18 ++++++++++++++++++
 .../infrastructure/simRoutes.http.ts           |  6 +++++-
 packages/sim-objenious-cron/index.ts           |  4 ++--
 4 files changed, 27 insertions(+), 5 deletions(-)
 create mode 100644 packages/sim-entrada-eventos/config/postgreConfig.ts

diff --git a/packages/sim-consumidor-objenious/index.ts b/packages/sim-consumidor-objenious/index.ts
index d616a8a..da34b87 100644
--- a/packages/sim-consumidor-objenious/index.ts
+++ b/packages/sim-consumidor-objenious/index.ts
@@ -1,5 +1,5 @@
 
-import { OperationsRepository } from "sim-shared/infrastructure/OperationRepository.js"
+import { ObjeniousOperationsRepository } from "sim-shared/infrastructure/ObjeniousOperationRepository.js"
 import { startRMQClient } from "#config/eventBus.config.js"
 import { httpInstance } from "#config/httpClient.config.js"
 import { pgPool } from "#config/postgreConfig.js"
@@ -17,7 +17,7 @@ async function startWorker() {
 
   await pgClient.checkDatabaseConnection()
 
-  const operationRepository = new OperationsRepository(pgClient)
+  const operationRepository = new ObjeniousOperationsRepository(pgClient)
 
   const simActivationController = new SimController(
     rmqClient,
diff --git a/packages/sim-entrada-eventos/config/postgreConfig.ts b/packages/sim-entrada-eventos/config/postgreConfig.ts
new file mode 100644
index 0000000..f2fd926
--- /dev/null
+++ b/packages/sim-entrada-eventos/config/postgreConfig.ts
@@ -0,0 +1,18 @@
+import { Pool } from 'pg';
+import { PgClient } from 'sim-shared/infrastructure/PgClient.js'
+import { env } from './env/index.js';
+
+// Configuracion de la conexion a la BDD, deberia ser la 
+// Misma para todos los servicios pero hasta que se unifique todo 
+// se hace una por servicio.
+export const pgPool = new Pool({
+  user: env.POSTGRES_USER,
+  host: env.POSTGRES_HOST,
+  database: env.POSTGRES_DATABASE,
+  password: env.POSTGRES_PASSWORD,
+  port: Number(env.POSTGRES_PORT) || 5432,
+});
+
+export const postgresClient = new PgClient({
+  pool: pgPool
+}) 
diff --git a/packages/sim-entrada-eventos/infrastructure/simRoutes.http.ts b/packages/sim-entrada-eventos/infrastructure/simRoutes.http.ts
index c163d37..de9a1f3 100644
--- a/packages/sim-entrada-eventos/infrastructure/simRoutes.http.ts
+++ b/packages/sim-entrada-eventos/infrastructure/simRoutes.http.ts
@@ -2,11 +2,15 @@ import { rabbitmqEventBus } from '#config/eventBusConfig.js';
 import { SimUsecases } from '../aplication/Sim.usecases.js';
 import { SimController } from '../aplication/Sim.controller.js';
 import { Router } from 'express';
+import { OrderRepository } from 'sim-shared/infrastructure/OrderRepository.js';
+import { postgresClient } from '#config/postgreConfig.js';
 
 const simRoutes = Router()
+const orderRepository = new OrderRepository(postgresClient)
 
 const simUseCases = new SimUsecases({
-  eventBus: rabbitmqEventBus
+  eventBus: rabbitmqEventBus,
+  orderRepository: orderRepository
 })
 
 const simController = new SimController({
diff --git a/packages/sim-objenious-cron/index.ts b/packages/sim-objenious-cron/index.ts
index 6f51158..6c4cedb 100644
--- a/packages/sim-objenious-cron/index.ts
+++ b/packages/sim-objenious-cron/index.ts
@@ -3,7 +3,7 @@ import { pgPool } from "./config/postgreConfig.js"
 import { PgClient } from "sim-shared/infrastructure/PgClient.js"
 import { httpInstance } from "./config/httpClient.config.js"
 import { CheckObjeniousRequests } from "./tasks/check_objenious_request.js"
-import { OperationsRepository } from "sim-shared/infrastructure/OperationRepository.js"
+import { ObjeniousOperationsRepository } from "sim-shared/infrastructure/ObjeniousOperationRepository.js"
 
 async function startCron() {
   const commonSettings = {
@@ -15,7 +15,7 @@ async function startCron() {
   const pgClient = new PgClient({ pool: pgPool })
   await pgClient.checkDatabaseConnection()
   await pgClient.checkDatabaseConnection()
-  const operationRepository = new OperationsRepository(pgClient)
+  const operationRepository = new ObjeniousOperationsRepository(pgClient)
 
   const objTask = new CheckObjeniousRequests(
     operationRepository,