emitter-io / python Goto Github PK

from emitter import Client

master_sub_key = "full_authorized_subscription_key"  
master_channel = "/#/" 
emitter_host = "api.emitter.io"
emitter_port = "8080"


def on_connect():
    print("Connected: \n\n")


def on_disconnect():
    print("Disconnected\n\n")
    print("Reconnecting in 1 minute...")
    time.sleep(60)
    emitter.connect(host=emitter_host, port=emitter_port, secure=False)


def on_error(e):
    print(f"Error received: {str(e)}\n\n")


def on_me(me):
    print(f"Information about Me received: {str(me)}\n\n")


def on_subscribe(m, channel):
    print(f"Message received on handler for {channel}: {m.as_string()}\n\n"),


def on_presence(p):
    print(f"Presence message on channel: '{str(p)}'\n\n"),


def on_keygen(kg):
    print(f"Keygen message received: {str(kg)}\n\n")


def on_keyban(kb):
    print(f"Keyban message received: {str(kb)}\n\n")


def on_message(m):
    print(
        f"Message received on default handler, destined to {m.channel}: {m.as_string()}\n\n"
    )


def mqtt_setup():
    emitter = Client()
    emitter.on_connect = on_connect
    emitter.on_disconnect = on_disconnect
    emitter.on_error = on_error
    emitter.on_keygen = on_keygen
    emitter.on_keyban = on_keyban
    emitter.on_me = on_me
    emitter.on_presence = on_presence
    emitter.on_message = on_message

    emitter.connect(host=emitter_host, port=emitter_port, secure=False)
    emitter.subscribe(
       master_sub_key,
       master_channel,
       optional_handler=lambda m: on_subscribe(m, master_channel),
       options={Client.with_last(5)},
       )
    emitter.loop_start()

# ****
from .mqtt import mqtt_setup

mqtt_setup()

# ****

def _format_channel(key, channel, options={}):
        k = key.strip("/")
        c = channel.strip("/")
        o = Client._format_options(options)
        
        formatted = "{key}/{channel}/{options}".format(key=k, channel=c, options=o)
        return formatted