-//consumeNetworkStream :: ([m] -> Task ()) (Shared ([m],Bool,[n],Bool)) -> Task () | iTask m & iTask n
-//consumeNetworkStream processTask channel
-// = ((watch channel >>* [OnValue (ifValue ifProcess process)]) <! id) @! ()
-// where
-// ifProcess (received,receiveStopped,_,_)
-// = receiveStopped || (not (isEmpty received))
-//
-// process (received,receiveStopped,_,_)
-// = upd empty channel
-// >>| if (isEmpty received) (return ()) (processTask received)
-// @! receiveStopped
-//
-// empty :: ([m],Bool,[m],Bool) -> ([m],Bool,[m],Bool)
-// empty (_,rs,s,ss) = ([],rs,s,ss)
+//Start world = startEngine (mTaskManager
+// >>* [OnAction (Action "Shutdown") (always $ shutDown)]) world
+
+mTaskManager :: Task ()
+mTaskManager = startupDevices >>| anyTask
+ [ viewmTasks @! ()
+ , whileUnchanged sdsStore manageShares
+ , whileUnchanged deviceStore $ manageDevices process
+ ] <<@ ApplyLayout (sequenceLayouts
+ [ arrangeWithSideBar 0 LeftSide 260 True
+ , arrangeSplit Vertical 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
+ >>= \devices->case devices of
+ [] = viewInformation "No devices yet" [] ()
+ ds = fromJust ('DM'.get mTaskTask allmTasks)
+ >>= \bc->(enterChoice "Choose Device" [ChooseFromDropdown \t->t.deviceName] ds
+ -&&- enterInformation "Timeout" []
+ ) >>* [OnAction (Action "Send") (withValue $ Just o sendToDevice mTaskTask bc)]
+ @! ()
+ )
+
+ process :: MTaskDevice (Shared Channels) -> Task ()
+ process device ch = forever (watch ch >>* [OnValue (
+ ifValue (not o isEmpty o fst3)
+ (\t->upd (appFst3 (const [])) ch >>| proc (fst3 t)))])
+ where
+ proc :: [MTaskMSGRecv] -> Task ()
+ proc [] = treturn ()
+ proc [MTEmpty:ms] = proc ms
+ 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
+ MTTaskDelAck i = deviceTaskDeleteAcked device i @! ()
+ MTDevSpec s = deviceAddSpec device s @! ()
+ _ = treturn ()
+ ) >>| proc ms