X-Git-Url: https://git.martlubbers.net/?a=blobdiff_plain;f=Devices%2FmTaskDevice.icl;h=a99097ddea029cadf935362c6e853397e392aa1f;hb=de76c5f5ac6a0c4291b51d5b2c16e3611b5c99e3;hp=6f6480af1167892e0c03594fdab0187a6b7dcb74;hpb=ee38806680e1706a4aea577d1ed699860f1fb0e8;p=mTask.git diff --git a/Devices/mTaskDevice.icl b/Devices/mTaskDevice.icl index 6f6480a..a99097d 100644 --- a/Devices/mTaskDevice.icl +++ b/Devices/mTaskDevice.icl @@ -7,6 +7,7 @@ import iTasks import iTasksTTY import TTY import qualified Data.Map as DM +import qualified Data.List as DL import Utils.SDS import Utils.Devices @@ -98,22 +99,6 @@ deleteDevice d = upd (\(r,s,ss)->(r,s,True)) (channels d) // >>| upd (removeShares d) sdsStore @! () -sendToDevice :: String (Main (ByteCode () Stmt)) (MTaskDevice, MTaskInterval) -> Task () -sendToDevice wta mTask (device, timeout) = - get bcStateStore @ toMessages timeout o toRealByteCode (unMain mTask) - >>= \(msgs, st1)->set st1 bcStateStore - >>| toSDSRecords st1 - >>= \sdss->set sdss sdsStore//MTaskShareaddToSDSShare - >>| sendMessages msgs device - >>| makeTask wta -1 - >>= withDevices device o addTask - @! () - where - sharename i = device.deviceChannels +++ "-" +++ toString i - toSDSRecords st = sequence "" [makeShare wta sdsi sdsval\\{sdsi,sdspub,sdsval}<-st.sdss]// | sdspub] - - addTask :: MTaskTask MTaskDevice -> MTaskDevice - addTask task device = {device & deviceTasks=[task:device.deviceTasks]} sendMessages :: [MTaskMSGSend] -> (MTaskDevice -> Task Channels) sendMessages msgs = upd (\(r,s,ss)->(r,msgs++s,ss)) o channels @@ -130,6 +115,9 @@ deviceTaskAcked dev i ackFirst [t:ts] = if (t.ident == -1) [{t & ident=i}:ts] [t:ackFirst ts] +getDevice :: String -> Task MTaskDevice +getDevice n = get deviceStore @ fromJust o 'DL'.find (\s->s.deviceName == n) + deviceTaskDelete :: MTaskDevice MTaskTask -> Task () deviceTaskDelete dev task = sendMessages [MTTaskDel task.ident] dev @! ()