- f [] = []
- f [MTEmpty:xs] = f xs
- f [x:xs] = [toString x:f xs]
-
- viewSh :: [(Int, Shared Int)] (Shared ([MTaskMSGRecv],Bool,[MTaskMSGSend],Bool)) -> Task ()
- viewSh [] ch = return ()
- viewSh [(i, sh):xs] ch
- # sharename = "SDS-" +++ toString i
- = (
- viewSharedInformation ("SDS-" +++ toString i) [] sh ||-
- forever (
- enterInformation sharename []
- >>* [OnAction ActionOk
- (ifValue (\j->j>=1 && j <= 3)
- (\c->set c sh
- >>= \_->sendMsg (toSDSUpdate i c) ch
- @! ()
- )
- )]
- )
- ) ||- viewSh xs ch
-
- sdsShares = makeShares st
-
- (msgs, st) = toMessages 500 (toRealByteCode (unMain bc))
-
- bc :: Main (ByteCode () Stmt)
- bc = sds \x=1 In sds \pinnetje=1 In {main =
- IF (digitalRead D3 ==. lit True) (
- x =. x +. lit 1 :.
- pub x
- ) (
- noOp
- ) :.
- IF (pinnetje ==. lit 1) (
- digitalWrite D0 (lit True) :.
- digitalWrite D1 (lit False) :.
- digitalWrite D2 (lit False)
- ) (
- IF (pinnetje ==. lit 2) (
- digitalWrite D0 (lit False) :.
- digitalWrite D1 (lit True) :.
- digitalWrite D2 (lit False)
- ) (
- digitalWrite D0 (lit False) :.
- digitalWrite D1 (lit False) :.
- digitalWrite D2 (lit True)
- )
- )}
-// bc :: Main (ByteCode Int Stmt)
-// bc = sds \x=1 In {main =
-// If (x ==. lit 3)
-// (x =. lit 1)
-// (x =. x +. lit 1) :. pub x}
-
-makeShares :: BCState -> [(Int, Shared Int)]
-makeShares {sdss=[]} = []
-makeShares s=:{sdss=[(i,d):xs]} =
- [(i, ms ("mTaskSDS-" +++ toString i) 1):makeShares {s & sdss=xs}]
- where
- ms name i = sdsFocus name (memoryStore name (Just i))
+ dropEmpty (r,s,ss) = (filter ((=!=)MTEmpty) r,s,ss)
+
+ addDevice :: (Shared [MTaskDevice]) -> Task SerTCP
+ addDevice devices = enterInformation "Device type" []
+ >&^ \sh->whileUnchanged sh $ \mty->case mty of
+ Nothing = viewInformation "No type selected yet" [] "" @! ()
+ Just ty = case ty of
+ TCPDevice = (enterInformation "Name" [] -&&- enterInformation "Hostname" [] -&&- enterInformation "Port" [])
+ >>= \(name, (host, port))->cont name (syncNetworkChannel host port)
+ SerialDevice = accWorld getTTYDevices
+ >>= \dl->(enterInformation "Name" [] -&&- enterChoice "Device" [] dl -&&- updateInformation "Settings" [] zero)
+ >>= \(name, (dev, set))->cont name (syncSerialChannel dev set)
+ where
+ cont :: String ((Shared Channels) -> Task ()) -> Task ()
+ cont name synfun = get randomInt
+ @ (\randint->{deviceConnected=Just (name +++ toString randint), deviceName=name, deviceTasks=[], deviceTask=Nothing})
+ >>= \dev->appendTopLevelTask 'DM'.newMap True (synfun $ channels dev)
+ >>= \tid->upd (\l->[{dev & deviceTask=Just tid}:l]) devices
+ @! ()
+
+// >= \ty->get randomInt @ (\randint->{deviceConnected=Just (name +++ toString randint), deviceName=name, deviceTasks=[]})
+// >>= \dev->let ch = channels dev in case ty of
+// TCPDevice = enterInformation "Hostname and port" []
+// >>= \(host, port)->cont dev ||- syncNetworkChannel host port ch
+// SerialDevice = accWorld getDevices
+// >>= \dl->(enterChoice "Device" [] dl -&&- updateInformation "Settings" [] zero)
+// >>= \(device, settings)->cont dev ||- syncSerialChannel device settings ch
+// where
+// cont d = (upd (\l->[d:l]) devices >>| addDevice devices)
+
+// connectDevice :: [MTaskDevice] -> Task ()
+// connectDevice [] = treturn ()
+// connectDevice [d:ds] = (case d.deviceConnected of
+// (Just sh) = viewSharedInformation "Buffers" [] sh @! ()
+// Nothing = viewInformation ("Connect " +++ d.deviceName) [] "" >>* [
+// OnAction (Action "connect") (const $ Just $ connect d)]
+// ) -|| connectDevice ds
+
+ deviceviewer :: [MTaskDevice] -> [MTaskDeviceStatus]
+ deviceviewer ds = [{MTaskDeviceStatus | name = d.deviceName,
+ connected = if (isNothing d.deviceConnected) False True,
+ tasks = d.deviceTasks}\\d<-ds]
+
+// showTabbed :: [MTaskDevice] -> Task ()
+// showTabbed [] = viewInformation "" [] "No devices yet" @! ()
+// showTabbed [l:ls] = foldr (\e es->manageDevice e ||- es) (manageDevice l) ls
+//
+// manageDevice :: MTaskDevice -> Task ()
+// manageDevice md =
+// either viewTCP viewSer md.deviceSettings
+// ||- maybe
+// (treturn () >>* [OnAction (Action "Connect") (always shutDown)] @! ())
+// (\b->viewSharedInformation "Buffers" [] b @! ())
+// md.deviceConnected
+// <<@ ArrangeVertical
+
+ mapPar :: (a -> Task a) [a] -> Task ()
+ mapPar f l = foldr1 (\x y->f x ||- y) l <<@ ArrangeWithTabs @! ()
+ allAtOnce t = foldr1 (||-) t @! ()
+ //allAtOnce = (flip (@!) ()) o foldr1 (||-)