Handle publisher errors

Author: stavshamir

build.gradle

@@ -6,7 +6,7 @@ plugins {
 }
 
 group = 'io.github.springwolf'
-version = '0.3.0' + (Boolean.valueOf(System.getProperty('snapshot')) ? '-SNAPSHOT' : '')
+version = '0.3.1' + (Boolean.valueOf(System.getProperty('snapshot')) ? '-SNAPSHOT' : '')
 sourceCompatibility = '1.8'
 
 node {

src/app/channels/channel-main/channel-main.component.ts

@@ -6,6 +6,7 @@ import { PublisherService } from 'src/app/shared/publisher.service';
 import { MatSnackBar } from '@angular/material/snack-bar';
 import { Operation } from 'src/app/shared/models/channel.model';
 import { Subscription } from 'rxjs';
+import { STATUS } from 'angular-in-memory-web-api';
 
 @Component({
   selector: 'app-channel-main',
@@ -53,9 +54,8 @@ export class ChannelMainComponent implements OnInit {
       const json = JSON.parse(example);
 
       this.publisherService.publish(this.protocolName, this.channelName, json).subscribe(
-        _ => this.snackBar.open('Example payload sent to: ' + this.channelName, 'PUBLISHED', {
-          duration: 3000
-        })
+        _ => this.handlePublishSuccess(),
+        err => this.handlePublishError(err)
       );
     } catch(error) {
       this.snackBar.open('Example payload is not valid', 'ERROR', {
@@ -64,4 +64,21 @@ export class ChannelMainComponent implements OnInit {
     }
   }
 
+  private handlePublishSuccess() {
+    return this.snackBar.open('Example payload sent to: ' + this.channelName, 'PUBLISHED', {
+      duration: 3000
+    });
+  }
+
+  private handlePublishError(err: {status?: number}) {
+    let msg = 'Publish failed';
+    if (err?.status === STATUS.NOT_FOUND) {
+      msg += ': no publisher was provided for ' + this.protocolName;
+    }
+
+    return this.snackBar.open(msg, 'ERROR', {
+      duration: 4000
+    });
+  }
+
 }

src/app/shared/mock-server.ts

@@ -19,4 +19,17 @@ export class MockServer implements InMemoryDbService {
 
     return undefined;
   }
+
+  post(reqInfo: RequestInfo) {
+    if (reqInfo.req.url.endsWith('/publish')) {
+      return reqInfo.utils.createResponse$(() => {
+        return {
+          status: STATUS.OK
+        }
+      })
+    }
+
+    return undefined;
+  }
+
 }