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

diff --git a/miTask.icl b/miTask.icl
index 84b2563..e5483cc 100644
--- a/miTask.icl
+++ b/miTask.icl
@@ -7,15 +7,108 @@ from Text import class Text(concat,join,split), instance Text String
 import iTasks
 import mTask
 
+derive class iTask MTaskMSGRecv, MTaskMSGSend
+
 Start :: *World -> *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 :: Int (Shared ([MTaskMSGRecv],Bool,[MTaskMSGSend],Bool)) -> Task ()
+mTaskTask port ch =
+	syncNetworkChannel "localhost" port "\n" decode encode` ch ||-
+	sendMsg msgs ch ||-
+	(
+		(
+			consumeNetworkStream (processSDSs sdsShares messageShare) ch ||-
+			viewSharedInformation "channels" [ViewWith lens] ch ||-
+			viewSh sdsShares ch
+		) >>* [OnAction ActionFinish (always shutDown)]
+	)
+	where
+		encode` m
+		| not (trace_tn (toString (toJSON m))) = undef
+		= encode m
+
+		messageShare :: Shared [String]
+		messageShare = sharedStore "mTaskMessagesRecv" []
+
+		processSDSs :: [(Int, Shared Int)] (Shared [String]) [MTaskMSGRecv] -> Task ()
+		processSDSs _ _ [] = return ()
+		processSDSs s y [x:xs] = updateSDSs s y x >>= \_->processSDSs s y xs
+
+		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
+
+		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]
+
+		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}]
 
-mTaskTask :: Task ()
-mTaskTask = withShared ([],False,[],False) (\ch->
-		syncNetworkChannel "localhost" 8123 "\n" id id ch ||- 
-		updateSharedInformation "channels" [] ch @! ())
+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) (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
@@ -33,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
@@ -45,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)