X-Git-Url: https://git.martlubbers.net/?a=blobdiff_plain;ds=sidebyside;f=miTask.icl;h=2a80f5cc8492b51a36f716add3ab037b69f4bf7f;hb=71726cdfddd9dfa11395f10ef3b5af28613fd5a0;hp=c7b68dd5f856edc693e2529bd1f6b3b1d66503bf;hpb=22938a745f2763f2f4366247043d7edc5c96a1d0;p=mTask.git diff --git a/miTask.icl b/miTask.icl index c7b68dd..2a80f5c 100644 --- a/miTask.icl +++ b/miTask.icl @@ -24,27 +24,46 @@ import iTasks._Framework.Serialization import TTY, iTasksTTY -//derive class iTask ByteSize, Parity, BaudRate, TTYSettings, TCPSettings -//derive class iTask MTaskDeviceSpec, MTaskResource, MTaskTask, MTaskDevice +Start world = startEngine [ + publish "/manage" $ const $ mTaskManager + >>* [OnAction (Action "Shutdown") (always $ shutDown)], + publish "/" $ const demo + ] world -Start world = startEngine (mTaskManager - >>* [OnAction (Action "Shutdown") (always $ shutDown)]) world +demo = viewSharedInformation "Devices" [] deviceStoreNP + >>* [OnValue $ ifValue pred (cont o hd)] + where + pred [] = False + pred [x:_] = not $ isEmpty x.deviceShares + + cont :: MTaskDevice -> Task () + cont dev + # rs = getRealShare dev (hd dev.deviceShares) + = get rs >>= \oldvalue-> + forever (updateSharedInformation "Blinkyblink" [] (getRealShare dev (hd dev.deviceShares)) + >>* [OnAction ActionContinue (const $ Just $ treturn ())]) + -|| (wait "bigger than 10" (\x->x == oldvalue) rs + >>= viewInformation "Bigger:)" []) + + toInt :: BCValue -> Int + toInt (BCValue e) = dynToInt (dynamic e) + + dynToInt :: Dynamic -> Int + dynToInt (a :: Int) = a + dynToInt x = abort "Not an int" mTaskManager :: Task () -mTaskManager = startupDevices >>| anyTask - [ viewmTasks @! () - , whileUnchanged sdsStore manageShares - , whileUnchanged deviceStore $ manageDevices process - ] <<@ ApplyLayout (sequenceLayouts - [ arrangeWithSideBar 0 LeftSide 260 True - , arrangeSplit Vertical True - ]) +mTaskManager = (>>|) startupDevices $ + viewmTasks ||- + ((manageShares ||- whileUnchanged deviceStoreNP (manageDevices process)) + <<@ ArrangeSplit Vertical True) + <<@ ArrangeWithSideBar 0 LeftSide 260 True where viewmTasks :: Task String viewmTasks = enterChoiceWithShared "Available mTasks" [ChooseFromList id] mTaskTaskStore >&^ \sh->whileUnchanged sh $ \mi->forever (case mi of Nothing = viewInformation "No task selected" [] () - Just mTaskTask = get deviceStore + Just mTaskTask = get deviceStoreNP >>= \devices->case devices of [] = viewInformation "No devices yet" [] () ds = fromJust ('DM'.get mTaskTask allmTasks) @@ -65,8 +84,8 @@ mTaskManager = startupDevices >>| anyTask proc [m:ms] = traceValue (toString m) >>| (case m of // MTSDSAck i = traceValue (toString m) @! () // MTSDSDelAck i = traceValue (toString m) @! () - MTPub i val = updateShare i val - MTTaskAck i = deviceTaskAcked device i + MTPub i val = updateShareFromPublish device i val @! () + MTTaskAck i mem = deviceTaskAcked device i mem @! () MTTaskDelAck i = deviceTaskDeleteAcked device i @! () MTDevSpec s = deviceAddSpec device s @! () _ = treturn ()