tweak ux when config is new

Signed-off-by: Jason Sherman <[email protected]>

app/frontend/src/components/designer/settings/FormEventStreamSettings.vue

@@ -238,7 +238,7 @@ defineExpose({
     </v-expand-transition>
     <v-row class="pl-6 m-0">
       <v-col cols="12" class="pl-0 pr-0 pb-0">
-        <span>
+        <span v-if="form.eventStreamConfig.updatedBy">
           <span :lang="locale" class="font-weight-bold"
             >{{ $t('trans.formSettings.eventStreamUpdatedBy') }}:
           </span>

app/src/forms/form/encryptionKey/service.js

@@ -30,6 +30,7 @@ const service = {
     // special case for forms. they have only one event stream configuration
     // that requires an encryption key if it has private streams.
     // NOTE: event stream config will remove this key if it is unneeded!
+
     const externalTrx = transaction != undefined;
     let trx;
     let id;
@@ -51,6 +52,7 @@ const service = {
         }
       } else {
         // add a new configuration.
+        if (data && !data.algorithm && !data.key) return; // no encryption key to insert
         id = uuidv4();
         data.id = id;
         data.formId = formId;

app/src/forms/form/eventStreamConfig/service.js

@@ -24,6 +24,7 @@ const service = {
       // let's deal with encryption key
       const encKey = await encryptionKeyService.upsertForEventStreamConfig(formId, data.encryptionKey, currentUser, transaction);
       data.encryptionKeyId = encKey && data.enablePrivateStream ? encKey.id : null;
+      data.encryptionKey = null; // only want the id for config upsert
 
       if (existing) {
         // do we need to update?

event-stream-service/package.json

@@ -5,6 +5,7 @@
   "license": "Apache-2.0",
   "scripts": {},
   "dependencies": {
+    "cryptr": "^6.3.0",
     "nats": "^2.28.0"
   }
 }

event-stream-service/pullConsumer.js

@@ -1,4 +1,5 @@
 const { AckPolicy, connect } = require("nats");
+const Cryptr = require("cryptr");
 
 // connection info
 const servers = ["localhost:4222", "localhost:4223", "localhost:4224"];
@@ -13,6 +14,7 @@ const STREAM_NAME = "CHEFS";
 const FILTER_SUBJECTS = ["PUBLIC.forms.>", "PRIVATE.forms.>"];
 const MAX_MESSAGES = 2;
 const DURABLE_NAME = "pullConsumer";
+const ENCRYPTION_KEY = "";
 
 const printMsg = (m) => {
   // illustrate grabbing the sequence and timestamp from the nats message...
@@ -22,7 +24,17 @@ const printMsg = (m) => {
       `msg seq: ${m.seq}, subject: ${m.subject}, timestamp: ${ts}, streamSequence: ${m.info.streamSequence}, deliverySequence: ${m.info.deliverySequence}`
     );
     // illustrate (one way of) grabbing message content as json
-    console.log(JSON.stringify(m.json(), null, 2));
+    const data = m.json();
+    console.log(JSON.stringify(data, null, 2));
+    try {
+      if (data && data["payload"] && data["payload"]["data"]) {
+        const cryptr = new Cryptr(ENCRYPTION_KEY);
+        const d = cryptr.decrypt(data["payload"]["data"]);
+        console.log(JSON.stringify(d, null, 2));
+      }
+    } catch (err) {
+      console.error("Error decrypting payload.data");
+    }
   } catch (e) {
     console.error(`Error printing message: ${e.message}`);
   }