wip: change dynamodb from getItem to query api

Author: yeehaa123

functions/index.js

@@ -9,6 +9,7 @@ exports.split = db_out.app.core.split;
 exports.retrieve = db_out.app.core.retrieve;
 exports.save = db_out.app.core.save;
 exports.index = db_out.app.core.index;
+exports.augment = db_out.app.core.augment;
 exports.debug = db_out.app.core.debug;
 exports.dump = db_out.app.core.dump;
 exports.combine = db_out.app.core.combine;

functions/src/app/augment/index.cljs

@@ -0,0 +1,17 @@
+(ns app.augment.index
+  (:require [app.augment.mappings :refer [mappings]]
+            [app.augment.specs :refer [specs]]
+            [backend-shared.service.index :as service]
+            [shared.protocols.convertible :as cv]
+            [shared.protocols.queryable :as qa]
+            [cljs.core.async :as async])
+  (:require-macros [cljs.core.async.macros :refer [go]]))
+
+(def adapters {:db {:table-names {:bookmarks (.. js/process -env -bookmarksTable)}}})
+
+(defn augment [& args]
+  (go
+    (let [{:keys [event] :as service} (apply service/create specs mappings adapters args)
+          {:keys [added] :as payload} (cv/to-db-events event)
+          res                         (async/<! (qa/fetch service added))]
+      (service/done service res))))

functions/src/app/augment/mappings.cljs

@@ -0,0 +1,21 @@
+(ns app.augment.mappings
+  (:require [backend-shared.service.index :refer [perform fetch]]
+            [shared.protocols.actionable :as ac]
+            [shared.protocols.queryable :as qa]
+            [shared.protocols.loggable :as log])
+  (:require-macros [cljs.core.async.macros :refer [go]]))
+
+(defn mappings []
+
+  (defmethod fetch :bookmarks [{:keys [db]} payload]
+    (let [query (map (fn [{:keys [bookmark-url]}] {:resource-url bookmark-url}) payload)]
+      (qa/fetch db query)))
+
+  (defmethod perform [:put :nothing] [_ _]
+    (go {:error :no-payload}))
+
+  (defmethod perform [:put :errors] [_ [_ errors]]
+    (go errors))
+
+  (defmethod perform :default [{:keys [bucket]} action]
+    (ac/perform bucket action)))

functions/src/app/augment/specs.cljs

@@ -0,0 +1,10 @@
+(ns app.augment.specs
+  (:require [cljs.spec :as spec]
+            [shared.specs.action :as action :refer [action-spec]]))
+
+(spec/def ::resource-url :base/url)
+(spec/def :query/bookmark (spec/keys :req-un [::resource-url]))
+
+(defn specs []
+  (spec/def :offcourse/query (spec/or :bookmarks (spec/coll-of :query/resource)
+                                      :errors (spec/coll-of :offcourse/error))))

functions/src/app/authorize/mappings.cljs

@@ -3,12 +3,13 @@
             [shared.protocols.actionable :as ac]
             [shared.protocols.convertible :as cv]
             [shared.protocols.queryable :as qa]
-            [shared.protocols.loggable :as log])
+            [shared.protocols.loggable :as log]
+            [cljs.core.async :as async])
   (:require-macros [cljs.core.async.macros :refer [go]]))
 
 (defn mappings []
 
-  (defmethod fetch :identity [{:keys [db]} query]
+  (defmethod fetch :identity [{:keys [db table-names]} query]
     (qa/fetch db query))
 
   (defmethod fetch :error [{:keys [db]} error]

functions/src/app/core.cljs

@@ -4,6 +4,7 @@
             [backend-shared.index]
             [app.query.index :as query]
             [app.transform.index :as transform]
+            [app.augment.index :as augment]
             [app.command.index :as command]
             [app.retrieve.index :as retrieve]
             [app.index.index :as index]
@@ -21,6 +22,7 @@
 (def ^:export download download/download)
 (def ^:export save save/save)
 (def ^:export index index/index)
+(def ^:export augment augment/augment)
 (def ^:export debug debug/debug)
 (def ^:export retrieve retrieve/retrieve)
 

functions/src/app/query/mappings.cljs

@@ -23,4 +23,4 @@
     (handle-request index query true))
 
   (defmethod fetch :resource [{:keys [db stage]} query]
-    (go (async/<! (qa/fetch db query)))))
+    (qa/fetch db query)))

serverless.yml

@@ -11,6 +11,7 @@ provider:
         -  dynamodb:GetItem
         -  dynamodb:BatchGetItem
         -  dynamodb:PutItem
+        -  dynamodb:query
         -  dynamodb:Scan
         -  s3:PutObject
         -  s3:GetObject
@@ -43,6 +44,11 @@ functions:
           integration: lambda
           authorizer: authorize
 
+  augment:
+    handler: functions/index.augment
+    environment:
+      bookmarksTable: "bookmarks-${opt:stage}"
+
   query:
     handler: functions/index.query
     environment: