Fix some bugs from API changes

void-spark · Jan 24, 2022 · b8998a1 · b8998a1
1 parent 8b7a4cf
commit b8998a1
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 4 deletions.
diff --git a/plugin.service.mqtt/addon.xml b/plugin.service.mqtt/addon.xml
@@ -1,5 +1,5 @@
 <?xml version="1.0" encoding="UTF-8" standalone="yes"?>
-<addon id="plugin.service.mqtt" name="MQTT Adapter" version="0.21" provider-name="owagner,jvandenbroek,richcrabtree,Eugene Schava,rubikscuber,DevTown,2Zero,Marcin U,drlobo,existsec,Aitor Iturrioz,Marian Soban,Mark Ferry,Patrick Pimentel Jr.,void-spark">
+<addon id="plugin.service.mqtt" name="MQTT Adapter" version="0.22" provider-name="owagner,jvandenbroek,richcrabtree,Eugene Schava,rubikscuber,DevTown,2Zero,Marcin U,drlobo,existsec,Aitor Iturrioz,Marian Soban,Mark Ferry,Patrick Pimentel Jr.,void-spark">
   <requires>
     <import addon="xbmc.python" version="3.0.0"/>
   </requires>

diff --git a/plugin.service.mqtt/changelog.txt b/plugin.service.mqtt/changelog.txt
@@ -1,3 +1,7 @@
+v0.22 - 2022-01-24
+  - Fixed some things to follow conventions
+  - Tested on 19.4 Matrix
+
 v0.21 - 2021-03-22
   - Convert to work with Kodi 19 Matrix (just some minor changes were needed)
   - Update MQTT client Paho to latest: 1.5.1 

diff --git a/plugin.service.mqtt/service.py b/plugin.service.mqtt/service.py
@@ -39,8 +39,7 @@ def ignorelist(data,val):
 
 def mqttlogging(log):
     if  __addon__.getSetting("mqttdebug")=='true':
-        #xbmc.log(log)
-        xbmc.log(log,level=xbmc.LOGNOTICE)
+        xbmc.log(log,level=xbmc.LOGINFO)
 
 def sendrpc(method,params):
     res=xbmc.executeJSONRPC(json.dumps({"jsonrpc":"2.0","method":method,"params":params,"id":1}))
@@ -260,6 +259,7 @@ def processcecstate(data):
 		os.system('kodi-send --action=""')
 
 def processcommand(topic,data):
+    mqttlogging("MQTT: Received command %s with data %s" % (topic, data))
     if topic=="notify":
         processnotify(data)
     elif topic=="play":
@@ -287,7 +287,7 @@ def msghandler(mqc,userdata,msg):
             return
         mytopic=msg.topic[len(topic):]
         if mytopic.startswith("command/"):
-            processcommand(mytopic[8:],msg.payload)
+            processcommand(mytopic[8:],msg.payload.decode("utf-8"))
     except Exception as e:
         mqttlogging("MQTT: Error processing message %s: %s" % (type(e).__name__,e))