X-Git-Url: https://git.martlubbers.net/?a=blobdiff_plain;f=miTask.icl;h=62b6ce1738c7e51720e05c0b9fed6c0de29d605f;hb=c23eb53a452d0aea1a26ba60fe8ce9abcb77ea02;hp=f8fa8bae4785cae9628977b3617d402a509b0229;hpb=4dff4046c87727f8b09558969f7c655b9e4de3c1;p=mTask.git

diff --git a/miTask.icl b/miTask.icl
index f8fa8ba..62b6ce1 100644
--- a/miTask.icl
+++ b/miTask.icl
@@ -10,38 +10,43 @@ import mTask
 derive class iTask MTaskMessage
 
 Start :: *World -> *World
-Start world = startEngine (withShared ([], False, [], False) mTaskTask) world
-//Start world = startEngine mTaskTask world
+Start world = startEngine (
+	enterInformation "Port Number?" []
+	>>= \port->withShared ([], False, [], False) (mTaskTask port)
+	) world
+Start world = startEngine mTaskTask world
 
-mTaskTask :: (Shared ([MTaskMessage],Bool,[MTaskMessage],Bool)) -> Task ()
-mTaskTask ch =
-	syncNetworkChannel "localhost" 8124 "\n" decode encode ch ||-
+mTaskTask :: Int (Shared ([MTaskMessage],Bool,[MTaskMessage],Bool)) -> Task ()
+mTaskTask port ch =
+	syncNetworkChannel "localhost" port "\n" decode encode ch ||-
 	(
-		sendMsg (hd msgs) ch >>= \_->
-		sendMsg (hd (tl msgs)) ch >>= \_->
+		sendMsg msgs ch >>= \_->
 		viewSharedInformation "channels" [ViewWith lens] ch @! ()
-	)
+	) >>* [OnAction ActionFinish (always shutDown)]
 	where
 		lens :: ([MTaskMessage],Bool,[MTaskMessage],Bool) -> ([String], [String])
-		lens (r,_,s,_) = (map toString r, map toString s)
+		lens (r,_,s,_) = (f r, f s)
+			where
+				f [] = []
+				f [MTEmpty:xs] = f xs
+				f [x:xs] = [toString x:f xs]
 
-		msgs = toMessages 500 (toRealByteCode (unMain bc))
+		msgs
+		| not (trace_tn (fst (toReadableByteCode (unMain bc)))) = undef
+		= toMessages 500 (toRealByteCode (unMain bc))
 
-		bc :: Main (ByteCode Int Expr)
-		bc = sds \x=0 In {main = x =. x +. lit 1}
+		bc :: Main (ByteCode Int Stmt)
+		bc = sds \x=1 In {main =
+			If (x ==. lit 3)
+			(x =. lit 1)
+			(x =. x +. lit 1) :. pub x}
 
-makemTask :: Int (Main (ByteCode a Expr)) -> String
-makemTask to bc
-# (bc, st) = toRealByteCode (unMain bc)
-= "t" +++ toString (toChar (to / 265))
-	+++ toString (toChar (to rem 265)) +++ toString bc +++ "\n"
-
-sendMsg :: MTaskMessage (Shared ([MTaskMessage],Bool,[MTaskMessage],Bool)) -> Task ()
+sendMsg :: [MTaskMessage] (Shared ([MTaskMessage],Bool,[MTaskMessage],Bool)) -> Task ()
 sendMsg m ch
-| not (trace_tn ("\'" +++ toString m +++ "\'")) = undef
-= upd (\(r,rs,s,ss)->(r,rs,s ++ [m],ss)) ch @! ()
+| not (trace_tn (join "\n" (map (toString o toJSON) m))) = undef
+= upd (\(r,rs,s,ss)->(r,rs,s ++ m,ss)) ch @! ()
 
-syncNetworkChannel :: String Int String (String -> m) (m -> String) (Shared ([m],Bool,[m],Bool)) -> Task () | iTask m
+syncNetworkChannel :: String Int String (String -> m) (n -> String) (Shared ([m],Bool,[n],Bool)) -> Task () | iTask m & iTask n
 syncNetworkChannel server port msgSeparator decodeFun encodeFun channel
 	= tcpconnect server port channel {ConnectionHandlers|onConnect=onConnect,whileConnected=whileConnected,onDisconnect=onDisconnect} @! ()
 	where
@@ -59,17 +64,17 @@ syncNetworkChannel server port msgSeparator decodeFun encodeFun channel
 		onDisconnect l (received,receiveStopped,send,sendStopped)
 			= (Ok l,Just (received,True,send,sendStopped))
 
-consumeNetworkStream :: ([m] -> Task ()) (Shared ([m],Bool,[m],Bool)) -> Task () | iTask m
-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)
+//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)