from dragonfly.server import Server
from dragonfly.logger import setup
import threading

# sets up logging
setup()

# initializes a server
server = Server(config="config.dfcfg")

# runs the mainloop in another thread
t = threading.Thread(target=server.start, daemon=True)
t.start()

input("Presse RETURN to stop")

# closes the server
server.stop()

from dragonfly.client import Client
from dragonfly.logger import setup

def on_c(self, code):
    if code & 0x80:
        print(f"Connection failed with code {code}")
    
    else:
        print("Connected")

def on_d(self, code):
    print("Disconnected")

def on_m(self, topic, msg):
    print(msg)

# sets up logging
setup()

username = input("username: ")
password = input("password: ")
if not username: username = None
if not password: password = None

# initializes a client
client = Client(username, password)

# connects to the server
client.connect()

# sets up callbacks for certain events
client.on_connected = on_c
client.on_disconnected = on_d
client.on_message = on_m

# subscribes to topic 'chat'
client.subscribe("chat")

# sends all user input to topic 'chat'
# exits if input is empty
while True:
    c = input()
    if c == "":
        break
    
    # publishes to topic 'chat'
    client.publish("chat", c)

# unsubscribes from topic 'chat'
client.unsubscribe("chat")

# disconnects from the server
client.disconnect()