Comillas

delete
delete env
2026-05-11 12:15:37 +02:00 · 2026-05-11 10:10:17 +02:00 · 2026-05-11 10:09:16 +02:00 · 2026-05-11 10:05:26 +02:00 · 2026-05-11 09:23:49 +02:00 · 2026-05-08 14:49:43 +02:00
184 changed files with 7157 additions and 1313 deletions
--- a/.env
+++ b/.env
@@ -1,29 +0,0 @@
-PORT=3000
-API_HOSTNAME=0.0.0.0
-RABBITMQ_USER=guest
-RABBITMQ_PASSWORD=guest
-
-ENVIORMENT=development
-
-#RABBITMQ_HOST=rabbitmq-sim-broker
-RABBITMQ_HOST=localhost
-RABBITMQ_PORT=5672
-RABBITMQ_USER=guest
-RABBITMQ_PASSWORD=guest
-RABBITMQ_SECURE=false
-RABBITMQ_VHOST=sim-vhost
-
-# Hay cosas que unificar de varios servicios
-#POSTGRES_HOST=postgresql-sim
-POSTGRES_HOST=localhost
-POSTGRES_DB=postgres
-POSTGRES_DATABASE=postgres
-POSTGRES_PORT=5433
-POSTGRES_USER=postgres
-POSTGRES_PASSWORD=1234
-
-# Para el postgres local para generar el script de resultado de migraciones
-PGHOST=localhost
-PGUSER=alvar
-PGPASSWORD=alvar
-PGPORT=5433
--- a/.gitignore
+++ b/.gitignore
@@ -16,7 +16,11 @@ node_modules
 #!.yarn/cache
 .pnp.*

+# Certificados
 *.pem
-
+*.p12
+*.key

 dist/*
+
+.env
--- a/README.md
+++ b/README.md
@@ -12,13 +12,13 @@ La compañia a la que pertenece cada peticion y por tanto el servicio que lo va

 ## Decisiones pendientes

- [x] La capa worker según acción y la de operaciones de proveedores, se podrían unir en una sola con un enrutamiento por acción y compañía, pasando de tener claves `sim.[acción]` a `sim.[compañia].[acción]`. *Se ha aplicado el cambio ahora las routing keys tienen la estructura `sim.[compañia].[acción]`*
- [x] La estructura de RMQ se genera por medio del JSON, igual habría que definir cada cola en el worker que la consuma para poder añadir workers sin parar el RMQ. *Se ha aplicado el cambio, ahora solo se define en el json el broker principal para garantizar que exita sin servicios consumidores. Sin embargo tal como estan estructurdos los proyectos no es posible reiniciar solo un servicio*
+- [x] La capa worker según acción y la de operaciones de proveedores, se podrían unir en una sola con un enrutamiento por acción y compañía, pasando de tener claves `sim.[acción]` a `sim.[compañia].[acción]`. _Se ha aplicado el cambio ahora las routing keys tienen la estructura `sim.[compañia].[acción]`_
+- [x] La estructura de RMQ se genera por medio del JSON, igual habría que definir cada cola en el worker que la consuma para poder añadir workers sin parar el RMQ. _Se ha aplicado el cambio, ahora solo se define en el json el broker principal para garantizar que exita sin servicios consumidores. Sin embargo tal como estan estructurdos los proyectos no es posible reiniciar solo un servicio_
 - [ ] Versionado de la API.
- [x] Método para sacar la compañía a partir del iccid, o buscar en la BDD si no es posible. *De momento es un objeto Map en el servicio de gateway*
- [ ] Cola de mensajes que no se han podido procesar. Distinguir según error de red; se reintenta; o error del propio mensaje; se envía a la cola de errores. v2 Se ha creado una cola de delay pero no se distingue el tipo de error, despues de n reintentos el mensaje va a la cola de dead-letter.
- [ ] Seguimiento de las peticiones de Objenious, por cada peticion hay qye hacer un seguimiento del request y de los mass action para saber si las activaciones han tenido exito. Habria que crear otra cola para consultar cada x tiempo o mejor un cron?
- [ ] Actualizar en la base de datos el estado de las peticiones de las sim y añadir el número de telefono cuando se activen o cuando se cumpla una accion. 
+- [x] Método para sacar la compañía a partir del iccid, o buscar en la BDD si no es posible. _De momento es un objeto Map en el servicio de gateway_
+- [ ] Cola de mensajes que no se han podido procesar. Distinguir según error de red; se reintenta; o error del propio mensaje; se envía a la cola de errores. v2 Se ha creado una cola de delay pero no se distingue el tipo de error, después de n reintentos el mensaje va a la cola de dead-letter.
+- [x] Seguimiento de las peticiones de Objenious, por cada peticion hay qye hacer un seguimiento del request y de los mass action para saber si las activaciones han tenido exito. Habria que crear otra cola para consultar cada x tiempo o mejor un cron?
+- [x] Actualizar en la base de datos el estado de las peticiones de las sim y añadir el número de telefono cuando se activen o cuando se cumpla una accion.

 ## Versión con consumidores basados en la compañia

@@ -32,8 +32,15 @@ OBJENIOUS (33)2011a

 ## Diagrama de las colas de Rabbitmq

-Actualmente la topologia de las colas consiste en un exchage principal que recibe todos los mensajes y los redistribuye en las colas de cada empresa y a la de logs. Para evitar reintentos de mensajes instantaneos, que podrian ser inutiles si algún servicio se ha caido, se ha añadido una cola de delay que alamcena los mesajes fallidos durante n segundos antes de ser reenviados al exchange principal. Si despues de n reintentos el mensaje sigue fallando se envia a la cola de dead-letter para ser procesado manualmente.
+Actualmente la topología de las colas consiste en un exchage principal que recibe todos los mensajes y los redistribuye en las colas de cada empresa y a la de logs. Para evitar reintentos de mensajes instantáneos, que podrían ser inútiles si algún servicio se ha caído, se ha añadido una cola de delay que almacena los mensajes fallidos durante n segundos antes de ser reenviados al exchange principal. Si después de n reintentos el mensaje sigue fallando se envía a la cola de dead-letter para ser procesado manualmente.

 ![img](./imgs/diagrama-rabbit.png)

-La decisión del numero de reintentos y la cola de dlx se hace en los servicios, con una configuracion global en shared.
+La decisión del numero de reintentos y la cola de dlx se hace en los servicios, con una configuración global en shared.
+
+## Puertos internos para comunicaciones entre sub-servicios
+
+- **3000**: Gateway (sim-entrada-eventos)
+- **3001**: Consumidor NOS (sim-consumidor-nos)
+- **3002**: Consumidor Objenious (sim-consumidor-objenious)
+- **3003**: Consumidor Alai (sim-consumidor-alai)
--- a/deployment/database/migrations/1.0.0_orders.sql
+++ b/deployment/database/migrations/1.0.0_orders.sql
@@ -24,7 +24,6 @@ CREATE TABLE IF NOT EXISTS order_tracking (
    payload JSONB,                                          -- Duda si es optimo guardar la copia, es útil en caso de fallo
    
    -- Campos de reintentos?
-
    status order_status NOT NULL DEFAULT 'pending',
    retry_count INT DEFAULT 0,
    error_message TEXT,                                      -- Razón del fallo
--- a/deployment/database/migrations/1.2.0_Cola-pausa-cancelacion.sql
+++ b/deployment/database/migrations/1.2.0_Cola-pausa-cancelacion.sql
@@ -0,0 +1,32 @@
+/**
+* Para la tarea WEBINT-328-Pausas-cacelaciones.
+* Almacena las pausas/cancelaciones que no se han podido hacer porque la linea esta en
+* "Test"
+*/
+
+
+DO $$ BEGIN
+  CREATE TYPE SUSPENDTERMINATE AS ENUM ('suspend','terminate');
+EXCEPTION
+    WHEN duplicate_object THEN null;
+END $$;
+
+CREATE TABLE IF NOT EXISTS pause_cancel_tasks (
+    id BIGINT PRIMARY KEY GENERATED ALWAYS AS IDENTITY,
+    iccid TEXT NOT NULL,
+    operation_type SUSPENDTERMINATE,
+    last_checked TIMESTAMPTZ, -- Última vez que se ha comprobado que no esté en test
+    activation_date TIMESTAMPTZ, -- Fecha de activacion para comprobar si ha pasdo un mes
+    next_check TIMESTAMPTZ, -- Si se ha comprobado se asignará la siguiente fecha de revision
+
+    completed_date TIMESTAMPTZ, -- Cuando se ha completado, para bien o mal.
+    error TEXT,
+    action_data JSONB -- datos de la operacion original.
+);
+
+-- Indice de las tareas que no han terminado 
+CREATE INDEX idx_pause_cancel_tasks_pending 
+ON pause_cancel_tasks (next_check) 
+WHERE completed_date IS NULL;
+
+
--- a/deployment/develop/docker/Dockerfile
+++ b/deployment/develop/docker/Dockerfile
@@ -8,6 +8,8 @@ RUN corepack enable
 COPY ./dist/packages ./packages
 COPY ./.yarnrc.yml ./
 COPY ./docs ./docs
+# Para las migraciones
+COPY ./deployment ./deployment

 COPY ./package.json ./

--- a/deployment/develop/docker/docker-compose.yaml
+++ b/deployment/develop/docker/docker-compose.yaml
@@ -72,6 +72,7 @@ services:
      - ${PORT}
    volumes:
      - ./.env:/home/node/app/.env:ro
+      - ./sim-consumidor-nos.env:/home/node/app/packages/sim-consumidor-nos/.env:ro
      - ./sim-consumidor-objenious.env:/home/node/app/packages/sim-consumidor-objenious/.env:ro
      - ./sim-objenious-cron.env:/home/node/app/packages/sim-objenious-cron/.env:ro
      - ./obj.pem:/home/node/app/packages/sim-consumidor-objenious/obj.pem:ro
--- a/deployment/develop/docker/entrypoint.sh
+++ b/deployment/develop/docker/entrypoint.sh
@@ -1,4 +1,6 @@
 #!/bin/sh
 cd /home

-cd /home/node/app && yarn start
+cd /home/node/app
+yarn migrate
+yarn start
--- a/deployment/develop/jenkinsfile.groovy
+++ b/deployment/develop/jenkinsfile.groovy
@@ -44,15 +44,27 @@ pipeline {
 								),
 								sshTransfer(
 									cleanRemote: false,
-									execCommand: "ln -sf $BASE_REMOTE_PATH/vault/savefamily/sf-sims/sim-consumidor-objenious.env $APP_REMOTE_PATH/sim-consumidor-objenious.env"
+									execCommand: "ln -sf $BASE_REMOTE_PATH/vault/savefamily/sf-sims/sim-consumidor-objenious.env $APP_REMOTE_PATH/packages/sim-consumidor-objenious/.env"
 								),
 								sshTransfer(
 									cleanRemote: false,
-									execCommand: "ln -sf $BASE_REMOTE_PATH/vault/savefamily/sf-sims/sim-objenious-cron.env $APP_REMOTE_PATH/sim-objenious-cron.env"
+									execCommand: "ln -sf $BASE_REMOTE_PATH/vault/savefamily/sf-sims/sim-consumidor-nos.env $APP_REMOTE_PATH/packages/sim-consumidor-nos/.env"
 								),
 								sshTransfer(
 									cleanRemote: false,
-									execCommand: "ln -sf $BASE_REMOTE_PATH/vault/savefamily/sf-sims/obj.pem $APP_REMOTE_PATH/obj.pem"
+									execCommand: "ln -sf $BASE_REMOTE_PATH/vault/savefamily/sf-sims/sim-consumidor-alai.env $APP_REMOTE_PATH/packages/sim-consumidor-alai/.env"
+								),
+								sshTransfer(
+									cleanRemote: false,
+									execCommand: "ln -sf $BASE_REMOTE_PATH/vault/savefamily/sf-sims/wsaccess_alaisecure_com_cert_client_new.p12 $APP_REMOTE_PATH/packages/wsaccess_alaisecure_com_cert_client_new.p12"
+								),
+								sshTransfer(
+									cleanRemote: false,
+									execCommand: "ln -sf $BASE_REMOTE_PATH/vault/savefamily/sf-sims/sim-objenious-cron.env $APP_REMOTE_PATH/packages/sim-objenious-cron/.env"
+								),
+								sshTransfer(
+									cleanRemote: false,
+									execCommand: "ln -sf $BASE_REMOTE_PATH/vault/savefamily/sf-sims/obj.pem $APP_REMOTE_PATH/packages/sim-consumidor-objenious/obj.pem"
 								),
 								sshTransfer(
 									cleanRemote: false,
@@ -69,7 +81,6 @@ pipeline {
 									cleanRemote: false,
 									remoteDirectory: "$APP_REMOTE_PATH",
 									sourceFiles: "deployment/database/**/*",
-									removePrefix: "deployment",
 								),
 								sshTransfer(
 									cleanRemote: false,
--- a/deployment/local/docker/docker-compose.yaml
+++ b/deployment/local/docker/docker-compose.yaml
@@ -7,6 +7,7 @@ networks:
 services:
  rabbitmq-sim-broker:
    container_name: rabbitmq-sim-broker
+    hostname: rabbitmq-sim
    image: "rabbitmq:4.2.2-management"
    ports:
      - "5672:5672"
@@ -23,6 +24,7 @@ services:
      RABBITMQ_DEFAULT_USER: ${RABBITMQ_USER}
      RABBITMQ_DEFAULT_PASS: ${RABBITMQ_PASSWORD}
    volumes:
+      - ./rabbitmq-data/:/var/lib/rabbitmq/
      - ./rabbitmq_plugins/enabled_plugins:/etc/rabbitmq/enabled_plugins:ro
      - ./deployment/local/rabbit/rabbitmq.conf:/etc/rabbitmq/rabbitmq.conf:ro
      - ./deployment/local/rabbit/definitions.json:/etc/rabbitmq/definitions.json:ro
--- a/docs/sim-alai/Change
+++ b/docs/sim-alai/Change
@@ -0,0 +1,32 @@
+info:
+  name: Change External ID
+  type: http
+  seq: 7
+
+http:
+  method: GET
+  url: "{{baseurl}}/v1/subscription/{{subscription}}?action=MODIFY"
+  params:
+    - name: action
+      value: MODIFY
+      type: query
+  body:
+    type: json
+    data: |-
+      {
+        "externalID":""
+      }
+  auth:
+    type: bearer
+    token: "{{alai_token}}"
+
+runtime:
+  variables:
+    - name: subscription
+      value: asdasdasd
+
+settings:
+  encodeUrl: true
+  timeout: 0
+  followRedirects: true
+  maxRedirects: 5
--- a/docs/sim-alai/IMEI
+++ b/docs/sim-alai/IMEI
@@ -0,0 +1,22 @@
+info:
+  name: IMEI of subscription
+  type: http
+  seq: 5
+
+http:
+  method: GET
+  url: "{{baseurl}}/v1/subscription/{{subscription}}/imei"
+  auth:
+    type: bearer
+    token: "{{alai_token}}"
+
+runtime:
+  variables:
+    - name: subscription
+      value: SID1848557_TS1766417781101_0
+
+settings:
+  encodeUrl: true
+  timeout: 0
+  followRedirects: true
+  maxRedirects: 5
--- a/docs/sim-alai/Login.yml
+++ b/docs/sim-alai/Login.yml
@@ -0,0 +1,51 @@
+info:
+  name: Login
+  type: http
+  seq: 2
+
+http:
+  method: POST
+  url: "{{baseurl}}/v1/auth/login"
+  body:
+    type: json
+    data: |-
+      {
+        "username": "{{username}}",
+        "password": "{{password}}",
+        "brandID": "{{brandId}}"
+      }
+  auth: inherit
+
+runtime:
+  scripts:
+    - type: after-response
+      code: |-
+        const data = res.getBody();
+
+        if (data.status != 200) {
+          console.error("Error de login: ", data)
+          return 1;
+        }
+
+        if (data && data.accessToken) {
+
+          bru.setEnvVar("alai_token", data.accessToken);
+
+          if (data.tokenType) {
+            bru.setEnvVar("alai_token_type", data.tokenType);
+          }
+          
+          console.log("Token guardado correctamente");
+        } else {
+          console.error("No se pudo encontrar el accessToken en la respuesta");
+        }
+
+settings:
+  encodeUrl: true
+  timeout: 0
+  followRedirects: true
+  maxRedirects: 5
+
+docs: |-
+  Necesita un certificado p12 (PFX) y la contraseña asociada para efectuar la operacion.
+  Collection Settings => ClientCertificates => Add Certificate
--- a/docs/sim-alai/New
+++ b/docs/sim-alai/New
@@ -0,0 +1,16 @@
+info:
+  name: New Order
+  type: http
+  seq: 3
+
+http:
+  method: POST
+  url: "{{baseurl}}/v1/order"
+  auth:
+    type: bearer
+
+settings:
+  encodeUrl: true
+  timeout: 0
+  followRedirects: true
+  maxRedirects: 5
--- a/docs/sim-alai/SIM.yml
+++ b/docs/sim-alai/SIM.yml
@@ -0,0 +1,22 @@
+info:
+  name: SIM
+  type: http
+  seq: 4
+
+http:
+  method: GET
+  url: "{{baseurl}}/v1/sim/{{iccid}}"
+  auth:
+    type: bearer
+    token: "{{alai_token}}"
+
+runtime:
+  variables:
+    - name: iccid
+      value: "8934909001500561503"
+
+settings:
+  encodeUrl: true
+  timeout: 0
+  followRedirects: true
+  maxRedirects: 5
--- a/docs/sim-alai/Subscription.yml
+++ b/docs/sim-alai/Subscription.yml
@@ -0,0 +1,22 @@
+info:
+  name: Subscription
+  type: http
+  seq: 4
+
+http:
+  method: GET
+  url: "{{baseurl}}/v1/subscription/{{subscription}}"
+  auth:
+    type: bearer
+    token: "{{alai_token}}"
+
+runtime:
+  variables:
+    - name: subscription
+      value: SID1776275_TS1759238704226_0
+
+settings:
+  encodeUrl: true
+  timeout: 0
+  followRedirects: true
+  maxRedirects: 5
--- a/docs/sim-alai/certificates/alai_cert.p12
+++ b/docs/sim-alai/certificates/alai_cert.p12
--- a/docs/sim-alai/environments/local.yml
+++ b/docs/sim-alai/environments/local.yml
@@ -0,0 +1,7 @@
+name: local
+color: "#2E8A54"
+variables:
+  - name: baseurl
+    value: http://localhost:3002
+  - secret: true
+    name: token
--- a/docs/sim-alai/environments/prod.yml
+++ b/docs/sim-alai/environments/prod.yml
@@ -0,0 +1,15 @@
+name: prod
+color: "#CE4F3B"
+variables:
+  - name: baseurl
+    value: https://wsaccess.alaisecure.com/bssrest
+  - name: username
+    value: palomaibanez
+  - name: password
+    value: palomaibanez123
+  - secret: true
+    name: certPasswd
+  - name: brandId
+    value: savefamily
+  - name: alai_token
+    value: eyJhbGciOiJIUzM4NCJ9.eyJiciI6InNhdmVmYW1pbHkiLCJpcCI6Ijg4LjE1LjE1Ny4xNjciLCJzdWIiOiJwYWxvbWFpYmFuZXoiLCJzIjoiRVdTMTY0YWJhYWRlNjA3ZDAyIiwicG9zIjoic2F2ZWZhbWlseUNhYyIsImlkV3NVc2VyIjoiODYiLCJpc012bmEiOmZhbHNlLCJkb21haW4iOiJBbGFpfHNhdmVmYW1pbHkiLCJpYXQiOjE3NzgxNTEzMzYsImV4cCI6MTc3ODE2MjEzNn0.zCFBJJsa0Krc7n5vUFF00z9Tq7m0dRlCGzs2Od67jaLCCn-mnIyyU424PkazacRW
--- a/docs/sim-alai/opencollection.yml
+++ b/docs/sim-alai/opencollection.yml
@@ -0,0 +1,26 @@
+opencollection: 1.0.0
+
+info:
+  name: sim-alai
+config:
+  proxy:
+    inherit: true
+    config:
+      protocol: http
+      hostname: ""
+      port: ""
+      auth:
+        username: ""
+        password: ""
+      bypassProxy: ""
+  clientCertificates:
+    - domain: wsaccess.alaisecure.com
+      type: pkcs12
+      pkcs12FilePath: certificates\alai_cert.p12
+      passphrase: iHaaek+zyzWz6cH6rg==
+bundled: false
+extensions:
+  bruno:
+    ignore:
+      - node_modules
+      - .git
--- a/docs/sim-api-documentation.html
+++ b/docs/sim-api-documentation.html
--- a/docs/sim-api/Activate.bru
+++ b/docs/sim-api/Activate.bru
@@ -6,16 +6,80 @@ meta {

 post {
  url: {{baseurl}}/sim/activate
-  body: formUrlEncoded
+  body: json
  auth: inherit
 }

+body:json {
+  {
+    "iccid": "1234"
+  }
+}
+
 body:form-urlencoded {
-  iccid: 8933201125068886692
-  offer: SAVEFAMILY1
+  iccid: 123
+  offer: mensual
 }

 settings {
  encodeUrl: true
  timeout: 0
 }
+
+docs {
+  Campos de entrada: 
+  ```ts
+  // Header requerido
+  // > content-type:application/x-www-form-urlencoded
+  // > content-type:application/json
+  // Cualquiera de los 2 es valido
+  
+  // Esquema body
+  {
+    iccid: string,
+    offer: "mensual" | "anual" | "SAVEFAMILY1" | "SAVEFAMILY2"
+    webhook?: string,
+  }
+  ```
+  
+  En el campo `offer` "mensual" equivale a "SAVEFAMILY2" y "anual" a "SAVEFAMILY1" porque se mantien los códigos de Oferta de Objenious por compatibilidad pero se espera usar "mensual" y "anual" y hacer la conversión en el servicio de cada proveedor.
+  
+  Para las llamadas al webhook se va a usar siempre el metodo `POST`, ahora mismo no se firman los mensajes. Se introduce la URL completa tal que `https://dominion.com/v1/endpoint`.
+  
+  Respuestas:
+  - **200**: OK 
+  ``` ts
+  // Esquema
+  {
+    iccid: string,
+    operation: string,
+    message_id: string, //uuidv7
+  }
+  ```
+  ``` json
+  // Ejemplo
+  {
+    "iccid": "89332011250651xxxxx",
+    "operation": "activation",
+    "message_id": "019dbeaf-8abb-7783-8b51-94fbd9f0b0df"
+  }
+  ```
+  
+  *iccid*: Confirmación del iccid enviado.
+  *operation*: Confirmación de la operacion que se ha aplicado.
+  *message_id*: Id de la operación, para consultar en orders.
+  
+  > A futuro se va a incluir un campo `"ref":[]` para añadir los enlaces a las consultas de la operación. El body va a permitir tambien json.
+  
+  - **402**: Algún campo es incorrecto
+  Se indica que campo es incorrecto, si hubiese mas de uno solo aparecería el primero en comprobarse.
+  ```json
+    "errors": {
+      "msg": "La longitud del iccid es incorrecta debera ser de 19 caracteres",
+      "field": "iccid"
+    }
+  ```
+  
+  - **500**: Error general
+  Ha ocurrido un error imprevisto durante la 
+}
--- a/docs/sim-api/Activation
+++ b/docs/sim-api/Activation
@@ -1,7 +1,7 @@
 meta {
  name: Activation Email Health
  type: http
-  seq: 8
+  seq: 9
 }

 post {
--- a/docs/sim-api/Activation
+++ b/docs/sim-api/Activation
@@ -1,7 +1,7 @@
 meta {
  name: Activation Email
  type: http
-  seq: 6
+  seq: 8
 }

 post {
--- a/docs/sim-api/Alai/Preactivate.bru
+++ b/docs/sim-api/Alai/Preactivate.bru
@@ -0,0 +1,20 @@
+meta {
+  name: Preactivate
+  type: http
+  seq: 2
+}
+
+get {
+  url: {{baseAlai}}/preactivate?iccid=8934909001400027654
+  body: none
+  auth: inherit
+}
+
+params:query {
+  iccid: 8934909001400027654
+}
+
+settings {
+  encodeUrl: true
+  timeout: 0
+}
--- a/docs/sim-api/Alai/Select
+++ b/docs/sim-api/Alai/Select
@@ -0,0 +1,20 @@
+meta {
+  name: Select SIM
+  type: http
+  seq: 1
+}
+
+get {
+  url: {{baseAlai}}/select/?iccid=8934909001500561503
+  body: none
+  auth: inherit
+}
+
+params:query {
+  iccid: 8934909001500561503
+}
+
+settings {
+  encodeUrl: true
+  timeout: 0
+}
--- a/docs/sim-api/Alai/folder.bru
+++ b/docs/sim-api/Alai/folder.bru
@@ -0,0 +1,8 @@
+meta {
+  name: Alai
+  seq: 14
+}
+
+auth {
+  mode: inherit
+}
--- a/docs/sim-api/Cancel.bru
+++ b/docs/sim-api/Cancel.bru
@@ -1,7 +1,7 @@
 meta {
  name: Cancel
  type: http
-  seq: 1
+  seq: 4
 }

 post {
@@ -11,7 +11,7 @@ post {
 }

 body:form-urlencoded {
-  iccid: 8933201125068886692
+  iccid: 8933201125068889894
 }

 settings {
--- a/docs/sim-api/Docs.bru
+++ b/docs/sim-api/Docs.bru
@@ -1,7 +1,7 @@
 meta {
  name: Docs
  type: http
-  seq: 12
+  seq: 11
 }

 get {
--- a/docs/sim-api/Health.bru
+++ b/docs/sim-api/Health.bru
@@ -1,7 +1,7 @@
 meta {
  name: Health
  type: http
-  seq: 5
+  seq: 7
 }

 get {
--- a/docs/sim-api/Nos/Select.bru
+++ b/docs/sim-api/Nos/Select.bru
@@ -0,0 +1,16 @@
+meta {
+  name: Select
+  type: http
+  seq: 1
+}
+
+get {
+  url: {{baseurl}}/portugal/select
+  body: none
+  auth: inherit
+}
+
+settings {
+  encodeUrl: true
+  timeout: 0
+}
--- a/docs/sim-api/Nos/folder.bru
+++ b/docs/sim-api/Nos/folder.bru
@@ -0,0 +1,8 @@
+meta {
+  name: Nos
+  seq: 15
+}
+
+auth {
+  mode: inherit
+}
--- a/docs/sim-api/Objenious/France
+++ b/docs/sim-api/Objenious/France
@@ -0,0 +1,26 @@
+meta {
+  name: France Suspended Lines
+  type: http
+  seq: 16
+}
+
+get {
+  url: {{baseurl}}/france/lines?status=SUSPENDED&limit=100
+  body: none
+  auth: inherit
+}
+
+params:query {
+  status: SUSPENDED
+  limit: 100
+}
+
+vars:pre-request {
+  iccid: 8933201125065160331
+  ~baseurl: http://localhost:3002
+}
+
+settings {
+  encodeUrl: true
+  timeout: 0
+}
--- a/docs/sim-api/Objenious/France
+++ b/docs/sim-api/Objenious/France
@@ -0,0 +1,21 @@
+meta {
+  name: France Suspended Time
+  type: http
+  seq: 15
+}
+
+get {
+  url: {{baseurl}}/france/lines/{{iccid}}/suspended-time
+  body: none
+  auth: inherit
+}
+
+vars:pre-request {
+  iccid: 8933201125065160331
+  ~baseurl: http://localhost:3002
+}
+
+settings {
+  encodeUrl: true
+  timeout: 0
+}
--- a/docs/sim-api/Objenious/folder.bru
+++ b/docs/sim-api/Objenious/folder.bru
@@ -0,0 +1,8 @@
+meta {
+  name: Objenious
+  seq: 16
+}
+
+auth {
+  mode: inherit
+}
--- a/docs/sim-api/Orders/Get
+++ b/docs/sim-api/Orders/Get
@@ -1,7 +1,7 @@
 meta {
  name: Get pending orders
  type: http
-  seq: 11
+  seq: 10
 }

 get {
--- a/docs/sim-api/Orders/Order
+++ b/docs/sim-api/Orders/Order
@@ -5,7 +5,7 @@ meta {
 }

 get {
-  url: {{baseurl}}/orders/
+  url: {{baseurl}}/orders/019dbeaf-8abb-7783-8b51-94fbd9f0b0df
  body: none
  auth: inherit
 }
--- a/docs/sim-api/Orders/Orders
+++ b/docs/sim-api/Orders/Orders
@@ -5,15 +5,11 @@ meta {
 }

 get {
-  url: {{baseurl}}/orders/message_id/019c93d3-014a-711d-b958-03dd629be78d
+  url: {{baseurl}}/orders/message_id/019dbeaf-8abb-7783-8b51-94fbd9f0b0df
  body: none
  auth: inherit
 }

-params:query {
-  ~message_id: 019c93d3-014a-711d-b958-03dd629be78d
-}
-
 settings {
  encodeUrl: true
  timeout: 0
--- a/docs/sim-api/Orders/folder.bru
+++ b/docs/sim-api/Orders/folder.bru
@@ -0,0 +1,45 @@
+meta {
+  name: Orders
+  seq: 3
+}
+
+auth {
+  mode: inherit
+}
+
+docs {
+  # Orders
+  
+  Los *order* representan ordenes que se hacen al servidor y representan en que estado se encuentran las peticiones. Los *order* se generan cuando se solicita una operacion y devuelven su identificador en el campo `message_id` de todas las respuestas a peticiones que requieran cambios. Los identificadores de `order` son UUIDv7, aunque tambien tienen asociado un id tradicional BIGINT en la BDD.
+  
+  ## Ciclo de vida
+  
+  Cuando se crea un *order* comienza en estado `pending`, inicando que ha entrado en la cola y está pendiente de iniciarse; una vez se ha consumido por un servicio pasa a estado `running` indicando que la operacion asociada al *order* ha comenzado, el order continuara en este estado durante un tiempo indefinido (pueden pasar semanas para algunos casos), hasta que la tara finalize correctamente o con errores. En el caso que la tarea finalize con éxito el *order* pasará a estado `finished`, en caso de que haya habido un error el estado será `failed` y se almacenará el error en los campos `error_message` y opcionalemente en `error_stacktrace` según gravedad del error.
+  
+  - Caso normal
+  `pending` -> `running` -> `finished`
+  
+  - Error durante el consumo
+  `pending` -> `failed`
+  
+  - Error durante la operacion
+  `pending` -> `running` -> `failed`
+  
+  ## Endpoints 
+  Estan sujetos a cambios en cuanto a mostrar información
+  
+  - [WIP]**GET** /orders?{query} 
+  Devuelve todos los orders con un campo que tenga el valor especificado en la query
+  
+  - **GET** /orders/{id}
+  Devuelve el order objetivo según su UUID de mensaje (No según el uuid de mensaje)
+   
+  - **GET** /orders/base_id/{id}
+  Devuelve el id según su id de la bdd, no es el metodo normal de usar la api
+  
+  - **GET** /orders/pending
+  Devuelve todas las order que no hayan finalizado
+  
+  
+  
+}
--- a/docs/sim-api/Pause.bru
+++ b/docs/sim-api/Pause.bru
@@ -1,7 +1,7 @@
 meta {
  name: Pause
  type: http
-  seq: 1
+  seq: 5
 }

 post {
@@ -15,7 +15,7 @@ params:query {
 }

 body:form-urlencoded {
-  iccid: 8933201125065160414
+  iccid: 8933201125065160331
 }

 settings {
--- a/docs/sim-api/Preactivate.bru
+++ b/docs/sim-api/Preactivate.bru
@@ -1,7 +1,7 @@
 meta {
  name: Preactivate
  type: http
-  seq: 1
+  seq: 6
 }

 post {
--- a/docs/sim-api/ReActivate.bru
+++ b/docs/sim-api/ReActivate.bru
@@ -0,0 +1,21 @@
+meta {
+  name: ReActivate
+  type: http
+  seq: 12
+}
+
+post {
+  url: {{baseurl}}/sim/reActivate
+  body: formUrlEncoded
+  auth: inherit
+}
+
+body:form-urlencoded {
+  iccid: 8935103196306448300
+  ~offer: SAVEFAMILY1
+}
+
+settings {
+  encodeUrl: true
+  timeout: 0
+}
--- a/docs/sim-api/Select.bru
+++ b/docs/sim-api/Select.bru
@@ -0,0 +1,20 @@
+meta {
+  name: Select
+  type: http
+  seq: 13
+}
+
+get {
+  url: {{baseurl}}/sim/select?iccid=8935103196306448300
+  body: none
+  auth: inherit
+}
+
+params:query {
+  iccid: 8935103196306448300
+}
+
+settings {
+  encodeUrl: true
+  timeout: 0
+}
--- a/docs/sim-api/Test
+++ b/docs/sim-api/Test
@@ -1,7 +1,7 @@
 meta {
  name: Test Order
  type: http
-  seq: 9
+  seq: 10
 }

 post {
--- a/docs/sim-api/collection.bru
+++ b/docs/sim-api/collection.bru
@@ -1,5 +1,6 @@
 docs {
-  Los endpoint tienen unos campos comunes de entrada:
+  Todos los endpoint tienen unos campos comunes de entrada:
+
  ```ts
  {
    iccid: string,
--- a/docs/sim-api/environments/local.bru
+++ b/docs/sim-api/environments/local.bru
@@ -1,3 +1,5 @@
 vars {
  baseurl: http://localhost:3000
+  baseAlai: http://localhost:3002
 }
+color: #2E8A54
--- a/docs/sim-api/environments/prod.bru
+++ b/docs/sim-api/environments/prod.bru
@@ -1,3 +1,4 @@
 vars {
  baseurl: https://sf-sims.savefamilygps.net
 }
+color: #CE4F3B
--- a/docs/sim-api/environments/simconnections.bru
+++ b/docs/sim-api/environments/simconnections.bru
@@ -0,0 +1,4 @@
+vars {
+  baseurl: http://sim-connections.savefamilygps.net
+}
+color: #C77A0F
--- a/docs/sim-api/test
+++ b/docs/sim-api/test
@@ -0,0 +1,20 @@
+meta {
+  name: test proxy
+  type: http
+  seq: 13
+}
+
+get {
+  url: {{baseurl}}/simconnections/alai/select?iccid=1111111111111111111
+  body: none
+  auth: inherit
+}
+
+params:query {
+  iccid: 1111111111111111111
+}
+
+settings {
+  encodeUrl: true
+  timeout: 0
+}
--- a/docs/sim-nos/Select
+++ b/docs/sim-nos/Select
@@ -0,0 +1,23 @@
+info:
+  name: Select Page
+  type: http
+  seq: 6
+
+http:
+  method: GET
+  url: "{{baseurl}}/selectPage"
+  params:
+    - name: iccid
+      value: "8935103196306448300"
+      type: query
+      disabled: true
+  body:
+    type: json
+    data: ""
+  auth: inherit
+
+settings:
+  encodeUrl: true
+  timeout: 0
+  followRedirects: true
+  maxRedirects: 5
--- a/docs/sim-nos/Select.yml
+++ b/docs/sim-nos/Select.yml
@@ -0,0 +1,25 @@
+info:
+  name: Select
+  type: http
+  seq: 5
+
+http:
+  method: GET
+  url: "{{baseurl}}/select?iccid=8935103196306448300"
+  params:
+    - name: iccid
+      value: "8935103196306448300"
+      type: query
+  body:
+    type: json
+    data: |-
+      {
+        "iccid": "8933201125068890066"
+      }
+  auth: inherit
+
+settings:
+  encodeUrl: true
+  timeout: 0
+  followRedirects: true
+  maxRedirects: 5
--- a/docs/sim-nos/environments/local.yml
+++ b/docs/sim-nos/environments/local.yml
@@ -0,0 +1,7 @@
+name: local
+color: "#2E8A54"
+variables:
+  - name: baseurl
+    value: http://localhost:3001
+  - secret: true
+    name: token
--- a/docs/sim-nos/environments/prod.yml
+++ b/docs/sim-nos/environments/prod.yml
@@ -0,0 +1,7 @@
+name: prod
+color: "#CE4F3B"
+variables:
+  - name: baseurl
+    value: https://nosconnectcenter-api.iot-x.com
+  - secret: true
+    name: token
--- a/docs/sim-nos/opencollection.yml
+++ b/docs/sim-nos/opencollection.yml
@@ -0,0 +1,10 @@
+opencollection: 1.0.0
+
+info:
+  name: sim-nos
+bundled: false
+extensions:
+  bruno:
+    ignore:
+      - node_modules
+      - .git
--- a/docs/sim-nos/subscriber
+++ b/docs/sim-nos/subscriber
@@ -0,0 +1,22 @@
+info:
+  name: subscriber actions
+  type: http
+  seq: 1
+
+http:
+  method: GET
+  url: "{{baseurl}}/subscribers/{{iccid}}/actions"
+  auth:
+    type: bearer
+    token: "{{token}}"
+
+runtime:
+  variables:
+    - name: iccid
+      value: "8935103196306448300"
+
+settings:
+  encodeUrl: true
+  timeout: 0
+  followRedirects: true
+  maxRedirects: 5
--- a/docs/sim-nos/subscriber
+++ b/docs/sim-nos/subscriber
@@ -0,0 +1,22 @@
+info:
+  name: subscriber info
+  type: http
+  seq: 2
+
+http:
+  method: GET
+  url: "{{baseurl}}/subscribers/{{iccid}}"
+  auth:
+    type: bearer
+    token: "{{token}}"
+
+runtime:
+  variables:
+    - name: iccid
+      value: "8935103196306448300"
+
+settings:
+  encodeUrl: true
+  timeout: 0
+  followRedirects: true
+  maxRedirects: 5
--- a/docs/sim-nos/subscriber
+++ b/docs/sim-nos/subscriber
@@ -0,0 +1,22 @@
+info:
+  name: subscriber products available
+  type: http
+  seq: 4
+
+http:
+  method: GET
+  url: "{{baseurl}}/subscribers/{{iccid}}/products/available"
+  auth:
+    type: bearer
+    token: "{{token}}"
+
+runtime:
+  variables:
+    - name: iccid
+      value: "8935103196306448300"
+
+settings:
+  encodeUrl: true
+  timeout: 0
+  followRedirects: true
+  maxRedirects: 5
--- a/docs/sim-nos/subscribers.yml
+++ b/docs/sim-nos/subscribers.yml
@@ -0,0 +1,22 @@
+info:
+  name: subscribers
+  type: http
+  seq: 3
+
+http:
+  method: GET
+  url: "{{baseurl}}/subscribers"
+  auth:
+    type: bearer
+    token: "{{token}}"
+
+runtime:
+  variables:
+    - name: iccid
+      value: "8935103196306448300"
+
+settings:
+  encodeUrl: true
+  timeout: 0
+  followRedirects: true
+  maxRedirects: 5
--- a/docs/sim-objenious/Alarms/Alarm
+++ b/docs/sim-objenious/Alarms/Alarm
@@ -0,0 +1,24 @@
+meta {
+  name: Alarm by id
+  type: http
+  seq: 2
+}
+
+get {
+  url: {{baseUrl}}alarms/{{alarmId}}
+  body: none
+  auth: bearer
+}
+
+auth:bearer {
+  token: {{ws-access-token-partenaire}}
+}
+
+vars:pre-request {
+  alarmId: 2439
+}
+
+settings {
+  encodeUrl: true
+  timeout: 0
+}
--- a/docs/sim-objenious/Alarms/Alerts.bru
+++ b/docs/sim-objenious/Alarms/Alerts.bru
@@ -0,0 +1,28 @@
+meta {
+  name: Alerts
+  type: http
+  seq: 3
+}
+
+get {
+  url: {{baseUrl}}alarms/alerts?pageNumber=100
+  body: none
+  auth: bearer
+}
+
+params:query {
+  pageNumber: 100
+}
+
+auth:bearer {
+  token: {{ws-access-token-partenaire}}
+}
+
+vars:pre-request {
+  alarmId: 2439
+}
+
+settings {
+  encodeUrl: true
+  timeout: 0
+}
--- a/docs/sim-objenious/Alarms/All
+++ b/docs/sim-objenious/Alarms/All
@@ -0,0 +1,20 @@
+meta {
+  name: All Alarms
+  type: http
+  seq: 1
+}
+
+get {
+  url: {{baseUrl}}alarms
+  body: none
+  auth: bearer
+}
+
+auth:bearer {
+  token: {{ws-access-token-partenaire}}
+}
+
+settings {
+  encodeUrl: true
+  timeout: 0
+}
--- a/docs/sim-objenious/Alarms/folder.bru
+++ b/docs/sim-objenious/Alarms/folder.bru
@@ -0,0 +1,8 @@
+meta {
+  name: Alarms
+  seq: 21
+}
+
+auth {
+  mode: inherit
+}
--- a/docs/sim-objenious/Appel
+++ b/docs/sim-objenious/Appel
@@ -5,16 +5,16 @@ meta {
 }

 get {
-  url: https://api-getway.objenious.com/ws/lines?pageSize=1000&simStatus=ACTIVATED
+  url: https://api-getway.objenious.com/ws/lines?identifier.identifierType=ICCID&identifier.identifiers=8933201125065160455
  body: formUrlEncoded
  auth: bearer
 }

 params:query {
-  pageSize: 1000
-  simStatus: ACTIVATED
-  ~identifier.identifierType: ICCID
-  ~identifier.identifiers: 8933201125065160455
+  identifier.identifierType: ICCID
+  identifier.identifiers: 8933201125065160455
+  ~pageSize: 1000
+  ~simStatus: ACTIVATED
 }

 auth:bearer {
--- a/docs/sim-objenious/Consumption
+++ b/docs/sim-objenious/Consumption
@@ -0,0 +1,38 @@
+meta {
+  name: Consumption details
+  type: http
+  seq: 21
+}
+
+get {
+  url: https://api-getway.objenious.com/ws/diagXL/massHistories
+  body: formUrlEncoded
+  auth: bearer
+}
+
+auth:bearer {
+  token: {{ws-access-token-partenaire}}
+}
+
+body:json {
+    {
+    "identifier": {  
+      "identifiers": ["8933201124059175967"],
+      "identifierType": "ICCID"
+    }
+    }
+}
+
+body:form-urlencoded {
+  identifier.identifierType: "ICCID"
+  identifier.identifiers: ["8933201125068889373"]
+}
+
+vars:pre-request {
+  ~id: 5187320
+}
+
+settings {
+  encodeUrl: true
+  timeout: 0
+}
--- a/docs/sim-objenious/Line
+++ b/docs/sim-objenious/Line
@@ -0,0 +1,41 @@
+meta {
+  name: Line by iccid
+  type: http
+  seq: 22
+}
+
+get {
+  url: https://api-getway.objenious.com/ws/lines?pageSize=1000&simStatus=ACTIVATED
+  body: formUrlEncoded
+  auth: bearer
+}
+
+params:query {
+  pageSize: 1000
+  simStatus: ACTIVATED
+  ~identifier.identifierType: ICCID
+  ~identifier.identifiers: 8933201125065160455
+}
+
+auth:bearer {
+  token: {{ws-access-token-partenaire}}
+}
+
+body:json {
+    {
+    "identifier": {  
+      "identifiers": ["8933201124059175967"],
+      "identifierType": "ICCID"
+    }
+    }
+}
+
+body:form-urlencoded {
+  ~identifier.identifierType: "ICCID"
+  ~identifier.identifiers: ["8933201124059175967"]
+}
+
+settings {
+  encodeUrl: true
+  timeout: 0
+}
--- a/docs/sim-objenious/Mass
+++ b/docs/sim-objenious/Mass
@@ -5,13 +5,13 @@ meta {
 }

 get {
-  url: {{actionsUrl}}/massActions?massActionId=5192767
+  url: {{actionsUrl}}/massActions?massActionId=5363116
  body: formUrlEncoded
  auth: bearer
 }

 params:query {
-  massActionId: 5192767
+  massActionId: 5363116
  ~identifier.identifierType: ICCID
  ~identifier.identifiers: 8933201125065160463,8933201125065160422
 }
--- a/package.json
+++ b/package.json
@@ -7,11 +7,11 @@
  ],
  "scripts": {
    "test": "vitest watch",
-    "build": "yarn workspaces foreach -A --exclude sim-consumidor-nos run build && cp .env dist/ && yarn setup:runtime",
+    "build": "rm -rf ./dist && yarn workspaces foreach -Api run build && yarn setup:runtime",
    "setup:runtime": "mkdir -p dist/packages/node_modules && ln -sf ../sim-shared dist/packages/node_modules/sim-shared && ln -sf ../sf-consumidor-objenious dist/packages/node_modules/sim-consumidor-objenious",
-    "start": "yarn setup:runtime && yarn workspaces foreach -Apiv --exclude sim-consumidor-nos run start",
+    "start": "yarn workspaces foreach -Apiv run start",
    "typecheck": "npx tsc --noEmit",
-    "dev": "yarn workspaces foreach -Apiv --exclude sim-consumidor-nos run dev ",
+    "dev": "yarn workspaces foreach -Apiv run dev",
    "lint": "eslint .",
    "lint:fix": "eslint --fix .",
    "format": "prettier --write .",
@@ -19,7 +19,7 @@
    "migrate": "yarn db-migrate -e .env -m deployment/database/migrations -t 99.0.0"
  },
  "dependencies": {
-    "@sf-alvar/db-migrate": "1.0.3",
+    "@sf-alvar/db-migrate": "1.0.6",
    "@tsconfig/node22": "^22.0.5",
    "amqp-connection-manager": "^5.0.0",
    "amqplib": "^0.10.9",
@@ -28,7 +28,7 @@
    "dotenv": "^17.2.3",
    "express": "^5.2.1",
    "pg": "^8.18.0",
-    "typescript": "^5.9.3",
+    "typescript": "^6.0.3",
    "uuidv7": "^1.1.0",
    "vite": "^7.3.1",
    "vite-tsconfig-paths": "^6.0.5"
--- a/packages/_template/config/env/index.ts
+++ b/packages/_template/config/env/index.ts
@@ -1,5 +1,4 @@
 export const env = {
-  ENVIRONMENT: process.env.ENVIORMENT,
  POSTGRES_USER: process.env.POSTGRES_USER,
  POSTGRES_PASSWORD: process.env.POSTGRES_PASSWORD,
  POSTGRES_PORT: process.env.POSTGRES_PORT,
--- a/packages/sim-consumidor-alai/aplication/AlaiTokenManager.ts
+++ b/packages/sim-consumidor-alai/aplication/AlaiTokenManager.ts
@@ -0,0 +1,43 @@
+import { AlaiRepository } from "#infrastructure/AlaiRepository.js";
+import { JWTToken } from "sim-shared/domain/JWT.js";
+import { JWTProvider } from "sim-shared/infrastructure/HTTPClient.js";
+import { httpsAgent } from "#config/httpsAgent.js";
+
+export class AlaiTokenManager implements JWTProvider<{}> {
+
+  isRefreshing: boolean = false;
+  authToken: JWTToken<{}> | undefined;
+
+  private async getNewAuthToken() {
+    // TODO: Si no funcionase hay que reprogramar los mensajes para ser 
+    // consumidos mas tarde.
+    const res = await AlaiRepository.login(httpsAgent);
+
+    if (res.error != undefined) {
+      console.error("Error obteniendo el token de ALAI", res.error)
+    } else {
+      console.log("Obtenido token de ALAI: ", res)
+      this.authToken = new JWTToken(res.data.accessToken)
+    }
+  }
+
+  public tryRefreshToken(): Promise<JWTToken<{}>> {
+    // En Alai no existe el concepto de refresh, se solicita otro token nuevo
+    return this.getAccessToken()
+  };
+
+  public async getAccessToken(): Promise<JWTToken<{}>> {
+    // Caso 1: El token actual es valido
+    if (this.authToken != undefined && !this.authToken.isExpired()) {
+      return this.authToken
+    } else {
+      // Caso 2: El token actual no existe o ha expirado
+      await this.getNewAuthToken()
+    }
+
+    // Si después de todo no se ha generado el token es un error catastrofico
+    if (this.authToken == undefined) throw new Error("Error obteniendo tokens de auth")
+
+    return this.authToken
+  };
+}
--- a/packages/sim-consumidor-alai/aplication/DebugTokenManager.ts
+++ b/packages/sim-consumidor-alai/aplication/DebugTokenManager.ts
@@ -0,0 +1,50 @@
+import { JWTToken } from "sim-shared/domain/JWT.js";
+import { JWTProvider } from "sim-shared/infrastructure/HTTPClient.js";
+import { LegacyJWTTokenRepository } from "#infrastructure/LegacyJWTTokensRepository.js";
+import { env } from "#config/env/env.js";
+
+const tokenDir = String(env.ALAI_CERTIFICATES_DIR)
+const tokenFile = ".debugToken"
+
+/**
+ * Usa un token guardado a mano en archivo para no gastar tokens de Alai
+ */
+export class DebugTokenManager implements JWTProvider<{}> {
+
+  isRefreshing: boolean = false;
+  authToken: JWTToken<{}> | undefined;
+
+  private async getNewAuthToken() {
+    // TODO: Si no funcionase hay que reprogramar los mensajes para ser 
+    // consumidos mas tarde.
+    const res = LegacyJWTTokenRepository.getTokenFromFile(tokenDir, tokenFile)
+
+
+    if (res.error != undefined) {
+      console.error("Error obteniendo el token de ALAI", res.error)
+    } else {
+      this.authToken = new JWTToken(res.data)
+      console.log("[d] Token DEBUG: ", this.authToken)
+    }
+  }
+
+  public tryRefreshToken(): Promise<JWTToken<{}>> {
+    // En Alai no existe el concepto de refresh, se solicita otro token nuevo
+    return this.getAccessToken()
+  };
+
+  public async getAccessToken(): Promise<JWTToken<{}>> {
+    // Caso 1: El token actual es valido
+    if (this.authToken != undefined && !this.authToken.isExpired()) {
+      return this.authToken
+    } else {
+      // Caso 2: El token actual no existe o ha expirado
+      await this.getNewAuthToken()
+    }
+
+    // Si después de todo no se ha generado el token es un error catastrofico
+    if (this.authToken == undefined) throw new Error("Error obteniendo tokens de auth")
+
+    return this.authToken
+  };
+}
--- a/packages/sim-consumidor-alai/aplication/SimAlai.controller.ts
+++ b/packages/sim-consumidor-alai/aplication/SimAlai.controller.ts
@@ -0,0 +1,195 @@
+import { ConsumeMessage } from "amqplib";
+import { Request, Response } from "express"
+import { SimAlaiUsecases } from "./SimAlai.usecases.js";
+import { EventBus } from "sim-shared/domain/EventBus.port.js";
+import { Result } from "sim-shared/domain/Result.js";
+import { SimEvents } from "sim-shared/domain/SimEvents.js";
+import { iccidValidator } from "./httpValidators.js";
+import { alaiSimToCommonSim } from "#domain/transformers.js";
+
+export class SimAlaiController {
+
+  constructor(
+    private uscases: SimAlaiUsecases,
+    private eventBus: EventBus,
+  ) {
+  }
+
+  private validateMsg(msg: ConsumeMessage | null) {
+    if (msg == undefined) return false;
+    const msgData = this.decodeMsg(msg) as SimEvents.general
+    if (msgData == undefined || msgData.payload == undefined) throw new Error("Mensaje invalido")
+    return msgData;
+  }
+
+  private decodeMsg(msg: ConsumeMessage): object | undefined {
+    if (msg.content == undefined) {
+      console.warn('[Sim.controller] Mensaje vacío');
+      return undefined;
+    }
+
+    try {
+      // Convertir el Buffer a String (UTF-8)
+      const contentJson = JSON.parse(Buffer.from(msg.content).toString('utf8'))
+      return contentJson;
+
+    } catch (error) {
+      console.error('Error al decodificar JSON:', error);
+      console.error(Buffer.from(msg.content).toString(("utf8")))
+      // Aquí podrías decidir devolver el string crudo o null
+      return undefined;
+    }
+  }
+
+  /**
+   * Metodo duplicado se puede generalizar la a una clase sharedController con las funciones basicas
+   * TODO: meter un check de 429
+   */
+  private async tryUseCase<T extends any>
+    (msg: ConsumeMessage, usecase: () => Promise<Result<string, T>>): Promise<Result<string, T>> {
+    try {
+      const result = await usecase()
+      if (result.error == undefined) {
+        await this.eventBus.ack(msg)
+        return result
+      } else {
+        console.error("Error procesando el caso de uso (Alai)", result.error)
+        this.eventBus.nack(msg)
+        return result
+      }
+    } catch (e) {
+      console.error("Error general procesando el caso de uso (Alai)")
+      this.eventBus.nack(msg)
+      return {
+        error: String(e)
+      }
+    }
+  }
+
+  public activate() {
+    return async (msg: ConsumeMessage) => {
+      console.log("[i] Evento activate ", msg.fields)
+      const data = this.validateMsg(msg) as SimEvents.activation
+      const iccid = data.payload.iccid
+      const correlation_id = data.headers?.message_id
+      const res = await this.tryUseCase(msg, this.uscases.activate({
+        iccid: iccid,
+        correlation_id: correlation_id
+      }))
+      return res;
+    }
+  }
+
+  public suspend() {
+    return async (msg: ConsumeMessage) => {
+      console.log("Evento suspend ", msg.fields)
+      const data = this.validateMsg(msg) as SimEvents.suspend
+      const iccid = data.payload.iccid
+      const correlation_id = data.headers?.message_id
+      const res = await this.tryUseCase(msg, this.uscases.suspend({
+        iccid: iccid,
+        correlation_id: correlation_id
+      }))
+      return res;
+    }
+  }
+
+
+
+  public reActivate() {
+    return async (msg: ConsumeMessage) => {
+      console.log("Evento reActivate ", msg.fields)
+      const data = this.validateMsg(msg) as SimEvents.reActivation
+      const iccid = data.payload.iccid
+      const correlation_id = data.headers?.message_id
+      const res = await this.tryUseCase(msg, this.uscases.reactivate({
+        iccid: iccid,
+        correlation_id: correlation_id
+      }))
+
+      return res;
+    }
+  }
+
+
+  public terminate() {
+    return async (msg: ConsumeMessage) => {
+      console.log("Evento reActivate ", msg.fields)
+      const data = this.validateMsg(msg) as SimEvents.reActivation
+      const iccid = data.payload.iccid
+      const correlation_id = data.headers?.message_id
+      const res = await this.tryUseCase(msg, this.uscases.terminate({
+        iccid: iccid,
+        correlation_id: correlation_id
+      }))
+
+      return res;
+    }
+  }
+
+
+  /**
+  * Select especificamente por REST para evitar pasar por las colas.
+  * La respuesta es instantanea no se tiene que registrar como operación.
+  */
+  public selectREST() {
+    return async (req: Request, res: Response) => {
+      const { query } = req
+      const body = { iccid: query.iccid as string }
+      console.log("Evento select", body)
+      const validateBody = iccidValidator.validate(body);
+
+      if (validateBody.error != undefined) {
+        res.status(422).json(validateBody)
+        return;
+      }
+
+      const iccid: string | string[] = body.iccid
+
+      if (Array.isArray(iccid)) {
+        // TODO: Automatizar la paginacion
+        //const usecaseRes = this.uscases.selectMany({ iccid })
+      } else {
+        //const usecaseRes = await this.uscases.selectOne(iccid)
+        const usecaseRes = await this.uscases.selectCompleteSim(iccid)
+        if (usecaseRes.error != undefined) {
+          res.status(500).json(usecaseRes)
+          return;
+        } else {
+          const { sim, subscription, imei } = usecaseRes.data
+          const simData = alaiSimToCommonSim(sim, subscription, imei)
+          res.send(simData)
+          return;
+        }
+      }
+
+      res.status(200).json(validateBody)
+    }
+  }
+
+  /**
+    public selectPageREST() {
+      return async (req: Request, res: Response) => {
+        const { offset, limit, filter, orderBy } = req.query
+        const params = {
+          offset: (offset != undefined) ? Number(offset) : undefined,
+          limit: (limit != undefined) ? Number(limit) : undefined,
+          filter: (filter != undefined) ? String(filter) : undefined,
+          orderBy: (orderBy != undefined) ? String(orderBy) : undefined
+        }
+  
+        const usecaseRes = await this.uscases.selectPage(params)
+  
+        if (usecaseRes.error != undefined) {
+          res.status(500).json(usecaseRes)
+          return;
+        } else {
+          res.status(200).send(usecaseRes.data)
+          return;
+        }
+      }
+    }
+    **/
+}
+
+
--- a/packages/sim-consumidor-alai/aplication/SimAlai.router.ts
+++ b/packages/sim-consumidor-alai/aplication/SimAlai.router.ts
@@ -0,0 +1,79 @@
+/**
+ * Dirige cada mensaje dependiendo de el tipo de acción que contenga
+ * Podría hacerse con varias colas, pero así se controla mejor que
+ * las operaciones se hagan de 1 en 1.
+ */
+
+import { ConsumeMessage } from "amqplib";
+import { EventBus } from "sim-shared/domain/EventBus.port.js";
+import { Result } from "sim-shared/domain/Result.js";
+import { SimAlaiController } from "./SimAlai.controller.js";
+
+type FuncType = ((m: ConsumeMessage) => Promise<Result<string, any>>)
+
+export class SimAlaiRouter {
+  private readonly routes: Map<string, FuncType>;
+
+  // WIP
+  constructor(
+    private readonly simController: SimAlaiController,
+    private readonly eventBus: EventBus
+  ) {
+    this.routes = new Map<string, FuncType>([
+      ["activate", this.simController.activate()],
+      ["pause", this.simController.suspend()],
+      ["reactivate", this.simController.reActivate()],
+      ["cancel", this.simController.terminate()],
+      ["preActivate", this.simController.activate()]
+    ]);
+  }
+
+  /**
+   * Enruta el mensaje a la acción correspondiente basándose en la routing key
+   * TODO: No estoy seguro que deba meter el nack aqui
+   * - De moemento el ack-nack se gestiona en los controller, por si acaso hay casos
+   *   limite en 
+   */
+  public route = async (msg: ConsumeMessage | null): Promise<void> => {
+    if (!msg) {
+      console.error("[Router] Mensaje vacío");
+      return;
+    }
+
+    const action = this.extractAction(msg);
+
+    if (!action) {
+      console.error("[Router] La routing key no tiene una acción definida", msg.fields.routingKey);
+      this.eventBus.nack(msg)
+      return;
+    }
+
+    const handler = this.routes.get(action);
+
+    if (!handler) {
+      console.error(`[Router] La acción '${action}' no tiene un controlador asociado`);
+      this.eventBus.nack(msg)
+      return;
+    }
+
+    try {
+      console.log("[Router] Ejecutando operación:", action);
+
+      // El controlador devuelve una función (thunk) que debe ser ejecutada
+      const executeParams = handler(msg);
+
+      if (typeof executeParams === "function") {
+        const res = await executeParams;
+      }
+
+    } catch (error) {
+      console.error(`[Router] Error al ejecutar la operación '${action}':`, error);
+      this.eventBus.nack(msg)
+    }
+  };
+
+  private extractAction(msg: ConsumeMessage): string | undefined {
+    // Se asume que la acción está en la tercera posición: domain.compañia.accion
+    return msg.fields.routingKey.split(".")[2];
+  }
+}
--- a/packages/sim-consumidor-alai/aplication/SimAlai.usecases.ts
+++ b/packages/sim-consumidor-alai/aplication/SimAlai.usecases.ts
@@ -0,0 +1,262 @@
+/**
+ * Documentación de referencia:
+ * https://pelion-help.iot-x.com/nos/en-US/Content/API/APIReference/API%20Reference.htm?tocpath=_____7
+ *
+ * En nos el correlation_id ya va a ser obligatorio en todos los mensajes
+ *
+ * TODO:
+ * - Control de errores más preciso
+ *
+ */
+import { AlaiAPI } from "#domain/AlaiAPI.js";
+import { AlaiRepository } from "#infrastructure/AlaiRepository.js";
+import { ConsumeMessage } from "amqplib";
+import { ErrorOrderDTO, FinishOrderDTO, UpdateOrderDTO } from "sim-shared/domain/Order.js";
+import { Result } from "sim-shared/domain/Result.js";
+import { HttpClient } from "sim-shared/infrastructure/HTTPClient.js";
+import { OrderRepository } from "sim-shared/infrastructure/OrderRepository.js";
+import { isOmittedExpression } from "typescript";
+
+export class SimAlaiUsecases {
+  constructor(
+    private httpClient: HttpClient,
+    private alaiRepository: AlaiRepository,
+    private orderRepository: OrderRepository
+  ) {
+  }
+
+  private async setRunning(correlation_id: string) {
+    const updateData: UpdateOrderDTO = {
+      new_status: "running",
+      correlation_id: correlation_id
+    }
+    const order = await this.orderRepository.updateOrder(updateData)
+    return order
+  }
+
+  private async setFinished(correlation_id: string) {
+    // En NOS el updateOrder se hace con el correlation_id que viene en la cabecera del
+    // mensaje consumido
+    const updateData: FinishOrderDTO = {
+      correlation_id: correlation_id
+    }
+    const order = await this.orderRepository.finishOrder(updateData)
+    return order
+  }
+
+  private async setFailed(correlation_id: string, reason: string, detail?: string) {
+    // En NOS el updateOrder se hace con el correlation_id que viene en la cabecera del
+    // mensaje consumido
+    const updateData: ErrorOrderDTO = {
+      status: "failed",
+      correlation_id: correlation_id,
+      reason: reason,
+      error: reason,
+      stackTrace: detail
+    }
+
+    console.log("SET FAILED DATA:", updateData)
+    const order = await this.orderRepository.errorOrder(updateData)
+    console.log("SET FAILED RES:", order)
+    return order
+  }
+
+  /**
+   * Gestiona el ciclo de vida de una petición. No aplica 
+   * a peticiones de lectura (no pasan por la cola y no generan un order)
+   */
+  public usecaseTemplate<T, R>(
+    func: (_: T) => Promise<Result<string, R>>,
+    args: T,
+    correlation_id?: string | undefined
+  ) {
+    return async (): Promise<Result<string, R>> => {
+      // Operacion pending -> running
+      if (correlation_id != undefined)
+        this.setRunning(correlation_id)
+          .then()
+          .catch(e => console.error("Error actualizando el order", e))
+      else
+        console.warn("[!] Se ha lanzado una caso de uso sin correlation_id")
+
+      try {
+        const res = await func(args)
+
+        if (res.error != undefined) {
+          console.log("Error peticion: ", res, correlation_id)
+          if (correlation_id != undefined)
+            this.setFailed(correlation_id, res.error)
+              .then(e => console.log("failed", e))
+              .catch(e => console.error(e))
+          return res;
+        } else {
+          if (correlation_id != undefined)
+            this.setFinished(correlation_id).then()
+          return res;
+        }
+
+      } catch (e) {
+        if (correlation_id != undefined)
+          this.setFailed(correlation_id, "Error general de operacion de SIM (NOS) ", String(e)).then()
+        return {
+          error: "Error general de operacion de SIM (NOS) " + String(e)
+        }
+      }
+
+    }
+  }
+
+  public activate(args: {
+    iccid: string,
+    correlation_id: string | undefined
+  }) {
+    return this.usecaseTemplate(async (iccid /*iccid*/) => {
+      const order = await this.alaiRepository.createOrder()
+      if (order.error != undefined) {
+        // Falla el crearse un order (problema de servidor, token, etc)
+        console.error(order.error)
+        return order
+      }
+      const reserved = await this.alaiRepository.createReserve(order.data.id, iccid)
+      return reserved
+    }, args.iccid, args.correlation_id)
+  }
+
+  public preactivate(args: {
+    iccid: string,
+    correlation_id: string | undefined,
+    externalId: string | undefined // Por compatibilidad
+  }) {
+    const inputargs = {
+      iccid: args.iccid,
+      externalId: args.externalId
+    }
+    return this.usecaseTemplate(async (args) => {
+      const order = await this.alaiRepository.createOrder()
+      if (order.error != undefined) {
+        return order
+      }
+      const orderId = order.data.id
+      const reserve = await this.alaiRepository.createReserve(orderId, args.iccid)
+      if (reserve.error != undefined) {
+        return reserve
+      }
+
+      const applyOrder = await this.alaiRepository.applyOrder(orderId)
+      if (applyOrder.error != undefined) {
+        return applyOrder
+      }
+
+      const preactivatedSim = await this.alaiRepository.getSimByICCID(args.iccid)
+      if (preactivatedSim.error != undefined) {
+        return preactivatedSim
+      }
+
+      // TODO: Controlar sim no encotrada (No deberia pasar)
+      const subscriptionId = preactivatedSim.data!.subscription.id
+      if (args.externalId) {
+        const externalIdAdded = await this.alaiRepository.changeExternalId(subscriptionId, args.externalId)
+        if (externalIdAdded.error != undefined) {
+          return externalIdAdded
+        }
+      }
+
+      // En connections acaba buscando el numero.
+      const subscription = await this.alaiRepository.getSubscriptionById(subscriptionId)
+      return subscription
+    }, inputargs, args.correlation_id)
+  }
+
+  public suspend(args: {
+    iccid: string,
+    correlation_id: string | undefined
+  }) {
+    return this.usecaseTemplate(async (args) => {
+      const subscription = await this.alaiRepository.getSimByICCID(args.iccid)
+      if (subscription.error != undefined) {
+        return subscription
+      }
+
+      // TODO: Controlar que no se encuentre la subscription
+      const suspension = this.alaiRepository.pauseSubscription(subscription.data!.id)
+      return suspension
+    }, args, args.correlation_id)
+  }
+
+
+  public reactivate(args: {
+    iccid: string,
+    correlation_id: string | undefined
+  }) {
+    return this.usecaseTemplate(async (args) => {
+      const subscription = await this.alaiRepository.getSimByICCID(args.iccid)
+      if (subscription.error != undefined) {
+        return subscription
+      }
+
+      // TODO: Controlar que no se encuentre la subscription
+      const suspension = this.alaiRepository.unPauseSubscription(subscription.data!.id)
+      return suspension
+    }, args, args.correlation_id)
+  }
+
+
+  public terminate(args: {
+    iccid: string,
+    correlation_id: string | undefined
+  }) {
+    return this.usecaseTemplate(async (args) => {
+      const subscription = await this.alaiRepository.getSimByICCID(args.iccid)
+      if (subscription.error != undefined) {
+        return subscription
+      }
+
+      // TODO: Controlar que no se encuentre la subscription
+      const suspension = this.alaiRepository.terminateSubscription(subscription.data!.id)
+      return suspension
+    }, args, args.correlation_id)
+  }
+
+  public async selectOne(iccid: string) {
+    const sim = await this.alaiRepository.getSimByICCID(iccid)
+    return sim
+  }
+
+  /**
+  * Para sacar los datos de una liena hay que sacar sim -> subscripcion -> imei 
+  * son 3 llamadas distintas.
+  */
+  public async selectCompleteSim(iccid: string): Promise<Result<string, {
+    sim: AlaiAPI.Sim,
+    subscription: AlaiAPI.Subscription,
+    imei: AlaiAPI.GetImeiSubscriptionDTO
+  }>> {
+    const sim = await this.alaiRepository.getSimByICCID(iccid)
+
+    if (sim.error != undefined) {
+      return sim
+    }
+
+    const subscriptionId = sim.data!.subscription.id
+    const subscription = await this.alaiRepository.getSubscriptionById(subscriptionId)
+
+    if (subscription.error != undefined) {
+      return subscription
+    }
+
+    const imei = await this.alaiRepository.getImeiFromSubscription(subscriptionId)
+    if (imei.error != undefined) {
+      return imei
+    }
+
+    return {
+      data: {
+        sim: sim.data!,
+        subscription: subscription.data!,
+        imei: imei.data!
+      }
+    }
+
+
+  }
+}
--- a/packages/sim-consumidor-alai/aplication/SslService.ts
+++ b/packages/sim-consumidor-alai/aplication/SslService.ts
@@ -0,0 +1,55 @@
+import fs from "fs";
+import path from "path";
+import { Result } from "sim-shared/domain/Result.js";
+
+export type P12Cert = {
+  cainfo: string,
+  p12cert: string
+}
+
+export type SSLCert = {
+  cainfo: string,
+  sslcert: string,
+  keypem: string
+}
+
+/**
+ * TODO: 
+ * - Se ha usado https.Agent en su lugar, eliminar si no se usa
+ */
+export class SSLCertificateLoader {
+
+  constructor(
+    private certificatesDir: string,
+  ) {
+  }
+
+  public loadCertificatesP12(caFile: string, certFile: string): Result<string, P12Cert> {
+    try {
+      const cainfo = fs.readFileSync(path.resolve(this.certificatesDir, caFile)).toString();
+      const p12cert = fs.readFileSync(path.resolve(this.certificatesDir, certFile)).toString();
+      return { data: { cainfo, p12cert } };
+    } catch (e) {
+      console.error("[x] Error cargando los certificados P12", e)
+      return {
+        error: String(e)
+      }
+    }
+  }
+
+  public loadCertificatesSSL(caFile: string, certFile: string, keyFile: string): Result<string, SSLCert> {
+    try {
+      const cainfo = fs.readFileSync(path.resolve(this.certificatesDir, caFile)).toString();
+      const sslcert = fs.readFileSync(path.resolve(this.certificatesDir, certFile), { encoding: null }).toString();
+      const keypem = fs.readFileSync(path.resolve(this.certificatesDir, keyFile), { encoding: null }).toString();
+      return { data: { cainfo, sslcert, keypem } };
+    } catch (e) {
+      console.error("[x] Error cargando los certificados SSL", e)
+      return {
+        error: String(e)
+      }
+    }
+  }
+
+}
+
--- a/packages/sim-consumidor-alai/aplication/httpValidators.ts
+++ b/packages/sim-consumidor-alai/aplication/httpValidators.ts
@@ -0,0 +1,39 @@
+import { BodyValidator, Validator } from "sim-shared/aplication/BodyValidator.js";
+
+const iccidNotNull = <Validator<{ iccid: unknown }>>{
+  field: "iccid",
+  errorMsg: "El iccid no está definido",
+  validationFunc: (a: { iccid: unknown }) => {
+    return (a.iccid != null && a.iccid != undefined)
+  }
+}
+
+const iccidValueOrArray = <Validator<{ iccid: unknown }>>{
+  field: "iccid",
+  errorMsg: "El iccid debe de ser un único valor o una lista",
+  validationFunc: (a: { iccid: unknown }) => {
+    return (typeof a.iccid == "string" || Array.isArray(a.iccid))
+  }
+}
+
+const iccidLongitudValidator = <Validator<{ iccid: string | string[] }>>{
+  field: "iccid",
+  errorMsg: "La longitud del iccid/s es incorrecta debera ser de 19 caracteres",
+  validationFunc: (a: { iccid: string | string[] }) => {
+    if (Array.isArray(a.iccid)) {
+      const res = (a.iccid as string[]).filter(e => e.length != 19)
+      if (res.length > 0) return false;
+    } else {
+      return (a.iccid as string).length == 19
+    }
+  },
+}
+
+export const iccidValidator = new BodyValidator<{ iccid: string | string[] }>(
+  [
+    iccidNotNull,
+    iccidValueOrArray,
+    iccidLongitudValidator,
+  ]
+)
+
--- a/packages/sim-consumidor-alai/certificates/.debugToken
+++ b/packages/sim-consumidor-alai/certificates/.debugToken
@@ -0,0 +1 @@
+eyJhbGciOiJIUzM4NCJ9.eyJiciI6InNhdmVmYW1pbHkiLCJpcCI6Ijg4LjE1LjE1Ny4xNjciLCJzdWIiOiJwYWxvbWFpYmFuZXoiLCJzIjoiRVdTMTY0NmFmNjNlZGUyMjgzIiwicG9zIjoic2F2ZWZhbWlseUNhYyIsImlkV3NVc2VyIjoiODYiLCJpc012bmEiOmZhbHNlLCJkb21haW4iOiJBbGFpfHNhdmVmYW1pbHkiLCJpYXQiOjE3Nzc4OTk3MzcsImV4cCI6MTc3NzkxMDUzN30.PvTTRhUpKlslGOerQsLY4RLBXdQ5FIVvUKb_1ZK4b2Zggt04KZhwX0d-XoLAcP93
--- a/packages/sim-consumidor-alai/certificates/wsaccess_alaisecure_com_cert_client_new.p12
+++ b/packages/sim-consumidor-alai/certificates/wsaccess_alaisecure_com_cert_client_new.p12
--- a/packages/sim-consumidor-alai/config/env/env.ts
+++ b/packages/sim-consumidor-alai/config/env/env.ts
@@ -0,0 +1,61 @@
+import { loadEnvFile } from "node:process";
+import path from "node:path";
+import assert from "node:assert";
+
+try {
+  loadEnvFile(path.join("../../.env")) // Global
+} catch (e) {
+  console.error("Error cargando el .env desde ../../.env")
+}
+
+try {
+  loadEnvFile(path.join("./.env")) // base
+} catch (e) {
+  console.error("Error cargando el .env desde ./.env")
+}
+
+
+export const env = {
+  ENVIRONMENT: process.env.ENVIORMENT,
+  POSTGRES_USER: process.env.POSTGRES_USER,
+  POSTGRES_PASSWORD: process.env.POSTGRES_PASSWORD,
+  POSTGRES_PORT: process.env.POSTGRES_PORT,
+  POSTGRES_HOST: process.env.POSTGRES_HOST,
+  POSTGRES_DATABASE: process.env.POSTGRES_DATABASE,
+  RABBITMQ_HOST: String(process.env.RABBITMQ_HOST ?? "localhost"),
+  RABBITMQ_USER: String(process.env.RABBITMQ_USER ?? "test"),
+  RABBITMQ_PASSWORD: String(process.env.RABBITMQ_PASSWORD ?? "test"),
+  RABBITMQ_EXCHANGE: String(process.env.RABBITMQ_EXCHANGE ?? "/"),
+  RABBITMQ_PORT: parseInt(process.env.RABBITMQ_PORT ?? "5672"),
+  RABBITMQ_MODULENAME: process.env.MODULENAME,
+  RABBITMQ_TTL: process.env.RABBITMQ_TTL,
+  RABBITMQ_SECURE: process.env.RABBITMQ_SECURE,
+  RABBITMQ_RETRY_INTERVAL: process.env.RABBITMQ_INTERVAL,
+  RABBITMQ_VHOST: String(process.env.RABBITMQ_VHOST),
+
+  ALAI_PORT: parseInt(process.env.ALAI_PORT ?? "3002"),
+  ALAI_HOST: String(process.env.ALAI_HOST),
+
+  // ESPECIFICO ALAI
+  ALAI_API_URL: process.env.ALAI_API_URL,
+  ALAI_CERTIFICATES_DIR: process.env.ALAI_CERTIFICATES_DIR,
+  ALAI_CERTIFICATE_NAME: process.env.ALAI_CERTIFICATE_NAME,
+  ALAI_CERTIFICATE_PASSWORD: process.env.ALAI_CERTIFICATE_PASSWORD,
+  ALAI_USERNAME: process.env.ALAI_USERNAME,
+  ALAI_PASSWORD: process.env.ALAI_PASSWORD,
+  ALAI_BRANDID: process.env.ALAI_BRANDID,
+
+  ALAI_PACKAGE: process.env.ALAI_PACKAGE,
+  ALAI_SUBSCRIBER_ID: process.env.ALAI_SUBSCRIBER_ID
+};
+
+assert.ok(env.ALAI_SUBSCRIBER_ID != undefined, "ALAI_SUBSCRIBER_ID no definido")
+assert.ok(env.ALAI_PACKAGE != undefined, "ALAI_PACKAGE no definido")
+assert.ok(env.ALAI_USERNAME != undefined, "ALAI_USERNAME no definido")
+assert.ok(env.ALAI_PASSWORD != undefined, "ALAI_PASSWORD no definido")
+assert.ok(env.ALAI_BRANDID != undefined, "ALAI_BRANDID no definido")
+assert.ok(env.ALAI_API_URL != undefined, "ALAI_API_URL no definido")
+
+assert.ok(env.ALAI_CERTIFICATE_NAME != undefined, "ALAI_CERTIFICATE_NAME no definido")
+assert.ok(env.ALAI_CERTIFICATES_DIR != undefined, "ALAI_CERTIFICATES_DIR no definido")
+assert.ok(env.ALAI_CERTIFICATE_PASSWORD != undefined, "ALAI_CERTIFICATE_PASSWORD no definido")
--- a/packages/sim-consumidor-alai/config/eventBus.config.ts
+++ b/packages/sim-consumidor-alai/config/eventBus.config.ts
@@ -0,0 +1,72 @@
+import { RabbitMQEventBus, RMQConnectionParams } from "sim-shared/infrastructure/RabbitMQEventBus.js"
+import { Channel } from "amqp-connection-manager"
+import { env } from "./env/env.js"
+
+const rmqUser = env.RABBITMQ_USER
+const rmqPass = env.RABBITMQ_PASSWORD
+const rmqHost = env.RABBITMQ_HOST
+const rmqPort = Number(env.RABBITMQ_PORT)
+const rmqSecure = false
+const rmqVhost = env.RABBITMQ_VHOST
+
+export const rmqConnOptions = <RMQConnectionParams>{
+  username: rmqUser,
+  password: rmqPass,
+  vhost: rmqVhost,
+  hostname: rmqHost,
+  port: rmqPort,
+  secure: rmqSecure,
+}
+
+
+const BASE_ALAI_KEY = "sim.alai.#"
+const QUEUES = {
+  MAIN: "sim.alai",
+  DLX: "sim.alai.dlx",
+  DELAY: "sim.alai.delayed",
+}
+
+const EXCHANGES = {
+  MAIN: "sim.exchange",
+  DLX: "sim.ex.alai.dlx",
+  DEL: "sim.ex.alai.delayed"
+}
+
+export const rabbitmqEventBus = new RabbitMQEventBus({
+  connectionParams: rmqConnOptions,
+  buildStructure: buildQueues,
+  maxRetry: 2,
+  delayedExchange: EXCHANGES.DEL,
+  dlxExchange: EXCHANGES.DLX
+})
+
+async function buildQueues(channel: Channel) {
+
+  const DELAY = 10 * 1000
+
+  await channel.assertExchange(EXCHANGES.DEL, "topic")
+  await channel.assertExchange(EXCHANGES.DLX, "topic")
+  await channel.assertExchange(EXCHANGES.MAIN, "topic")
+
+  await channel.assertQueue(QUEUES.MAIN)
+  await channel.assertQueue(QUEUES.DLX)
+  await channel.assertQueue(QUEUES.DELAY, {
+    durable: true,
+    arguments: {
+      'x-message-ttl': DELAY,
+      'x-dead-letter-exchange': EXCHANGES.MAIN,
+    }
+  })
+
+  // Cola dead-letter 
+  await channel.bindQueue(QUEUES.DLX, EXCHANGES.DLX, BASE_ALAI_KEY)
+  // Cola delay
+  await channel.bindQueue(QUEUES.DELAY, EXCHANGES.DEL, BASE_ALAI_KEY)
+  // Cola nos -> main exchange
+  await channel.bindQueue(QUEUES.MAIN, EXCHANGES.MAIN, BASE_ALAI_KEY)
+}
+
+export async function startRMQClient() {
+  await rabbitmqEventBus.connect()
+  return rabbitmqEventBus
+}
--- a/packages/sim-consumidor-alai/config/httpClient.config.ts
+++ b/packages/sim-consumidor-alai/config/httpClient.config.ts
@@ -0,0 +1,17 @@
+import { HttpClient } from "sim-shared/infrastructure/HTTPClient.js"
+import { AlaiTokenManager } from "#aplication/AlaiTokenManager.js"
+import { env } from "#config/env/env.js";
+import { httpsAgent } from "./httpsAgent.js"
+import { DebugTokenManager } from "#aplication/DebugTokenManager.js";
+
+const tokenManager = new AlaiTokenManager()
+//const debugTokenManagr = new DebugTokenManager()
+//console.error("USANDO DebugTokenManager! Eliminar en prod")
+
+
+export const alaiHttp = new HttpClient({
+  baseURL: env.ALAI_API_URL as string,
+  headers: {},
+  jwtManager: tokenManager,
+  httpsAgent: httpsAgent
+})
--- a/packages/sim-consumidor-alai/config/httpsAgent.ts
+++ b/packages/sim-consumidor-alai/config/httpsAgent.ts
@@ -0,0 +1,14 @@
+import fs from 'fs';
+import https from 'https';
+import { env } from './env/env.js';
+import path from 'path';
+
+const certificatesDir = String(env.ALAI_CERTIFICATES_DIR)
+const certificateName = String(env.ALAI_CERTIFICATE_NAME)
+const certificatePassword = String(env.ALAI_CERTIFICATE_PASSWORD)
+
+export const httpsAgent = new https.Agent({
+  pfx: fs.readFileSync(path.join(certificatesDir, certificateName)),
+  passphrase: certificatePassword
+});
+
--- a/packages/sim-consumidor-alai/config/postgreConfig.ts
+++ b/packages/sim-consumidor-alai/config/postgreConfig.ts
@@ -0,0 +1,18 @@
+import { Pool, QueryResult } from 'pg';
+import { PgClient } from 'sim-shared/infrastructure/PgClient.js'
+import { env } from './env/env.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) || 5433,
+});
+
+export const pgClient = new PgClient({
+  pool: pgPool
+}) 
--- a/packages/sim-consumidor-alai/domain/AlaiAPI.ts
+++ b/packages/sim-consumidor-alai/domain/AlaiAPI.ts
@@ -0,0 +1,294 @@
+import { StringMappingType } from "typescript"
+
+export namespace AlaiAPI {
+
+  export type LoginResponseDTO = {
+    accessToken: string,
+    tokenType: string,
+    refreshToken: string,
+    expiresIn: string // isodate
+  }
+
+  /**
+  Hardcodeado en:
+  sf-sim-connections/context/infrastructure/api/alaiService.js
+  const data = {
+      type: "RETAIL",
+      salesChannel: "OWN_CALLCENTER",
+      status: "CONFIRMED",
+      packages: [{ id: "Tarifa_250MB_100MIN_5SMS" }],
+      subscriber: { id: "16216" }
+  };
+   */
+  export type CreateOrderDTO = {
+    type: "RETAIL" | string,
+    salesChannel: "OWN_CALLCENTER" | string,
+    status: "CONFIRMED" | string,
+    packages: { id: "Tarifa_250MB_100MIN_5SMS" | string }[],
+    subscriber: {
+      id: string
+    }
+  }
+
+  type OrderPackage = {
+    id: string,
+    name: string,
+    packagePrices: unknown,
+    packageInstance: {
+      id: string,
+      name: string,
+      links: Link[]
+    }
+  }
+
+  type Link = {
+    rel: string,
+    href: string,
+    hreflang: string,
+    media: string,
+    title: string,
+    type: string,
+    deprecation: string,
+    profile: string,
+    name: string
+  }
+
+  export type UpdateSubscriptionDTO = {
+    location: string
+  }
+
+  export type ApplyOrderDTO = UpdateSubscriptionDTO
+
+  export type Subscription = {
+    id: string,
+    name: string,
+    domain: string,
+    status: Status,
+    networkStatus: NetworkStatus,
+    type: "RETAIL" | string,
+    portabilityStatus: "NO_PORTABILITY" | string,
+    billingType: string,
+    creationDate: string, // ISODATE
+    firstActivationDate: string, // ISODATE
+    terminationDate: string, // ISODATE
+    balance: number,
+    balanceExpirationDate: string, // ISODATE
+    lastTrafficDate: string, // ISODATE
+    externalName: string,
+    language: string,
+    ntwID: string,
+    publicIdentity: string,
+    externalID: string,
+    lastMsisdnID: string,
+    msisdn: {
+      id: string,
+      name: string,
+      links: Link[]
+    },
+    lastIccID: string,
+    priceplan: {
+      id: string,
+      name: string,
+      pricePlanName: string
+    },
+    salesData: {
+      salesChannel: string,
+      salesPerson: string,
+    },
+    address: {
+      country: string,
+      state: string,
+      county: string,
+      city: string,
+      street: string,
+      postalCode: string,
+      number: string,
+      description: string,
+      neighborhood: string,
+      typeSettlement: string,
+      normalized: boolean,
+      externalID: string,
+      externalType: string,
+      spainSpecial: {
+        externalRefList:
+        {
+          refId: string,
+          refType: string
+        }[],
+        streetType: number,
+        ineCityCode: string,
+        ineSingularEntityCode: string,
+        floor: string,
+        door: string,
+        apartmentNumber: string,
+        staircaseNumber: string,
+        streetNrLast: string,
+        streetNrLastSuffix: string,
+        subUnitNumber: string,
+        buildingName: string,
+        homeID: string
+      },
+      iranSpecial: unknown,
+      mexicoSpecial: unknown,
+      brazilSpecial: unknown,
+    },
+    msisdnList: {
+      id: string,
+      name: string,
+      links: Link[]
+    }[],
+    terminalList: {
+      id: string,
+      name: string,
+      links: Link[]
+    }[]
+
+  }
+
+  export type CreateOrderResponseDTO = {
+    id: string,
+    name: string,
+    domain: string,
+    orderCode: string,
+    externalID: string,
+    type: string,
+    status: string,
+    saleStatus: string,
+    distributionStatus: string,
+    description: string,
+    salesChannel: string,
+    salesPerson: string,
+    deliveryType: string,
+    distributionInfo: {
+      providerID: string,
+      providerReference: string,
+      providerTracking: string,
+      cashOnDelivery: boolean,
+      prepaidShipping: boolean,
+      description: string,
+      events: {
+        status: string,
+        observations: string,
+        date: string | Date,
+        expectedDeliveryDate: string | Date,
+        completedDeliveryDate: string | Date,
+      }[]
+    },
+    packages: OrderPackage[],
+    subscription: {
+      id: string,
+      name: string,
+      links: Link[]
+    }
+    subscriber: {
+      id: string,
+      name: string,
+      links: Link[]
+    }
+    brand: {
+      id: string,
+      name: string,
+      links: Link[]
+    }
+    pos: {
+      id: string,
+      name: string,
+      links: Link[]
+    }
+    links: Link[]
+  }
+
+  export type NetworkStatus =
+    "ACTIVE" |
+    "BLOCKED" |
+    "DEACTIVATE" |
+    "FRAUD" |
+    "PRE_ACTIVE"
+
+  export type Status =
+    "ABORTED" |
+    "ACTIVE" |
+    "BLOCKEDCORE" |
+    "BLOCKEDFRAUD" |
+    "CANCELLED" |
+    "CONFIGURING" |
+    "DELETED" |
+    "PRE_ACTIVE" |
+    "TERMINATED"
+
+  export type Sim = {
+    id: string,
+    name: string,
+    simCode: string,
+    puk: string,
+    puk2: string,
+    pin: string,
+    pin2: string,
+    status: string,
+    storeStatus: string,
+    statusEsim: string,
+    pool: {
+      id: string,
+      name: string,
+      links: Link[]
+    },
+    sourcePool: {
+      id: string,
+      name: string,
+      links: Link[]
+    },
+    subscription: {
+      id: string,
+      name: string,
+      links: Link[]
+    },
+    imsi: {
+      id: string,
+      name: string,
+      links: Link[]
+    },
+    msisdn: {
+      id: string,
+      name: string,
+      links: Link[]
+    },
+    distributedPos: {
+      id: string,
+      name: string,
+      links: Link[]
+    },
+    pkgi: {
+      id: string,
+      name: string,
+      links: Link[]
+    },
+    links: Link[]
+  }
+
+  export type GetImeiSubscriptionDTO = {
+    links: Link[],
+    content: {
+      id: string,
+      sim: {
+        id: string,
+        links: Link[]
+      },
+      imsi: string,
+      lastChange: string, //ISODATE
+      lastUpdate: string, //ISODATE
+      model: string,
+      subscription: {
+        id: string,
+        links: Link[]
+      },
+      links: Link[]
+    }[],
+    page: {
+      size: number,
+      totalElements: number,
+      totalPages: number,
+      number: number
+    }
+  }
+}
+
--- a/packages/sim-consumidor-alai/domain/transformers.ts
+++ b/packages/sim-consumidor-alai/domain/transformers.ts
@@ -0,0 +1,47 @@
+import { Result } from "sim-shared/domain/Result.js";
+import { AlaiAPI } from "./AlaiAPI.js";
+import { CommonSim } from "sim-shared/domain/CommonSim.js";
+
+const alaiStates = new Map<AlaiAPI.Status, CommonSim<any>["billing_status"]>([
+  ["ABORTED", "SUSPENDED"],
+  ["ACTIVE", "ACTIVE"],
+  ["BLOCKEDCORE", "SUSPENDED"],
+  ["BLOCKEDFRAUD", "SUSPENDED"],
+  ["CANCELLED", "TERMINATED"],
+  ["CONFIGURING", "SUSPENDED"],
+  ["DELETED", "TERMINATED"],
+  ["PRE_ACTIVE", "PREACTIVATED"],
+  ["TERMINATED", "TERMINATED"]
+])
+
+const alaiNetworkStates = new Map<AlaiAPI.NetworkStatus, CommonSim<any>["network_status"]>([
+  ["ACTIVE", "ACTIVE"],
+  ["PRE_ACTIVE", "PREACTIVATED"],
+  ["BLOCKED", "SUSPENDED"],
+  ["DEACTIVATE", "SUSPENDED"],
+  ["FRAUD", "TERMINATED"]
+])
+
+export function alaiSimToCommonSim(alaiSim: AlaiAPI.Sim, alaiSubscription: AlaiAPI.Subscription, imeiSubscription: AlaiAPI.GetImeiSubscriptionDTO):
+  Result<string, CommonSim<AlaiAPI.Subscription>> {
+
+  const status = alaiStates.get(alaiSubscription.status) ?? "UNKNOWN"
+  const networkStatus = alaiNetworkStates.get(alaiSubscription.networkStatus) ?? "UNKNOWN"
+
+  const commonSim: CommonSim<AlaiAPI.Subscription> = {
+    company: "ALAI",
+    tariff: alaiSubscription.name,
+    iccid: alaiSim.id,
+    msisdn: alaiSubscription.lastMsisdnID,
+    billing_status: status,
+    network_status: networkStatus,
+    raw: alaiSubscription,
+    imei: imeiSubscription.content[0].id ?? "0",
+    preactivation_date: new Date(alaiSubscription.creationDate),
+    activation_date: new Date(alaiSubscription.firstActivationDate)
+  }
+
+  return {
+    data: commonSim
+  }
+}
--- a/packages/sim-consumidor-alai/index.ts
+++ b/packages/sim-consumidor-alai/index.ts
@@ -0,0 +1,78 @@
+import express from "express"
+import cors from 'cors';
+import { env } from "#config/env/env.js"
+import { startRMQClient } from "#config/eventBus.config.js";
+import { SimAlaiRouter } from "#aplication/SimAlai.router.js";
+import { SimAlaiController } from "#aplication/SimAlai.controller.js";
+import { SimAlaiUsecases } from "#aplication/SimAlai.usecases.js";
+import { alaiHttp } from "#config/httpClient.config.js";
+import { AlaiRepository } from "#infrastructure/AlaiRepository.js";
+import { OrderRepository } from "sim-shared/infrastructure/OrderRepository.js";
+import { pgClient } from "#config/postgreConfig.js";
+
+const RMQ_QUEUE = "sim.alai"
+const PORT = env.ALAI_PORT
+const HOSTNAME = env.ALAI_HOST
+
+async function startWorker() {
+  // Instancia de dependencias
+
+  const rmqClient = await startRMQClient()
+
+  const orderRepository = new OrderRepository(pgClient)
+
+  const alaiRepository = new AlaiRepository(alaiHttp)
+
+  const alaiUsecases = new SimAlaiUsecases(
+    alaiHttp,
+    alaiRepository,
+    orderRepository
+  )
+
+  const alaiController = new SimAlaiController(
+    alaiUsecases,
+    rmqClient
+  )
+
+  const simRouter = new SimAlaiRouter(
+    alaiController,
+    rmqClient
+  )
+
+  // RMQ
+  rmqClient.consume(RMQ_QUEUE, simRouter.route)
+    .then(() => console.log("Cliente rmq creado con exito"))
+    .catch(e => console.error("Error conectando con RABBITMQ", e))
+
+  // Express
+  const app = express()
+  app.use(cors());
+  app.use(express.json());
+  app.use(express.urlencoded({ extended: true }));
+
+  // WIP
+  app.get("/select", alaiController.selectREST())
+  app.get("/health",
+    (req, res) => res.json({
+      ok: "alai"
+    }))
+  //app.get("/selectPage", alaiController.selectPageREST())
+
+  app.listen(PORT, HOSTNAME, (e) => {
+    if (e == undefined) {
+      console.log("[o] Servidor (Alai) iniciado en el puerto %d", PORT)
+    } else {
+      console.error("Error express ", e)
+    }
+  })
+}
+
+startWorker()
+  .then(e => {
+    console.log("[o] Worker de SIM de Alai iniciado")
+  })
+  .catch(e => {
+    console.log("[x] Error iniciando worker de SIM de Alai", e)
+  })
+
+export default {}
--- a/packages/sim-consumidor-alai/infrastructure/AlaiJwtService.ts
+++ b/packages/sim-consumidor-alai/infrastructure/AlaiJwtService.ts
--- a/packages/sim-consumidor-alai/infrastructure/AlaiRepository.test.ts
+++ b/packages/sim-consumidor-alai/infrastructure/AlaiRepository.test.ts
--- a/packages/sim-consumidor-alai/infrastructure/AlaiRepository.ts
+++ b/packages/sim-consumidor-alai/infrastructure/AlaiRepository.ts
@@ -0,0 +1,190 @@
+import { AlaiAPI } from "#domain/AlaiAPI.js";
+import axios, { AxiosError, AxiosResponse } from "axios";
+import { Result } from "sim-shared/domain/Result.js";
+import { env } from "#config/env/env.js";
+import { HttpClient } from "sim-shared/infrastructure/HTTPClient.js";
+import https from "https"
+
+export class AlaiRepository {
+  constructor(
+    private httpClient: HttpClient
+  ) {
+  }
+
+  private async manageRequest<E, T>(promiseReq: Promise<AxiosResponse<T>>): Promise<Result<string, T>> {
+    try {
+      const res = await promiseReq
+      return {
+        data: res.data
+      }
+    } catch (e) {
+      if (axios.isAxiosError(e)) {
+        const error = e as AxiosError
+        return {
+          error: error.code + " : " + String(error.response?.statusText)
+        }
+      } else {
+        return {
+          error: String(e)
+        }
+      }
+    }
+  }
+
+  public static async login(httpsAgent: https.Agent): Promise<Result<string, AlaiAPI.LoginResponseDTO>> {
+    const alaiUrl = env.ALAI_API_URL
+    const endpoint = "/v1/auth/login"
+    const fullUrl = alaiUrl + endpoint
+    const data = {
+      "username": env.ALAI_USERNAME,
+      "password": env.ALAI_PASSWORD,
+      "brandID": env.ALAI_BRANDID
+    }
+
+    try {
+      const loginRes = await axios.post<AlaiAPI.LoginResponseDTO>(fullUrl, data, { httpsAgent })
+      return {
+        data: loginRes.data
+      }
+    } catch (e) {
+      if (axios.isAxiosError(e)) {
+        const error = e as AxiosError
+        return {
+          error: error.code + " : " + String(error.response?.statusText)
+        }
+      } else {
+        return {
+          error: String(e)
+        }
+      }
+    }
+  }
+
+  /**
+  * Los orders son la unidad que envuelve las peticiones para garantizar ideponencia.
+  */
+  public async createOrder() {
+    // POST
+    const endpoint = "/v1/order"
+    const data: AlaiAPI.CreateOrderDTO = {
+      type: "RETAIL",
+      salesChannel: "OWN_CALLCENTER",
+      status: "CONFIRMED",
+      packages: [{ id: env.ALAI_PACKAGE as string }],
+      subscriber: { id: env.ALAI_SUBSCRIBER_ID as string }
+    }
+    const promReq = this.httpClient.post<AlaiAPI.CreateOrderResponseDTO>(endpoint, data)
+    const res = await this.manageRequest(promReq)
+    return res
+  }
+
+  public async applyOrder(orderId: string) {
+    const endpoint = `/v1/order/${orderId}`
+    const params = new URLSearchParams([
+      ["action", "APPLY"]
+    ])
+    const promReq = this.httpClient.patch<AlaiAPI.ApplyOrderDTO>(endpoint, undefined, { params: params })
+    const res = await this.manageRequest(promReq)
+    return res
+  }
+
+  /*
+  * Ver estado del order para debug
+  */
+  public async getOrder(orderId: string) {
+    const endpoint = `/v1/order/${orderId}`
+    const promReq = this.httpClient.post<AlaiAPI.CreateOrderResponseDTO>(endpoint, undefined)
+    const res = await this.manageRequest(promReq)
+    return res
+  }
+
+  /**
+  * Antes se usaba PATCH /v1/sim/{iccid}/{orderId} pero en la docu ha pasado a POST
+  */
+  public async createReserve(orderId: string, iccid: string): Promise<Result<string, AlaiAPI.CreateOrderResponseDTO>> {
+    const endpoint = `/v1/sim/${iccid}/order/${orderId}`
+    // Crear la reserva no usa datos en el body
+    const promReq = this.httpClient.post<AlaiAPI.CreateOrderResponseDTO>(endpoint, undefined)
+    const res = await this.manageRequest(promReq)
+    return res
+  }
+
+  /**
+  * IMPORTANTE:
+  * - En el campo subscription viene el id para los cambios de estado, no se hacen
+  *   sobre la sim, sino sobre la subscription
+  */
+  public async getSimByICCID(iccid: string) {
+    const endpoint = `/v1/sim/${iccid}`
+    const promReq = this.httpClient.get<AlaiAPI.Sim | undefined>(endpoint, undefined)
+    const res = await this.manageRequest(promReq)
+    return res
+  }
+
+  public async pauseSubscription(subscriptionId: string) {
+    const endpoint = `/v1/subscription/${subscriptionId}`
+    // En teoria ahora se usa ["action", "BLOCK"] pero no he probado
+    const params = new URLSearchParams([
+      ["action", "CHANGE_STATUS"]
+    ])
+    const data = {
+      status: "BLOCKEDCORE"
+    }
+    const promReq = this.httpClient.patch<AlaiAPI.UpdateSubscriptionDTO | undefined>(endpoint, data, { params: params })
+    const res = await this.manageRequest(promReq)
+    return res
+  }
+
+  public async unPauseSubscription(subscriptionId: string) {
+    const endpoint = `/v1/subscription/${subscriptionId}`
+    // En teoria ahora se usa ["action", "UNBLOCK"] pero no he probado
+    const params = new URLSearchParams([
+      ["action", "CHANGE_STATUS"]
+    ])
+    const data = {
+      status: "ACTIVE"
+    }
+    const promReq = this.httpClient.patch<AlaiAPI.UpdateSubscriptionDTO | undefined>(endpoint, data, { params: params })
+    const res = await this.manageRequest(promReq)
+    return res
+  }
+
+  public async terminateSubscription(subscriptionId: string) {
+    const endpoint = `/v1/subscription/${subscriptionId}`
+    //  Esta llamada si es de acuerdo a la docu
+    const params = new URLSearchParams([
+      ["action", "TERMINATE"]
+    ])
+    const promReq = this.httpClient.patch<AlaiAPI.UpdateSubscriptionDTO | undefined>(endpoint, undefined, { params: params })
+    const res = await this.manageRequest(promReq)
+    return res
+  }
+
+  public async changeExternalId(subscriptionId: string, externalId: string) {
+    const endpoint = `/v1/subscription/${subscriptionId}`
+    //  Esta llamada si es de acuerdo a la docu
+    const params = new URLSearchParams([
+      ["action", "MODIFY"]
+    ])
+    const data = {
+      externalID: externalId
+    }
+    const promReq = this.httpClient.patch<AlaiAPI.UpdateSubscriptionDTO | undefined>(endpoint, data, { params: params })
+    const res = await this.manageRequest(promReq)
+    return res
+  }
+
+  public async getSubscriptionById(subscriptionId: string) {
+    const endpoint = `/v1/subscription/${subscriptionId}`
+    const promReq = this.httpClient.get<AlaiAPI.Subscription | undefined>(endpoint)
+    const res = await this.manageRequest(promReq)
+    return res
+  }
+
+  public async getImeiFromSubscription(subscriptionId: string) {
+    const endpoint = `/v1/subscription/${subscriptionId}/imei`
+    const promReq = this.httpClient.get<AlaiAPI.GetImeiSubscriptionDTO | undefined>(endpoint)
+    const res = await this.manageRequest(promReq)
+    return res
+  }
+}
--- a/packages/sim-consumidor-alai/infrastructure/LegacyJWTTokensRepository.ts
+++ b/packages/sim-consumidor-alai/infrastructure/LegacyJWTTokensRepository.ts
@@ -0,0 +1,65 @@
+import path from "path";
+import fs from 'fs';
+import { Result } from "sim-shared/domain/Result.js";
+import { PgClient } from "sim-shared/infrastructure/PgClient.js";
+
+type TokenLine = {
+  id: number,
+  url: string,
+  user_name: string,
+  pass: string,
+  brand_id: string,
+  cert_file: string,
+  key_file: string,
+  ca_file: string,
+  p12_file: string,
+  cert_password: string,
+  token: string
+}
+
+/**
+ * Repositorio para usar los tokens guardados en la bdd de intranet o en un archivo
+ */
+export class LegacyJWTTokenRepository {
+  constructor(
+    // En prod (no deberia usarse) tiene que apuntar a intranet
+    private pgClient: PgClient
+  ) {
+  }
+
+  public async getTokenFromDB(): Promise<Result<string, string>> {
+    const query = "SELECT * FROM alai_api_credentials;"
+
+    try {
+      const res = await this.pgClient.query<TokenLine>(query)
+      if (res.rowCount == 0) {
+        return {
+          error: "Error recuperando el token actual"
+        }
+      } else {
+        return {
+          data: res.rows[0].token
+        }
+      }
+    } catch (e) {
+      return {
+        error: String(e)
+      }
+    }
+  }
+
+  public static getTokenFromFile(dir: string, file: string): Result<string, string> {
+    try {
+      const tokenPath = path.join(dir, file)
+      const fileContent = fs.readFileSync(tokenPath).toString()
+      return {
+        data: fileContent
+      }
+    } catch (e) {
+      return {
+        error: "[d!] No se ha podido leer el archivo del token de debug" + String(e)
+      }
+    }
+  }
+
+}
--- a/packages/sim-consumidor-alai/package.json
+++ b/packages/sim-consumidor-alai/package.json
@@ -0,0 +1,71 @@
+{
+  "name": "sim-consumidor-alai",
+  "type": "module",
+  "description": "consumidor generico de eventos de alai",
+  "main": "index.ts",
+  "imports": {
+    "#config/*.js": {
+      "types": "./config/*.ts",
+      "default": "./config/*.js"
+    },
+    "#config/*": {
+      "types": "./config/*.ts",
+      "default": "./config/*.js"
+    },
+    "#infrastructure/*.js": {
+      "types": "./infrastructure/*.ts",
+      "default": "./infrastructure/*.js"
+    },
+    "#infrastructure/*": {
+      "types": "./infrastructure/*.ts",
+      "default": "./infrastructure/*.js"
+    },
+    "#domain/*.js": {
+      "types": "./domain/*.ts",
+      "default": "./domain/*.js"
+    },
+    "#domain/*": {
+      "types": "./domain/*.ts",
+      "default": "./domain/*.js"
+    },
+    "#aplication/*.js": {
+      "types": "./aplication/*.ts",
+      "default": "./aplication/*.js"
+    },
+    "#aplication/*": {
+      "types": "./aplication/*.ts",
+      "default": "./aplication/*.js"
+    }
+  },
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1",
+    "build": "yarn tsc --project tsconfig.json && yarn tsc-alias && cp package.json ../../dist/packages/sim-consumidor-nos/ && cp -r certificates/ ../../dist/packages/sim-consumidor-alai/",
+    "esbuild": "esbuild index.ts --platform=node",
+    "start": "node ../../dist/packages/sim-consumidor-nos/index.js",
+    "dev": "tsx watch index.ts"
+  },
+  "author": "",
+  "license": "ISC",
+  "packageManager": "yarn@4.12.0",
+  "dependencies": {
+    "@tsconfig/node22": "*",
+    "amqplib": "^0.10.9",
+    "cors": "*",
+    "dotenv": "*",
+    "express": "*",
+    "sim-shared": "sim-shared:*",
+    "typescript": "*"
+  },
+  "devDependencies": {
+    "@types/amqplib": "^0.10.8",
+    "@types/cors": "*",
+    "@types/express": "*",
+    "@types/node": "*",
+    "@types/supertest": "*",
+    "prettier": "*",
+    "supertest": "*",
+    "tsc-alias": "^1.8.16",
+    "tsx": "*",
+    "vitest": "*"
+  }
+}
--- a/packages/sim-consumidor-alai/readme.md
+++ b/packages/sim-consumidor-alai/readme.md
@@ -0,0 +1,5 @@
+# Alai
+
+## Particularidades de las operaciones de Alai
+
+TODO: Copiar de obsidian
--- a/packages/sim-consumidor-alai/tsconfig.json
+++ b/packages/sim-consumidor-alai/tsconfig.json
@@ -0,0 +1,41 @@
+{
+  "extends": "../../tsconfig.json",
+  "compilerOptions": {
+    "outDir": "../../dist",
+    "rootDir": "../../",
+    "paths": {
+      "#config/*": [
+        "./config/*"
+      ],
+      "#infrastructure/*": [
+        "./infrastructure/*"
+      ],
+      "#domain/*": [
+        "./domain/*"
+      ],
+      "#aplication/*": [
+        "./aplication/*"
+      ],
+      "config/*": [
+        "./config/*"
+      ],
+      "infrastructure/*": [
+        "./infrastructure/*"
+      ],
+      "domain/*": [
+        "./domain/*"
+      ]
+    }
+  },
+  "exclude": [
+    "node_modules"
+  ],
+  "include": [
+    "**/*.ts",
+    "**/*.d.ts",
+    "../../packages/sim-shared/**/*.ts"
+  ],
+  "files": [
+    "index.ts"
+  ]
+}
--- a/packages/sim-consumidor-nos/.env
+++ b/packages/sim-consumidor-nos/.env
@@ -1,5 +0,0 @@
-PORT=3000
-RABBITMQ_USER=guest
-RABBITMQ_PASSWORD=guest
-
-ENVIORMENT=development
--- a/packages/sim-consumidor-nos/aplication/SimNOS.controller.ts
+++ b/packages/sim-consumidor-nos/aplication/SimNOS.controller.ts
@@ -1,65 +1,185 @@
-import { EventBus } from "sim-shared/domain/EventBus.port.js";
 import { ConsumeMessage } from "amqplib";
+import { Request, Response } from "express"
+import { SimNosUsecases } from "./SimNOS.usecases.js";
+import { EventBus } from "sim-shared/domain/EventBus.port.js";
+import { Result } from "sim-shared/domain/Result.js";
+import { SimEvents } from "sim-shared/domain/SimEvents.js";
+import { iccidValidator } from "./httpValidators.js";
+import { error } from "node:console";
+import { nosSimToCommonSim } from "#domain/transformers.js";

 export class SimNosController {
-  private eventBus: EventBus;
-  private activationUseCases: any;
-
-  private routes = new Map<string, () => void>([
-    ["activate", async () => { console.log("caso de uso activate") }],
-    ["pause", async () => { console.log("caso de uso pause") }],
-    ["cancel", async () => { console.log("caso de uso cancel") }],
-  ])

  constructor(
-    eventBus: EventBus
+    private uscases: SimNosUsecases,
+    private eventBus: EventBus,
  ) {
-    this.eventBus = eventBus
-
-    // No se si hay un sistema mejor
-    // convertor en const () => {} para conservar el contexto??
-    this.recibeMsg = this.recibeMsg.bind(this)
  }

-  public async recibeMsg(msg: ConsumeMessage | null) {
-    if (!this.validateActivationMsg(msg)) {
-      throw new Error("Error consumiendo el mensaje no es valido")
-    }
+  private validateMsg(msg: ConsumeMessage | null) {
+    if (msg == undefined) return false;
+    const msgData = this.decodeMsg(msg) as SimEvents.general
+    if (msgData == undefined || msgData.payload == undefined) throw new Error("Mensaje invalido")
+    return msgData;
+  }

-    msg = msg!
-
-    const msgParsed = JSON.parse(String(msg.content))
-    const msgKey = msg.fields.routingKey.split(".")
-    const accion = msgKey[2]
-
-    if (accion == undefined) {
-      console.error("La routingKey es incorrecta: " + accion)
-      this.eventBus.nack(msg)
-      return;
-    }
-
-    if (this.routes.get(accion) == undefined) {
-      console.error("No hay una ruta definida para la accion")
-      this.eventBus.nack(msg)
-      return;
+  private decodeMsg(msg: ConsumeMessage): object | undefined {
+    if (msg.content == undefined) {
+      console.warn('[Sim.controller] Mensaje vacío');
+      return undefined;
    }

    try {
-      this.routes.get(accion)!()
-    } catch (err) {
-      console.log("Error procesando el mensaje")
-      this.eventBus.nack(msg)
-    } finally {
-      this.eventBus.ack(msg)
+      // Convertir el Buffer a String (UTF-8)
+      const contentJson = JSON.parse(Buffer.from(msg.content).toString('utf8'))
+      return contentJson;
+
+    } catch (error) {
+      console.error('Error al decodificar JSON:', error);
+      console.error(Buffer.from(msg.content).toString(("utf8")))
+      // Aquí podrías decidir devolver el string crudo o null
+      return undefined;
    }
  }

  /**
-  * TODO:
-  * - Loguear motivos de la no validacion
+   * Metodo duplicado se puede generalizar la a una clase sharedController con las funciones basicas
+   */
+  private async tryUseCase<T extends any>
+    (msg: ConsumeMessage, usecase: () => Promise<Result<string, T>>): Promise<Result<string, T>> {
+    try {
+      const result = await usecase()
+      if (result.error == undefined) {
+        await this.eventBus.ack(msg)
+        return result
+      } else {
+        console.error("Error procesando el caso de uso (NOS)", result.error)
+        this.eventBus.nack(msg)
+        return result
+      }
+    } catch (e) {
+      console.error("Error general procesando el caso de uso (NOS)")
+      this.eventBus.nack(msg)
+      return {
+        error: String(e)
+      }
+    }
+  }
+
+  public activate() {
+    return async (msg: ConsumeMessage) => {
+      console.log("[i] Evento activate ", msg.fields)
+      const data = this.validateMsg(msg) as SimEvents.activation
+      const iccid = data.payload.iccid
+      const correlation_id = data.headers?.message_id
+      const res = await this.tryUseCase(msg, this.uscases.activate({
+        iccid: iccid,
+        correlation_id: correlation_id
+      }))
+
+      return res;
+    }
+  }
+
+  public suspend() {
+    return async (msg: ConsumeMessage) => {
+      console.log("Evento suspend ", msg.fields)
+      const data = this.validateMsg(msg) as SimEvents.suspend
+      const iccid = data.payload.iccid
+      const correlation_id = data.headers?.message_id
+      const res = await this.tryUseCase(msg, this.uscases.suspend({
+        iccid: iccid,
+        correlation_id: correlation_id
+      }))
+
+      return res;
+    }
+  }
+
+  public terminate() {
+    return async (msg: ConsumeMessage) => {
+      console.log("Evento termiante no soportado ", msg.fields)
+    }
+  }
+
+  public reActivate() {
+    return async (msg: ConsumeMessage) => {
+      console.log("Evento reActivate ", msg.fields)
+      const data = this.validateMsg(msg) as SimEvents.reActivation
+      const iccid = data.payload.iccid
+      const correlation_id = data.headers?.message_id
+      const res = await this.tryUseCase(msg, this.uscases.reactivate({
+        iccid: iccid,
+        correlation_id: correlation_id
+      }))
+
+      return res;
+    }
+  }
+
+  /**
+  * Select especificamente por REST para evitar pasar por las colas.
+  * La respuesta es instantanea no se tiene que registrar como operación.
  */
-  private validateActivationMsg(msg: ConsumeMessage | null) {
-    if (msg == undefined) return false;
-    return true;
+  public selectREST() {
+    return async (req: Request, res: Response) => {
+      const { query } = req
+      const body = { iccid: query.iccid as string }
+      console.log("Evento select", body)
+      const validateBody = iccidValidator.validate(body);
+
+      if (validateBody.error != undefined) {
+        res.status(422).json(validateBody)
+        return;
+      }
+
+      const iccid: string | string[] = body.iccid
+
+      if (Array.isArray(iccid)) {
+        // TODO: Automatizar la paginacion
+        //const usecaseRes = this.uscases.selectMany({ iccid })
+      } else {
+        const usecaseRes = await this.uscases.selectOne({ iccid })
+        if (usecaseRes.error != undefined) {
+          res.status(500).json(usecaseRes)
+          return;
+        } else {
+          const simComun = nosSimToCommonSim(usecaseRes.data)
+          res.status(200).send({ data: simComun })
+          return;
+        }
+      }
+
+      res.status(501).json({
+        errors: {
+          msg: "No está implementada la busqueda por lista de iccid"
+        }
+      })
+    }
+  }
+
+
+  public selectPageREST() {
+    return async (req: Request, res: Response) => {
+      const { offset, limit, filter, orderBy } = req.query
+      const params = {
+        offset: (offset != undefined) ? Number(offset) : undefined,
+        limit: (limit != undefined) ? Number(limit) : undefined,
+        filter: (filter != undefined) ? String(filter) : undefined,
+        orderBy: (orderBy != undefined) ? String(orderBy) : undefined
+      }
+
+      const usecaseRes = await this.uscases.selectPage(params)
+
+      if (usecaseRes.error != undefined) {
+        res.status(500).json(usecaseRes)
+        return;
+      } else {
+        res.status(200).send(usecaseRes)
+        return;
+      }
+    }
  }
 }
+
+
--- a/packages/sim-consumidor-nos/aplication/SimNOS.router.ts
+++ b/packages/sim-consumidor-nos/aplication/SimNOS.router.ts
@@ -0,0 +1,79 @@
+/**
+ * Dirige cada mensaje dependiendo de el tipo de acción que contenga
+ * Podría hacerse con varias colas, pero así se controla mejor que
+ * las operaciones se hagan de 1 en 1.
+ */
+
+import { ConsumeMessage } from "amqplib";
+import { SimNosController } from "./SimNOS.controller.js";
+import { EventBus } from "sim-shared/domain/EventBus.port.js";
+import { Result } from "sim-shared/domain/Result.js";
+
+type FuncType = ((m: ConsumeMessage) => Promise<Result<string, any>>)
+
+export class SimNosRouter {
+  private readonly routes: Map<string, FuncType>;
+
+  constructor(
+    private readonly simController: SimNosController,
+    private readonly eventBus: EventBus
+  ) {
+    this.routes = new Map<string, FuncType>([
+      //["select", undefined],
+      ["activate", this.simController.activate()],
+      ["pause", this.simController.suspend()],
+      ["reactivate", this.simController.reActivate()],
+      //["cancel", this.simController.terminate()],
+      //["preActivate", this.simController.preActivate()]
+    ]);
+  }
+
+  /**
+   * Enruta el mensaje a la acción correspondiente basándose en la routing key
+   * TODO: No estoy seguro que deba meter el nack aqui
+   * - De moemento el ack-nack se gestiona en los controller, por si acaso hay casos
+   *   limite en 
+   */
+  public route = async (msg: ConsumeMessage | null): Promise<void> => {
+    if (!msg) {
+      console.error("[Router] Mensaje vacío");
+      return;
+    }
+
+    const action = this.extractAction(msg);
+
+    if (!action) {
+      console.error("[Router] La routing key no tiene una acción definida", msg.fields.routingKey);
+      this.eventBus.nack(msg)
+      return;
+    }
+
+    const handler = this.routes.get(action);
+
+    if (!handler) {
+      console.error(`[Router] La acción '${action}' no tiene un controlador asociado`);
+      this.eventBus.nack(msg)
+      return;
+    }
+
+    try {
+      console.log("[Router] Ejecutando operación:", action);
+
+      // El controlador devuelve una función (thunk) que debe ser ejecutada
+      const executeParams = handler(msg);
+
+      if (typeof executeParams === "function") {
+        const res = await executeParams;
+      }
+
+    } catch (error) {
+      console.error(`[Router] Error al ejecutar la operación '${action}':`, error);
+      this.eventBus.nack(msg)
+    }
+  };
+
+  private extractAction(msg: ConsumeMessage): string | undefined {
+    // Se asume que la acción está en la tercera posición: domain.compañia.accion
+    return msg.fields.routingKey.split(".")[2];
+  }
+}
--- a/packages/sim-consumidor-nos/aplication/SimNOS.usecases.ts
+++ b/packages/sim-consumidor-nos/aplication/SimNOS.usecases.ts
@@ -0,0 +1,156 @@
+/**
+ * Documentación de referencia:
+ * https://pelion-help.iot-x.com/nos/en-US/Content/API/APIReference/API%20Reference.htm?tocpath=_____7
+ *
+ * En nos el correlation_id ya va a ser obligatorio en todos los mensajes
+ *
+ * TODO:
+ * - Control de errores más preciso
+ *
+ */
+import { NosHttpClient } from "#infrastructure/NosHttpClient.js";
+import { NosRepository } from "#infrastructure/NosRepository.js";
+import { ErrorOrderDTO, FinishOrderDTO, UpdateOrderDTO } from "sim-shared/domain/Order.js";
+import { Result } from "sim-shared/domain/Result.js";
+import { OrderRepository } from "sim-shared/infrastructure/OrderRepository.js";
+
+export class SimNosUsecases {
+  constructor(
+    private httpClient: NosHttpClient,
+    private nosRepository: NosRepository,
+    private orderRepository: OrderRepository
+  ) {
+  }
+
+  private async setRunning(correlation_id: string) {
+    // En NOS el updateOrder se hace con el correlation_id que viene en la cabecera del
+    // mensaje consumido
+    const updateData: UpdateOrderDTO = {
+      new_status: "running",
+      correlation_id: correlation_id
+    }
+    const order = await this.orderRepository.updateOrder(updateData)
+    return order
+  }
+
+  private async setFinished(correlation_id: string) {
+    // En NOS el updateOrder se hace con el correlation_id que viene en la cabecera del
+    // mensaje consumido
+    const updateData: FinishOrderDTO = {
+      correlation_id: correlation_id
+    }
+    const order = await this.orderRepository.finishOrder(updateData)
+    return order
+  }
+
+  private async setFailed(correlation_id: string, reason: string, detail?: string) {
+    // En NOS el updateOrder se hace con el correlation_id que viene en la cabecera del
+    // mensaje consumido
+    const updateData: ErrorOrderDTO = {
+      status: "failed",
+      correlation_id: correlation_id,
+      reason: reason,
+      error: reason,
+      stackTrace: detail
+    }
+
+    console.log("SET FAILED DATA:", updateData)
+    const order = await this.orderRepository.errorOrder(updateData)
+    console.log("SET FAILED RES:", order)
+    return order
+  }
+
+  public usecaseTemplate<T, R>(
+    func: (_: T) => Promise<Result<string, R>>,
+    args: T,
+    correlation_id?: string | undefined
+  ) {
+    return async () => {
+      // Operacion pending -> running
+      if (correlation_id != undefined)
+        this.setRunning(correlation_id)
+          .then()
+          .catch(e => console.error("Error actualizando el order", e))
+
+      try {
+        const res = await func(args)
+
+        if (res.error != undefined) {
+          console.log("Error peticion: ", res, correlation_id)
+          if (correlation_id != undefined)
+            this.setFailed(correlation_id, res.error)
+              .then(e => console.log("failed", e))
+              .catch(e => console.error(e))
+          return res;
+        } else {
+          if (correlation_id != undefined)
+            this.setFinished(correlation_id).then()
+          return res;
+        }
+
+      } catch (e) {
+        if (correlation_id != undefined)
+          this.setFailed(correlation_id, "Error general de operacion de SIM (NOS) ", String(e)).then()
+        return {
+          error: "Error general de operacion de SIM (NOS) " + String(e)
+        }
+      }
+
+    }
+  }
+
+  public activate(args: {
+    iccid: string,
+    correlation_id?: string
+  }) {
+    return this.usecaseTemplate(
+      (args) => this.nosRepository.activateSim(args), args.iccid, args.correlation_id)
+  }
+
+  public suspend(args: {
+    iccid: string,
+    correlation_id?: string
+  }) {
+    return this.usecaseTemplate(
+      (args) => this.nosRepository.bar(args), args.iccid, args.correlation_id)
+  }
+
+  public reactivate(args: {
+    iccid: string,
+    correlation_id?: string
+  }) {
+    return this.usecaseTemplate(
+      (args) => this.nosRepository.unbar(args), args.iccid, args.correlation_id)
+  }
+
+  public terminate(args: { iccid: string }) {
+    throw new Error("No hay termination para NOS")
+  }
+
+  /* Importante: Las operaciones de lectua no dejan registro en orders */
+
+  public async selectOne(args: {
+    iccid: string
+  }) {
+    const res = await this.nosRepository.getLineInfo(args.iccid)
+    return res
+  }
+
+  public async selectPage(args: {
+    offset?: number,
+    limit?: number,
+    filter?: string,
+    orderBy?: string
+  }) {
+    const res = await this.nosRepository.getLinePage(args)
+    return res
+  }
+
+  /**
+  public selectMany(args: {
+    iccid: string[]
+  }) {
+    return {}
+  }
+*/
+}
--- a/packages/sim-consumidor-nos/aplication/httpValidators.ts
+++ b/packages/sim-consumidor-nos/aplication/httpValidators.ts
@@ -0,0 +1,39 @@
+import { BodyValidator, Validator } from "sim-shared/aplication/BodyValidator.js";
+
+const iccidNotNull = <Validator<{ iccid: unknown }>>{
+  field: "iccid",
+  errorMsg: "El iccid no está definido",
+  validationFunc: (a: { iccid: unknown }) => {
+    return (a.iccid != null && a.iccid != undefined)
+  }
+}
+
+const iccidValueOrArray = <Validator<{ iccid: unknown }>>{
+  field: "iccid",
+  errorMsg: "El iccid debe de ser un único valor o una lista",
+  validationFunc: (a: { iccid: unknown }) => {
+    return (typeof a.iccid == "string" || Array.isArray(a.iccid))
+  }
+}
+
+const iccidLongitudValidator = <Validator<{ iccid: string | string[] }>>{
+  field: "iccid",
+  errorMsg: "La longitud del iccid/s es incorrecta debera ser de 19 caracteres",
+  validationFunc: (a: { iccid: string | string[] }) => {
+    if (Array.isArray(a.iccid)) {
+      const res = (a.iccid as string[]).filter(e => e.length != 19)
+      if (res.length > 0) return false;
+    } else {
+      return (a.iccid as string).length == 19
+    }
+  },
+}
+
+export const iccidValidator = new BodyValidator<{ iccid: string | string[] }>(
+  [
+    iccidNotNull,
+    iccidValueOrArray,
+    iccidLongitudValidator,
+  ]
+)
+
--- a/packages/sim-consumidor-nos/config/env/index.ts
+++ b/packages/sim-consumidor-nos/config/env/index.ts
@@ -1,8 +1,18 @@
 import { loadEnvFile } from "node:process";
-loadEnvFile("../../.env")
+import path from "node:path";
+
+try {
+  loadEnvFile(path.join("./.env")) // base
+} catch (e) {
+  console.error("Error cargando el .env desde ./.env")
+}
+try {
+  loadEnvFile(path.join("../../.env")) // Global
+} catch (e) {
+  console.error("Error cargando el .env desde ../../.env")
+}

 export const env = {
-  ENVIRONMENT: process.env.ENVIORMENT,
  POSTGRES_USER: process.env.POSTGRES_USER,
  POSTGRES_PASSWORD: process.env.POSTGRES_PASSWORD,
  POSTGRES_PORT: process.env.POSTGRES_PORT,
@@ -18,5 +28,12 @@ export const env = {
  RABBITMQ_SECURE: process.env.RABBITMQ_SECURE,
  RABBITMQ_RETRY_INTERVAL: process.env.RABBITMQ_INTERVAL,
  RABBITMQ_VHOST: String(process.env.RABBITMQ_VHOST),
+
+  APP_PORT: Number(process.env.NOS_PORT),
+  APP_HOST: String(process.env.NOS_HOST),
+
+  // ESPECIFICO NOS
+  NOS_BASE_URL: String(process.env.NOS_BASE_URL),
+  NOS_ACCESS_TOKEN: String(process.env.NOS_ACCESS_TOKEN)
 };

--- a/packages/sim-consumidor-nos/config/eventBus.config.ts
+++ b/packages/sim-consumidor-nos/config/eventBus.config.ts
@@ -0,0 +1,72 @@
+import { RabbitMQEventBus, RMQConnectionParams } from "sim-shared/infrastructure/RabbitMQEventBus.js"
+import { Channel } from "amqp-connection-manager"
+import { env } from "./env/env.js"
+
+const rmqUser = env.RABBITMQ_USER
+const rmqPass = env.RABBITMQ_PASSWORD
+const rmqHost = env.RABBITMQ_HOST
+const rmqPort = Number(env.RABBITMQ_PORT)
+const rmqSecure = false
+const rmqVhost = env.RABBITMQ_VHOST
+
+export const rmqConnOptions = <RMQConnectionParams>{
+  username: rmqUser,
+  password: rmqPass,
+  vhost: rmqVhost,
+  hostname: rmqHost,
+  port: rmqPort,
+  secure: rmqSecure,
+}
+
+
+const QUEUES = {
+  NOS: "sim.nos",
+  NOSDLX: "sim.nos.dlx",
+  NOSDEL: "sim.nos.delayed",
+}
+
+const EXCHANGES = {
+  MAIN: "sim.exchange",
+  DLX: "sim.ex.nos.dlx",
+  DEL: "sim.ex.nos.delayed"
+}
+
+export const rabbitmqEventBus = new RabbitMQEventBus({
+  connectionParams: rmqConnOptions,
+  buildStructure: buildQueues,
+  maxRetry: 2,
+  delayedExchange: EXCHANGES.DEL,
+  dlxExchange: EXCHANGES.DLX
+})
+
+async function buildQueues(channel: Channel) {
+
+  const DELAY = 10 * 1000
+  const BASE_NOS_KEY = "sim.nos.#"
+
+  await channel.assertExchange(EXCHANGES.DEL, "topic")
+  await channel.assertExchange(EXCHANGES.DLX, "topic")
+  await channel.assertExchange(EXCHANGES.MAIN, "topic")
+
+  await channel.assertQueue(QUEUES.NOS)
+  await channel.assertQueue(QUEUES.NOSDLX)
+  await channel.assertQueue(QUEUES.NOSDEL, {
+    durable: true,
+    arguments: {
+      'x-message-ttl': DELAY,
+      'x-dead-letter-exchange': EXCHANGES.MAIN,
+    }
+  })
+
+  // Cola dead-letter 
+  await channel.bindQueue(QUEUES.NOSDLX, EXCHANGES.DLX, "sim.nos.#")
+  // Cola delay
+  await channel.bindQueue(QUEUES.NOSDEL, EXCHANGES.DEL, BASE_NOS_KEY)
+  // Cola nos -> main exchange
+  await channel.bindQueue(QUEUES.NOS, EXCHANGES.MAIN, BASE_NOS_KEY)
+}
+
+export async function startRMQClient() {
+  await rabbitmqEventBus.connect()
+  return rabbitmqEventBus
+}
--- a/packages/sim-consumidor-nos/config/eventBusConfig.ts
+++ b/packages/sim-consumidor-nos/config/eventBusConfig.ts
@@ -1,39 +0,0 @@
-import { RabbitMQEventBus, RMQConnectionParams } from "sim-shared/infrastructure/RabbitMQEventBus.js"
-import { env } from "./env"
-
-const rmqUser = env.RABBITMQ_USER
-const rmqPass = env.RABBITMQ_PASSWORD
-const rmqHost = env.RABBITMQ_HOST
-const rmqPort = Number(env.RABBITMQ_PORT)
-const rmqSecure = false
-const rmqVhost = env.RABBITMQ_VHOST
-
-export const rmqConnOptions = <RMQConnectionParams>{
-  username: rmqUser,
-  password: rmqPass,
-  vhost: rmqVhost,
-  hostname: rmqHost,
-  port: rmqPort,
-  secure: rmqSecure,
-}
-
-export const rabbitmqEventBus = new RabbitMQEventBus({
-  connectionParams: rmqConnOptions
-})
-
-export async function startRMQClient() {
-  await rabbitmqEventBus.connect().catch(async e => {
-    console.error("Error en la conexion RMQ")
-    await rabbitmqEventBus.connect()
-  })
-
-  // Bindings especificos, deberia meterlos en la clase
-  try {
-    await rabbitmqEventBus.channel?.assertQueue("sim.nos")
-  } catch {
-    console.log("[i] Cola de sims de nos creada")
-    await rabbitmqEventBus.channel?.bindQueue("sim.nos", "sim.exchange", "sim.nos.*")
-  }
-
-  return rabbitmqEventBus
-}
--- a/Show More
+++ b/Show More
Author	SHA1	Message	Date
Alvar San Martin	86478b1073	Comillas	2026-05-11 12:15:37 +02:00
Alvar San Martin	976cf1c3d2	delete	2026-05-11 10:10:17 +02:00
Alvar San Martin	e4ba1576e5	delete env	2026-05-11 10:09:16 +02:00
Alvar San Martin	4baa9f708f	Certificado p12	2026-05-11 10:05:26 +02:00
Alvar San Martin	6fb25e6055	Ignore p12 certificado	2026-05-11 09:23:49 +02:00
Alvar San Martin	63698ee1aa	Misma info de sim para el /select	2026-05-08 14:49:43 +02:00
Alvar San Martin	410f659db0	Sim comun para nos	2026-05-08 12:06:24 +02:00
Alvar San Martin	08c972e720	Todos los datos de Alai para agrupar	2026-05-07 16:19:18 +02:00
Alvar San Martin	c4e4d87303	Imei from subscription, SIM común	2026-05-07 13:53:02 +02:00
Alvar San Martin	9c74fb9a7b	Funcionan todos los select, pendiente el general	2026-05-07 11:37:35 +02:00
Alvar San Martin	1d7c2b2946	puertos	2026-05-07 10:36:16 +02:00
Alvar San Martin	d2c86396b1	Organizacion docs	2026-05-07 09:20:26 +02:00
Alvar San Martin	3cf5c3695e	Pruebas a los endpoints internos	2026-05-06 16:59:09 +02:00
Alvar San Martin	7dda25fbfb	Router para el select de cualquier sim	2026-05-06 16:47:52 +02:00
Alvar San Martin	eefb7c5a79	pruebas	2026-05-05 17:31:08 +02:00
Alvar San Martin	13944a64d2	ontroladores y rutas	2026-05-05 17:01:24 +02:00
Alvar San Martin	07e60690ab	Ajuste de preactivacion con externalID	2026-05-05 14:24:24 +02:00
Alvar San Martin	036ae20ac3	Subscripciones de ALAI	2026-05-05 13:12:31 +02:00
Alvar San Martin	189de6c0fb	La conexión con alai funciona	2026-05-04 15:12:53 +02:00
Alvar San Martin	113d9f3786	Debug para tokens de Alai	2026-05-04 13:39:54 +02:00
Alvar San Martin	331d920379	Operaciones basicas ALAI	2026-05-04 09:37:06 +02:00
Alvar San Martin	a615fc2b81	Agente https para certificados	2026-04-30 17:41:49 +02:00
Alvar San Martin	f98097d11d	Estructura para el token de alai cabecera automatica de bearer para todas las requests a alai	2026-04-30 15:49:59 +02:00
Alvar San Martin	3e76c3c931	Merge branch 'main' into WEBINT-335_migracion_alai	2026-04-29 17:12:55 +02:00
Alvar San Martin	bb31efb271	Merge main -> migracion alai	2026-04-29 17:08:30 +02:00
Alvar San Martin	c9733113cf	Persistencia de rabbit	2026-04-29 13:25:46 +02:00
Alvar San Martin	4c1d6ac2c4	No se crean los enlaces simbolicos en start	2026-04-29 13:19:47 +02:00
Alvar San Martin	07e7a0d457	.env de NOS en el compose	2026-04-29 12:47:59 +02:00
Alvar San Martin	48361ab33f	El .env no se deberia mover en el paso de build	2026-04-29 12:24:27 +02:00
Alvar San Martin	a3c7c224b1	Copia del env de nos	2026-04-29 11:26:00 +02:00
Alvar San Martin	324aec3001	Merge branch 'WEBINT-338_tiempo_suspension'	2026-04-28 17:25:09 +02:00
Alvar San Martin	05e941710b	Limpieza	2026-04-28 17:24:28 +02:00
Alvar San Martin	f78a333e1e	Merge pull request 'WEBINT-338_tiempo_suspension' (#2 ) from WEBINT-338_tiempo_suspension into main Reviewed-on: #2	2026-04-28 13:40:03 +00:00
Alvar San Martin	01c55cba0f	No se traquea el .env	2026-04-28 15:35:00 +02:00
Alvar San Martin	10b2ae244c	ignore	2026-04-28 15:33:08 +02:00
Alvar San Martin	2dba2ebfae	Query de sims por networkStatus y tiempo de suspension	2026-04-28 15:23:27 +02:00
Alvar San Martin	d7eb4ad326	Gateway para francia funciona	2026-04-27 17:24:40 +02:00
Alvar San Martin	d818441bde	Docu	2026-04-27 16:30:22 +02:00
Alvar San Martin	c91965567d	Actualizacion docs	2026-04-27 15:17:20 +02:00
Alvar San Martin	d063b47bec	Merge branch 'main' into WEBINT-338_tiempo_suspension	2026-04-27 14:00:08 +02:00
Alvar San Martin	6112de297b	Bug duplicados solo en la primera linea	2026-04-27 13:46:34 +02:00
Alvar San Martin	166c940295	Fix	2026-04-27 13:32:55 +02:00
Alvar San Martin	246e4cb83b	Comentarios	2026-04-27 13:03:47 +02:00
Alvar San Martin	4517796ef3	Calculo del tiempo en suspension	2026-04-27 12:12:12 +02:00
Alvar San Martin	858932f260	Test	2026-04-27 11:11:47 +02:00
Alvar San Martin	a84f600fa2	Test orders	2026-04-27 11:05:09 +02:00
Alvar San Martin	4e02ea021d	Docs orders	2026-04-27 09:33:55 +02:00
Alvar San Martin	9ec127433d	Template alai	2026-04-23 13:18:50 +02:00
Alvar San Martin	e1450c6e97	POST -> PATCH	2026-04-22 15:22:37 +02:00
Alvar San Martin	e40a19bbfb	Bug de correlation_id undefined	2026-04-22 13:31:24 +02:00
Alvar San Martin	fbdb64f3a1	Arreglo de bugs ordes	2026-04-22 12:59:23 +02:00
Alvar San Martin	9a29f49669	Fix orders nos	2026-04-22 12:31:46 +02:00
Alvar San Martin	c2081191ae	Trazabilidad de nos, arreglo de orders	2026-04-21 17:39:09 +02:00
Alvar San Martin	f0f3827fd0	Registro del estado/resultado de las operaciones de NOS	2026-04-21 15:51:16 +02:00
Alvar San Martin	ee8f84bc57	Typescript 6	2026-04-21 13:33:01 +02:00
Alvar San Martin	f95677d503	Error pageNOS	2026-04-21 12:50:54 +02:00
Alvar San Martin	59b0b57ec2	Merge branch 'main' into WEBINT-334-migracion-nos	2026-04-21 10:47:08 +02:00
Alvar San Martin	9174b0b6a4	Nombres de colas	2026-04-21 10:22:53 +02:00
Alvar San Martin	e62c49ce91	Endpoints NOS	2026-04-21 10:11:21 +02:00
Alvar San Martin	32990b4dcd	Controladores y rutas	2026-04-17 15:49:53 +02:00
Alvar San Martin	da2413002b	Repositorio de nos completo	2026-04-17 14:06:41 +02:00
Alvar San Martin	fdbb81ba64	Inicio port NOS	2026-04-16 17:46:32 +02:00
Alvar San Martin	964ea6add9	Inicio migracion NOS	2026-04-16 12:44:31 +02:00
Alvar San Martin	602878acf4	console log de debug	2026-04-16 12:01:31 +02:00
Alvar San Martin	0aa52feaac	Proxy	2026-04-16 11:51:30 +02:00
Alvar San Martin	15b70309da	Fix networkStatus	2026-04-15 15:11:13 +02:00
Alvar San Martin	7001fccbf7	Problema de creacion de operacion de pausa/cancelacion	2026-04-15 13:50:20 +02:00
Alvar San Martin	cffee785b2	logs	2026-04-15 12:48:08 +02:00
Alvar San Martin	33d260310c	Reactivate cuando la linea esté suspendida	2026-04-15 12:47:26 +02:00
Alvar San Martin	e359acc1d5	Validaciones pausa instantaneas	2026-04-15 11:47:33 +02:00
Alvar San Martin	bb4bce4a6d	fix	2026-04-15 11:11:55 +02:00
Alvar San Martin	eac74ef0cd	Error key evento	2026-04-15 10:31:21 +02:00
Alvar San Martin	1dc4eb5648	validador	2026-04-15 10:28:52 +02:00
Alvar San Martin	a35a6c2b60	Error endpoint	2026-04-15 10:27:58 +02:00
Alvar San Martin	1f78f4a3e1	Periodo pruebas reducidio	2026-04-15 10:18:49 +02:00
Alvar San Martin	1e98559f3a	Fix	2026-04-15 10:17:36 +02:00
Alvar San Martin	ef0f860b9d	Erro handler	2026-04-14 16:20:15 +02:00
Alvar San Martin	0bff55379f	tab	2026-04-14 16:15:01 +02:00
Alvar San Martin	4d34308a13	Bug de logueo de operacion	2026-04-14 16:07:17 +02:00
Alvar San Martin	70bf73b0a4	Error query	2026-04-10 11:11:12 +02:00
Alvar San Martin	e3849d8217	Archivos de migraciones	2026-04-09 12:48:36 +02:00
Alvar San Martin	d9854a12a8	Version de migrate	2026-04-09 12:31:06 +02:00
Alvar San Martin	48d387a8da	Migraciones antes de lanzar start	2026-04-09 12:10:40 +02:00
Alvar San Martin	93d3e13793	Merge pull request 'WEBINT-328-Pausas-cacelaciones' (#1 ) from WEBINT-328-Pausas-cacelaciones into main Reviewed-on: #1	2026-04-09 10:03:47 +00:00
Alvar San Martin	031f5d5cf0	nombre de columna con mayus	2026-04-09 11:59:06 +02:00
Alvar San Martin	047669bab2	Acabados de corregir bugs	2026-04-09 11:53:49 +02:00
Alvar San Martin	5ea5939e3a	Bug de finaliazacion de tareas erroneas	2026-04-09 09:08:11 +02:00
Alvar San Martin	7ff3f13af4	Funcionan las suspensiones	2026-04-08 17:37:47 +02:00
Alvar San Martin	a9589f578b	Solucionado cierrre de pool para test	2026-04-08 14:47:57 +02:00
Alvar San Martin	a27e4b30d2	Cron completo y mejora de logs	2026-04-08 13:48:57 +02:00
Alvar San Martin	4168949b9e	Endpoint preparados	2026-04-08 10:08:54 +02:00
Alvar San Martin	e6ff54a15d	Usecases	2026-04-07 17:43:17 +02:00
Alvar San Martin	3956797020	Las operaciones basicas del repositorio de pause/cancel funcionan y tienen test	2026-04-07 15:40:19 +02:00
Alvar San Martin	7d88359263	Refactor de jwt y base de la bdd de pausas-cancelaciones	2026-04-07 13:20:31 +02:00
Alvar San Martin	1b6da651a6	Ajustado el periodo de comprobaciones	2026-03-27 12:47:10 +01:00
Alvar San Martin	9b305f887f	Test .env ajustado	2026-03-27 12:24:20 +01:00
Alvar San Martin	9506b9e28e	Error de nombre de activacion	2026-03-27 10:59:15 +01:00
Alvar San Martin	61c0edca07	Logs del envio	2026-03-27 10:52:03 +01:00
Alvar San Martin	9470b5605d	Pribando el env	2026-03-27 10:50:03 +01:00
Alvar San Martin	9d63d23754	Mejor gestion de errores para los order	2026-03-26 12:21:28 +01:00
				`@@ -0,0 +1 @@`
				`eyJhbGciOiJIUzM4NCJ9.eyJiciI6InNhdmVmYW1pbHkiLCJpcCI6Ijg4LjE1LjE1Ny4xNjciLCJzdWIiOiJwYWxvbWFpYmFuZXoiLCJzIjoiRVdTMTY0NmFmNjNlZGUyMjgzIiwicG9zIjoic2F2ZWZhbWlseUNhYyIsImlkV3NVc2VyIjoiODYiLCJpc012bmEiOmZhbHNlLCJkb21haW4iOiJBbGFpfHNhdmVmYW1pbHkiLCJpYXQiOjE3Nzc4OTk3MzcsImV4cCI6MTc3NzkxMDUzN30.PvTTRhUpKlslGOerQsLY4RLBXdQ5FIVvUKb_1ZK4b2Zggt04KZhwX0d-XoLAcP93`