feat: error handling (#3)

.github/workflows/main-push.yml

@@ -26,5 +26,3 @@ jobs:
           tags: aamdigital/deployer-ms:latest
           cache-from: type=gha
           cache-to: type=gha,mode=max
-          build-args: |
-            RUN_TESTS=${{ true }}

package.json

@@ -31,7 +31,8 @@
     "@sentry/node": "^7.38.0",
     "reflect-metadata": "^0.1.13",
     "rimraf": "^3.0.2",
-    "rxjs": "^7.8.0"
+    "rxjs": "^7.8.0",
+    "tail": "^2.2.6"
   },
   "devDependencies": {
     "@nestjs/cli": "^9.2.0",
@@ -41,6 +42,7 @@
     "@types/jest": "^29.4.0",
     "@types/node": "^18.13.0",
     "@types/supertest": "^2.0.12",
+    "@types/tail": "^2.2.3",
     "@typescript-eslint/eslint-plugin": "^5.52.0",
     "@typescript-eslint/parser": "^5.52.0",
     "eslint": "^8.34.0",

src/app.controller.ts

@@ -10,7 +10,8 @@ import { DeploymentInfo } from './deployment-info.dto';
 import * as fs from 'fs';
 import { HttpService } from '@nestjs/axios';
 import { ConfigService } from '@nestjs/config';
-import { catchError, map } from 'rxjs';
+import { catchError, mergeMap, Observable, Subject } from 'rxjs';
+import { Tail } from 'tail';
 
 @Controller()
 export class AppController {
@@ -37,11 +38,11 @@ export class AppController {
           }
           throw err;
         }),
-        map(() => this.writeCommandsToPipe(deploymentInfo)),
+        mergeMap(() => this.writeCommandsToPipe(deploymentInfo)),
       );
   }
 
-  private writeCommandsToPipe(deploymentInfo: DeploymentInfo) {
+  private writeCommandsToPipe(deploymentInfo: DeploymentInfo): Observable<any> {
     console.log('info', deploymentInfo);
 
     if (
@@ -59,6 +60,26 @@ export class AppController {
     const ws = fs.createWriteStream('dist/assets/arg-pipe');
     ws.write(args);
     ws.close();
-    return { ok: true };
+    return this.getResult();
+  }
+
+  private getResult() {
+    const result = new Subject();
+    const tail = new Tail('dist/assets/log.txt');
+    tail.on('line', (line: string) => {
+      console.log('processing line', line);
+      if (line.startsWith('ERROR')) {
+        const message = line.replace('ERROR ', '');
+        result.error(new BadRequestException(message));
+        result.complete();
+        tail.unwatch();
+      } else if (line.startsWith('DONE')) {
+        result.next({ ok: true });
+        result.complete();
+        tail.unwatch();
+      }
+    });
+
+    return result.asObservable();
   }
 }