46 lines
1.5 KiB
Python
46 lines
1.5 KiB
Python
import os, re, hashlib, sys, traceback
|
|
import asyncio
|
|
|
|
|
|
import settings
|
|
|
|
# Plexus is the main (pubsub) event bus that all gateways communicate through
|
|
# There are three main events all should keep track of:
|
|
# new_user: each gateway must emit this event for each native user before sending message events
|
|
# message: a native user has sent a message OR edited one. all gateways should relay the message to their own native channels
|
|
# message_delete: a native user has deleted a message. all gateways should delete the respective message in their own native channels
|
|
class Plexus:
|
|
def __init__(self):
|
|
self.pubsub_callbacks = {}
|
|
|
|
def sub(self, event_name, callback):
|
|
if event_name not in self.pubsub_callbacks:
|
|
self.pubsub_callbacks[event_name] = []
|
|
self.pubsub_callbacks[event_name].append(callback)
|
|
|
|
def pub(self, event_name, *args):
|
|
print(event_name, args)
|
|
if event_name in self.pubsub_callbacks:
|
|
for callback in self.pubsub_callbacks[event_name]:
|
|
try:
|
|
callback(*args)
|
|
except:
|
|
print(traceback.format_exc())
|
|
PLEXUS = Plexus()
|
|
|
|
for name, data in settings.XMPPs.items():
|
|
import gateway_xmpp
|
|
data["handler"] = gateway_xmpp.GatewayXMPP(PLEXUS, settings, name, data)
|
|
|
|
for name, data in settings.DISCORDs.items():
|
|
import gateway_discord
|
|
data["handler"] = gateway_discord.GatewayDiscord(PLEXUS, settings, name, data)
|
|
|
|
for name, data in settings.MATRIXs.items():
|
|
import gateway_matrix
|
|
data["handler"] = gateway_matrix.GatewayMatrix(PLEXUS, settings, name, data)
|
|
|
|
PLEXUS.pub("ready")
|
|
|
|
asyncio.get_event_loop().run_forever()
|