From 54701c196a9052de5410ebed16a9605d0fc10faf Mon Sep 17 00:00:00 2001 From: qvalentin Date: Sun, 15 Jan 2023 16:38:57 +0100 Subject: [PATCH] init backend --- backend/.gitignore | 2 + backend/CHANGELOG.md | 11 + backend/LICENSE | 30 +++ backend/README.md | 1 + backend/Setup.hs | 2 + backend/app/Main.hs | 6 + backend/jitsi-rooms.cabal | 61 +++++ backend/package.yaml | 59 +++++ backend/src/Lib.hs | 7 + backend/stack.yaml | 67 ++++++ backend/stack.yaml.lock | 13 ++ backend/test/Spec.hs | 2 + README.md => frontend/README.md | 0 index.html => frontend/index.html | 0 package.json => frontend/package.json | 0 {public => frontend/public}/vite.svg | 0 {src => frontend/src}/App.css | 0 {src => frontend/src}/App.tsx | 0 {src => frontend/src}/assets/react.svg | 0 {src => frontend/src}/background/constants.ts | 0 .../src}/components/jitsi/JitsiEntrypoint.tsx | 0 .../src}/components/jitsi/types.ts | 0 .../src}/components/meeting/Meeting.tsx | 0 .../components/meeting/MeetingNameInput.css | 0 .../components/meeting/MeetingNameInput.tsx | 0 .../src}/components/sidebar/Sidebar.css | 0 .../src}/components/sidebar/Sidebar.tsx | 0 .../src}/components/sidebar/SidebarHeader.tsx | 0 .../sidebar/useSidebarVisibility.ts | 0 {src => frontend/src}/hooks/useRoomName.ts | 0 {src => frontend/src}/index.css | 0 {src => frontend/src}/main.tsx | 0 {src => frontend/src}/vite-env.d.ts | 0 tsconfig.json => frontend/tsconfig.json | 0 .../tsconfig.node.json | 0 vite.config.ts => frontend/vite.config.ts | 0 yarn.lock => frontend/yarn.lock | 0 prodsody/mod_jitsi_rooms.lua | 219 ++++++++++++++++++ 38 files changed, 480 insertions(+) create mode 100644 backend/.gitignore create mode 100644 backend/CHANGELOG.md create mode 100644 backend/LICENSE create mode 100644 backend/README.md create mode 100644 backend/Setup.hs create mode 100644 backend/app/Main.hs create mode 100644 backend/jitsi-rooms.cabal create mode 100644 backend/package.yaml create mode 100644 backend/src/Lib.hs create mode 100644 backend/stack.yaml create mode 100644 backend/stack.yaml.lock create mode 100644 backend/test/Spec.hs rename README.md => frontend/README.md (100%) rename index.html => frontend/index.html (100%) rename package.json => frontend/package.json (100%) rename {public => frontend/public}/vite.svg (100%) rename {src => frontend/src}/App.css (100%) rename {src => frontend/src}/App.tsx (100%) rename {src => frontend/src}/assets/react.svg (100%) rename {src => frontend/src}/background/constants.ts (100%) rename {src => frontend/src}/components/jitsi/JitsiEntrypoint.tsx (100%) rename {src => frontend/src}/components/jitsi/types.ts (100%) rename {src => frontend/src}/components/meeting/Meeting.tsx (100%) rename {src => frontend/src}/components/meeting/MeetingNameInput.css (100%) rename {src => frontend/src}/components/meeting/MeetingNameInput.tsx (100%) rename {src => frontend/src}/components/sidebar/Sidebar.css (100%) rename {src => frontend/src}/components/sidebar/Sidebar.tsx (100%) rename {src => frontend/src}/components/sidebar/SidebarHeader.tsx (100%) rename {src => frontend/src}/components/sidebar/useSidebarVisibility.ts (100%) rename {src => frontend/src}/hooks/useRoomName.ts (100%) rename {src => frontend/src}/index.css (100%) rename {src => frontend/src}/main.tsx (100%) rename {src => frontend/src}/vite-env.d.ts (100%) rename tsconfig.json => frontend/tsconfig.json (100%) rename tsconfig.node.json => frontend/tsconfig.node.json (100%) rename vite.config.ts => frontend/vite.config.ts (100%) rename yarn.lock => frontend/yarn.lock (100%) create mode 100644 prodsody/mod_jitsi_rooms.lua diff --git a/backend/.gitignore b/backend/.gitignore new file mode 100644 index 0000000..c368d45 --- /dev/null +++ b/backend/.gitignore @@ -0,0 +1,2 @@ +.stack-work/ +*~ \ No newline at end of file diff --git a/backend/CHANGELOG.md b/backend/CHANGELOG.md new file mode 100644 index 0000000..69f4028 --- /dev/null +++ b/backend/CHANGELOG.md @@ -0,0 +1,11 @@ +# Changelog for `jitsi-rooms` + +All notable changes to this project will be documented in this file. + +The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/), +and this project adheres to the +[Haskell Package Versioning Policy](https://pvp.haskell.org/). + +## Unreleased + +## 0.1.0.0 - YYYY-MM-DD diff --git a/backend/LICENSE b/backend/LICENSE new file mode 100644 index 0000000..c5b6c16 --- /dev/null +++ b/backend/LICENSE @@ -0,0 +1,30 @@ +Copyright Author name here (c) 2023 + +All rights reserved. + +Redistribution and use in source and binary forms, with or without +modification, are permitted provided that the following conditions are met: + + * Redistributions of source code must retain the above copyright + notice, this list of conditions and the following disclaimer. + + * Redistributions in binary form must reproduce the above + copyright notice, this list of conditions and the following + disclaimer in the documentation and/or other materials provided + with the distribution. + + * Neither the name of Author name here nor the names of other + contributors may be used to endorse or promote products derived + from this software without specific prior written permission. + +THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS +"AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT +LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR +A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT +OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, +SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT +LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, +DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY +THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT +(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE +OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. diff --git a/backend/README.md b/backend/README.md new file mode 100644 index 0000000..df37730 --- /dev/null +++ b/backend/README.md @@ -0,0 +1 @@ +# jitsi-rooms diff --git a/backend/Setup.hs b/backend/Setup.hs new file mode 100644 index 0000000..9a994af --- /dev/null +++ b/backend/Setup.hs @@ -0,0 +1,2 @@ +import Distribution.Simple +main = defaultMain diff --git a/backend/app/Main.hs b/backend/app/Main.hs new file mode 100644 index 0000000..4c6b30f --- /dev/null +++ b/backend/app/Main.hs @@ -0,0 +1,6 @@ +module Main (main) where + +import Lib + +main :: IO () +main = someFunc diff --git a/backend/jitsi-rooms.cabal b/backend/jitsi-rooms.cabal new file mode 100644 index 0000000..6e16372 --- /dev/null +++ b/backend/jitsi-rooms.cabal @@ -0,0 +1,61 @@ +cabal-version: 1.12 + +-- This file has been generated from package.yaml by hpack version 0.35.1. +-- +-- see: https://github.com/sol/hpack + +name: jitsi-rooms +version: 0.1.0.0 +description: Please see the README on GitHub at +homepage: https://github.com/githubuser/jitsi-rooms#readme +bug-reports: https://github.com/githubuser/jitsi-rooms/issues +author: Author name here +maintainer: example@example.com +copyright: 2023 Author name here +license: BSD3 +license-file: LICENSE +build-type: Simple +extra-source-files: + README.md + CHANGELOG.md + +source-repository head + type: git + location: https://github.com/githubuser/jitsi-rooms + +library + exposed-modules: + Lib + other-modules: + Paths_jitsi_rooms + hs-source-dirs: + src + ghc-options: -Wall -Wcompat -Widentities -Wincomplete-record-updates -Wincomplete-uni-patterns -Wmissing-export-lists -Wmissing-home-modules -Wpartial-fields -Wredundant-constraints + build-depends: + base >=4.7 && <5 + default-language: Haskell2010 + +executable jitsi-rooms-exe + main-is: Main.hs + other-modules: + Paths_jitsi_rooms + hs-source-dirs: + app + ghc-options: -Wall -Wcompat -Widentities -Wincomplete-record-updates -Wincomplete-uni-patterns -Wmissing-export-lists -Wmissing-home-modules -Wpartial-fields -Wredundant-constraints -threaded -rtsopts -with-rtsopts=-N + build-depends: + base >=4.7 && <5 + , jitsi-rooms + default-language: Haskell2010 + +test-suite jitsi-rooms-test + type: exitcode-stdio-1.0 + main-is: Spec.hs + other-modules: + Paths_jitsi_rooms + hs-source-dirs: + test + ghc-options: -Wall -Wcompat -Widentities -Wincomplete-record-updates -Wincomplete-uni-patterns -Wmissing-export-lists -Wmissing-home-modules -Wpartial-fields -Wredundant-constraints -threaded -rtsopts -with-rtsopts=-N + build-depends: + base >=4.7 && <5 + , jitsi-rooms + default-language: Haskell2010 diff --git a/backend/package.yaml b/backend/package.yaml new file mode 100644 index 0000000..46307d1 --- /dev/null +++ b/backend/package.yaml @@ -0,0 +1,59 @@ +name: jitsi-rooms +version: 0.1.0.0 +github: "githubuser/jitsi-rooms" +license: BSD3 +author: "Author name here" +maintainer: "example@example.com" +copyright: "2023 Author name here" + +extra-source-files: +- README.md +- CHANGELOG.md + +# Metadata used when publishing your package +# synopsis: Short description of your package +# category: Web + +# To avoid duplicated efforts in documentation and dealing with the +# complications of embedding Haddock markup inside cabal files, it is +# common to point users to the README.md file. +description: Please see the README on GitHub at + +dependencies: +- base >= 4.7 && < 5 + +ghc-options: +- -Wall +- -Wcompat +- -Widentities +- -Wincomplete-record-updates +- -Wincomplete-uni-patterns +- -Wmissing-export-lists +- -Wmissing-home-modules +- -Wpartial-fields +- -Wredundant-constraints + +library: + source-dirs: src + +executables: + jitsi-rooms-exe: + main: Main.hs + source-dirs: app + ghc-options: + - -threaded + - -rtsopts + - -with-rtsopts=-N + dependencies: + - jitsi-rooms + +tests: + jitsi-rooms-test: + main: Spec.hs + source-dirs: test + ghc-options: + - -threaded + - -rtsopts + - -with-rtsopts=-N + dependencies: + - jitsi-rooms diff --git a/backend/src/Lib.hs b/backend/src/Lib.hs new file mode 100644 index 0000000..58a29cb --- /dev/null +++ b/backend/src/Lib.hs @@ -0,0 +1,7 @@ +module Lib + ( someFunc + ) where + +someFunc :: IO () +someFunc = putS + diff --git a/backend/stack.yaml b/backend/stack.yaml new file mode 100644 index 0000000..078a301 --- /dev/null +++ b/backend/stack.yaml @@ -0,0 +1,67 @@ +# This file was automatically generated by 'stack init' +# +# Some commonly used options have been documented as comments in this file. +# For advanced use and comprehensive documentation of the format, please see: +# https://docs.haskellstack.org/en/stable/yaml_configuration/ + +# Resolver to choose a 'specific' stackage snapshot or a compiler version. +# A snapshot resolver dictates the compiler version and the set of packages +# to be used for project dependencies. For example: +# +# resolver: lts-3.5 +# resolver: nightly-2015-09-21 +# resolver: ghc-7.10.2 +# +# 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. +# +# resolver: ./custom-snapshot.yaml +# resolver: https://example.com/snapshots/2018-01-01.yaml +resolver: + url: https://raw.githubusercontent.com/commercialhaskell/stackage-snapshots/master/lts/20/6.yaml + +# User packages to be built. +# Various formats can be used as shown in the example below. +# +# packages: +# - some-directory +# - https://example.com/foo/bar/baz-0.0.2.tar.gz +# subdirs: +# - auto-update +# - wai +packages: +- . +# Dependency packages to be pulled from upstream that are not in the resolver. +# These entries can reference officially published versions as well as +# forks / in-progress versions pinned to a git hash. For example: +# +# extra-deps: +# - acme-missiles-0.3 +# - git: https://github.com/commercialhaskell/stack.git +# commit: e7b331f14bcffb8367cd58fbfc8b40ec7642100a +# +# extra-deps: [] + +# Override default flag values for local packages and extra-deps +# flags: {} + +# Extra package databases containing global packages +# extra-package-dbs: [] + +# Control whether we use the GHC we find on the path +# system-ghc: true +# +# Require a specific version of stack, using version ranges +# require-stack-version: -any # Default +# require-stack-version: ">=2.7" +# +# Override the architecture used by stack, especially useful on Windows +# arch: i386 +# arch: x86_64 +# +# Extra directories used by stack for building +# extra-include-dirs: [/path/to/dir] +# extra-lib-dirs: [/path/to/dir] +# +# Allow a newer minor version of GHC than the snapshot specifies +# compiler-check: newer-minor diff --git a/backend/stack.yaml.lock b/backend/stack.yaml.lock new file mode 100644 index 0000000..ccf34b4 --- /dev/null +++ b/backend/stack.yaml.lock @@ -0,0 +1,13 @@ +# This file was autogenerated by Stack. +# You should not edit this file by hand. +# For more information, please see the documentation at: +# https://docs.haskellstack.org/en/stable/lock_files + +packages: [] +snapshots: +- completed: + sha256: 4905c93319aa94aa53da8f41d614d7bacdbfe6c63a8c6132d32e6e62f24a9af4 + size: 649315 + url: https://raw.githubusercontent.com/commercialhaskell/stackage-snapshots/master/lts/20/6.yaml + original: + url: https://raw.githubusercontent.com/commercialhaskell/stackage-snapshots/master/lts/20/6.yaml diff --git a/backend/test/Spec.hs b/backend/test/Spec.hs new file mode 100644 index 0000000..cd4753f --- /dev/null +++ b/backend/test/Spec.hs @@ -0,0 +1,2 @@ +main :: IO () +main = putStrLn "Test suite not yet implemented" diff --git a/README.md b/frontend/README.md similarity index 100% rename from README.md rename to frontend/README.md diff --git a/index.html b/frontend/index.html similarity index 100% rename from index.html rename to frontend/index.html diff --git a/package.json b/frontend/package.json similarity index 100% rename from package.json rename to frontend/package.json diff --git a/public/vite.svg b/frontend/public/vite.svg similarity index 100% rename from public/vite.svg rename to frontend/public/vite.svg diff --git a/src/App.css b/frontend/src/App.css similarity index 100% rename from src/App.css rename to frontend/src/App.css diff --git a/src/App.tsx b/frontend/src/App.tsx similarity index 100% rename from src/App.tsx rename to frontend/src/App.tsx diff --git a/src/assets/react.svg b/frontend/src/assets/react.svg similarity index 100% rename from src/assets/react.svg rename to frontend/src/assets/react.svg diff --git a/src/background/constants.ts b/frontend/src/background/constants.ts similarity index 100% rename from src/background/constants.ts rename to frontend/src/background/constants.ts diff --git a/src/components/jitsi/JitsiEntrypoint.tsx b/frontend/src/components/jitsi/JitsiEntrypoint.tsx similarity index 100% rename from src/components/jitsi/JitsiEntrypoint.tsx rename to frontend/src/components/jitsi/JitsiEntrypoint.tsx diff --git a/src/components/jitsi/types.ts b/frontend/src/components/jitsi/types.ts similarity index 100% rename from src/components/jitsi/types.ts rename to frontend/src/components/jitsi/types.ts diff --git a/src/components/meeting/Meeting.tsx b/frontend/src/components/meeting/Meeting.tsx similarity index 100% rename from src/components/meeting/Meeting.tsx rename to frontend/src/components/meeting/Meeting.tsx diff --git a/src/components/meeting/MeetingNameInput.css b/frontend/src/components/meeting/MeetingNameInput.css similarity index 100% rename from src/components/meeting/MeetingNameInput.css rename to frontend/src/components/meeting/MeetingNameInput.css diff --git a/src/components/meeting/MeetingNameInput.tsx b/frontend/src/components/meeting/MeetingNameInput.tsx similarity index 100% rename from src/components/meeting/MeetingNameInput.tsx rename to frontend/src/components/meeting/MeetingNameInput.tsx diff --git a/src/components/sidebar/Sidebar.css b/frontend/src/components/sidebar/Sidebar.css similarity index 100% rename from src/components/sidebar/Sidebar.css rename to frontend/src/components/sidebar/Sidebar.css diff --git a/src/components/sidebar/Sidebar.tsx b/frontend/src/components/sidebar/Sidebar.tsx similarity index 100% rename from src/components/sidebar/Sidebar.tsx rename to frontend/src/components/sidebar/Sidebar.tsx diff --git a/src/components/sidebar/SidebarHeader.tsx b/frontend/src/components/sidebar/SidebarHeader.tsx similarity index 100% rename from src/components/sidebar/SidebarHeader.tsx rename to frontend/src/components/sidebar/SidebarHeader.tsx diff --git a/src/components/sidebar/useSidebarVisibility.ts b/frontend/src/components/sidebar/useSidebarVisibility.ts similarity index 100% rename from src/components/sidebar/useSidebarVisibility.ts rename to frontend/src/components/sidebar/useSidebarVisibility.ts diff --git a/src/hooks/useRoomName.ts b/frontend/src/hooks/useRoomName.ts similarity index 100% rename from src/hooks/useRoomName.ts rename to frontend/src/hooks/useRoomName.ts diff --git a/src/index.css b/frontend/src/index.css similarity index 100% rename from src/index.css rename to frontend/src/index.css diff --git a/src/main.tsx b/frontend/src/main.tsx similarity index 100% rename from src/main.tsx rename to frontend/src/main.tsx diff --git a/src/vite-env.d.ts b/frontend/src/vite-env.d.ts similarity index 100% rename from src/vite-env.d.ts rename to frontend/src/vite-env.d.ts diff --git a/tsconfig.json b/frontend/tsconfig.json similarity index 100% rename from tsconfig.json rename to frontend/tsconfig.json diff --git a/tsconfig.node.json b/frontend/tsconfig.node.json similarity index 100% rename from tsconfig.node.json rename to frontend/tsconfig.node.json diff --git a/vite.config.ts b/frontend/vite.config.ts similarity index 100% rename from vite.config.ts rename to frontend/vite.config.ts diff --git a/yarn.lock b/frontend/yarn.lock similarity index 100% rename from yarn.lock rename to frontend/yarn.lock diff --git a/prodsody/mod_jitsi_rooms.lua b/prodsody/mod_jitsi_rooms.lua new file mode 100644 index 0000000..968d5a8 --- /dev/null +++ b/prodsody/mod_jitsi_rooms.lua @@ -0,0 +1,219 @@ +---@diagnostic disable: deprecated +local it = require "util.iterators"; +local json = require "util.json"; +local array = require "util.array"; +local iterators = require "util.iterators"; +local jid = require "util.jid"; + +local async_handler_wrapper = module:require "util".async_handler_wrapper; +local get_room_from_jid = module:require "util".get_room_from_jid; +local muc_domain_prefix = module:get_option_string("muc_mapper_domain_prefix", "conference"); +local domain_name = "meet.jitsi" + +function debug_table_recursive(aTable, depth) + if (depth > 5) then + return "" + end + local result = {} + for key, value in pairs(aTable) do + --log("debug", key); + if (type(value) == "table") + then + table.insert(result, string.format("\"%s\":%s", tostring(key), debug_table_recursive(value, depth + 1))) + elseif (type(value) == "function") + then + --table.insert(result, string.format("\"%s\":%s", tostring(key), debug_table_recursive(it.join(value)))) + else + table.insert(result, string.format("\"%s\":\"%s\"", tostring(key), tostring(value))) + --log("debug", key); + end + end + return "{" .. table.concat(result, ",") .. "}" +end + +function get_participants_for_room(room_name) + + local room_address = jid.join(room_name, muc_domain_prefix .. "." .. domain_name); + local room = get_room_from_jid(room_address); + local occupants_json = array(); + if room then + local occupants = room._occupants; + if occupants then + participant_count = iterators.count(room:each_occupant()); + for _, occupant in room:each_occupant() do + -- filter focus as we keep it as hidden participant + if string.sub(occupant.nick, -string.len("/focus")) ~= "/focus" then + for _, pr in occupant:each_session() do + local nick = pr:get_child_text("nick", "http://jabber.org/protocol/nick") or ""; + local email = pr:get_child_text("email") or ""; + local avatarURL = pr:get_child_text("avatarURL") or "" -- does not work :( + occupants_json:push({ + jid = tostring(occupant.nick), + email = tostring(email), + display_name = tostring(nick), + avatarURL = tostring(avatarURL) + }); + end + end + end + end + log("debug", + "there are %s occupants in room", tostring(participant_count)); + return occupants_json + else + log("debug", "no such room exists"); + end + return occupants_json +end + +function get_all_rooms_with_participants() + + local sessions = prosody.full_sessions; + + local someTable = (it.join(it.keys(sessions))); + local actual_rooms = someTable[1][2] + + local roomNames = {} + for _, v in pairs(actual_rooms) do + table.insert(roomNames, v["jitsi_web_query_room"]) + end + + local rooms_with_participants = {} + for _, room_name in pairs(roomNames) do + rooms_with_participants[room_name] = get_participants_for_room(room_name) + end + return json.encode(rooms_with_participants) +end + +--- Handles request for retrieving the room participants details +-- @param event the http event, holds the request query +-- @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() }; +end + +function module.load() + -- Ensure that mod_http is loaded: + -- + module:depends("http"); + + -- Now publish our HTTP 'app': + 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; + + }; + }); +end + +-------- event stuff +-- +-- +-- +-- +-- +-- +-- +-- +-- + +local http = require "net.http"; +local is_healthcheck_room = module:require "util".is_healthcheck_room; +--- Start non-blocking HTTP call +-- @param url URL to call +-- @param options options table as expected by net.http where we provide optional headers, body or method. +local function async_http_request(url, options) + local completed = false; + local timed_out = false; + + local function cb_(response_body, response_code) + if not timed_out then -- request completed before timeout + completed = true; + + module:log("debug", "%s %s returned code %s", options.method, url, response_code); + end + end + + http.request(url, options, cb_); +end + +--- Checks if event is triggered by healthchecks or focus user. +function is_system_event(event) + if is_healthcheck_room(event.room.jid) then + return true; + end + + if event.occupant and jid.node(event.occupant.jid) == "focus" then + return true; + end + + return false; +end + +function handle_room_event(event) + module:log('info', "hallo irgendwas ist passiert"); + if is_system_event(event) then + return; + end + + async_http_request("https://www.toptal.com/developers/postbin/1673793686086-1283829133026", + { + method = "POST", + body = get_all_rooms_with_participants() + }) + +end + +--Helper function to wait till a component is loaded before running the given callback +function run_when_component_loaded(component_host_name, callback) + local function trigger_callback() + module:log('info', 'Component loaded %s', component_host_name); + callback(module:context(component_host_name), component_host_name); + end + + if prosody.hosts[component_host_name] == nil then + module:log('debug', 'Host %s not yet loaded. Will trigger when it is loaded.', component_host_name); + prosody.events.add_handler('host-activated', function(host) + if host == component_host_name then + trigger_callback(); + end + end); + else + trigger_callback(); + end +end + +-- Helper function to wait till a component's muc module is loaded before running the given callback +function run_when_muc_module_loaded(component_host_module, component_host_name, callback) + local function trigger_callback() + module:log('info', 'MUC module loaded for %s', component_host_name); + callback(prosody.hosts[component_host_name].modules.muc, component_host_module); + end + + if prosody.hosts[component_host_name].modules.muc == nil then + module:log('debug', 'MUC module for %s not yet loaded. Will trigger when it is loaded.', component_host_name); + prosody.hosts[component_host_name].events.add_handler('module-loaded', function(event) + if (event.module == 'muc') then + trigger_callback(); + end + end); + else + trigger_callback() + end +end + +local main_muc_component_host = muc_domain_prefix .. "." .. domain_name +-- Handle events on main muc module +run_when_component_loaded(main_muc_component_host, function(host_module, host_name) + run_when_muc_module_loaded(host_module, host_name, function(main_muc, main_module) + 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-occupant-joined", handle_room_event, -2); + main_module:hook("muc-occupant-left", handle_room_event, -2); + main_module:hook("muc-room-destroyed", handle_room_event, -2); + end); +end);