module Hydra.Dsl.Lib.Flows where

import Hydra.Dsl.Base
import Hydra.Core
import Hydra.Compute
import Hydra.Phantoms
import Hydra.Sources.Libraries
import qualified Hydra.Dsl.Terms as Terms
import qualified Hydra.Dsl.Types as Types

import qualified Data.Map as M


-- Primitives

apply :: Datum (Flow s (x -> y) -> Flow s x -> Flow s y)
apply :: forall s x y. Datum (Flow s (x -> y) -> Flow s x -> Flow s y)
apply = Term -> Datum (Flow s (x -> y) -> Flow s x -> Flow s y)
forall a. Term -> Datum a
Datum (Term -> Datum (Flow s (x -> y) -> Flow s x -> Flow s y))
-> Term -> Datum (Flow s (x -> y) -> Flow s x -> Flow s y)
forall a b. (a -> b) -> a -> b
$ Name -> Term
Terms.primitive Name
_flows_apply

bind :: Datum (Flow s x -> (x -> Flow s y) -> Flow s y)
bind :: forall s x y. Datum (Flow s x -> (x -> Flow s y) -> Flow s y)
bind = Term -> Datum (Flow s x -> (x -> Flow s y) -> Flow s y)
forall a. Term -> Datum a
Datum (Term -> Datum (Flow s x -> (x -> Flow s y) -> Flow s y))
-> Term -> Datum (Flow s x -> (x -> Flow s y) -> Flow s y)
forall a b. (a -> b) -> a -> b
$ Name -> Term
Terms.primitive Name
_flows_bind

fail :: Datum (String -> Flow s x)
fail :: forall s x. Datum (String -> Flow s x)
fail = Term -> Datum (String -> Flow s x)
forall a. Term -> Datum a
Datum (Term -> Datum (String -> Flow s x))
-> Term -> Datum (String -> Flow s x)
forall a b. (a -> b) -> a -> b
$ Name -> Term
Terms.primitive Name
_flows_fail

map :: Datum ((x -> y) -> Flow s x -> Flow s y)
map :: forall x y s. Datum ((x -> y) -> Flow s x -> Flow s y)
map = Term -> Datum ((x -> y) -> Flow s x -> Flow s y)
forall a. Term -> Datum a
Datum (Term -> Datum ((x -> y) -> Flow s x -> Flow s y))
-> Term -> Datum ((x -> y) -> Flow s x -> Flow s y)
forall a b. (a -> b) -> a -> b
$ Name -> Term
Terms.primitive Name
_flows_map

mapList :: Datum ((x -> Flow s y) -> [x] -> Flow s [y])
mapList :: forall x s y. Datum ((x -> Flow s y) -> [x] -> Flow s [y])
mapList = Term -> Datum ((x -> Flow s y) -> [x] -> Flow s [y])
forall a. Term -> Datum a
Datum (Term -> Datum ((x -> Flow s y) -> [x] -> Flow s [y]))
-> Term -> Datum ((x -> Flow s y) -> [x] -> Flow s [y])
forall a b. (a -> b) -> a -> b
$ Name -> Term
Terms.primitive Name
_flows_mapList

pure :: Datum (x -> Flow s x)
pure :: forall x s. Datum (x -> Flow s x)
pure = Term -> Datum (x -> Flow s x)
forall a. Term -> Datum a
Datum (Term -> Datum (x -> Flow s x)) -> Term -> Datum (x -> Flow s x)
forall a b. (a -> b) -> a -> b
$ Name -> Term
Terms.primitive Name
_flows_pure

-- Accessors

flowState :: Datum (Maybe x) -> Datum s -> Datum Trace -> Datum (FlowState s x)
flowState :: forall x s.
Datum (Maybe x) -> Datum s -> Datum Trace -> Datum (FlowState s x)
flowState Datum (Maybe x)
value Datum s
state Datum Trace
trace = Name -> [Field] -> Datum (FlowState s x)
forall a. Name -> [Field] -> Datum a
record Name
_FlowState [
    Name
_FlowState_valueName -> Datum (Maybe x) -> Field
forall a. Name -> Datum a -> Field
>>: Datum (Maybe x)
value,
    Name
_FlowState_stateName -> Datum s -> Field
forall a. Name -> Datum a -> Field
>>: Datum s
state,
    Name
_FlowState_traceName -> Datum Trace -> Field
forall a. Name -> Datum a -> Field
>>: Datum Trace
trace]

flowStateState :: Datum (FlowState s x -> s)
flowStateState :: forall s x. Datum (FlowState s x -> s)
flowStateState = Name -> Name -> Datum (FlowState s x -> s)
forall a b. Name -> Name -> Datum (a -> b)
project Name
_FlowState Name
_FlowState_state

flowStateTrace :: Datum (FlowState s x -> Trace)
flowStateTrace :: forall s x. Datum (FlowState s x -> Trace)
flowStateTrace = Name -> Name -> Datum (FlowState s x -> Trace)
forall a b. Name -> Name -> Datum (a -> b)
project Name
_FlowState Name
_FlowState_trace

flowStateValue :: Datum (FlowState s x -> Maybe x)
flowStateValue :: forall s x. Datum (FlowState s x -> Maybe x)
flowStateValue = Name -> Name -> Datum (FlowState s x -> Maybe x)
forall a b. Name -> Name -> Datum (a -> b)
project Name
_FlowState Name
_FlowState_value

trace :: Datum [String] -> Datum [String] -> Datum (M.Map String (Term)) -> Datum Trace
trace :: Datum [String]
-> Datum [String] -> Datum (Map String Term) -> Datum Trace
trace Datum [String]
stack Datum [String]
messages Datum (Map String Term)
other = Name -> [Field] -> Datum Trace
forall a. Name -> [Field] -> Datum a
record Name
_Trace [
    Name
_Trace_stackName -> Datum [String] -> Field
forall a. Name -> Datum a -> Field
>>: Datum [String]
stack,
    Name
_Trace_messagesName -> Datum [String] -> Field
forall a. Name -> Datum a -> Field
>>: Datum [String]
messages,
    Name
_Trace_otherName -> Datum (Map String Term) -> Field
forall a. Name -> Datum a -> Field
>>: Datum (Map String Term)
other]
    
traceStack :: Datum (Trace -> [String])
traceStack :: Datum (Trace -> [String])
traceStack = Name -> Name -> Datum (Trace -> [String])
forall a b. Name -> Name -> Datum (a -> b)
project Name
_Trace Name
_Trace_stack

traceMessages :: Datum (Trace -> [String])
traceMessages :: Datum (Trace -> [String])
traceMessages = Name -> Name -> Datum (Trace -> [String])
forall a b. Name -> Name -> Datum (a -> b)
project Name
_Trace Name
_Trace_messages

traceOther :: Datum (Trace -> M.Map String (Term))
traceOther :: Datum (Trace -> Map String Term)
traceOther = Name -> Name -> Datum (Trace -> Map String Term)
forall a b. Name -> Name -> Datum (a -> b)
project Name
_Trace Name
_Trace_other

unFlow :: Datum (Flow s x -> s -> Trace -> FlowState s x)
unFlow :: forall s x. Datum (Flow s x -> s -> Trace -> FlowState s x)
unFlow = Name -> Datum (Flow s x -> s -> Trace -> FlowState s x)
forall a b. Name -> Datum (a -> b)
unwrap Name
_Flow