mqttagent

commit 63efe0a8f50534d7a50a26b3e2dc1b0854d0e66e
parent 377fbe3754e39e74f9ff0a3571bd9a7604aca745
Author: Natasha Kerensikova <natgh@instinctive.eu>
Date:   Sun, 20 Apr 2025 16:44:10 +0000

Log callback is removed
Diffstat:
M
cmd/mqttagent-full/main.go
 | 
2
--
M
cmd/mqttagent-lite/main.go
 | 
7
+++----
M
mqttagent.go
 | 
4
----

3 files changed, 3 insertions(+), 10 deletions(-)
diff --git a/cmd/mqttagent-full/main.go b/cmd/mqttagent-full/main.go
@@ -43,8 +43,6 @@ func (agent *fullMqttAgent) Setup(L *lua.LState) {
 	L.SetField(mt, "__index", L.SetFuncs(L.NewTable(), luaSqloggerMethods))
 }
 
-func (agent *fullMqttAgent) Log(L *lua.LState, msg *mqttagent.MqttMessage) {}
-
 func (agent *fullMqttAgent) Teardown(L *lua.LState) {
 	for _, logger := range agent.loggers {
 		logger.Close()
diff --git a/cmd/mqttagent-lite/main.go b/cmd/mqttagent-lite/main.go
@@ -19,15 +19,14 @@ package main
 import (
 	"os"
 
-	"instinctive.eu/go/mqttagent"
 	"github.com/yuin/gopher-lua"
+	"instinctive.eu/go/mqttagent"
 )
 
 type liteMqttAgent struct{}
 
-func (agent liteMqttAgent) Setup(L *lua.LState)                           {}
-func (agent liteMqttAgent) Log(L *lua.LState, msg *mqttagent.MqttMessage) {}
-func (agent liteMqttAgent) Teardown(L *lua.LState)                        {}
+func (agent liteMqttAgent) Setup(L *lua.LState)    {}
+func (agent liteMqttAgent) Teardown(L *lua.LState) {}
 
 func main() {
 	var agent liteMqttAgent
diff --git a/mqttagent.go b/mqttagent.go
@@ -31,13 +31,11 @@ import (
 
 type MqttAgent interface {
 	Setup(L *lua.LState)
-	Log(L *lua.LState, msg *MqttMessage)
 	Teardown(L *lua.LState)
 }
 
 type MqttReloadingAgent interface {
 	Setup(L *lua.LState)
-	Log(L *lua.LState, msg *MqttMessage)
 	ReloadBegin(oldL, newL *lua.LState)
 	ReloadAbort(oldL, newL *lua.LState)
 	ReloadEnd(oldL, newL *lua.LState)
@@ -177,8 +175,6 @@ func tableIsEmpty(t *lua.LTable) bool {
 }
 
 func processMsg(L *lua.LState, msg *MqttMessage) {
-	stateAgent(L).Log(L, msg)
-
 	cnx := L.RawGetInt(stateCnxTable(L), msg.ClientId).(*lua.LTable)
 	subTbl := L.RawGetInt(cnx, keySubTable).(*lua.LTable)
 	L.ForEach(subTbl, func(key, value lua.LValue) { dispatchMsg(L, msg, cnx, key, value) })