Add ACMS.API.REST.Collection

backend/lib/ACMS/API/REST/Collection.hs

@@ -0,0 +1,56 @@
+{-# LANGUAGE OverloadedStrings #-}
+module ACMS.API.REST.Collection where
+
+import Data.Aeson qualified as A
+import Data.Aeson.KeyMap qualified as AM
+import Data.ByteString.Lazy.UTF8 qualified as LB
+import Data.Function ((&))
+import Data.Text qualified as T
+import Network.HTTP.Simple
+import Text.Printf (printf)
+
+type CollectionName = T.Text
+
+list :: T.Text -> IO [A.Object]
+list c =
+  "http://localhost:8081"
+    & setRequestMethod "POST"
+    & setRequestBodyLBS (LB.fromString (printf "SELECT %s FROM %s" c c))
+    & httpLBS
+    >>= A.throwDecode . getResponseBody
+
+read :: T.Text -> T.Text -> IO [A.Object]
+read c i =
+  "http://localhost:8081"
+    & setRequestMethod "POST"
+    & setRequestBodyLBS
+      (LB.fromString (printf "SELECT %s FROM %s WHERE %s.$fileName == \"%s\"" c c c i))
+    & httpLBS
+    >>= A.throwDecode . getResponseBody
+
+update :: T.Text -> T.Text -> A.Object -> IO ()
+update c i o =
+  "http://localhost:8081"
+    & setRequestMethod "POST"
+    & setRequestBodyLBS
+      (LB.fromString (printf "UPDATE %s SET %s WHERE %s.$fileName == \"%s\"" c (LB.toString (A.encode o)) c i))
+    & httpLBS
+    >>= A.throwDecode . getResponseBody
+
+create :: T.Text -> T.Text -> A.Object -> IO ()
+create c i o =
+  "http://localhost:8081"
+    & setRequestMethod "POST"
+    & setRequestBodyLBS
+      (LB.fromString (printf "INSERT %s INTO %s" (LB.toString (A.encode (AM.insert "$fileName" (A.String i) o))) c))
+    & httpLBS
+    >>= A.throwDecode . getResponseBody
+
+delete :: T.Text -> T.Text -> IO [A.Object]
+delete c i =
+  "http://localhost:8081"
+    & setRequestMethod "POST"
+    & setRequestBodyLBS
+      (LB.fromString (printf "DELETE FROM %s WHERE %s.$fileName == \"%s\"" c c i))
+    & httpLBS
+    >>= A.throwDecode . getResponseBody