AliasAlreadyTaken/yl_matterbridge#10 Adds recveive timeout setting

util as api to mods that want use an alternative gateway to send msgs

.luacheckrc

@@ -0,0 +1,13 @@
+unused_args = true
+allow_defined_top = false
+
+globals = {
+    "minetest",
+    "core",
+    "yl_matterbridge"
+}
+
+read_globals = {
+    -- Builtin
+    "dump", "DIR_DELIM"
+}

LICENSE

@@ -1,6 +1,6 @@
 MIT License
 
-Copyright (c) <year> <copyright holders>
+Copyright (c) 2024 AliasAlreadyTaken
 
 Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions:
 

README.md

@@ -30,6 +30,8 @@ Download and install [matterbridge](https://github.com/42wim/matterbridge)
 
 ## Configuration
 
+### Matterbridge
+
 Create a config for [matterbridge](https://github.com/42wim/matterbridge) and the chat protocols you want to use.
 
 * https://github.com/42wim/matterbridge/wiki/How-to-create-your-config
@@ -42,7 +44,7 @@ An example config for minetest looks like this
 BindAddress="127.0.0.1:4242"
 Buffer=1000
 RemoteNickFormat="{NICK}"
-#Token="DISABLED, NOT YET SUPPORTED"
+#Token="mytotallysecrettoken"
 ```
 Gateway section:
 
@@ -55,6 +57,54 @@ account="api.mt"
 channel="api"
 ```
 
+### Minetest
+
+See also [settingtypes.txt](settingtypes.txt)
+
+On top of adding `yl_matterbridge` to http_mods, there are settings to add to minetest.conf:
+
+```
+yl_matterbridge.address = 127.0.0.1
+```
+
+The address or IP to the matterbridge server
+
+```
+yl_matterbridge.port = 4242
+```
+
+The port the matterbridge server listens on
+
+```
+yl_matterbridge.gateway = default
+```
+
+The name of the gateway of the matterbridge server
+
+```
+yl_matterbridge.token
+```
+
+A secret token string to identify yourself towards the matterbridge server
+
+```
+yl_matterbridge.debug = false
+```
+
+Set this to true to enable debugging
+
+```
+yl_matterbridge.fetch_interval = 0.0
+```
+
+Specifies the interval (in seconds) at which a new query is sent to the bridge.
+
+```
+yl_matterbridge.receive_timeout = 0.89
+```
+
+Specifies the timeout (in seconds) a query to the bridge waits before it breaks.
+
 ## Modmakers
 
 API: Overwrite these function in your chat mod, if you want to handle messages yourself
@@ -109,11 +159,11 @@ There is no reason to believe it doesn't work anywhere, but you never know.
 
 ### Windows
 
-MT versions 5.0.0, 5.0.1, 5.1.0, 5.1.1, 5.2.0, 5.3.0, 5.4.0 5.4.1, 5.5.0
+MT versions 5.0.0, 5.0.1, 5.1.0, 5.1.1, 5.2.0, 5.3.0, 5.4.0 5.4.1, 5.5.0, 5.6.0, 5.6.1, 5.7.0, 5.8.0
 
 ### Linux
 
-MT versions 5.5.0
+MT versions 5.5.0, 5.6.0, 5.6.1, 5.7.0, 5.8.0
 
 ### MacOS
 
@@ -132,6 +182,7 @@ unknown
 If you know a project that uses this bridge tell us and we will add it to the list.
 
 * smart_chat : https://github.com/acmgit/smart_chat/
+* player_events: https://github.com/insanity54/matterbridge_player_events
 
 ## Uninstall
 

init.lua

@@ -1,24 +1,21 @@
 -- Version 1.0.3
 -- Author AliasAlreadyTaken
 -- License MIT
-
 -- Changelog
-
 -- 0.0.1 First puny attempts
 -- 0.0.2 Feature complete including settings
 -- 1.0.0 Ready for release
 -- 1.0.1 Bugfix https://gitea.your-land.de/your-land/bugtracker/issues/1646
 -- 1.0.2 Bugfix settingtypes: bool instead of boolean
 -- 1.0.3 Release to cdb
-
 local mod_start_time = core.get_us_time()
 core.log("action", "[MOD] yl_matterbridge loading")
 
 yl_matterbridge = {}
---yl_matterbridge.error = {}
---yl_matterbridge.modstorage = core.get_mod_storage()
---yl_matterbridge.modpath = core.get_modpath("yl_matterbridge") .. DIR_DELIM
---yl_matterbridge.worldpath = core.get_worldpath() .. DIR_DELIM
+-- yl_matterbridge.error = {}
+-- yl_matterbridge.modstorage = core.get_mod_storage()
+-- yl_matterbridge.modpath = core.get_modpath("yl_matterbridge") .. DIR_DELIM
+-- yl_matterbridge.worldpath = core.get_worldpath() .. DIR_DELIM
 
 yl_matterbridge.information = {}
 yl_matterbridge.information.version = "1.0.3"
@@ -29,12 +26,16 @@ yl_matterbridge.information.source = "https://gitea.your-land.de/AliasAlreadyTak
 yl_matterbridge.information.additional =
     "Sends and receives ingame chat to and from matterbridge https://github.com/42wim/matterbridge"
 
+yl_matterbridge.enabled = true
+
 local settings = {}
 settings.address = core.settings:get("yl_matterbridge.address") or "127.0.0.1"
 settings.port = core.settings:get("yl_matterbridge.port") or "4242"
 settings.gateway = core.settings:get("yl_matterbridge.gateway") or "default"
 settings.token = core.settings:get("yl_matterbridge.token") or ""
 settings.debug = core.settings:get_bool("yl_matterbridge.debug", false) or false
+settings.fetch_interval = tonumber(core.settings:get("yl_matterbridge.fetch_interval") or "0.0") or 0
+settings.receive_timeout = tonumber(core.settings:get("yl_matterbridge.receive_timeout") or "0.89") or 0.89
 
 local http = core.request_http_api()
 
@@ -51,91 +52,90 @@ end
 local url_send = "http://" .. settings.address .. ":" .. settings.port .. "/api/message"
 local url_receive = "http://" .. settings.address .. ":" .. settings.port .. "/api/messages"
 
-function send(user_name, message_text)
+local function send(user_name, message_text, gateway)
+    if yl_matterbridge.enabled == false then
+        return false
+    end
     if settings.debug then
-        core.log(
-            "action",
-            "[MOD] yl_matterbridge : send user_name = " .. dump(user_name) .. ",  message_text = " .. dump(message_text)
-        )
+        core.log("action", "[MOD] yl_matterbridge : send user_name = " .. dump(user_name) .. ",  message_text = " ..
+            dump(message_text))
     end
     local timeout = 10
-    local data = {
+    local data_in = {
         text = message_text,
         username = user_name,
-        gateway = settings.gateway
+        gateway = gateway or settings.gateway
     }
 
-    http.fetch(
-        {
-            url = url_send,
-            extra_headers = post_headers,
-            timeout = timeout,
-            post_data = core.write_json(data)
-        },
-        function(result)
-            if not result.completed or not result.succeeded or not result.code == 200 then
-                core.log("error", "[MOD] yl_matterbridge: send/http.fetch failed. Result = " .. dump(result))
-                return false
-            else
-                if settings.debug then
-                    local data = core.parse_json(result.data)
-                    core.log(
-                        "action",
-                        "[MOD] yl_matterbridge : send result = " .. dump(result) .. ", data = " .. dump(data)
-                    )
-                end
-                return true
+    http.fetch({
+        url = url_send,
+        extra_headers = post_headers,
+        timeout = timeout,
+        post_data = core.write_json(data_in)
+    }, function(result)
+        if (not result.completed) or (not result.succeeded) or (result.code ~= 200) then
+            core.log("error", "[MOD] yl_matterbridge: send/http.fetch failed. Result = " .. dump(result))
+            return false
+        else
+            if settings.debug then
+                local data_out = core.parse_json(result.data)
+                core.log("action",
+                    "[MOD] yl_matterbridge : send result = " .. dump(result) .. ", data = " .. dump(data_out))
             end
+            return true
         end
-    )
+    end)
 end
 
-local function receive()
+local timer = 0
+
+local function receive(dtime)
+    if yl_matterbridge.enabled == false then
+        return false
+    end
     if settings.debug then
         core.log("action", "[MOD] yl_matterbridge : receive")
     end
-    local timeout = 0
 
-    http.fetch(
-        {
-            url = url_receive,
-            extra_headers = post_headers,
-            timeout = timeout
-        },
-        function(result)
-            if not result.completed or not result.succeeded or not result.code == 200 then
-                core.log("error", "[MOD] yl_matterbridge: receive/http.fetch failed. Result (req) = " .. dump(result))
-                return false
-            else
-                local data = core.parse_json(result.data)
-                if not data then
-                    if not next(data) then
-                        if settings.debug then
-                            core.log(
-                                "error",
-                                "[MOD] yl_matterbridge: receive/http.fetch failed. Result (data) = " .. dump(result)
-                            )
-                        end
+    timer = timer + dtime
+    if timer <= settings.fetch_interval then
+        return false
+    end
+    timer = 0
+
+    http.fetch({
+        url = url_receive,
+        extra_headers = post_headers,
+        timeout = settings.receive_timeout
+    }, function(result)
+        if (not result.completed) or (not result.succeeded) or (result.code ~= 200) then
+            core.log("error", "[MOD] yl_matterbridge: receive/http.fetch failed. Result (req) = " .. dump(result))
+            return false
+        else
+            local data_out = core.parse_json(result.data)
+            if not data_out then
+                if not next(data_out) then
+                    if settings.debug then
+                        core.log("error",
+                            "[MOD] yl_matterbridge: receive/http.fetch failed. Result (data) = " .. dump(result))
                     end
-                    return false
                 end
-                for _, dataset in ipairs(data) do
-                    if dataset then
-                        if settings.debug then
-                            core.log("action", "[MOD] yl_matterbridge : dataset = " .. dump(dataset))
-                        end
-                        yl_matterbridge.receive_all_from_bridge(dataset)
-                    else
-                        core.log(
-                            "error",
-                            "[MOD] yl_matterbridge: receive/http.fetch failed. No dataset in returned data = " ..
-                                dump(data)
-                        )
+                return false
+            end
+            for _, dataset in ipairs(data_out) do
+                if dataset then
+                    if settings.debug then
+                        core.log("action", "[MOD] yl_matterbridge : dataset = " .. dump(dataset))
                     end
+                    yl_matterbridge.receive_all_from_bridge(dataset)
+                else
+                    core.log("error",
+                        "[MOD] yl_matterbridge: receive/http.fetch failed. No dataset in returned data = " ..
+                            dump(data_out))
                 end
             end
         end
-    )
+    end)
 end
 
 -- API
@@ -155,17 +155,15 @@ function yl_matterbridge.receive_all_from_bridge(dataset)
         local account_name = dataset.account
         yl_matterbridge.receive_from_bridge(user_name, message_text, account_name)
     else
-        core.log(
-            "error",
-            "[MOD] yl_matterbridge: receive/http.fetch failed. No dataset in returned data = " .. dump(dataset)
-        )
+        core.log("error",
+            "[MOD] yl_matterbridge: receive/http.fetch failed. No dataset in returned data = " .. dump(dataset))
     end
 end
 
 -- Call this function to feed into the bridge from your own mod, if you unset yl_matterbridge.chat_message
 
-function yl_matterbridge.send_to_bridge(user_name, message_text)
-    send(user_name, message_text)
+function yl_matterbridge.send_to_bridge(user_name, message_text, gateway)
+    send(user_name, message_text, gateway)
 end
 
 -- Set this function to yl_matterbridge.chat_message = function() end

settingtypes.txt

@@ -8,7 +8,7 @@
 # Defaults to 127.0.0.1
 yl_matterbridge.address (Bridge IP address or URL) string 127.0.0.1
 
-# The port the matterbridge server listens to
+# The port the matterbridge server listens on
 # You need to set this to the port of the API connection, which you configured in the toml
 # Defaults to 4242
 yl_matterbridge.port (Bridge port) string 4242
@@ -27,3 +27,13 @@ yl_matterbridge.token (Bridge token) string
 # If set to true, the mod will write every send and receive to the log, among other debug messages.
 # Optional, default false
 yl_matterbridge.debug (Debug mode) bool false
+
+# Fetch/Receive interval
+# Specifies the interval (in seconds) at which a new query is sent to the bridge. A value of 0.0 means queries are sent on every server step.
+# Optional, defaults to 0.0
+yl_matterbridge.fetch_interval (Fetch/Receive interval) float 0.0 0.0 30.0
+
+# Receive timeout
+# Specifies the timeout (in seconds) a query to the bridge waits before it breaks. Set low for good connections and/or low fetch_interval.
+# Optional, defaults to 0.89
+yl_matterbridge.receive_timeout (Receive timeout) float 0.89 0.1 10.0