diff --git a/src/app/services/processcommand.ts b/src/app/services/processcommand.ts index f275533..6a8d725 100644 --- a/src/app/services/processcommand.ts +++ b/src/app/services/processcommand.ts @@ -1,4 +1,5 @@ export class ProcessCommand { command: string; process_name: string; + error?: string; } diff --git a/src/app/services/processmanager.service.ts b/src/app/services/processmanager.service.ts index 3e948a6..f8d289c 100644 --- a/src/app/services/processmanager.service.ts +++ b/src/app/services/processmanager.service.ts @@ -3,6 +3,7 @@ import { Injectable } from '@angular/core'; import { WebSocketService } from './websocket.service'; import { ProcessCommand } from './processcommand'; import { filter } from 'rxjs/operators'; +import { WSMessage } from './wsmessage'; @Injectable() @@ -16,9 +17,17 @@ export class ProcessManagerService { this.webSocketService.connect(); } - subscribeCallback(process_name: string, callback: (event: any) => void) { - this.webSocketService.observeKey(this.key) - .pipe(filter(message => message.data.process_name === process_name)).subscribe(callback); + subscribeCallback(process_name: string, callback: (event: WSMessage) => void) { + this.observeProcessMessage(process_name).subscribe(callback); + } + + subscribeErrorCallback(process_name: string, callback: (event: WSMessage) => void) { + this.observeProcessMessage(process_name).pipe(filter(message => 'error' in message.data)).subscribe(callback); + } + + observeProcessMessage(process_name: string) { + return this.webSocketService.observeKey(this.key) + .pipe(filter(message => message.data.process_name === process_name)); } sendCommand(command: string, process_name: string) { diff --git a/src/app/webide/webide.component.html b/src/app/webide/webide.component.html index f2c6bfd..96bcb4c 100644 --- a/src/app/webide/webide.component.html +++ b/src/app/webide/webide.component.html @@ -27,7 +27,9 @@ [class.btn-success]="deployButtonState === 'DEPLOYED'" [class.btn-info]="deployButtonState === 'DEPLOYING'" [class.disabled]="deployButtonState === 'DEPLOYING' || deployButtonState === 'DEPLOYED'" + [class.btn-danger]="deployButtonState === 'FAILED'" >Deploy Deploy -
Reloading app...
+
Reloading app...
+ Deployment failed diff --git a/src/app/webide/webide.component.ts b/src/app/webide/webide.component.ts index e221950..0c41590 100644 --- a/src/app/webide/webide.component.ts +++ b/src/app/webide/webide.component.ts @@ -51,6 +51,7 @@ export class WebideComponent implements OnInit { this.requestCode(); this.processManagerService.init(); this.processManagerService.subscribeCallback('login', (event) => { this.setDeployButtonState('DEPLOYED'); }); + this.processManagerService.subscribeErrorCallback('login', (event) => { this.setDeployButtonState('FAILED'); }); this.resetAutoSaveCountdown(); }