.drone.yml

@@ -18,7 +18,6 @@ trigger:
   event:
     include:
       - tag
-      - push
 
 volumes:
 - name: drone-shared

backend/app/Main.hs

@@ -1,11 +1,7 @@
 module Main (main) where
 
 import ClassyPrelude
-import GHC.IO.Encoding (setLocaleEncoding)
-import GHC.IO.Encoding.UTF8 (utf8)
 import Lib (runBothServers)
 
 main :: IO ()
-main = do
+main = runBothServers
-  setLocaleEncoding utf8
-  runBothServers

backend/converted.nix

@@ -10,7 +10,6 @@
 , text
 , uuid
 , wai
-, wai-extra
 , warp
 , websockets
 }:
@@ -31,7 +30,6 @@ mkDerivation {
     text
     uuid
     wai
-    wai-extra
     warp
     websockets
   ];
@@ -46,7 +44,6 @@ mkDerivation {
     text
     uuid
     wai
-    wai-extra
     warp
     websockets
   ];

backend/default.nix

@@ -30,8 +30,5 @@ pkgs.dockerTools.buildImage {
       "9160/tcp" = { };
       "8081/tcp" = { };
     };
-    Env = [
-      "LANG=en_US.UTF-8"
-    ];
   };
 }

backend/jitsi-rooms.cabal

@@ -1,6 +1,6 @@
 cabal-version: 1.12
 
--- This file has been generated from package.yaml by hpack version 0.35.2.
+-- This file has been generated from package.yaml by hpack version 0.35.0.
 --
 -- see: https://github.com/sol/hpack
 
@@ -29,13 +29,12 @@ library
       Lib
       RoomDataHandler
       State.ConnectedClientsState
-      State.GenericTVarState
       State.RoomDataState
-      State.RoomsState
       Types.AppTypes
       Types.ConnectionState
       Types.Participant
       Types.RoomData
+      Types.RoomsState
       Types.User
       Types.UsersData
       Types.WebEnv
@@ -66,7 +65,6 @@ library
     , time
     , uuid
     , wai
-    , wai-extra
     , warp
     , websockets
   default-language: Haskell2010
@@ -93,7 +91,6 @@ executable jitsi-rooms-exe
     , time
     , uuid
     , wai
-    , wai-extra
     , warp
     , websockets
   default-language: Haskell2010

backend/nix/sources.json

@@ -1,14 +0,0 @@
-{
-    "nixpkgs": {
-        "branch": "nixpkgs-unstable",
-        "description": "Nix Packages collection",
-        "homepage": "https://github.com/NixOS/nixpkgs",
-        "owner": "NixOS",
-        "repo": "nixpkgs",
-        "rev": "abfd31179174133ab8131139d650297bf4da63b7",
-        "sha256": "1jmkz6l7sj876wzyn5niyfaxshbmw9fp3g8r41k1wbjvmm5xrnsn",
-        "type": "tarball",
-        "url": "https://github.com/NixOS/nixpkgs/archive/abfd31179174133ab8131139d650297bf4da63b7.tar.gz",
-        "url_template": "https://github.com/<owner>/<repo>/archive/<rev>.tar.gz"
-    }
-}

backend/nix/sources.nix

@@ -1,194 +0,0 @@
-# This file has been generated by Niv.
-
-let
-
-  #
-  # The fetchers. fetch_<type> fetches specs of type <type>.
-  #
-
-  fetch_file = pkgs: name: spec:
-    let
-      name' = sanitizeName name + "-src";
-    in
-      if spec.builtin or true then
-        builtins_fetchurl { inherit (spec) url sha256; name = name'; }
-      else
-        pkgs.fetchurl { inherit (spec) url sha256; name = name'; };
-
-  fetch_tarball = pkgs: name: spec:
-    let
-      name' = sanitizeName name + "-src";
-    in
-      if spec.builtin or true then
-        builtins_fetchTarball { name = name'; inherit (spec) url sha256; }
-      else
-        pkgs.fetchzip { name = name'; inherit (spec) url sha256; };
-
-  fetch_git = name: spec:
-    let
-      ref =
-        if spec ? ref then spec.ref else
-          if spec ? branch then "refs/heads/${spec.branch}" else
-            if spec ? tag then "refs/tags/${spec.tag}" else
-              abort "In git source '${name}': Please specify `ref`, `tag` or `branch`!";
-      submodules = if spec ? submodules then spec.submodules else false;
-      submoduleArg =
-        let
-          nixSupportsSubmodules = builtins.compareVersions builtins.nixVersion "2.4" >= 0;
-          emptyArgWithWarning =
-            if submodules == true
-            then
-              builtins.trace
-                (
-                  "The niv input \"${name}\" uses submodules "
-                  + "but your nix's (${builtins.nixVersion}) builtins.fetchGit "
-                  + "does not support them"
-                )
-                {}
-            else {};
-        in
-          if nixSupportsSubmodules
-          then { inherit submodules; }
-          else emptyArgWithWarning;
-    in
-      builtins.fetchGit
-        ({ url = spec.repo; inherit (spec) rev; inherit ref; } // submoduleArg);
-
-  fetch_local = spec: spec.path;
-
-  fetch_builtin-tarball = name: throw
-    ''[${name}] The niv type "builtin-tarball" is deprecated. You should instead use `builtin = true`.
-        $ niv modify ${name} -a type=tarball -a builtin=true'';
-
-  fetch_builtin-url = name: throw
-    ''[${name}] The niv type "builtin-url" will soon be deprecated. You should instead use `builtin = true`.
-        $ niv modify ${name} -a type=file -a builtin=true'';
-
-  #
-  # Various helpers
-  #
-
-  # https://github.com/NixOS/nixpkgs/pull/83241/files#diff-c6f540a4f3bfa4b0e8b6bafd4cd54e8bR695
-  sanitizeName = name:
-    (
-      concatMapStrings (s: if builtins.isList s then "-" else s)
-        (
-          builtins.split "[^[:alnum:]+._?=-]+"
-            ((x: builtins.elemAt (builtins.match "\\.*(.*)" x) 0) name)
-        )
-    );
-
-  # The set of packages used when specs are fetched using non-builtins.
-  mkPkgs = sources: system:
-    let
-      sourcesNixpkgs =
-        import (builtins_fetchTarball { inherit (sources.nixpkgs) url sha256; }) { inherit system; };
-      hasNixpkgsPath = builtins.any (x: x.prefix == "nixpkgs") builtins.nixPath;
-      hasThisAsNixpkgsPath = <nixpkgs> == ./.;
-    in
-      if builtins.hasAttr "nixpkgs" sources
-      then sourcesNixpkgs
-      else if hasNixpkgsPath && ! hasThisAsNixpkgsPath then
-        import <nixpkgs> {}
-      else
-        abort
-          ''
-            Please specify either <nixpkgs> (through -I or NIX_PATH=nixpkgs=...) or
-            add a package called "nixpkgs" to your sources.json.
-          '';
-
-  # The actual fetching function.
-  fetch = pkgs: name: spec:
-
-    if ! builtins.hasAttr "type" spec then
-      abort "ERROR: niv spec ${name} does not have a 'type' attribute"
-    else if spec.type == "file" then fetch_file pkgs name spec
-    else if spec.type == "tarball" then fetch_tarball pkgs name spec
-    else if spec.type == "git" then fetch_git name spec
-    else if spec.type == "local" then fetch_local spec
-    else if spec.type == "builtin-tarball" then fetch_builtin-tarball name
-    else if spec.type == "builtin-url" then fetch_builtin-url name
-    else
-      abort "ERROR: niv spec ${name} has unknown type ${builtins.toJSON spec.type}";
-
-  # If the environment variable NIV_OVERRIDE_${name} is set, then use
-  # the path directly as opposed to the fetched source.
-  replace = name: drv:
-    let
-      saneName = stringAsChars (c: if isNull (builtins.match "[a-zA-Z0-9]" c) then "_" else c) name;
-      ersatz = builtins.getEnv "NIV_OVERRIDE_${saneName}";
-    in
-      if ersatz == "" then drv else
-        # this turns the string into an actual Nix path (for both absolute and
-        # relative paths)
-        if builtins.substring 0 1 ersatz == "/" then /. + ersatz else /. + builtins.getEnv "PWD" + "/${ersatz}";
-
-  # Ports of functions for older nix versions
-
-  # a Nix version of mapAttrs if the built-in doesn't exist
-  mapAttrs = builtins.mapAttrs or (
-    f: set: with builtins;
-    listToAttrs (map (attr: { name = attr; value = f attr set.${attr}; }) (attrNames set))
-  );
-
-  # https://github.com/NixOS/nixpkgs/blob/0258808f5744ca980b9a1f24fe0b1e6f0fecee9c/lib/lists.nix#L295
-  range = first: last: if first > last then [] else builtins.genList (n: first + n) (last - first + 1);
-
-  # https://github.com/NixOS/nixpkgs/blob/0258808f5744ca980b9a1f24fe0b1e6f0fecee9c/lib/strings.nix#L257
-  stringToCharacters = s: map (p: builtins.substring p 1 s) (range 0 (builtins.stringLength s - 1));
-
-  # https://github.com/NixOS/nixpkgs/blob/0258808f5744ca980b9a1f24fe0b1e6f0fecee9c/lib/strings.nix#L269
-  stringAsChars = f: s: concatStrings (map f (stringToCharacters s));
-  concatMapStrings = f: list: concatStrings (map f list);
-  concatStrings = builtins.concatStringsSep "";
-
-  # https://github.com/NixOS/nixpkgs/blob/8a9f58a375c401b96da862d969f66429def1d118/lib/attrsets.nix#L331
-  optionalAttrs = cond: as: if cond then as else {};
-
-  # fetchTarball version that is compatible between all the versions of Nix
-  builtins_fetchTarball = { url, name ? null, sha256 }@attrs:
-    let
-      inherit (builtins) lessThan nixVersion fetchTarball;
-    in
-      if lessThan nixVersion "1.12" then
-        fetchTarball ({ inherit url; } // (optionalAttrs (!isNull name) { inherit name; }))
-      else
-        fetchTarball attrs;
-
-  # fetchurl version that is compatible between all the versions of Nix
-  builtins_fetchurl = { url, name ? null, sha256 }@attrs:
-    let
-      inherit (builtins) lessThan nixVersion fetchurl;
-    in
-      if lessThan nixVersion "1.12" then
-        fetchurl ({ inherit url; } // (optionalAttrs (!isNull name) { inherit name; }))
-      else
-        fetchurl attrs;
-
-  # Create the final "sources" from the config
-  mkSources = config:
-    mapAttrs (
-      name: spec:
-        if builtins.hasAttr "outPath" spec
-        then abort
-          "The values in sources.json should not have an 'outPath' attribute"
-        else
-          spec // { outPath = replace name (fetch config.pkgs name spec); }
-    ) config.sources;
-
-  # The "config" used by the fetchers
-  mkConfig =
-    { sourcesFile ? if builtins.pathExists ./sources.json then ./sources.json else null
-    , sources ? if isNull sourcesFile then {} else builtins.fromJSON (builtins.readFile sourcesFile)
-    , system ? builtins.currentSystem
-    , pkgs ? mkPkgs sources system
-    }: rec {
-      # The sources, i.e. the attribute set of spec name to spec
-      inherit sources;
-
-      # The "pkgs" (evaluated nixpkgs) to use for e.g. non-builtin fetchers
-      inherit pkgs;
-    };
-
-in
-mkSources (mkConfig {}) // { __functor = _: settings: mkSources (mkConfig settings); }

backend/nix/stack-integration.nix

@@ -1,16 +0,0 @@
-let
-  sources = import ./sources.nix;
-  pkgs = import sources.nixpkgs { };
-in
-
-# See https://docs.haskellstack.org/en/stable/nix_integration/#using-a-custom-shellnix-file
-{ ghc }:
-
-pkgs.haskell.lib.buildStackProject {
-  inherit ghc;
-  name = "haskell-stack-nix";
-  # System dependencies needed at compilation time
-  buildInputs = [
-    pkgs.zlib
-  ];
-}

backend/package.yaml

@@ -33,7 +33,6 @@ dependencies:
   - lifted-base
   - mtl
   - time
-  - wai-extra
 
 ghc-options:
   - -Wall

backend/src/BroadcastUserData.hs

@@ -8,9 +8,9 @@ where
 import ClassyPrelude
 import Data.Aeson (encode)
 import Network.WebSockets qualified as WS
-import State.ConnectedClientsState (ConnectedClients, MonadConnectedClientsRead (getConnctedClients))
+import State.ConnectedClientsState (MonadConnectedClientsRead (getConnctedClients))
 import State.RoomDataState (MonadRoomDataStateRead (getRoomDataState))
-import Types.ConnectionState (Client (..))
+import Types.ConnectionState (Client (..), ConnectedClients)
 import Types.User (User, clientToUser)
 import Types.UsersData (UsersData (..))
 
@@ -41,8 +41,8 @@ broadCastToClientsGeneric ::
   Text ->
   m ()
 broadCastToClientsGeneric message = do
-  connectedClients <- getConnctedClients
+  state <- getConnctedClients
-  liftIO (broadcast message connectedClients)
+  liftIO $ broadcast message state
 
 broadcast :: Text -> ConnectedClients -> IO ()
 broadcast message clients = do

backend/src/Lib.hs

@@ -6,9 +6,9 @@ module Lib
 where
 
 import ClassyPrelude
-import State.ConnectedClientsState (initConnectionsState)
-import State.RoomsState (initRoomsState)
 import Types.AppTypes
+import Types.ConnectionState (initConnectionsState)
+import Types.RoomsState (initRoomsState)
 import WebServer (runWebServer)
 import WebSocket.Server (runWebSocketServer)
 

backend/src/RoomDataHandler.hs

@@ -16,12 +16,16 @@ import Network.Wai
     consumeRequestBodyStrict,
     responseLBS,
   )
+import State.ConnectedClientsState (MonadConnectedClientsRead)
 import State.RoomDataState
   ( MonadRoomDataStateModify (setRoomDataState),
     MonadRoomDataStateRead,
   )
-import State.RoomsState
+import Types.AppTypes (HasConnectedClientState)
-  ( roomStateDiffers,
+import Types.RoomsState
+  ( HasRoomsState,
+    roomStateDiffers,
+    updateRoomState,
   )
 import Types.WebEnv
   ( HasWebEnv (getRequest),
@@ -40,7 +44,7 @@ roomDataHandler ::
   m ResponseReceived
 roomDataHandler = do
   newRoomData <- parseBodyOrBadRequest
-  liftIO $ putStrLn "Got triggered from prosody"
+  liftIO $ putStrLn "Got triggered form prosody"
   whenM (roomStateDiffers newRoomData) $ do
     setRoomDataState newRoomData
     broadcastUserData

backend/src/State/ConnectedClientsState.hs

@@ -1,10 +1,6 @@
 module State.ConnectedClientsState
   ( MonadConnectedClientsModify (..),
     MonadConnectedClientsRead (..),
-    ConnectedClients,
-    ConnectedClientsState,
-    HasConnectedClientState (..),
-    initConnectionsState,
     addWSClientGeneric,
     updateWSClientGeneric,
     removeWSClientGeneric,
@@ -14,24 +10,14 @@ where
 
 import ClassyPrelude
 import Data.UUID
+import Types.AppTypes
 import Types.ConnectionState
 
-type ConnectedClientsState = TVar ConnectedClients
-
-initConnectionsState :: IO ConnectedClientsState
-initConnectionsState = newTVarIO newConnectedClients
-
-newConnectedClients :: ConnectedClients
-newConnectedClients = []
-
 class Monad m => MonadConnectedClientsModify m where
   addWSClient :: Client -> m ()
   removeWSClient :: UUID -> m ()
   updateWSClient :: UUID -> (Client -> Client) -> m ()
 
-class HasConnectedClientState a where
-  getConnectedClientState :: a -> ConnectedClientsState
-
 addWSClientGeneric ::
   ( HasConnectedClientState env,
     MonadReader env m,
@@ -86,7 +72,9 @@ modifyState ::
   m ()
 modifyState modifyFunc = do
   state <- getConnectedClientState <$> ask
-  atomically $ modifyTVar state modifyFunc
+  modifyMVar_ state $ \s ->
+    let s' = modifyFunc s
+     in return s'
 
 class Monad m => MonadConnectedClientsRead m where
   getConnctedClients :: m ConnectedClients
@@ -98,4 +86,4 @@ getConnctedClientsGeneric ::
   ) =>
   m ConnectedClients
 getConnctedClientsGeneric = do
-  ask >>= readTVarIO . getConnectedClientState
+  ask >>= readMVar . getConnectedClientState

backend/src/State/GenericTVarState.hs

@@ -1,11 +0,0 @@
-module State.GenericTVarState (GenericTVarState, updateGenericTVarState, getGenericTVarState) where
-
-import ClassyPrelude
-
-type GenericTVarState a = TVar a
-
-updateGenericTVarState :: (MonadIO m) => GenericTVarState a -> a -> m ()
-updateGenericTVarState tv a = atomically $ writeTVar tv a
-
-getGenericTVarState :: (MonadIO m) => GenericTVarState a -> m a
-getGenericTVarState = readTVarIO

backend/src/Types/AppTypes.hs

@@ -1,10 +1,10 @@
 {-# LANGUAGE DerivingVia #-}
 
-module Types.AppTypes (Env (..), App (..), getConnectedClientState, AppProfile (Prod, Dev)) where
+module Types.AppTypes (Env (..), App (..), getConnectedClientState, HasConnectedClientState, AppProfile (Prod, Dev)) where
 
 import ClassyPrelude
-import State.ConnectedClientsState
+import Types.ConnectionState (ConnectedClientsState)
-import State.RoomsState
+import Types.RoomsState
   ( HasRoomsState (getRoomsState),
     RoomsState,
   )
@@ -17,6 +17,9 @@ data Env = Env
     profile :: AppProfile
   }
 
+class HasConnectedClientState a where
+  getConnectedClientState :: a -> ConnectedClientsState
+
 instance HasConnectedClientState Env where
   getConnectedClientState = connectedClientsState
 

backend/src/Types/ConnectionState.hs

@@ -1,6 +1,8 @@
 module Types.ConnectionState
   ( Client (..),
+    ConnectedClientsState,
     ConnectedClients,
+    initConnectionsState,
   )
 where
 
@@ -15,4 +17,12 @@ data Client = Client
     joinedRoom :: Bool
   }
 
+type ConnectedClientsState = MVar ConnectedClients
+
 type ConnectedClients = [Client]
+
+initConnectionsState :: IO ConnectedClientsState
+initConnectionsState = newMVar newConnectedClients
+
+newConnectedClients :: ConnectedClients
+newConnectedClients = []

backend/src/Types/RoomsState.hs

@@ -1,4 +1,4 @@
-module State.RoomsState
+module Types.RoomsState
   ( RoomsState,
     initRoomsState,
     HasRoomsState (..),
@@ -9,14 +9,13 @@ module State.RoomsState
 where
 
 import ClassyPrelude
-import State.GenericTVarState
 import State.RoomDataState (MonadRoomDataStateRead (getRoomDataState))
 import Types.RoomData (RoomsData)
 
-type RoomsState = GenericTVarState RoomsData
+type RoomsState = MVar RoomsData
 
 initRoomsState :: IO RoomsState
-initRoomsState = newTVarIO []
+initRoomsState = newMVar []
 
 class HasRoomsState a where
   getRoomsState :: a -> RoomsState
@@ -30,9 +29,8 @@ updateRoomState ::
   m ()
 updateRoomState newData = do
   state <- getRoomsState <$> ask
-  liftIO $ putStrLn "Upating room state"
+  _ <- swapMVar state newData
-  updateGenericTVarState state newData
+  return ()
-  liftIO $ putStrLn "Done Upating room state"
 
 getRoomState ::
   ( HasRoomsState env,
@@ -42,7 +40,7 @@ getRoomState ::
   m RoomsData
 getRoomState = do
   state <- getRoomsState <$> ask
-  getGenericTVarState state
+  readMVar state
 
 roomStateDiffers ::
   ( MonadRoomDataStateRead m

backend/src/Types/WebEnv.hs

@@ -6,11 +6,11 @@ where
 
 import ClassyPrelude
 import Network.Wai (Request, Response, ResponseReceived)
-import State.ConnectedClientsState (HasConnectedClientState (getConnectedClientState))
-import State.RoomsState (HasRoomsState (getRoomsState))
 import Types.AppTypes
   ( Env (..),
+    HasConnectedClientState (getConnectedClientState),
   )
+import Types.RoomsState (HasRoomsState (getRoomsState))
 
 class HasWebEnv a where
   getRequest :: a -> Request

backend/src/Types/WebSocketMessages/WebSocketMessages.hs

@@ -29,22 +29,23 @@ data WebSocketMessage = ClientInfoMessage SetClientInfo | JoinRoomMessage JoinRo
 instance FromJSON WebSocketMessage where
   parseJSON = genericParseJSON defaultOptions {sumEncoding = UntaggedValue}
 
-data SetClientInfo where
+data SetClientInfo = SetClientInfo
-  SetClientInfo :: {displayName :: Text} -> SetClientInfo
+  { displayName :: Text
+  }
   deriving (Generic, Show)
 
 instance FromJSON SetClientInfo
 
-data JoinRoom where
+data JoinRoom = JoinRoom
-  JoinRoom :: {roomName :: Text} -> JoinRoom
+  { roomName :: Text
+  }
   deriving (Generic, Show)
 
 instance FromJSON JoinRoom
 
-data AllChatMessageIncoming where
+data AllChatMessageIncoming = AllChatMessageIncoming
-  AllChatMessageIncoming ::
+  { content :: Text
-    {content :: Text} ->
+  }
-    AllChatMessageIncoming
   deriving (Generic, Show)
 
 instance FromJSON AllChatMessageIncoming

backend/src/WebServer.hs

@@ -15,7 +15,6 @@ import Control.Monad.Except
 import Network.HTTP.Types
 import Network.Wai
 import Network.Wai.Handler.Warp (run)
-import Network.Wai.Middleware.RequestLogger (logStdout)
 import RoomDataHandler (roomDataHandler)
 import State.ConnectedClientsState
   ( MonadConnectedClientsRead (..),
@@ -25,11 +24,13 @@ import State.RoomDataState
   ( MonadRoomDataStateModify (..),
     MonadRoomDataStateRead (getRoomDataState),
   )
-import State.RoomsState
+import Types.AppTypes (Env (..))
-  ( getRoomState,
+import Types.RoomsState
+  ( HasRoomsState (getRoomsState),
+    getRoomState,
+    roomStateDiffers,
     updateRoomState,
   )
-import Types.AppTypes (Env (..))
 import Types.WebEnv
 
 newtype ExceptTApp e a = E {unExceptTApp :: IO (Either e a)}
@@ -145,6 +146,6 @@ runWebServer ::
   ) =>
   m ()
 runWebServer = do
-  putStrLn "Webserver up and running at http://localhost:8081/"
+  putStrLn "http://localhost:8081/"
-  runWebApp >>= liftIO . (run 8081 . logStdout)
+  runWebApp >>= liftIO . run 8081
   return ()

backend/src/WebSocket/WSApp.hs

@@ -33,11 +33,11 @@ wsApp = do
   broadcastUserData
   withCleanUp $ forever $ do
     handleWSAction
+    broadcastUserData
 
 handleWSAction ::
   ( MonadWebSocketSession m,
     MonadConnectedClientsModify m,
-    MonadRoomDataStateRead m,
     MonadBroadcast m,
     MonadAllChat m
   ) =>
@@ -47,10 +47,8 @@ handleWSAction = do
   case msg of
     JoinRoomMessage _ -> do
       joinRoom
-      broadcastUserData
     ClientInfoMessage clientInfo -> do
       updateClientName clientInfo
-      broadcastUserData
     AllChatMessageIncomingMessage incomingMessage -> do
       broadCastAllChatMessage incomingMessage
 

backend/src/WebSocket/WSReaderTApp.hs

@@ -17,8 +17,7 @@ import ClassyPrelude
 import Data.UUID
 import Network.WebSockets qualified as WS
 import State.ConnectedClientsState
-  ( HasConnectedClientState,
+  ( MonadConnectedClientsModify (..),
-    MonadConnectedClientsModify (..),
     MonadConnectedClientsRead (..),
     addWSClientGeneric,
     getConnctedClientsGeneric,
@@ -26,8 +25,8 @@ import State.ConnectedClientsState
     updateWSClientGeneric,
   )
 import State.RoomDataState
-import State.RoomsState (HasRoomsState (..), getRoomState)
 import Types.AppTypes
+import Types.RoomsState (HasRoomsState (..), getRoomState)
 
 data WSEnv = WSEnv
   { appEnv :: Env,

backend/stack.yaml

@@ -16,7 +16,7 @@
 # this way we can use prebuild binaries for hls
 #resolver: nightly-2022-11-12
 #resolver: ghc-9.2.4
-resolver: lts-20.26
+resolver: lts-20.16
 #
 # The location of a snapshot can be provided as a file or url. Stack assumes
 # a snapshot provided as a file might change, whereas a url resource does not.

backend/stack.yaml.lock

@@ -6,7 +6,7 @@
 packages: []
 snapshots:
 - completed:
-    sha256: 5a59b2a405b3aba3c00188453be172b85893cab8ebc352b1ef58b0eae5d248a2
+    sha256: dad15e2ec0c09280a5c2e07190fb18710fc54472f029f34f861f686540824d81
-    size: 650475
+    size: 649592
-    url: https://raw.githubusercontent.com/commercialhaskell/stackage-snapshots/master/lts/20/26.yaml
+    url: https://raw.githubusercontent.com/commercialhaskell/stackage-snapshots/master/lts/20/16.yaml
-  original: lts-20.26
+  original: lts-20.16

frontend/index.html

@@ -2,7 +2,7 @@
 <html lang="en">
   <head>
     <meta charset="UTF-8" />
-    <link rel="icon" href="/favicon.ico" />
+    <link rel="icon" type="image/svg+xml" href="/vite.svg" />
     <meta name="viewport" content="width=device-width, initial-scale=1.0" />
     <title>FF Jitsi Rooms</title>
   </head>

frontend/public/vite.svg

@@ -0,0 +1 @@
+<svg xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" aria-hidden="true" role="img" class="iconify iconify--logos" width="31.88" height="32" preserveAspectRatio="xMidYMid meet" viewBox="0 0 256 257"><defs><linearGradient id="IconifyId1813088fe1fbc01fb466" x1="-.828%" x2="57.636%" y1="7.652%" y2="78.411%"><stop offset="0%" stop-color="#41D1FF"></stop><stop offset="100%" stop-color="#BD34FE"></stop></linearGradient><linearGradient id="IconifyId1813088fe1fbc01fb467" x1="43.376%" x2="50.316%" y1="2.242%" y2="89.03%"><stop offset="0%" stop-color="#FFEA83"></stop><stop offset="8.333%" stop-color="#FFDD35"></stop><stop offset="100%" stop-color="#FFA800"></stop></linearGradient></defs><path fill="url(#IconifyId1813088fe1fbc01fb466)" d="M255.153 37.938L134.897 252.976c-2.483 4.44-8.862 4.466-11.382.048L.875 37.958c-2.746-4.814 1.371-10.646 6.827-9.67l120.385 21.517a6.537 6.537 0 0 0 2.322-.004l117.867-21.483c5.438-.991 9.574 4.796 6.877 9.62Z"></path><path fill="url(#IconifyId1813088fe1fbc01fb467)" d="M185.432.063L96.44 17.501a3.268 3.268 0 0 0-2.634 3.014l-5.474 92.456a3.268 3.268 0 0 0 3.997 3.378l24.777-5.718c2.318-.535 4.413 1.507 3.936 3.838l-7.361 36.047c-.495 2.426 1.782 4.5 4.151 3.78l15.304-4.649c2.372-.72 4.652 1.36 4.15 3.788l-11.698 56.621c-.732 3.542 3.979 5.473 5.943 2.437l1.313-2.028l72.516-144.72c1.215-2.423-.88-5.186-3.54-4.672l-25.505 4.922c-2.396.462-4.435-1.77-3.759-4.114l16.646-57.705c.677-2.35-1.37-4.583-3.769-4.113Z"></path></svg>

frontend/src/App.tsx

@@ -20,7 +20,6 @@ function App() {
           conferenceData={conferenceData}
           setConferenceData={setConferenceData}
           userInfo={userInfo}
-          usersData={roomData}
         />
       </div>
     )

frontend/src/components/jitsi/JitsiEntrypoint.tsx

@@ -27,7 +27,7 @@ function JitsiEntrypoint({ roomName, userInfo, conferenceData, setConferenceData
       domain={JITSI_DOMAIN}
       roomName={roomName}
       configOverwrite={{
-        startWithAudioMuted: false,
+        startWithAudioMuted: true,
         disableModeratorIndicator: true,
         startScreenSharing: true,
         enableEmailInStats: false,

frontend/src/components/meeting/Meeting.css

@@ -1,7 +0,0 @@
-.meeting-quickjoin {
-  text-align: center
-}
-
-.meeting {
-  flex-grow: 3;
-}

frontend/src/components/meeting/Meeting.tsx

@@ -1,27 +1,19 @@
 import { ConferenceData } from '../../background/jitsi/eventListeners'
-import { UsersData } from '../../background/types/roomData'
 import useMeetingStarted from '../../hooks/useMeetingStarted'
 import { useRoomName } from '../../hooks/useRoomName'
 import JitsiEntrypoint from '../jitsi/JitsiEntrypoint'
 import { UserInfo } from '../jitsi/types'
 import MeetingNameInput from './MeetingNameInput'
-import './Meeting.css'
-import React from 'react'
 
 interface Props {
   conferenceData: ConferenceData | undefined
   setConferenceData: (newData: ConferenceData) => void
   userInfo: UserInfo
-  usersData: UsersData
 }
 
-function Meeting(props: Props) {
+function Meeting({ conferenceData, setConferenceData, userInfo }: Props) {
-  const { conferenceData, setConferenceData, userInfo, usersData } = props
-  console.log("[Rooms] meeting usersData", props)
   const [meetingStarted] = useMeetingStarted()
   const { roomName } = useRoomName()
-  const [_, setMeetingStarted] = useMeetingStarted()
-  const { updateAndSubmitRoomName: updateAndSubmitRoomName } = useRoomName()
 
   if (meetingStarted) {
     return (
@@ -34,32 +26,7 @@ function Meeting(props: Props) {
     )
   }
 
-  return (
+  return <MeetingNameInput roomName={roomName} currentUser={userInfo.displayName} />
-    <div className="meeting">
-      <MeetingNameInput roomName={roomName} currentUser={userInfo.displayName} />
-      <div className="meeting-quickjoin">
-        {usersData?.roomsData.map((roomData) => {
-          return (
-            <React.Fragment key={roomData.roomName}>
-              <h3>
-                <a
-                  href="#"
-                  onClick={() => {
-                    updateAndSubmitRoomName(roomData.roomName)
-                    setMeetingStarted(true)
-                  }}
-                >
-                  {decodeURI(roomData.roomName)}
-                </a>
-              </h3>
-              {roomData.participants.map((participant) => (
-                <div key={participant.jid}> {participant.displayName} </div>
-              ))}
-            </React.Fragment>
-          )
-        })}
-      </div>
-    </div>)
 }
 
 export default Meeting

frontend/src/components/meeting/MeetingNameInput.tsx

@@ -8,7 +8,7 @@ function MeetingNameInput(props: { roomName: string; currentUser: string }) {
   const [_, setMeetingStarted] = useMeetingStarted()
 
   const onInput: React.ChangeEventHandler<HTMLInputElement> = (event) => {
-    updateRoomName(encodeURI(event.target.value))
+    updateRoomName(event.target.value)
     event.preventDefault()
   }
 
@@ -23,7 +23,7 @@ function MeetingNameInput(props: { roomName: string; currentUser: string }) {
     <div className="meeting-name-input">
       <h1>Greetings {props.currentUser}</h1>
       <form onSubmit={onSubmit}>
-        <input placeholder="Roomname" type="text" value={decodeURI(roomName)} onChange={onInput} />
+        <input placeholder="Roomname" type="text" value={roomName} onChange={onInput} />
         <button type="submit">Enter the adventure</button>
       </form>
     </div>

frontend/src/components/sidebar/Sidebar.css

@@ -1,5 +1,4 @@
 .sidebar {
-  resize: horizontal;
   display: flex;
   flex-direction: column;
   white-space: nowrap;

frontend/src/components/sidebar/Sidebar.tsx

@@ -5,7 +5,6 @@ import { UsersData } from '../../background/types/roomData'
 import useMeetingStarted from '../../hooks/useMeetingStarted'
 import { useRoomName } from '../../hooks/useRoomName'
 import Chat from '../chat/Chat'
-import React from 'react'
 
 interface Props {
   usersData: UsersData
@@ -23,7 +22,7 @@ function Sidebar(props: Props) {
       <div className="sidebar-body">
         {props.usersData.roomsData.map((roomData) => {
           return (
-            <React.Fragment key={roomData.roomName}>
+            <>
               <h3>
                 <a
                   href="#"
@@ -32,18 +31,18 @@ function Sidebar(props: Props) {
                     setMeetingStarted(true)
                   }}
                 >
-                  {decodeURI(roomData.roomName)}
+                  {roomData.roomName}
                 </a>
               </h3>
               {roomData.participants.map((participant) => (
                 <div key={participant.jid}> {participant.displayName} </div>
               ))}
-            </React.Fragment>
+            </>
           )
         })}
       </div>
       <div>
-        <h3>No room</h3>
+        <h3> No room</h3>
         {props.usersData.usersWithOutRoom.map((user) => (
           <div key={user.uuid}>{user.name}</div>
         ))}

frontend/src/components/sidebar/useSidebarVisibility.ts

@@ -20,7 +20,7 @@ function useSidebarVisibility() {
   return { sidebarVisibility, toggleSidebarVisibility, sidebarToggleText }
 }
 const getSidebarToggleText = (sidebarVisibility: sidebarVisibilityOptions) => {
-  if (sidebarVisibility === 'full') return '<--'
+  if (sidebarVisibility === 'full') return '<-'
   if (sidebarVisibility === 'small') return '<-'
   if (sidebarVisibility === 'hidden') return '->'
 }

frontend/src/hooks/useBackendData.ts

@@ -7,23 +7,20 @@ import useWebSocketConnection from './useWebSocketConnection'
 function useBackendData(userInfo: UserInfo) {
   console.log('[Rooms] useBackendData')
 
-  const { onMessage, cleanUpOnMessage, sendMessage, disconnect } = useWebSocketConnection(userInfo)
+  const { onMessage, sendMessage, disconnect } = useWebSocketConnection(userInfo)
   const { roomData, setRoomData } = useRoomData()
   const { addChatMessage } = useAllChat()
 
   useEffect(() => {
-    console.log('[Rooms] add onMessage Listener')
+    onMessage((messageString) => {
-    const messageCallback = (messageString: string) => {
       console.log('[Rooms] message from ws', messageString)
       const messageObject = JSON.parse(messageString)
 
       !!messageObject.roomsData && setRoomData(messageObject)
       !!messageObject.content && addChatMessage(messageObject)
       return disconnect
-    }
+    })
-    onMessage(messageCallback)
+  }, [onMessage, setRoomData, disconnect])
-    return () => cleanUpOnMessage(messageCallback)
-  }, [])
 
   return { roomData, sendMessage }
 }

frontend/src/hooks/useRoomData.ts

@@ -2,15 +2,7 @@ import { useState } from 'react'
 import { UsersData } from '../background/types/roomData'
 
 function useRoomData() {
-  const [roomData, setRoomDataInternal] = useState<UsersData>()
+  const [roomData, setRoomData] = useState<UsersData>()
-
-  const setRoomData = (usersData: UsersData) => {
-    usersData.roomsData = usersData.roomsData.map((roomData) => {
-      roomData.roomName = decodeURI(roomData.roomName)
-      return roomData
-    })
-    setRoomDataInternal(usersData)
-  }
 
   return { roomData, setRoomData }
 }

frontend/src/hooks/useRoomName.ts

@@ -1,5 +1,5 @@
 import { atom, useAtom } from 'jotai'
-import { useCallback } from 'react'
+import { useCallback, useState } from 'react'
 
 const roomNameAtom = atom(getRoomNameFromUrl())
 
@@ -46,7 +46,7 @@ function setRoomNameInUrl(roomName: string) {
 
 function setRoomNameInTitle(roomName: string) {
   if (!!roomName) {
-    document.title = decodeURI(roomName)
+    document.title = roomName
   }
 }
 

frontend/src/hooks/useWebSocketConnection.ts

@@ -1,19 +1,19 @@
-import { atom, useAtom } from 'jotai'
+import { useCallback, useState } from 'react'
-import { useCallback, useEffect } from 'react'
 import { WEBSOCKET_URL } from '../background/constants'
 import { UserInfo } from '../components/jitsi/types'
 
+const createWebSocketConnection = (userInfo: UserInfo) => {
+  const webSocket = new WebSocket(WEBSOCKET_URL)
+  console.log('[Rooms] createWebSocketConnection')
+  webSocket.addEventListener('open', (_: Event) => webSocket.send(JSON.stringify(userInfo)))
 
-const webSocket = new WebSocket(WEBSOCKET_URL)
+  return webSocket
-const webSocketConnectionAtom = atom(webSocket)
+}
 
 function useWebSocketConnection(userInfo: UserInfo) {
   console.log('[Rooms] useWebSocketConnection')
 
-  const [webSocketConnection] = useAtom(webSocketConnectionAtom)
+  const [webSocketConnection] = useState<WebSocket>(() => createWebSocketConnection(userInfo))
-  useEffect(() => {
-    sendMessageNowOrLater(webSocketConnection, JSON.stringify(userInfo))
-  }, [webSocketConnection, userInfo]);
 
   const sendMessage = useCallback(
     (message: string) => {
@@ -37,19 +37,8 @@ function useWebSocketConnection(userInfo: UserInfo) {
   )
 
   const disconnect = useCallback(webSocketConnection.close, [webSocketConnection])
-  const cleanUpOnMessage = useCallback((callbackToRemove: any) => {
-    console.log('[Rooms] cleanUpOnMessage')
-    webSocketConnection.removeEventListener('message', callbackToRemove)
-  }, [webSocketConnection])
 
-  return { onMessage, cleanUpOnMessage, sendMessage, disconnect }
+  return { onMessage, sendMessage, disconnect }
-}
-
-const sendMessageNowOrLater = (webSocket: WebSocket, message: string) => {
-  if (webSocket.readyState !== WebSocket.OPEN) {
-    return webSocket.addEventListener('open', (_: Event) => webSocket.send(message))
-  }
-  webSocket.send(message)
 }
 
 export default useWebSocketConnection

frontend/src/index.css

@@ -51,9 +51,7 @@ button {
   background-color: #1a1a1a;
   cursor: pointer;
   transition: border-color 0.25s;
-  color: white;
 }
-
 button:hover {
   border-color: #646cff;
 }
@@ -62,6 +60,19 @@ button:focus-visible {
   outline: 4px auto -webkit-focus-ring-color;
 }
 
+@media (prefers-color-scheme: light) {
+  :root {
+    color: #213547;
+    background-color: #ffffff;
+  }
+  a:hover {
+    color: #747bff;
+  }
+  button {
+    background-color: #f9f9f9;
+  }
+}
+
 #root {
   height: 100%;
   width: 100%;
@@ -81,5 +92,4 @@ input {
   background-color: #2b2a33;
   border-color: #646cff;
   border-radius: 8px;
-  color: white;
 }

prodsody/Readme.md

@@ -10,7 +10,7 @@
 ### Get started
 
 - run `./run_dev.sh`
-- open [https://localhost:8443/](https://localhost:8443/) (accept the risk about self-signed certs)
+- open [https://localhost:8443/](https://localhost:8443/)
 - make changes to mod_jitsi_rooms.lua and save the file
 - prosody will be restarted
 - join a room in jitsi

prodsody/docker-compose.yml

@@ -347,7 +347,7 @@ services:
       meet.jitsi:
 
   jitsi-rooms:
-    image: jitsi-rooms
+    image: jitsi-rooms:67y5d9y2zbi7wkqm2jpcjj1k2614qwx2
     restart: ${RESTART_POLICY:-unless-stopped}
     ports:
       - '9160:9160'

prodsody/jitsi-meet-cfg/prosody/prosody-plugins-custom/mod_jitsi_rooms.lua

@@ -4,7 +4,6 @@ local json = require "util.json";
 local array = require "util.array";
 local iterators = require "util.iterators";
 local jid = require "util.jid";
-local http = require "util.http";
 
 local async_handler_wrapper = module:require "util".async_handler_wrapper;
 local get_room_from_jid = module:require "util".get_room_from_jid;
@@ -13,9 +12,9 @@ local domain_name = "meet.jitsi"
 
 
 function get_participants_for_room(room_name)
+
     local room_address = jid.join(room_name, muc_domain_prefix .. "." .. domain_name);
-    local decoded_room_address = http.urldecode(room_address);
+    local room = get_room_from_jid(room_address);
-    local room = get_room_from_jid(decoded_room_address);
     local occupants_json = array();
     if room then
         local occupants = room._occupants;
@@ -48,6 +47,7 @@ function get_participants_for_room(room_name)
 end
 
 function get_all_rooms_with_participants()
+
     local sessions = prosody.full_sessions;
 
     local someTable = (it.join(it.keys(sessions)));
@@ -74,7 +74,7 @@ end
 -- @return GET response, containing a json with participants details
 function handle_get_sessions(event)
     handle_room_event()
-    return { status_code = 200, body = get_all_rooms_with_participants() };
+    return { status_code = 200; body = get_all_rooms_with_participants() };
 end
 
 function module.load()
@@ -86,9 +86,9 @@ function module.load()
     module:log("info", "Hello! You can reach me at: %s", module:http_url());
     module:provides("http", {
         route = {
-            ["GET"] = function(event) return async_handler_wrapper(event, handle_get_sessions) end,
+            ["GET"] = function(event) return async_handler_wrapper(event, handle_get_sessions) end;
 
-        },
+        };
     });
 end
 
@@ -125,6 +125,7 @@ end
 
 --- Checks if event is triggered by healthchecks or focus user.
 function is_system_event(event)
+
     if event == nil or event.room == nil or event.room.jid == nil then
         return true;
     end
@@ -146,11 +147,12 @@ function handle_room_event(event)
         return;
     end
 
-    async_http_request("http://jitsi-rooms:8081/roomdata",
+    async_http_request("http://192.168.2.116:8081/roomdata",
         {
             method = "POST",
             body = get_all_rooms_with_participants()
         })
+
 end
 
 --Helper function to wait till a component is loaded before running the given callback

prodsody/mod_jitsi_rooms.lua

@@ -4,7 +4,6 @@ local json = require "util.json";
 local array = require "util.array";
 local iterators = require "util.iterators";
 local jid = require "util.jid";
-local http = require "util.http";
 
 local async_handler_wrapper = module:require "util".async_handler_wrapper;
 local get_room_from_jid = module:require "util".get_room_from_jid;
@@ -13,9 +12,9 @@ local domain_name = "meet.jitsi"
 
 
 function get_participants_for_room(room_name)
+
     local room_address = jid.join(room_name, muc_domain_prefix .. "." .. domain_name);
-    local decoded_room_address = http.urldecode(room_address);
+    local room = get_room_from_jid(room_address);
-    local room = get_room_from_jid(decoded_room_address);
     local occupants_json = array();
     if room then
         local occupants = room._occupants;
@@ -48,6 +47,7 @@ function get_participants_for_room(room_name)
 end
 
 function get_all_rooms_with_participants()
+
     local sessions = prosody.full_sessions;
 
     local someTable = (it.join(it.keys(sessions)));
@@ -74,7 +74,7 @@ end
 -- @return GET response, containing a json with participants details
 function handle_get_sessions(event)
     handle_room_event()
-    return { status_code = 200, body = get_all_rooms_with_participants() };
+    return { status_code = 200; body = get_all_rooms_with_participants() };
 end
 
 function module.load()
@@ -86,9 +86,9 @@ function module.load()
     module:log("info", "Hello! You can reach me at: %s", module:http_url());
     module:provides("http", {
         route = {
-            ["GET"] = function(event) return async_handler_wrapper(event, handle_get_sessions) end,
+            ["GET"] = function(event) return async_handler_wrapper(event, handle_get_sessions) end;
 
-        },
+        };
     });
 end
 
@@ -125,6 +125,7 @@ end
 
 --- Checks if event is triggered by healthchecks or focus user.
 function is_system_event(event)
+
     if event == nil or event.room == nil or event.room.jid == nil then
         return true;
     end
@@ -146,11 +147,12 @@ function handle_room_event(event)
         return;
     end
 
-    async_http_request("http://jitsi-rooms:8081/roomdata",
+    async_http_request("http://192.168.2.116:8081/roomdata",
         {
             method = "POST",
             body = get_all_rooms_with_participants()
         })
+
 end
 
 --Helper function to wait till a component is loaded before running the given callback
@@ -198,9 +200,9 @@ run_when_component_loaded(main_muc_component_host, function(host_module, host_na
         main_muc_service = main_muc; -- so it can be accessed from breakout muc event handlers
 
         -- the following must run after speakerstats (priority -1)
-        main_module:hook("muc-room-created", handle_room_event, -3);  -- must run after handle_main_room_created
+        main_module:hook("muc-room-created", handle_room_event, -3); -- must run after handle_main_room_created
         main_module:hook("muc-occupant-joined", handle_room_event, -2);
-        main_module:hook("muc-occupant-left", handle_room_event, -2); -- see also https://issues.prosody.im/1743
+        main_module:hook("muc-occupant-left", handle_room_event, -2);
         main_module:hook("muc-room-destroyed", handle_room_event, -2);
     end);
 end);