From 9c9a3aa86bf8048026f60a291884eee9d3181463 Mon Sep 17 00:00:00 2001
From: Dmitry Zuikov <dzuikov@gmail.com>
Date: Mon, 16 Jan 2023 11:34:06 +0300
Subject: [PATCH] wip

---
 hbs2-core/test/TestUniqProtoId.hs | 52 ++++++++++---------------------
 1 file changed, 16 insertions(+), 36 deletions(-)

diff --git a/hbs2-core/test/TestUniqProtoId.hs b/hbs2-core/test/TestUniqProtoId.hs
index 15e0a228..0c66160b 100644
--- a/hbs2-core/test/TestUniqProtoId.hs
+++ b/hbs2-core/test/TestUniqProtoId.hs
@@ -12,25 +12,6 @@ import Data.Map (Map)
 import Control.Monad.Reader
 import Control.Monad.Identity
 
-data ProtocolA = ProtocolA
-
-data ProtocolB = ProtocolB
-
-instance HasProtocol ProtocolA where
-  type instance ProtocolId ProtocolA = 1
-  type instance Encoded ProtocolA = String
-  decode = undefined
-  encode = undefined
-
-
-instance HasProtocol ProtocolB where
-  type instance ProtocolId ProtocolB = 2
-  type instance Encoded ProtocolB = String
-  decode = undefined
-  encode = undefined
-
--- class Response p (m :: Type -> Type) where
---   answer :: p -> m ()
 
 data AnyProtocol m = forall a . ( HasProtocol a
                                 , KnownNat (ProtocolId a)
@@ -49,7 +30,7 @@ data PingPong = Ping Int
 
 
 instance HasProtocol PingPong where
-  type instance ProtocolId PingPong = 3
+  type instance ProtocolId PingPong = 1
   type instance Encoded PingPong = PingPong
   decode = undefined
   encode = undefined
@@ -58,19 +39,18 @@ instance HasProtocol PingPong where
 class Response p (m :: Type -> Type) where
   answer :: p -> m ()
 
-anyProtocol :: forall p  m   . ( MonadIO m
-                               , Response p m
+makeProtocol :: forall p  m  . ( MonadIO m
+                               , Response p (EngineM m)
                                , HasProtocol p
                                , KnownNat (ProtocolId p)
                                )
-            => (p -> m ()) -> AnyProtocol m
-
-anyProtocol h = AnyProtocol { getProtoId  = natVal (Proxy @(ProtocolId p))
-                            , protoDecode = decode @p
-                            , protoEncode = encode @p
-                            , handle = h
-                            }
+            => (p -> EngineM m ()) -> AnyProtocol (EngineM m)
 
+makeProtocol h = AnyProtocol { getProtoId  = natVal (Proxy @(ProtocolId p))
+                             , protoDecode = decode @p
+                             , protoEncode = encode @p
+                             , handle = h
+                             }
 
 newtype EngineM m a = EngineM { fromEngine :: ReaderT () m a }
                       deriving ( Functor, Applicative, Monad, MonadTrans, MonadIO )
@@ -78,9 +58,12 @@ newtype EngineM m a = EngineM { fromEngine :: ReaderT () m a }
 runEngineM :: EngineM m a -> m a
 runEngineM f = runReaderT (fromEngine f) ()
 
-instance (Monad m, HasProtocol p) => Response p m where
-  answer = undefined
-
+instance (Monad m, HasProtocol p) => Response p (EngineM m) where
+  answer _ = do
+    -- TODO: get bus
+    -- TODO: encode
+    -- TODO: sendTo
+    undefined
 
 testUniqiProtoId :: IO ()
 testUniqiProtoId = do
@@ -91,19 +74,16 @@ testUniqiProtoId = do
   -- TODO: GET RECIPIENT
   -- TODO: GET PROTO-ID FROM MESSAGE
 
-  let pingpong = anyProtocol @PingPong @(EngineM IO)
+  let pingpong = makeProtocol @PingPong @IO
         \case
           Ping c -> lift (print "effect: PING") >> answer (Pong c)
           Pong _ -> lift (print "effect: PONG")
 
-
   -- FIXME: dispatcher!
   case Map.lookup 3 decoders of
     Just (AnyProtocol {protoDecode = decoder, handle = h}) -> maybe (pure ()) (runEngineM . h) (decoder "AAA")
     Nothing -> pure ()
 
-  -- let qq = natVal (Proxy @(ProtocolId ProtocolA))
-
   pure ()