From 4442240e689de91e2e0966fe09727895b5e2935b Mon Sep 17 00:00:00 2001
From: Martin McKeaveney <martin@shogunsystems.co.uk>
Date: Fri, 15 Jan 2021 13:24:36 +0000
Subject: [PATCH] dynamo integration

---
 .../EventsEditor/actions/ExecuteQuery.svelte  |  2 +-
 packages/server/src/integrations/dynamodb.js  | 71 ++++++++++++++++---
 2 files changed, 64 insertions(+), 9 deletions(-)

diff --git a/packages/builder/src/components/userInterface/EventsEditor/actions/ExecuteQuery.svelte b/packages/builder/src/components/userInterface/EventsEditor/actions/ExecuteQuery.svelte
index 8ffdc4ef14..175eff823b 100644
--- a/packages/builder/src/components/userInterface/EventsEditor/actions/ExecuteQuery.svelte
+++ b/packages/builder/src/components/userInterface/EventsEditor/actions/ExecuteQuery.svelte
@@ -50,7 +50,7 @@
 
   <Spacer medium />
 
-  {#if query}
+  {#if query?.parameters.length > 0}
     <ParameterBuilder
       bind:customParams={parameters.queryParams}
       parameters={query.parameters}
diff --git a/packages/server/src/integrations/dynamodb.js b/packages/server/src/integrations/dynamodb.js
index 196f7fd97f..b1c406fdf4 100644
--- a/packages/server/src/integrations/dynamodb.js
+++ b/packages/server/src/integrations/dynamodb.js
@@ -18,25 +18,56 @@ const SCHEMA = {
     },
   },
   query: {
+    create: {
+      DynamoConfig: {
+        type: QUERY_TYPES.FIELDS,
+        fields: {
+          table: {
+            type: FIELD_TYPES.STRING,
+            required: true,
+          },
+          customisable: true,
+        },
+      },
+    },
     read: {
       DynamoConfig: {
         type: QUERY_TYPES.FIELDS,
         fields: {
-          Table: {
+          table: {
             type: FIELD_TYPES.STRING,
             required: true,
           },
-          Index: {
+          index: {
             type: FIELD_TYPES.STRING,
           },
-          KeyConditionExpression: {
+          customisable: true,
+        },
+      },
+    },
+    update: {
+      DynamoConfig: {
+        type: QUERY_TYPES.FIELDS,
+        fields: {
+          table: {
             type: FIELD_TYPES.STRING,
+            required: true,
           },
-          ExpressionAttributeNames: {
+          customisable: true,
+        },
+      },
+    },
+    delete: {
+      "Dynamo Partition Key": {
+        type: QUERY_TYPES.FIELDS,
+        fields: {
+          table: {
             type: FIELD_TYPES.STRING,
+            required: true,
           },
-          ExpressionAttributeValues: {
+          key: {
             type: FIELD_TYPES.STRING,
+            required: true,
           },
         },
       },
@@ -55,12 +86,36 @@ class DynamoDBIntegration {
     AWS.config.update(this.config)
   }
 
+  async create(query) {
+    const response = await this.client.query({
+      TableName: query.table,
+      Item: query.json,
+    })
+    return response
+  }
+
   async read(query) {
     const response = await this.client.query({
       TableName: query.Table,
-      KeyConditionExpression: query.KeyConditionExpression,
-      ExpressionAttributeNames: query.ExpressionAttributeNames,
-      ExpressionAttributeValues: query.ExpressionAttributeValues,
+      ...query.json,
+    })
+    return response
+  }
+
+  async update(query) {
+    const response = await this.client.query({
+      TableName: query.Table,
+      ...query.json,
+    })
+    return response
+  }
+
+  async delete(query) {
+    const response = await this.client.query({
+      TableName: query.Table,
+      Key: {
+        id: query.key,
+      },
     })
     return response
   }