feat: Add headers to published events

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

@@ -14,7 +14,7 @@ <h4>{{ operation.message.description }}</h4>
                     (keyup)="recalculateLineCount('example', exampleTextArea.value)"
           ></textarea>
           <div fxLayout fxLayoutGap="8px">
-            <button mat-raised-button color="primary" (click)="publish(exampleTextArea.value)">
+            <button mat-raised-button color="primary" (click)="publish(exampleTextArea.value, headersTextArea.value)">
               Publish
             </button>
             <button mat-raised-button color="primary"

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

@@ -66,11 +66,12 @@ export class ChannelMainComponent implements OnInit {
     }
   }
 
-  publish(example: string): void {
+  publish(example: string, headers: string): void {
     try {
-      const json = JSON.parse(example);
+      const payloadJson = JSON.parse(example);
+      const headersJson = JSON.parse(headers)
 
-      this.publisherService.publish(this.protocolName, this.channelName, json).subscribe(
+      this.publisherService.publish(this.protocolName, this.channelName, payloadJson, headersJson).subscribe(
         _ => this.handlePublishSuccess(),
         err => this.handlePublishError(err)
       );

src/app/shared/publisher.service.ts

@@ -8,11 +8,12 @@ export class PublisherService {
 
   constructor(private http: HttpClient) { }
 
-  publish(protocol: string, topic: string, payload: object): Observable<unknown> {
+  publish(protocol: string, topic: string, payload: object, headers: object): Observable<unknown> {
     const url = Endpoints.getPublishEndpoint(protocol);
     const params = new HttpParams().set('topic', topic);
+    const body = {"payload" : payload, "headers" : headers }
     console.log(`Publishing to ${url}`);
-    return this.http.post(url, payload, { params });
+    return this.http.post(url, body, { params });
   }
 
 }