Merge pull request #378 from TaloDev/develop

Release 0.54.0

.github/workflows/docker.yml

@@ -6,9 +6,6 @@ on:
 jobs:
   build:
     runs-on: ubuntu-latest
-    strategy:
-      matrix:
-        image: [backend, clickhouse]
     steps:
       - name: Set up QEMU
         uses: docker/setup-qemu-action@v3
@@ -23,19 +20,19 @@ jobs:
           username: ${{ github.actor }}
           password: ${{ secrets.GITHUB_TOKEN }}
 
-      - name: Build and push (${{ matrix.image }})
+      - name: Build and push
         id: build-image
         uses: docker/build-push-action@v5
         with:
           platforms: linux/amd64,linux/arm64
           push: true
           file: ${{ matrix.image == 'backend' && 'Dockerfile' || 'clickhouse/Dockerfile' }}
           tags: |
-            ghcr.io/talodev/${{ matrix.image }}:latest
-            ghcr.io/talodev/${{ matrix.image }}:${{ github.ref_name }}
-          target: ${{ matrix.image == 'backend' && 'prod' || '' }}
+            ghcr.io/talodev/backend:latest
+            ghcr.io/talodev/backend:${{ github.ref_name }}
+          target: prod
 
-      - name: Image digest (${{ matrix.image }})
+      - name: Image digest
         run: echo ${{ steps.build-image.outputs.digest }}
 
   deploy:

__mocks__/bullmq.ts

@@ -31,14 +31,9 @@ export class Worker<T> extends EventEmitter {
   async process(job: Job<T>): Promise<void> {
     try {
       await this.processor(job)
-
-      await Promise.all(this.listeners('completed').map(async (handler) => {
-        await handler(job)
-      }))
+      await Promise.all(this.listeners('completed').map((handler) => handler(job)))
     } catch (err) {
-      await Promise.all(this.listeners('failed').map(async (handler) => {
-        await handler(job, err)
-      }))
+      await Promise.all(this.listeners('failed').map((handler) => handler(job, err)))
     }
   }
 }
@@ -59,6 +54,6 @@ export class Queue<T> {
 
   async add(jobName: string, data: T) {
     const job = new Job<T>(this.name, jobName, data)
-    await Promise.all(this.workers.map(async (worker) => await worker.process(job)))
+    await Promise.all(this.workers.map((worker) => worker.process(job)))
   }
 }

docker-compose.test.yml

@@ -30,9 +30,7 @@ services:
       - test-network
 
   test-clickhouse:
-    build:
-      context: .
-      dockerfile: ./clickhouse/Dockerfile
+    image: clickhouse/clickhouse-server:24.12-alpine
     environment:
       CLICKHOUSE_USER: ${CLICKHOUSE_USER}
       CLICKHOUSE_PASSWORD: ${CLICKHOUSE_PASSWORD}

docker-compose.yml

@@ -34,10 +34,7 @@ services:
       - 6379:6379
 
   clickhouse:
-    build:
-      context: .
-      dockerfile: ./clickhouse/Dockerfile
-    image: clickhouse
+    image: clickhouse/clickhouse-server:24.12-alpine
     environment:
       CLICKHOUSE_USER: ${CLICKHOUSE_USER}
       CLICKHOUSE_PASSWORD: ${CLICKHOUSE_PASSWORD}