2022-11-18 16:29:53 -06:00
|
|
|
# -*- coding: utf-8 -*-
|
|
|
|
|
import mastodon
|
|
|
|
|
from pubsub import pub
|
|
|
|
|
|
|
|
|
|
class StreamListener(mastodon.StreamListener):
|
|
|
|
|
|
|
|
|
|
def __init__(self, session_name, user_id):
|
|
|
|
|
self.session_name = session_name
|
|
|
|
|
self.user_id = user_id
|
|
|
|
|
super(StreamListener, self).__init__()
|
|
|
|
|
|
|
|
|
|
def on_update(self, status):
|
2022-11-19 19:36:21 -06:00
|
|
|
pub.sendMessage("mastodon.status_received", status=status, session_name=self.session_name)
|
|
|
|
|
|
|
|
|
|
def on_conversation(self, conversation):
|
|
|
|
|
pub.sendMessage("mastodon.conversation_received", conversation=conversation, session_name=self.session_name)
|
|
|
|
|
|
|
|
|
|
def on_notification(self, notification):
|
|
|
|
|
pub.sendMessage("mastodon.notification_received", notification=notification, session_name=self.session_name)
|
|
|
|
|
|
|
|
|
|
def on_unknown_event(self, event):
|
|
|
|
|
log.error("Unknown event: {}".format(event))
|
