Support codec endpoint templating and more flexible codecs (#444)

* Support namespace templating and header.

* Don't assume payload counts match before/after decoding.

This allows for use cases like compression where the codec may compress multiple payloads into one.

client/features/data-conversion.js

@@ -1,8 +1,9 @@
 import WebSocketAsPromised from 'websocket-as-promised';
 
-export const convertEventPayloadsWithRemoteEncoder = async (events, endpoint) => {
-  const headers = { 'Content-Type': 'application/json' };
+export const convertEventPayloadsWithRemoteEncoder = async (namespace, events, endpointTemplate) => {
+  const headers = { 'Content-Type': 'application/json', 'X-Namespace': namespace };
   const requests = [];
+  const endpoint = endpointTemplate.replaceAll('{namespace}', namespace);
 
   events.forEach(event => {
     let payloadsWrapper;
@@ -25,11 +26,13 @@ export const convertEventPayloadsWithRemoteEncoder = async (events, endpoint) =>
           decodedPayloads.forEach((payload, i) => {
             let data = window.atob(payload.data);
             try {
-              payloadsWrapper.payloads[i] = JSON.parse(data);
+              decodedPayloads[i] = JSON.parse(data);
             } catch {
-              payloadsWrapper.payloads[i] = data;
+              decodedPayloads[i] = data;
             }  
           });
+
+          payloadsWrapper.payloads = decodedPayloads
         })
         .catch(() => {
           payloadsWrapper.payloads.forEach((payload) => {

client/routes/workflow/index.vue

@@ -221,7 +221,7 @@ export default {
           }
 
           if (endpoint !== undefined) {
-            return convertEventPayloadsWithRemoteEncoder(events, endpoint).catch(error => {
+            return convertEventPayloadsWithRemoteEncoder(this.namespace, events, endpoint).catch(error => {
               console.error(error);
 
               this.$emit('onNotification', {