augment course with tags from resources

Author: yeehaa123

functions/src/app/augment/implementation.cljs

@@ -0,0 +1,16 @@
+(ns app.augment.implementation
+  (:require [shared.protocols.loggable :as log]))
+
+;; move this logic to course model
+
+(defn augment-checkpoint [{:keys [resource-url] :as checkpoint} tags url]
+  (if (= resource-url url)
+    (assoc checkpoint :tags tags)
+    checkpoint))
+
+(defn augment-checkpoints [course tags-data]
+  (update-in course [:checkpoints]
+             #(map (fn [checkpoint] (apply augment-checkpoint checkpoint tags-data)) %1)))
+
+(defn augment-course [course tags-data]
+  (reduce augment-checkpoints course tags-data))

functions/src/app/augment/index.cljs

@@ -4,7 +4,8 @@
             [backend-shared.service.index :as service]
             [shared.protocols.convertible :as cv]
             [shared.protocols.queryable :as qa]
-            [cljs.core.async :as async])
+            [cljs.core.async :as async]
+            [shared.protocols.actionable :as ac])
   (:require-macros [cljs.core.async.macros :refer [go]]))
 
 (def adapters {:db {:table-names {:bookmarks (.. js/process -env -bookmarksTable)
@@ -14,5 +15,6 @@
   (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))]
+          {:keys [found errors]}      (async/<! (qa/fetch service added))
+          res                         (async/<! (ac/perform service [:transform found]))]
       (service/done service res))))

functions/src/app/augment/mappings.cljs

@@ -1,5 +1,6 @@
 (ns app.augment.mappings
   (:require [backend-shared.service.index :refer [perform fetch]]
+            [app.augment.implementation :as impl]
             [shared.protocols.actionable :as ac]
             [shared.protocols.queryable :as qa]
             [shared.protocols.loggable :as log]
@@ -22,11 +23,16 @@
             courses-res     (async/<! (qa/fetch db courses-query))
             courses         (:found courses-res)
             errors          (mapcat :errors [courses-res bookmarks-res])]
-        {:resources resources
-         :courses   courses
-         :bookmarks bookmarks
+        {:found {:resources resources
+                 :courses   courses}
          :errors    (when-not (empty? errors) errors)})))
 
+  (defmethod perform [:transform :motherload] [_ [_ payload]]
+    (let [{:keys [resources courses]} payload
+          tags-data   (map #(identity [(:tags %1) (:resource-url %1)]) resources)
+          ;; move impl logic to course model
+          courses     (map #(impl/augment-course %1 tags-data) courses)]
+      (go courses)))
 
   (defmethod perform [:put :nothing] [_ _]
     (go {:error :no-payload}))

functions/src/app/augment/specs.cljs

@@ -4,7 +4,15 @@
 
 (spec/def :query/course-by-id (spec/keys :req-un [:course/course-id :course/revision]))
 
+(spec/def ::courses (spec/coll-of :offcourse/course))
+(spec/def ::resources (spec/coll-of :offcourse/resource))
+(spec/def ::motherload (spec/keys :req-un [::courses ::resources]))
+
 (defn specs []
+
+  (defmethod action-spec :transform [_]
+    (spec/tuple :offcourse/actions (spec/or :motherload ::motherload)))
+
   (spec/def :offcourse/query (spec/or :bookmarks (spec/coll-of :query/resource)
                                       :courses (spec/coll-of :query/course-by-id)
                                       :errors (spec/coll-of :offcourse/error))))