started externalizing devices

[mTask.git] / miTask.icl

diff --git a/miTask.icl b/miTask.icl
index 5a87999..81c765b 100644 (file)
--- a/miTask.icl
+++ b/miTask.icl
@@ -25,10 +25,11 @@ derive class iTask MTaskMSGRecv, MTaskMSGSend, SerTCP, UserLED
 
 :: SerTCP = SerialDevice | TCPDevice
 :: MTaskDevice = {
-               deviceTask :: Maybe TaskId,
-               deviceConnected :: Maybe String,
-               deviceName :: String,
-               deviceTasks :: [(String, Int)]
+                deviceTask :: Maybe TaskId
+               ,deviceChannels :: String
+               ,deviceName :: String
+               ,deviceTasks :: [(String, Int)]
+//             ,deviceSyncfun :: (Shared Channels) -> Task ()
        }
 :: MTaskShare = {
                initValue :: Int,
@@ -124,7 +125,7 @@ mTaskManager = anyTask
                                        @! ()
                                        where
                                                createBytecode st = toMessages timeout $ toRealByteCode (unMain $ fromJust ('DM'.get mTask mTaskMap)) st
-                                               sharename i = fromJust (device.deviceConnected) +++ "-" +++ toString i
+                                               sharename i = device.deviceChannels +++ "-" +++ toString i
                                                toSDSRecords st = [{MTaskShare |
                                                        initValue=toInt d1*265 + toInt d2,
                                                        withTask=mTask,
@@ -140,7 +141,7 @@ mTaskManager = anyTask
                getSDSRecord i = get sdsStore @ \l->hd [s\\s<-l | s.identifier == i]
 
                channels :: MTaskDevice -> Shared Channels
-               channels d = memoryShare (fromJust d.deviceConnected) ([], [], False)
+               channels d = memoryShare d.deviceChannels ([], [], False)
 
                viewShares :: [MTaskShare] -> Task ()
                viewShares st = anyTask $ map viewer st
@@ -166,10 +167,8 @@ mTaskManager = anyTask
                
                viewDevice :: MTaskDevice -> Task ()
                viewDevice d = (viewInformation "Device settings" [] d 
-                               ||- (case d.deviceConnected of
-                                       Just s = viewSharedInformation "Channels" [ViewAs dropEmpty] (channels d) @! ()
-                                       Nothing = viewInformation "No channels yet" [] "" @! ()
-                               )) <<@ ArrangeHorizontal
+                               ||- viewSharedInformation "Channels" [ViewAs dropEmpty] (channels d) @! ()
+                               ) <<@ ArrangeHorizontal
                        where
                                dropEmpty (r,s,ss) = (filter ((=!=)MTEmpty) r,s,ss)
 
@@ -185,11 +184,32 @@ mTaskManager = anyTask
                        where
                                cont :: String ((Shared Channels) -> Task ()) -> Task ()
                                cont name synfun = get randomInt 
-                                       @ (\randint->{deviceConnected=Just (name +++ toString randint), deviceName=name, deviceTasks=[], deviceTask=Nothing})
+                                       @ (\randint->{MTaskDevice |
+                                               deviceChannels=name +++ toString randint,
+                                               deviceName=name,
+                                               deviceTasks=[],
+                                               deviceTask=Nothing})
                                        >>= \dev->appendTopLevelTask 'DM'.newMap True (let ch = channels dev in process ch -||- synfun ch)
                                        >>= \tid->upd (\l->[{dev & deviceTask=Just tid}:l]) devices
                                        @! ()
 
+//             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 = (enterInformation "Name" [] -&&- enterTTYSettings)
+//                                             >>= \(name, set)->cont name (syncSerialChannel set encode decode)
+//                     where
+//                             cont :: String ((Shared Channels) -> Task ()) -> Task ()
+//                             cont name synfun = get randomInt 
+//                                     @ (\randint->{deviceChannels=name +++ toString randint, deviceName=name, deviceTasks=[], deviceTask=Nothing})
+//                                     >>= \dev->appendTopLevelTask 'DM'.newMap True (let ch = channels dev in process ch -||- synfun ch)
+//                                     >>= \tid->upd (\l->[{dev & deviceTask=Just tid}:l]) devices
+//                                     @! ()
+
                process :: (Shared Channels) -> Task ()
                process ch = forever (watch ch >>* [OnValue (
                                ifValue (not o isEmpty o fst3)
@@ -209,7 +229,7 @@ mTaskManager = anyTask
 
                deviceviewer :: [MTaskDevice] -> [MTaskDeviceStatus]
                deviceviewer ds = [{MTaskDeviceStatus | name = d.deviceName,
-                       connected = if (isNothing d.deviceConnected) False True,
+                       connected = if (isNothing d.deviceTask) False True,
                        tasks = [s +++ toString i\\(s, i)<-d.deviceTasks]}\\d<-ds]
 
                mapPar :: (a -> Task a) [a] -> Task ()
@@ -230,11 +250,11 @@ syncNetworkChannel server port channel = catchAll
                        = (Ok "", Just (msgs,[],sendStopped), map encode send, False)
 
                whileConnected :: (Maybe String) String ([MTaskMSGRecv], [MTaskMSGSend],Bool) -> (MaybeErrorString String, Maybe ([MTaskMSGRecv],[MTaskMSGSend],Bool), [String], Bool)
-               whileConnected Nothing acc (msgs,send,sendStopped)
-               = (Ok acc, Nothing, [], False)
-
-               whileConnected (Just newData) acc (msgs,send,sendStopped)
-               = (Ok acc, Just (msgs ++ [decode newData],[],False), map encode send, False)
+               
+               //whileConnected Nothing acc (msgs,send,sendStopped)
+               //= (Ok acc, Just (msgs,[],sendStopped), map encode send, False)
+               whileConnected mnewData acc (msgs,send,sendStopped)
+               = (Ok acc, Just (msgs ++ map decode (maybeToList mnewData),[],sendStopped), map encode send, False)
                //| sendStopped = (Ok acc, Just (msgs ++ [decode newData],[],False), map encode send, False)
 //             = (Ok acc, Just (msgs ++ [decode newData],[],False), [], False)