refactor: Make outbox wait several for 5 seconds before retry

Author: omardoescode

backend/Dockerfile

@@ -41,6 +41,7 @@ COPY --from=prerelease /usr/src/pylon/.pylon .pylon
 COPY --from=prerelease /usr/src/pylon/package.json .
 COPY --from=prerelease /usr/src/pylon/src src  
 COPY --from=prerelease /usr/src/pylon/tsconfig.json tsconfig.json
+COPY --from=prerelease /usr/src/pylon/migrations migrations
 
 # run the app
 USER bun

backend/src/workers/OutboxProcessor.ts

@@ -21,7 +21,6 @@ export default class OutboxProcessor {
     await this.producer
       .connect()
       .then(() => console.log("Producer successfully connected"));
-
     const interval = this.intervalMs;
 
     const run = async () => {

backend/src/workers/run_outbox_processor.ts

@@ -15,4 +15,4 @@ const outbox_processor = new OutboxProcessor(
   1000
 );
 
-await outbox_processor.start();
+await outbox_processor.start(); // blocks until failure or completion

docker-compose.yml

@@ -25,12 +25,29 @@ services:
       - POSTGRES_PORT
       - JWT_SECRET
       - KAFKA_URL=kafka:9092
-    command: sh -c "sleep 5 && bun run outbox"
+    command: bun run outbox
+    restart: unless-stopped
     depends_on:
       - postgres
       - kafka
     networks:
       - mynet
+
+  init_db:
+    build: ./backend
+    environment:
+      - POSTGRES_USER
+      - POSTGRES_PASSWORD
+      - POSTGRES_NAME
+      - POSTGRES_HOST
+      - POSTGRES_PORT
+      - JWT_SECRET
+      - KAFKA_URL=kafka:9092
+    command: bun run init_db
+    depends_on:
+      - postgres
+    networks:
+      - mynet
   postgres:
     image: postgres:16
     container_name: postgres_db
@@ -137,21 +154,21 @@ services:
     networks:
       - mynet
 
-  analytics_job:
-    build: ./analytics/
-    depends_on:
-      - jobmanager
-      - kafka
-    command: >
-      bash -c "
-        echo 'Waiting for JobManager...';
-        sleep 5;
-        /opt/flink/bin/flink run \
-          -m jobmanager:8081 \
-          /opt/flink/usrlib/*.jar
-      "
-    networks:
-      - mynet
+  # analytics_job:
+  #   build: ./analytics/
+  #   depends_on:
+  #     - jobmanager
+  #     - kafka
+  #   command: >
+  #     bash -c "
+  #       echo 'Waiting for JobManager...';
+  #       sleep 5;
+  #       /opt/flink/bin/flink run \
+  #         -m jobmanager:8081 \
+  #         /opt/flink/usrlib/*.jar
+  #     "
+  #   networks:
+  #     - mynet
 
 volumes:
   postgres_data: