build exists => 201

console-api/src/app.service.ts

@@ -196,7 +196,7 @@ export class AppService extends ConsoleLogger {
     }
     const depot = await this.getOrCreateDepot(app, depotDto);
     if (await this.checkExistingBuild(depot, version)) {
-      throw new BlankReturnMessageDto(404, 'Build exists').toException();
+      throw new BlankReturnMessageDto(201, 'Build exists').toException();
     }
     let build = new Build();
     build.depot = depot;

console-api/src/lock/lock.service.ts

-import { InjectRedis, Redis } from '@nestjs-modules/ioredis';
 import { Injectable } from '@nestjs/common';
 import Redlock from '@nanahira/redlock';
+import { ConfigService } from '@nestjs/config';
+import Redis from 'ioredis';
 
 @Injectable()
-export class LockService extends Redlock {
-  constructor(@InjectRedis() private readonly redis: Redis) {
-    super([redis]);
+export class LockService {
+  constructor(private config: ConfigService) { }
+  
+  getLockInstance() {
+    const url = this.config.get<string>('REDIS_URL');
+    const redis = new Redis(url);
+    return new Redlock([redis]);
   }
 }

console-api/src/mirror/mirror.service.ts

@@ -185,7 +185,7 @@ export class MirrorService extends ConsoleLogger implements OnApplicationBootstr
     if (!middleware.singleton) {
       return this.uploadWithMiddlewareProcess(uploadInfo, middleware);
     }
-    return this.redlock.using([`mirror:${middleware.identifier}`], 5000, () => this.uploadWithMiddlewareProcess(uploadInfo, middleware));
+    return this.redlock.getLockInstance().using([`mirror:${middleware.identifier}`], 5000, () => this.uploadWithMiddlewareProcess(uploadInfo, middleware));
   }
 
   async uploadWithRandomMiddleware(uploadInfo: UploadInfo, middlewares = Array.from(this.middlewares.values())) {