From 623ed5855ab2fca088c83c3c3bd4e3a6d18f1483 Mon Sep 17 00:00:00 2001 From: Mart Lubbers Date: Mon, 13 Feb 2017 19:43:56 +0100 Subject: [PATCH] started with layout --- install_clean.sh | 3 ++ miTask.icl | 115 +++++++++++++++++++++++++++-------------------- 2 files changed, 70 insertions(+), 48 deletions(-) diff --git a/install_clean.sh b/install_clean.sh index 005cbe7..e21a1c6 100755 --- a/install_clean.sh +++ b/install_clean.sh @@ -6,6 +6,9 @@ then exit 1; fi TARGET="$(realpath "$1")" +if [ -d "$TARGET" ]; then + mv "$TARGET" "$TARGET.$(date +%F)" +fi rm -fr "$TARGET" mkdir -p "$TARGET" curl -sSL ftp://ftp.cs.ru.nl/pub/Clean/builds/linux-x64/clean-bundle-complete-linux-x64-latest.tgz \ diff --git a/miTask.icl b/miTask.icl index d84121a..9af815e 100644 --- a/miTask.icl +++ b/miTask.icl @@ -20,25 +20,24 @@ import iTasks._Framework.TaskServer import iTasks._Framework.IWorld import iTasks._Framework.Store + import TTY derive class iTask Queue, TTYSettings, Parity, BaudRate, ByteSize derive class iTask MTaskMSGRecv, MTaskMSGSend, SerTCP, UserLED -derive class iTask MTaskDevice - -:: SerTCP = Serial | TCP :: *Resource | TTYd !*TTY +:: Channels :== ([MTaskMSGRecv], [MTaskMSGSend], Bool) + +:: SerTCP = SerialDevice | TCPDevice :: MTaskDevice = { - deviceConnected :: Maybe (Shared ([String], [String], Bool)), - deviceName :: String, - deviceSettings :: Either (String, Int) (String, TTYSettings) + deviceConnected :: Maybe String, + deviceName :: String } Start :: *World -> *World Start world = startEngine (mTaskManager >>* [OnAction (Action "Shutdown") (always $ shutDown)]) world -//Start world = startEngine mTaskTask world bc :: Main (ByteCode () Stmt) bc = sds \x=1 In sds \pinnetje=1 In {main = @@ -65,29 +64,71 @@ bc3 :: UserLED -> Main (ByteCode () Stmt) bc3 d = {main = ledOff d} :: MTaskDeviceStatus = {connected :: Bool, name :: String} -derive class iTask MTaskDeviceStatus +derive class iTask MTaskDeviceStatus, MTaskDevice mTaskManager :: Task () -mTaskManager = forever (addDevice >>= \d->upd (\l->[d:l]) deviceStore) - ||- viewSharedInformation "Devices" [ViewAs deviceviewer] deviceStore - ||- whileUnchanged deviceStore (\m->if (isEmpty m) - (viewInformation "No devices yet" [] "" @! ()) (connectDevice m)) @! () +mTaskManager = anyTask + [ viewmTasks @! () + , whileUnchanged deviceStore viewDevices + , addDevice deviceStore + , viewChannels deviceStore + ] <<@ ApplyLayout layout +// ||- whileUnchanged deviceStore (\m->if (isEmpty m) +// (viewInformation "No devices yet" [] "" @! ()) (connectDevice m)) @! () // ) where - 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 - - connect :: MTaskDevice -> Task () - connect d=:{deviceSettings} = withShared ([], [], False) $ \ch-> - case deviceSettings of - Left (host, port) = syncNetworkChannel host port ch - Right (dev, sett) = syncSerialChannel dev sett ch - ||- viewSharedInformation "Buffers" [] ch @! () + isValue (Value _ _) = True + isValue _ = False + + viewmTasks = viewInformation "MTasks" [] "" + + layout = sequenceLayouts + [ arrangeWithSideBar 0 LeftSide 260 True + , arrangeSplit Vertical True + , layoutSubs (SelectByPath [1, 0]) arrangeWithTabs + ] + + viewChannels :: (Shared [MTaskDevice]) -> Task () + viewChannels sh = whileUnchanged sh (\d->if (isEmpty d) + (viewInformation "No channels yet" [] "") + (viewInformation "Channels available" [] "")) @! () + + viewDevices :: [MTaskDevice] -> [Task ()] + viewDevices [] = viewInformation "No devices yet" [] "" @! () + viewDevices ds = [viewInformation "Device" [] d <<@ Title d.deviceName\\d<-ds] + + addDevice :: (Shared [MTaskDevice]) -> Task () + addDevice devices = enterInformation "Device type and name" [] + >>= \(name, ty)->get randomInt + >>= \ident->treturn (name +++ toString ident) + >>= \realname->let ch = channels realname in case ty of + TCPDevice = enterInformation "Hostname and port" [] + >>= \(host, port)->cont realname name ||- syncNetworkChannel host port ch + SerialDevice = accWorld getDevices + >>= \dl->(enterChoice "Device" [] dl -&&- updateInformation "Settings" [] zero) + >>= \(device, settings)->cont realname name ||- syncSerialChannel device settings ch + where + cont rn nm = (upd (\l->[dev rn nm:l]) devices >>| addDevice devices) + dev rn nm = {deviceConnected=Just rn,deviceName=nm} + + channels :: String -> Shared Channels + channels s = sdsFocus s $ memoryStore "" $ Just ([], [], False) + + getDevices :: !*World -> *(![String], !*World) + getDevices w = case readDirectory "/dev" w of + (Error (errcode, errmsg), w) = abort errmsg + (Ok entries, w) = (map ((+++) "/dev/") (filter isTTY entries), w) + + isTTY s = not (isEmpty (filter (flip startsWith s) prefixes)) + prefixes = ["ttyS", "ttyACM", "ttyUSB", "tty.usbserial"] + +// 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, @@ -114,27 +155,6 @@ mTaskManager = forever (addDevice >>= \d->upd (\l->[d:l]) deviceStore) allAtOnce t = foldr1 (||-) t @! () //allAtOnce = (flip (@!) ()) o foldr1 (||-) -addDevice :: Task MTaskDevice -addDevice = enterInformation "Device name" [] - -&&- enterInformation "Device type" [] - >>= \(name, ty)->(case ty of - TCP = (enterInformation "Host" [] -&&- enterInformation "Port" []) - >>= treturn o Left - Serial = accWorld getDevices - >>= \dl->(enterChoice "Device" [] dl -&&- updateInformation "Settings" [] zero) - >>= treturn o Right - ) >>= \set->treturn {MTaskDevice | - deviceConnected=Nothing, - deviceName=name, - deviceSettings=set} - where - getDevices :: !*World -> *(![String], !*World) - getDevices w = case readDirectory "/dev" w of - (Error (errcode, errmsg), w) = abort errmsg - (Ok entries, w) = (map ((+++) "/dev/") (filter isTTY entries), w) - where - isTTY s = not (isEmpty (filter (flip startsWith s) prefixes)) - prefixes = ["ttyS", "ttyACM", "ttyUSB", "tty.usbserial"] //mTaskTask :: Task () //mTaskTask = let (msgs, sdsShares) = makeMsgs 1000 bc in @@ -263,7 +283,6 @@ syncNetworkChannel server port channel 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) -// = (Ok acc, Just (msgs,[],sendStopped), map encode send, False) whileConnected (Just newData) acc (msgs,send,sendStopped) | sendStopped = (Ok acc, Just (msgs ++ [decode newData],[],False), map encode send, False) -- 2.20.1