From b872afe5a993719b916dc238ef36ff08c9f54fb0 Mon Sep 17 00:00:00 2001 From: 8cH9azbsFifZ Date: Sun, 12 Nov 2023 14:27:20 +0100 Subject: [PATCH] moved to udp2mqtt repo --- config.py | 4 --- mqtt_client_receiver.py | 46 --------------------------------- mqtt_client_transmitter.py | 52 -------------------------------------- 3 files changed, 102 deletions(-) delete mode 100644 mqtt_client_receiver.py delete mode 100644 mqtt_client_transmitter.py diff --git a/config.py b/config.py index b990e4f..6baf430 100644 --- a/config.py +++ b/config.py @@ -7,7 +7,3 @@ MAX_CLIENTS = 100 KEEPALIVE = 10 CHAT_WPM = 20 - -# MQTT configuration -MQTT_HOST = "broker.hivemq.com" -MQTT_PORT = 1883 diff --git a/mqtt_client_receiver.py b/mqtt_client_receiver.py deleted file mode 100644 index 7a7d85e..0000000 --- a/mqtt_client_receiver.py +++ /dev/null @@ -1,46 +0,0 @@ -#!/usr/local/bin/python3 -# Subscriber for MQTT with Morse Code Beep - -import paho.mqtt.client as paho -import config - -from mopp import * -from beep import * - -mopp = Mopp() - -def on_connect(mqttc, obj, flags, rc): - print("rc: " + str(rc)) - -def on_message(mqttc, obj, msg): - print(msg.topic + " " + str(msg.qos) + " " + str(msg.payload)) - - r = mopp.decode_message(msg.payload) - print (r) - - # Beep if message received - if not "Keepalive" in r: - b = Beep(speed=r["Speed"]) - b.beep_message(r["Message"]) - -def on_publish(mqttc, obj, mid): - print("mid: " + str(mid)) - -def on_subscribe(mqttc, obj, mid, granted_qos): - print("Subscribed: " + str(mid) + " " + str(granted_qos)) - -def on_log(mqttc, obj, level, string): - print(string) - - -mqttc = paho.Client() - -mqttc.on_message = on_message -mqttc.on_connect = on_connect -mqttc.on_publish = on_publish -mqttc.on_subscribe = on_subscribe - -mqttc.connect(config.MQTT_HOST, config.MQTT_PORT, 60) -mqttc.subscribe("m32_test", 0) - -mqttc.loop_forever() diff --git a/mqtt_client_transmitter.py b/mqtt_client_transmitter.py deleted file mode 100644 index b536090..0000000 --- a/mqtt_client_transmitter.py +++ /dev/null @@ -1,52 +0,0 @@ -#!/usr/local/bin/python3 -# Simple transmitter - -import paho.mqtt.client as paho -import logging -from mopp import * -import config - -logging.basicConfig(level=logging.DEBUG, format='%(message)s', ) - -mopp = Mopp() - - - -def on_connect(mqttc, obj, flags, rc): - print("rc: " + str(rc)) - -def on_message(mqttc, obj, msg): - print(msg.topic + " " + str(msg.qos) + " " + str(msg.payload)) - - r = mopp.decode_message(msg.payload) - print (r) - -def on_publish(mqttc, obj, mid): - print("mid: " + str(mid)) - pass - -def on_subscribe(mqttc, obj, mid, granted_qos): - print("Subscribed: " + str(mid) + " " + str(granted_qos)) - -def on_log(mqttc, obj, level, string): - print(string) - - -mqttc = paho.Client() - -mqttc.on_message = on_message -mqttc.on_connect = on_connect -mqttc.on_publish = on_publish -mqttc.on_subscribe = on_subscribe - -mqttc.connect(config.MQTT_HOST, config.MQTT_PORT, 60) -mqttc.loop_start() - -infot = mqttc.publish("m32_test", mopp.mopp(20,'hi'), qos=2) -#infot = mqttc.publish("m32_test", mopp.mopp(20,'hihio'), qos=2) -infot = mqttc.publish("m32_test", mopp.mopp(20,'hi'), qos=2) -infot = mqttc.publish("m32_test", mopp.mopp(20,'m'), qos=2) -#infot = mqttc.publish("m32_test", mopp.mopp(20,'this is a test'), qos=2) - -infot.wait_for_publish() -