        (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)]

          entity-to-activity-mapping-fn
          (store-activity activity-storage))))
  ([entity]
   (store-activity! (DBActivityStorage.) entity)))

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

      (catch Exception e
        (log/error (format "Error posting activity %s to coracle" activity-json) e)))))

(defn new-coracle-activity-storage
  ([bearer-token url]
   (CoracleActivityStorage. bearer-token url))
  ([]
   (new-coracle-activity-storage (:coracle-bearer-token config/environment) (:coracle-post-uri config/environment))))

(defrecord DBActivityStorage []
  ActivityStorage
