karaolidis/fbchat
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix frozen MQTT instances

Browse Source
This commit is contained in:
Mads Marquart
2020-01-23 11:26:30 +01:00
parent 89f90ef849
commit 0d139cee73
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
fbchat/_mqtt.py
View File

@@ -2,7 +2,7 @@ import attr
import random import random
import paho.mqtt.client import paho.mqtt.client
import requests import requests
from ._core import log, attrs_default from ._core import log, kw_only
from . import _util, _exception, _session, _graphql, _event_common, _event from . import _util, _exception, _session, _graphql, _event_common, _event
from typing import Iterable, Optional from typing import Iterable, Optional
@@ -21,7 +21,7 @@ def generate_session_id() -> int:
return random.randint(1, 2 ** 53) return random.randint(1, 2 ** 53)
@attrs_default @attr.s(slots=True, kw_only=kw_only, repr=False, eq=False)
class Listener: class Listener:
"""Helper, to listen for incoming Facebook events.""" """Helper, to listen for incoming Facebook events."""
@@ -35,6 +35,12 @@ class Listener:
_HOST = "edge-chat.facebook.com" _HOST = "edge-chat.facebook.com"
def __repr__(self) -> str:
# An alternative repr, to illustrate that you can't create the class directly
return "<fbchat.Listener session={} chat_on={} foreground={}>".format(
self.session, self._chat_on, self._foreground
)
@classmethod @classmethod
def connect(cls, session: _session.Session, chat_on: bool, foreground: bool): def connect(cls, session: _session.Session, chat_on: bool, foreground: bool):
"""Initialize a connection to the Facebook MQTT service. """Initialize a connection to the Facebook MQTT service.