adding missing files

src/Affection/MessageBus/Class.hs

@@ -0,0 +1,18 @@
+module Affection.MessageBus.Class where
+
+import Control.Concurrent.STM as STM
+
+import Data.IORef
+
+import Affection.MessageBus.Message
+
+type Channel msg = TChan msg
+
+class Participant prt where
+  partChannel        :: (Message msg) => prt -> IORef (Channel msg)
+
+  partConnectChannel :: (Message msg) => prt -> Channel msg -> IO ()
+
+  partListen         :: (Message msg) => prt -> IO msg
+
+  partBroadcast      :: (Message msg) => prt -> msg -> IO ()

src/Affection/MessageBus/Engine.hs

@@ -0,0 +1,3 @@
+module Affection.MessageBus.Engine where
+
+import Affection.MessageBus.Class

src/Affection/MessageBus/Message.hs

@@ -0,0 +1,4 @@
+module Affection.MessageBus.Message where
+
+class Message msg where
+  msgPayload :: msg -> a

src/Affection/MessageBus/Util.hs

@@ -0,0 +1,8 @@
+module Affection.MessageBus.Util where
+
+import Affection.MessageBus.Class
+import Affection.MessageBus.Message
+import Control.Concurrent.STM as STM
+
+newBroadcastChannel :: (Message msg) => IO (Channel msg)
+newBroadcastChannel = atomically $ newBroadcastTChan