From 87690a534cf7e19da7b9abdb0b950291cd56e59d Mon Sep 17 00:00:00 2001
From: Andrey Antukh <niwi@niwi.nz>
Date: Thu, 30 Dec 2021 11:45:44 +0100
Subject: [PATCH] :tada: Add missing files.

---
 backend/src/app/http/debug.clj | 87 ++++++++++++++++++++++++++++++++++
 1 file changed, 87 insertions(+)
 create mode 100644 backend/src/app/http/debug.clj

diff --git a/backend/src/app/http/debug.clj b/backend/src/app/http/debug.clj
new file mode 100644
index 000000000..a7415b0b5
--- /dev/null
+++ b/backend/src/app/http/debug.clj
@@ -0,0 +1,87 @@
+;; This Source Code Form is subject to the terms of the Mozilla Public
+;; License, v. 2.0. If a copy of the MPL was not distributed with this
+;; file, You can obtain one at http://mozilla.org/MPL/2.0/.
+;;
+;; Copyright (c) UXBOX Labs SL
+
+(ns app.http.debug
+  (:require
+   [app.common.transit :as t]
+   [app.common.data :as d]
+   [app.common.uuid :as uuid]
+   [app.db :as db]
+   [app.util.blob :as blob]
+   [app.util.json :as json]
+   [cuerdas.core :as str]
+   [integrant.core :as ig]))
+
+(defn retrieve-file-data
+  [{:keys [pool]} {:keys [params path-params] :as request}]
+  (let [id    (uuid/uuid (get path-params :id))
+        file  (db/get-by-id pool :file id)
+        wrap? (contains? params :wrap)]
+    {:status 200
+     :headers {"content-type" "application/transit+json"}
+     :body (-> (:data file)
+               (blob/decode)
+               (t/encode-str {:type :json-verbose})
+               (cond-> wrap? (json/write)))}))
+
+(def sql:retrieve-range-of-changes
+  "select revn, changes from file_change where file_id=? and revn >= ? and revn < ? order by revn")
+
+(def sql:retrieve-single-change
+  "select revn, changes from file_change where file_id=? and revn = ?")
+
+(defn retrieve-file-changes
+  [{:keys [pool]} {:keys [params path-params] :as request}]
+  (let [id    (uuid/uuid (get path-params :id))
+        revn  (:rev params "latest")
+        file  (db/get-by-id pool :file id)
+        wrap? (contains? params :wrap)]
+
+    (cond
+      (or (not file)
+          (not revn))
+      {:status 404 :body "not found"}
+
+      (str/includes? revn ":")
+      (let [[start end] (->> (str/split revn #":")
+                             (map d/read-string))
+            _ (prn "fofof" start end)
+            items (db/exec! pool [sql:retrieve-range-of-changes
+                                    id start end])
+            items (->> items
+                       (map :changes)
+                       (map blob/decode)
+                       (mapcat identity))]
+        {:status 200
+         :headers {"content-type" "application/transit+json"}
+         :body (-> items
+                   (t/encode-str {:type :json-verbose})
+                   (cond-> wrap? (json/write)))})
+
+      (d/num-string? revn)
+      (let [item (db/exec-one! pool [sql:retrieve-single-change id (d/read-string revn)])
+            _     (prn "KAKAKAKA")
+            _    (clojure.pprint/pprint item)
+
+            item (-> item
+                     :changes
+                     blob/decode)]
+        {:status 200
+         :headers {"content-type" "application/transit+json"}
+         :body (-> item
+                   (t/encode-str {:type :json-verbose})
+                   (cond-> wrap? (json/write)))})
+
+      :else
+      {:status 400
+       :body "bad arguments"})))
+
+
+
+(defmethod ig/init-key ::handlers
+  [_ {:keys [pool] :as cfg}]
+  {:retrieve-file-data (partial retrieve-file-data cfg)
+   :retrieve-file-changes (partial retrieve-file-changes cfg)})