Hi all! Let me introduce luamqtt - https://github.com/xHasKx/luamqtt - the MQTT client library for Lua programming language . It's not based on any C module and written in pure Lua code from scratch and completely follows OASIS standards for the MQTT v5.0 and the MQTT v3.1.1 protocols. The only main dependency is a luasocket module to open a TCP connection. But there is a mechanism to implement your own functions to open a TCP connection and send/receive from it. It's used, for example, in the OpenResty to use its ngx.socket.tcp module instead of luasocket. This is a thread for discussion, feedback and feature requests of the luamqtt . Alternatively, the GitHub issues are welcomed.

Awesome work, I just found it and looking to give it a try on LogicMachine which don't have mosquitto package available.

DmitryG , Thanks! And don't hesitate to post here your LogicMachine integration experience!

Thanks, the main challenge with LM is that it does not support libraries, a library should be wrapped as a user script, which is basically a single file. I'm still trying to get my head around on how to "compile" this as i'm not Lua expert, yet.

DmitryG So you have to emulate module loading by require() function: https://www.lua.org/manual/5.3/manual.html#pdf-require You may try to wrap each module file into a function, returning the module table. And write your own require() function calling that module-emulating functions. Do you succeed with opening TCP connection to internet from the LM device?

Hi, it does have require(), however full module should be within a single file. Haven't had time to play around with that yet. I'm also waiting for forum account confirmation so I can get example of the other library wrapped from multiple source files. I will be making connections to local MQTT broker, but internet is also possible if network allows that.

kial hi, I finally managed to find some time to try it out - seems to work without major changes, the only step i had to make is to pre-build scripts into single file and update bit logic wrapper (LM have built-in support bit.XXX functions, but not language "<<" feature)

DmitryG , FYI, from v3.1.1 luamqtt will not require "bit" module if used with Lua 5.2, because this Lua version has a built-in module "bit32". If your LM runtime has Lua 5.2 or higher - it can simplify your deploy process

Hi, I am trying to implement your piece of code in my Sierrawireless RV50X. I do not understand how to use the "run_ioloop" fonction in order to publish message every minute. can you help please ? thanks in advance

aquaboxsalus , it depends on the Lua runtime available on your Sierrawireless RV50X. If it has some usual Lua interpreter - you may check out this test as an example: https://github.com/xHasKx/luamqtt/blob/master/tests/spec/ioloop.lua#L43 Here you have a function loop_func() which will be called again and again by the ioloop. So you can insert a code into it to calculate how much time has passed since the last sending (use os.time for example). When you calculated a 1-minute diff - send an MQTT message or whatever you need.

thanks. in the documentation i see that we can create an ioloop specifiying sleep argument ( sleep interval after each iteration (default 0)) correct ? is it not better ? how to use that ? thanks

luamqtt - MQTT client written in pure lua

shal

zt190 take a look at device policy. It should allow your client to connect to the hub with given client-id, subscribe and publish to specific topics. Enable all options if unsure.
Here is the article we touch Azure device policy a bit: https://flespi.com/kb/flespi-to-azure

jp_one

Hi guys, many thanks for the great module! I'm trying to utilize SSL/TLS in order to securely communicate with flespi broker. Is my understanding correct, that luamqtt is not supporting certificate based authentication?

So if token is regarded as not secure enough and luamqtt is used as MQTT client, the only way would to go would be via port 8883 or 443?

kial

jp_one I'm trying to utilize SSL/TLS in order to securely communicate with flespi broker. Is my understanding correct, that luamqtt is not supporting certificate based authentication?

If you mean SSL/TLS secure transport for MQTT protocol - it's fully supported if your Lua runtime has a luasec (or compatible) module. And you can specify any custom SSL parameters like certificate file in the secure={...} table parameter in mqtt client instance constructor (see secure parameter description there).

If you are talking about new MQTT 5.0 packet type AUTH - it's also supported in the luamqtt with client:auth() method. But this is a broker-specific authentication method, thus you cannot use it with flespi broker.

jp_one So if token is regarded as not secure enough and luamqtt is used as MQTT client

Sorry, I can't understand this part. Can you please rephrase it?

jp_one the only way would to go would be via port 8883 or 443?

I would say that you always should use port 8883 and SSL/TLS secure connection.
But port 443 is for websocket transport, which is not supported by luamqtt.

OleBier

I currently have the problem that both update functions (loop and sync) block the process until a message is received.
With the system I want to implement this library in I don't have the possibility to create a thread or have this run externally somehow. So the whole program will stop running until messages come in. I do however have the possibility to continually call a function. I thought I could use the run_sync methode as from the description, but that also waits for an incoming message.
So I would need something more in line of a function that checks if a message was reveiced, if not it just moves along. Is there a straightforward way of calling such a function?

kial

OleBier Can you please check how it's working on a pull request https://github.com/xhaskx/luamqtt/pull/31 ?

kial

OleBier Do you have a way to operate with TCP sockets in async (non-blocking) mode in your system? What is the system?

OleBier

Unfortunately the pull request didn't help with the problem.

OleBier

Honestly I have no idea. I haven't worked with networking that much to have a deeper understanding of it.
I'm working with the Defold game engine which incorporates luasocket as default. It is possible to use other libraries, but anything that's not pure Lua needs to be adapted to the engine for it to work properly, so I would like to avoid that.
Previously I used the MQTT client library from Paho, with which you manually had to call the handler in intervalls, which was perfect for my use case as the game engine does provide a function that gets periodically called. Recently we've updated our server and along with it switched to a newer version of Mosquitto, but I constantly get disconnected from it. So I was looking into using a newer MQTT library that also features MQTT version 5 and this one looked very promising.
I hoped that there possibly would be some kind of function I could call instead of using the two give one. But poking at the library myself a bit I guess I will needs to make certain adjustments to use it.

kial

OleBier Regarding your description I suppose you need function ioloop_mt:iteration() - https://github.com/xHasKx/luamqtt/blob/master/mqtt/ioloop.lua#L109

You can access it with

local ioloop = require("mqtt.ioloop")

print(ioloop.get().iteration) -- function: 0x612d866782c0

This function intended to be run in some outer loop, but I think your engine's handler will be suitable for that too.

OleBier

Thank you for creating the library and all the help you have given me. I managed to get it working with adding the following code to the init.lua. Which is basically just a slightly changed run_ioloop(...)

local loop = ioloop_get()
function mqtt.init_ioloop(...)
	for i = 1, select("#", ...) do
		local cl = select(i, ...)
		loop:add(cl)
		if type(cl) ~= "function" then
			cl:start_connecting()
		end
	end
end

function mqtt.iterate_ioloop()
	loop:iteration()
end

BochraDahmen

Hello,

I’m using CoppeliaSim for robot simulation and LuaMQTT to connect the robot to a local Mosquitto MQTT broker. The issue is that the MQTT connection is blocking the simulation, preventing the robot from moving based on MQTT payloads received in topics.

I’m trying to use async code to handle the MQTT connection without blocking the simulation, but it’s not working as expected. When the MQTT connection is established, the simulation gets blocked.

I’ve used coroutines in CoppeliaSim and LuaMQTT’s callback functions, but the MQTT connection still seems to block the simulation.

Has anyone managed to make this work asynchronously in CoppeliaSim? Any help would be appreciated!

PS: Just to be clear, the broker works, and both publish and subscribe functions work. However, when the MQTT connection is established, the simulation crashes.

The link to my Lua script:
https://www.blackbox.ai/share/eb9b70e1-466e-4b61-8713-c810981d41ae

Thank you in advance for your help!

kial

BochraDahmen , the call for mqtt.run_ioloop(client) is blocking your runtime. You need to run ioloop_mt:iteration() method of the default ioloop instance there instead. Default ioloop can be obtained with require("mqtt.ioloop").get() function