From 4b50541a604d27125257c303de844e7fe1a0d843 Mon Sep 17 00:00:00 2001
From: Evgeny Mukha <profunctorlense@gmail.com>
Date: Fri, 4 Aug 2023 14:52:57 +0200
Subject: [PATCH] aggregates, predicates, sortings

---
 src/zd/blocks/content.clj | 60 +++++++++++++++++++++++++++++++++++----
 test/zd/system_test.clj   |  4 ++-
 2 files changed, 57 insertions(+), 7 deletions(-)

diff --git a/src/zd/blocks/content.clj b/src/zd/blocks/content.clj
index 6a2394f..c04695e 100644
--- a/src/zd/blocks/content.clj
+++ b/src/zd/blocks/content.clj
@@ -61,7 +61,7 @@
                        (filterv #(not (str/blank? %)))
                        (mapv (fn [x]
                                (if (str/starts-with? x "(")
-                                 ['expr (edamame.core/parse-string x)]
+                                 ['expr (edamame.core/parse-string x {:regex true})]
                                  (let [[e k] (str/split x #":" 2)]
                                    [(symbol e) (cond
                                                  (= k "*") (symbol k)
@@ -84,17 +84,45 @@
                                           (conj acc (list 'pull k cs))
                                           (conj acc k))))))
                                 []))
-        where-items  (->> xs
-                          (filterv #(not (re-matches #"^\s?>.*" %)))
-                          (mapv (fn [x] (edamame.core/parse-string (str/replace (str "[" x "]") #"#"  ":symbol/")))))
+        where-items
+        (->> xs
+             (filterv (every-pred #(not (str/ends-with? % " :asc"))
+                                  #(not (str/ends-with? % " :desc"))
+                                  #(not (re-matches #"^\s?>.*" %))))
+             (mapv (fn [x] (let [res (edamame.core/parse-string (str/replace (str "[" x "]") #"#"  ":symbol/")
+                                                                {:regex true})]
+                             (cond
+                               (list? (get res 1))
+                               (vector res)
+
+                               :else
+                               res)
+                             ))))
         where (->> where-items
                    (mapv (fn [x]
                            (clojure.walk/postwalk
                             (fn [y]
                               (if (and (keyword? y) (= "symbol" (namespace y)))
                                 (str "'" (name y))
-                                y)) x))))]
+                                y)) x))))
+
+        order-items
+        (->> xs
+             (filterv (every-pred #(or (str/ends-with? % " :asc")
+                                       (str/ends-with? % " :desc"))
+                                  #(not (re-matches #"^\s?>.*" %))))
+             (mapv (fn [x] (edamame.core/parse-string (str/replace (str "[" x "]") #"#"  ":symbol/") {:regex true}))))
+
+        order
+        (->> order-items
+             (mapv (fn [x]
+                     (clojure.walk/postwalk
+                       (fn [y]
+                         (if (and (keyword? y) (= "symbol" (namespace y)))
+                           (str "'" (name y))
+                           y)) x))))]
     (into {:where where
+           :order order
            :find find-items
            :columns columns
            :index @index} )))
@@ -114,7 +142,27 @@ p :role #roles.cto
 > (mean e)
 ")
 
-;; (parse-query q)
+(def q2
+  "
+e :parent #customers
+e :category cat
+(clojure.string/starts-with? cat \"s\")
+e :customer-since since
+e :asc
+
+> e:name
+> (count e)
+"
+  )
+
+(def q3
+  "
+e :parent #customers
+e asc
+> e
+")
+
+(parse-query q3)
 
 (defn render-table-value [ztx v block]
   (cond
diff --git a/test/zd/system_test.clj b/test/zd/system_test.clj
index 42e643a..e60f2aa 100644
--- a/test/zd/system_test.clj
+++ b/test/zd/system_test.clj
@@ -46,4 +46,6 @@
   (zen/start-system ztx 'zd.test/system))
 
 (comment
-  (restart! ztx))
+  (restart! ztx)
+
+  )