diff --git a/.env b/.env deleted file mode 100644 index d72f207..0000000 --- a/.env +++ /dev/null @@ -1,32 +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 - -# Proxy -CONNECTIONS_URL=https://sim-connections.savefamilygps.net diff --git a/.gitignore b/.gitignore index 195e0ed..f69b410 100644 --- a/.gitignore +++ b/.gitignore @@ -20,3 +20,5 @@ node_modules dist/* + +.env diff --git a/README.md b/README.md index c060e9a..6328041 100644 --- 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,14 @@ 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.  -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) diff --git a/deployment/develop/docker/docker-compose.yaml b/deployment/develop/docker/docker-compose.yaml index 0ff7ea6..d634523 100644 --- 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 diff --git a/deployment/develop/jenkinsfile.groovy b/deployment/develop/jenkinsfile.groovy index 291e0fe..3ca865d 100644 --- a/deployment/develop/jenkinsfile.groovy +++ b/deployment/develop/jenkinsfile.groovy @@ -46,6 +46,10 @@ pipeline { cleanRemote: false, execCommand: "ln -sf $BASE_REMOTE_PATH/vault/savefamily/sf-sims/sim-consumidor-objenious.env $APP_REMOTE_PATH/sim-consumidor-objenious.env" ), + sshTransfer( + cleanRemote: false, + execCommand: "ln -sf $BASE_REMOTE_PATH/vault/savefamily/sf-sims/sim-consumidor-nos.env $APP_REMOTE_PATH/sim-consumidor-nos.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" diff --git a/deployment/local/docker/docker-compose.yaml b/deployment/local/docker/docker-compose.yaml index 8c75daf..cb8322d 100644 --- 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 diff --git a/docs/sim-api-documentation.html b/docs/sim-api-documentation.html index 630a58f..86b95b6 100644 --- a/docs/sim-api-documentation.html +++ b/docs/sim-api-documentation.html @@ -14,7 +14,7 @@