1 implementation module Tasks.mTaskTask
5 import Devices.mTaskDevice
8 import iTasks._Framework.Serialization
10 derive class iTask MTaskTask, MTaskInterval, Main, ByteCode, Stmt, Expr, BC, BCState, RWST, Identity
12 makeTask :: String Int -> Task MTaskTask
13 makeTask name ident = get currentDateTime
14 @ \dt->{MTaskTask | name=name,ident=ident,dateAdded=dt}
16 sendTaskToDevice :: String (Main (ByteCode () Stmt)) (MTaskDevice, MTaskInterval) -> Task ()
17 sendTaskToDevice wta mTask (device, timeout) =
18 get bcStateStore @ toMessages timeout mTask
19 >>= \(msgs, st1)->set st1 bcStateStore
20 >>| toSDSRecords msgs st1 device
21 >>= \sdss->upd (mergeShares sdss) sdsStore
22 >>| sendMessages msgs device
24 >>= withDevices device o addTask
27 sharename i = device.deviceChannels +++ "-" +++ toString i
29 toSDSRecords :: [MTaskMSGSend] BCState MTaskDevice -> Task [MTaskShare]
30 toSDSRecords s st device = sequence ""
31 [makeShare wta device.deviceName sdsi sdsval
32 \\{sdsi,sdspub,sdsval}<-st.sdss
36 mergeShares a b = a ++ b
38 addTask :: MTaskTask MTaskDevice -> MTaskDevice
39 addTask task device = {device & deviceTasks=[task:device.deviceTasks]}