From d19777660c2f776739c53264ab576ca549c1fe46 Mon Sep 17 00:00:00 2001
From: Dmitry Zuikov <dzuikov@gmail.com>
Date: Thu, 26 Jan 2023 19:50:03 +0300
Subject: [PATCH] Cache -> HashMap in Messaging.Fake

---
 hbs2-core/lib/HBS2/Net/Messaging/Fake.hs | 25 +++++++++++++++++++-----
 hbs2-tests/hbs2-tests.cabal              |  1 +
 2 files changed, 21 insertions(+), 5 deletions(-)

diff --git a/hbs2-core/lib/HBS2/Net/Messaging/Fake.hs b/hbs2-core/lib/HBS2/Net/Messaging/Fake.hs
index ebf10bb7..75ae0212 100644
--- a/hbs2-core/lib/HBS2/Net/Messaging/Fake.hs
+++ b/hbs2-core/lib/HBS2/Net/Messaging/Fake.hs
@@ -8,6 +8,7 @@ import HBS2.Net.Proto
 import HBS2.Net.Messaging
 
 import Control.Concurrent.STM (atomically) -- as STM
+import Control.Concurrent.STM.TVar
 import Control.Concurrent.STM.TChan qualified as Chan
 import Control.Concurrent.STM.TChan (TChan,newTChanIO)
 import Control.Monad.IO.Class
@@ -16,28 +17,42 @@ import Data.Cache qualified as Cache
 import Data.List qualified as List
 import Data.Maybe
 import Data.Hashable
+import Data.HashMap.Strict (HashMap)
+import Data.HashMap.Strict as HashMap
+
 
 
 data FakeP2P proto msg =
   FakeP2P
   {
     blocking :: Bool
-  , fakeP2p  :: Cache (Peer proto) (TChan (From proto,msg))
+  , fakeP2p  :: TVar (HashMap (Peer proto) (TChan (From proto,msg)))
   }
 
-newFakeP2P :: Bool -> IO (FakeP2P peer msg)
+newFakeP2P :: (Eq (Peer peer), Hashable (Peer peer)) => Bool -> IO (FakeP2P peer msg)
 newFakeP2P block =
-  FakeP2P block <$> Cache.newCache Nothing
+  FakeP2P block <$> newTVarIO mempty
+
+getChan bus whom = do
+  ch <- newTChanIO
+  atomically $ stateTVar t (alter ch)
+
+  where
+    t = fakeP2p bus
+    alter ch x = case HashMap.lookup whom x of
+                          Just c -> (c, x)
+                          Nothing -> (ch, HashMap.insert whom ch x)
 
 instance ( (HasPeer proto, Hashable (Peer proto))
          ) => Messaging (FakeP2P proto msg) proto msg where
 
   sendTo bus (To whom) who msg = liftIO do
-    chan <- Cache.fetchWithCache (fakeP2p bus) whom $ const newTChanIO
+    ch <- newTChanIO
+    chan <- getChan bus whom
     atomically $ Chan.writeTChan chan (who, msg)
 
   receive bus (To me) = liftIO do
-    readChan =<< Cache.fetchWithCache (fakeP2p bus) me (const newTChanIO)
+    readChan =<< getChan bus me -- Cache.fetchWithCache (fakeP2p bus) me (const newTChanIO)
 
     where
       readChan | blocking bus = atomically . (List.singleton <$>) . Chan.readTChan
diff --git a/hbs2-tests/hbs2-tests.cabal b/hbs2-tests/hbs2-tests.cabal
index 6ea09760..61a931b1 100644
--- a/hbs2-tests/hbs2-tests.cabal
+++ b/hbs2-tests/hbs2-tests.cabal
@@ -51,6 +51,7 @@ common common-deps
 common shared-properties
   ghc-options:
         -Wall
+        -O2
         -fno-warn-type-defaults
         -- -fno-warn-unused-matches
         -- -fno-warn-unused-do-bind