Bump amqc to v0.3.2

mqterm/terminal.py

@@ -66,7 +66,6 @@ async def disconnect(self):
 
     async def handle_msg(self, topic, msg, properties={}):
         """Process a single MQTT message and apply to the appropriate job."""
-        topic = topic.decode("utf-8")
         if not topic.startswith(self.in_topic):
             self.logger.debug(f"Terminal received message on {topic}; ignoring")
             return

package.json

@@ -5,7 +5,7 @@
     ["mqterm/terminal.py", "github:solanus-systems/mqterm/mqterm/terminal.py"]
   ],
   "deps": [
-    ["github:solanus-systems/amqc", "v0.3.0"],
+    ["github:solanus-systems/amqc", "v0.3.2"],
     ["logging", "latest"]
   ],
   "version": "0.2.1"

tests/e2e/e2e_file_ops.py

@@ -42,14 +42,6 @@
 term = MqttTerminal(device_client, topic_prefix="/test")
 
 
-# def create_props(seq: int, client_id: str) -> dict:
-#     """Create MQTTv5 properties with a seq number and client ID."""
-#     return {
-#         CORRELATION_DATA: client_id.encode("utf-8"),
-#         USER_PROPERTY: {"seq": str(seq)},
-#     }
-
-
 async def send_file(buffer: BytesIO):
     """Send a file to the terminal."""
     # Send the first message that will create the job
@@ -154,5 +146,11 @@ async def main():
 
 
 if __name__ == "__main__":
-    asyncio.run(main())
+    try:
+        asyncio.run(main())
+    finally:
+        try:
+            os.unlink("test.txt")
+        except OSError:
+            pass
     print("\033[1m\tOK\033[0m")