Whitelist keys for api-gateway

pom.xml

@@ -11,7 +11,7 @@
 
   <groupId>dehli</groupId>
   <artifactId>serverless</artifactId>
-  <version>0.1.17</version>
+  <version>0.1.18</version>
   <name>serverless</name>
 
   <dependencies>

src/serverless/aws/api_gateway.cljs

@@ -11,13 +11,18 @@
   (new ApiGatewayManagementApi
        (clj->js {:apiVersion "2018-11-29" :endpoint endpoint})))
 
+;; Method helpers
+(def- base-xform #(select-keys % [:connection-id]))
+(defn- post-xform [p]
+  (-> p (update :data clj->json) (select-keys [:connection-id :data])))
+
 ;; Public methods
-(defn delete-connection [api params]
-  (js-call-v2 api "deleteConnection" params))
-(defn get-connection [api params]
-  (js-call-v2 api "getConnection" params))
-(defn post-to-connection [api params]
-  (js-call-v2 api "postToConnection" (update params :data clj->json)))
+(def delete-connection
+  (partial js-call-v2 "deleteConnection" base-xform))
+(def get-connection
+  (partial js-call-v2 "getConnection" base-xform))
+(def post-to-connection
+  (partial js-call-v2 "postToConnection" post-xform))
 
 ;; Accessors
 (def request-context :requestContext)

src/serverless/aws/sdk.cljs

@@ -16,7 +16,9 @@
     (js-invoke client method (clj->js args) (callback c))
     c))
 
-(defn js-call-v2 [client method args]
+(defn js-call-v2 [method xform client args]
   (let [c (promise-chan)]
-    (js-invoke client method (clj->js (kebab->pascal args)) (callback c))
+    (js-invoke client method
+               (clj->js (kebab->pascal (xform args)))
+               (callback c))
     c))