feat: Dead letter queue implementation

.gitignore

@@ -6,6 +6,7 @@ packages/api-main/data
 .env
 dist
 dist/
+data
 data/*
 .vscode/
 .idea/

docker-compose.yml

@@ -79,6 +79,11 @@ services:
     environment:
       RABBITMQ_ENDPOINT: "amqp://guest:guest@rabbitmq:5672"
       RABBITMQ_EXCHANGE: "dither"
+      RABBITMQ_DLX_EXCHANGE: "dither-dlx"
+      RABBITMQ_DLX_QUEUE: "dlx-queue"
+      RABBITMQ_QUEUE: "dither.Post"
+      RABBITMQ_LOG_EXCHANGE: "dither-log"
+      RABBITMQ_LOG_QUEUE: "log-queue"
       API_ROOT: "http://api-main:3001/v1"
     restart: always
     command: ["pnpm", "start"]
@@ -94,6 +99,11 @@ services:
     environment:
       RABBITMQ_ENDPOINT: "amqp://guest:guest@rabbitmq:5672"
       RABBITMQ_EXCHANGE: "dither"
+      RABBITMQ_DLX_EXCHANGE: "dither-dlx"
+      RABBITMQ_DLX_QUEUE: "dlx-queue"
+      RABBITMQ_QUEUE: "dither.Reply"
+      RABBITMQ_LOG_EXCHANGE: "dither-log"
+      RABBITMQ_LOG_QUEUE: "log-queue"
       API_ROOT: "http://api-main:3001/v1"
     restart: always
     command: ["pnpm", "start"]
@@ -109,6 +119,11 @@ services:
     environment:
       RABBITMQ_ENDPOINT: "amqp://guest:guest@rabbitmq:5672"
       RABBITMQ_EXCHANGE: "dither"
+      RABBITMQ_DLX_EXCHANGE: "dither-dlx"
+      RABBITMQ_DLX_QUEUE: "dlx-queue"
+      RABBITMQ_QUEUE: "dither.Like"
+      RABBITMQ_LOG_EXCHANGE: "dither-log"
+      RABBITMQ_LOG_QUEUE: "log-queue"
       API_ROOT: "http://api-main:3001/v1"
     restart: always
     command: ["pnpm", "start"]
@@ -124,6 +139,11 @@ services:
     environment:
       RABBITMQ_ENDPOINT: "amqp://guest:guest@rabbitmq:5672"
       RABBITMQ_EXCHANGE: "dither"
+      RABBITMQ_DLX_EXCHANGE: "dither-dlx"
+      RABBITMQ_DLX_QUEUE: "dlx-queue"
+      RABBITMQ_QUEUE: "dither.Dislike"
+      RABBITMQ_LOG_EXCHANGE: "dither-log"
+      RABBITMQ_LOG_QUEUE: "log-queue"
       API_ROOT: "http://api-main:3001/v1"
     restart: always
     command: ["pnpm", "start"]
@@ -139,6 +159,11 @@ services:
     environment:
       RABBITMQ_ENDPOINT: "amqp://guest:guest@rabbitmq:5672"
       RABBITMQ_EXCHANGE: "dither"
+      RABBITMQ_DLX_EXCHANGE: "dither-dlx"
+      RABBITMQ_DLX_QUEUE: "dlx-queue"
+      RABBITMQ_QUEUE: "dither.Follow"
+      RABBITMQ_LOG_EXCHANGE: "dither-log"
+      RABBITMQ_LOG_QUEUE: "log-queue"
       API_ROOT: "http://api-main:3001/v1"
     restart: always
     command: ["pnpm", "start"]
@@ -153,6 +178,11 @@ services:
     environment:
       RABBITMQ_ENDPOINT: "amqp://guest:guest@rabbitmq:5672"
       RABBITMQ_EXCHANGE: "dither"
+      RABBITMQ_DLX_EXCHANGE: "dither-dlx"
+      RABBITMQ_DLX_QUEUE: "dlx-queue"
+      RABBITMQ_QUEUE: "dither.Unfollow"
+      RABBITMQ_LOG_EXCHANGE: "dither-log"
+      RABBITMQ_LOG_QUEUE: "log-queue"
       API_ROOT: "http://api-main:3001/v1"
     restart: always
     command: ["pnpm", "start"]
@@ -167,6 +197,11 @@ services:
     environment:
       RABBITMQ_ENDPOINT: "amqp://guest:guest@rabbitmq:5672"
       RABBITMQ_EXCHANGE: "dither"
+      RABBITMQ_DLX_EXCHANGE: "dither-dlx"
+      RABBITMQ_DLX_QUEUE: "dlx-queue"
+      RABBITMQ_QUEUE: "dither.Flag"
+      RABBITMQ_LOG_EXCHANGE: "dither-log"
+      RABBITMQ_LOG_QUEUE: "log-queue"
       API_ROOT: "http://api-main:3001/v1"
     restart: always
     command: ["pnpm", "start"]
@@ -181,6 +216,27 @@ services:
     environment:
       RABBITMQ_ENDPOINT: "amqp://guest:guest@rabbitmq:5672"
       RABBITMQ_EXCHANGE: "dither"
+      RABBITMQ_DLX_EXCHANGE: "dither-dlx"
+      RABBITMQ_DLX_QUEUE: "dlx-queue"
+      RABBITMQ_QUEUE: "dither.Remove"
+      RABBITMQ_LOG_EXCHANGE: "dither-log"
+      RABBITMQ_LOG_QUEUE: "log-queue"
+      API_ROOT: "http://api-main:3001/v1"
+    restart: always
+    command: ["pnpm", "start"]
+  dead-letter-service:
+    container_name: "dead-letter-service"
+    build: ./packages/dead-letter-service
+    depends_on:
+      rabbitmq:
+        condition: service_healthy
+    environment:
+      RABBITMQ_ENDPOINT: "amqp://guest:guest@rabbitmq:5672"
+      RABBITMQ_EXCHANGE: "dither-dlx"
+      RABBITMQ_DLX_EXCHANGE: "dither"
+      RABBITMQ_DLX_QUEUE: "dlx-queue"
+      RABBITMQ_LOG_EXCHANGE: "dither-log"
+      RABBITMQ_LOG_QUEUE: "log-queue"
       API_ROOT: "http://api-main:3001/v1"
     restart: always
     command: ["pnpm", "start"]
@@ -225,4 +281,4 @@ volumes:
   rabbitmq-lib:
     driver: local
   rabbitmq-log:
-    driver: local
+    driver: local

packages/dead-letter-service/Dockerfile

@@ -0,0 +1,14 @@
+FROM node:23-slim
+
+WORKDIR /app
+
+RUN apt-get update && rm -rf /var/lib/apt/lists/*
+RUN corepack enable
+
+COPY package.json pnpm-lock.yaml ./
+COPY src ./src
+COPY tsconfig.json ./tsconfig.json
+
+RUN pnpm install --no-cache
+
+CMD ["pnpm", "start"]

packages/dead-letter-service/package.json

@@ -0,0 +1,30 @@
+{
+    "name": "dead-letter-service",
+    "version": "1.0.0",
+    "description": "",
+    "main": "dist/index.js",
+    "types": "dist/index.d.ts",
+    "license": "GnoGPL",
+    "publishConfig": {
+        "access": "public"
+    },
+    "files": [
+        "dist"
+    ],
+    "scripts": {
+        "start": "tsx ./src/index.ts",
+        "build": "tsc"
+    },
+    "author": "Stuyk",
+    "devDependencies": {
+        "@atomone/event-consumer": "^1.0.12",
+        "@types/node": "^22.13.10",
+        "typescript": "^5.8.2",
+        "vitest": "^3.0.9"
+    },
+    "dependencies": {
+        "@types/amqplib": "^0.10.7",
+        "amqplib": "^0.10.7",
+        "dead-letter-service": "link:"
+    }
+}