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

diff --git a/miTask.icl b/miTask.icl
index f8fa8ba..e5483cc 100644
--- a/miTask.icl
+++ b/miTask.icl
@@ -7,41 +7,108 @@ from Text import class Text(concat,join,split), instance Text String
 import iTasks
 import mTask
 
-derive class iTask MTaskMessage
+derive class iTask MTaskMSGRecv, MTaskMSGSend
 
 Start :: *World -> *World
-Start world = startEngine (withShared ([], False, [], False) 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 ([MTaskMSGRecv],Bool,[MTaskMSGSend],Bool)) -> Task ()
+mTaskTask port ch =
+	syncNetworkChannel "localhost" port "\n" decode encode` ch ||-
+	sendMsg msgs ch ||-
 	(
-		sendMsg (hd msgs) ch >>= \_->
-		sendMsg (hd (tl msgs)) ch >>= \_->
-		viewSharedInformation "channels" [ViewWith lens] ch @! ()
+		(
+			consumeNetworkStream (processSDSs sdsShares messageShare) ch ||-
+			viewSharedInformation "channels" [ViewWith lens] ch ||-
+			viewSh sdsShares ch
+		) >>* [OnAction ActionFinish (always shutDown)]
 	)
 	where
-		lens :: ([MTaskMessage],Bool,[MTaskMessage],Bool) -> ([String], [String])
-		lens (r,_,s,_) = (map toString r, map toString s)
+		encode` m
+		| not (trace_tn (toString (toJSON m))) = undef
+		= encode m
 
-		msgs = toMessages 500 (toRealByteCode (unMain bc))
+		messageShare :: Shared [String]
+		messageShare = sharedStore "mTaskMessagesRecv" []
 
-		bc :: Main (ByteCode Int Expr)
-		bc = sds \x=0 In {main = x =. x +. lit 1}
+		processSDSs :: [(Int, Shared Int)] (Shared [String]) [MTaskMSGRecv] -> Task ()
+		processSDSs _ _ [] = return ()
+		processSDSs s y [x:xs] = updateSDSs s y x >>= \_->processSDSs s y xs
 
-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"
+		updateSDSs :: [(Int, Shared Int)] (Shared [String]) MTaskMSGRecv -> Task ()
+		updateSDSs _ m (MTMessage s) = upd (\l->[s:l]) m @! ()
+		updateSDSs _ _ MTEmpty = return ()
+		updateSDSs [(id, sh):xs] m n=:(MTPub i d)
+		| id == i = set ((toInt d.[0])*265 + toInt d.[1]) sh @! ()
+		= updateSDSs xs m n
 
-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 @! ()
+		lens :: ([MTaskMSGRecv],Bool,[MTaskMSGSend],Bool) -> ([String], [String])
+		lens (r,_,s,_) = (f r, map toString s)
+			where
+				f [] = []
+				f [MTEmpty:xs] = f xs
+				f [x:xs] = [toString x:f xs]
 
-syncNetworkChannel :: String Int String (String -> m) (m -> String) (Shared ([m],Bool,[m],Bool)) -> Task () | iTask m
+		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 =
+				x =. x +. lit 1 :.
+				pub x :.
+				IF (pinnetje ==. lit 1) (
+					analogWrite A0 (lit 1) :.
+					analogWrite A1 (lit 0) :.
+					analogWrite A2 (lit 0)
+				) (
+					IF (pinnetje ==. lit 2) (
+						analogWrite A0 (lit 0) :.
+						analogWrite A1 (lit 1) :.
+						analogWrite A2 (lit 0)
+					) (
+						analogWrite A0 (lit 0):.
+						analogWrite A1 (lit 0):.
+						analogWrite A2 (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}
+
+makeShares :: BCState -> [(Int, Shared Int)]
+makeShares {sdss=[]} = []
+makeShares s=:{sdss=[(i,d):xs]} =
+	[(i, sharedStore ("mTaskSDS-" +++ toString i) 0):makeShares {s & sdss=xs}]
+
+sendMsg :: [MTaskMSGSend] (Shared ([MTaskMSGRecv],Bool,[MTaskMSGSend],Bool)) -> Task ()
+sendMsg m ch = upd (\(r,rs,s,ss)->(r,rs,s ++ m,ss)) ch @! ()
+
+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,7 +126,7 @@ 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 :: ([m] -> Task ()) (Shared ([m],Bool,[n],Bool)) -> Task () | iTask m & iTask n
 consumeNetworkStream processTask channel
 	= ((watch channel >>* [OnValue (ifValue ifProcess process)]) <! id) @! ()
 	where
@@ -71,5 +138,5 @@ consumeNetworkStream processTask channel
 			>>| if (isEmpty received) (return ()) (processTask received)
 			@!  receiveStopped
 		
-		empty :: ([m],Bool,[m],Bool) -> ([m],Bool,[m],Bool)
+		empty :: ([m],Bool,[n],Bool) -> ([m],Bool,[n],Bool)
 		empty (_,rs,s,ss) = ([],rs,s,ss)