        (assoc :entity :activity)
         storage/pg-store!)))
 
+(defn new-db-activity-storage []
+  (DBActivityStorage. ))
+
+(def coracle-activity-storage (new-coracle-activity-storage))
+(def db-activity-storage (new-db-activity-storage))
+
 (defn store-activity!
   ([activity-storage entity]
    (let [entity-to-activity-mapping-fn (get-mapping entity)]

            [objective8.back-end.storage.storage :as storage]
            [objective8.utils :as utils]
            [objective8.back-end.domain.objectives :as objectives]
            [clojure.tools.logging :as log]))

(defn objective->activity [objective]
  {"@context"  "http://www.w3.org/ns/activitystreams"

          entity-to-activity-mapping-fn
          (store-activity activity-storage))))
  ([entity]
   (store-activity! coracle-activity-storage entity)
   (store-activity! db-activity-storage entity)))      ;; TODO remove db storage when mooncake has been repointed

(defn retrieve-activities [query]
  (storage/pg-retrieve-activities (assoc query :entity :activity)))
