{-# LANGUAGE OverloadedStrings #-}

module ACMS.API.REST.Collection where

#ifndef ghcjs_HOST_OS
import Network.HTTP.Simple
#else
import ACMS.API.REST (setRequestMethod, setRequestBodyLBS)
#endif
import ACMS.API.REST (APIMonad, fetch, restRequest)
import Collection
import Data.Aeson qualified as A
import Data.Function ((&))
import Text.Printf (printf)

list :: (APIMonad m) => Collection -> m [A.Object]
list c =
  restRequest (printf "/collection/%s" c.name)
    & fetch
    >>= A.throwDecode

read :: (APIMonad m) => CollectionItem -> m (Maybe A.Object)
read ci =
  restRequest (printf "/collection/%s/%s" ci.collection.name ci.itemFileName)
    & fetch
    >>= A.throwDecode

update :: (APIMonad m) => CollectionItem -> A.Object -> m A.Object
update ci o =
  restRequest (printf "/collection/%s/%s" ci.collection.name ci.itemFileName)
    & setRequestMethod "PUT"
    & setRequestBodyLBS (A.encode o)
    & fetch
    >>= A.throwDecode

create :: (APIMonad m) => Collection -> A.Object -> m A.Object
create c o = do
  restRequest (printf "/collection/%s" c.name)
    & setRequestMethod "POST"
    & setRequestBodyLBS (A.encode o)
    & fetch
    >>= A.throwDecode

delete :: (APIMonad m) => CollectionItem -> m A.Object
delete ci =
  restRequest (printf "/collection/%s/%s" ci.collection.name ci.itemFileName)
    & setRequestMethod "DELETE"
    & fetch
    >>= A.throwDecode

schema :: (APIMonad m) => (A.FromJSON a) => Collection -> m a
schema c =
  restRequest (printf "/collection/%s/schema" c.name)
    & fetch
    >>= A.throwDecode