nurdspace-ircbot-plugin-python-example/deurbel.py at master · NURDspace/nurdspace-ircbot-plugin-python-example · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
#! /usr/bin/python3

# by FvH, released under Apache License v2.0

# either install 'python3-paho-mqtt' or 'pip3 install paho-mqtt'

import json
import paho.mqtt.client as mqtt
import threading
import time

import socket
import sys

mqtt_server  = 'mqtt.vm.nurd.space'
topic_prefix = 'GHBot/'
channels     = ['nurds']
prefix       = '!'

last_ring    = None

def announce_commands(client):
    target_topic = f'{topic_prefix}to/bot/register'

    client.publish(target_topic, 'cmd=doorbell|descr=Doorbell statistics')

def on_message(client, userdata, message):
    global last_ring
    global prefix

    text = message.payload.decode('utf-8')

    if message.topic == 'deurbel':
        last_ring = time.ctime()

        for channel in channels:
            announce_topic = f'{topic_prefix}to/irc/{channel}/privmsg'

            client.publish(announce_topic, '*** DOORBELL ***')

        return

    # space/door/front {"name":"tahtkev","date":"zondag 10 juli 2022","time":"15:29:36","msg":"Toegang verleend - met kaart","cardnr":666}
    #if message.topic == 'space/door/front':
    if message.topic == 'doordeamon/LiveEvents':
        try:
            j = json.loads(text)

            msg = f'--- {j["userName"]} opened the door ---'

            for channel in channels:
                announce_topic = f'{topic_prefix}to/irc/{channel}/privmsg'

                client.publish(announce_topic, msg)

        except Exception as e:
            print(f'Failed to announce entry: {e}, line number: {e.__traceback__.tb_lineno}')

        return

    topic = message.topic[len(topic_prefix):]

    if topic == 'from/bot/command' and text == 'register':
        announce_commands(client)

        return

    if topic == 'from/bot/parameter/prefix':
        prefix = text

        return

    if len(text) == 0:
        return

    parts   = topic.split('/')
    channel = parts[2] if len(parts) >= 3 else 'nurds'
    nick    = parts[3] if len(parts) >= 4 else 'jemoeder'

    if text[0] != prefix:
        return

    command = text[1:].split(' ')[0]

    if channel in channels or (len(channel) >= 1 and channel[0] == '\\'):
        response_topic = f'{topic_prefix}to/irc/{channel}/privmsg'

        if command == 'doorbell':
            if last_ring == None:
                client.publish(response_topic, 'The doorbell never rang')

            else:
                client.publish(response_topic, f'Last ring: {last_ring}')

def on_connect(client, userdata, flags, rc):
    client.subscribe(f'{topic_prefix}from/irc/#')

    client.subscribe(f'{topic_prefix}from/bot/command')

    client.subscribe(f'deurbel')

    client.subscribe(f'doordeamon/LiveEvents')

def announce_thread(client):
    while True:
        try:
            announce_commands(client)

            time.sleep(4.1)

        except Exception as e:
            print(f'Failed to announce: {e}')

client = mqtt.Client(f'{socket.gethostname()}_{sys.argv[0]}', clean_session=False)
client.on_message = on_message
client.on_connect = on_connect
client.connect(mqtt_server, port=1883, keepalive=4, bind_address="")

t = threading.Thread(target=announce_thread, args=(client,))
t.start()

client.loop_forever()