From 45200d8af7f3845a31a7eb437f00e86f068f33f0 Mon Sep 17 00:00:00 2001
From: Tulir Asokan <tulir@maunium.net>
Date: Mon, 31 Aug 2020 18:53:34 +0300
Subject: [PATCH] Log unknown MQTT events
---
mautrix_facebook/user.py | 11 +++++++----
1 file changed, 7 insertions(+), 4 deletions(-)
diff --git a/mautrix_facebook/user.py b/mautrix_facebook/user.py
index 1ffca33..72382eb 100644
--- a/mautrix_facebook/user.py
+++ b/mautrix_facebook/user.py
@@ -14,7 +14,7 @@
# You should have received a copy of the GNU Affero General Public License
# along with this program. If not, see <https://www.gnu.org/licenses/>.
from typing import (Any, Dict, List, Iterator, Optional, Iterable, Type, Callable, Awaitable,
- Union, TYPE_CHECKING)
+ Union, TYPE_CHECKING, cast)
import asyncio
import time
@@ -123,6 +123,7 @@ class User(BaseUser):
fbchat.Connect: self.on_connect,
fbchat.Disconnect: self.on_disconnect,
fbchat.Resync: self.on_resync,
+ fbchat.UnknownEvent: self.on_unknown_event,
}
@property
@@ -324,9 +325,8 @@ class User(BaseUser):
self.log.warning("Error fetching own info, retrying...", exc_info=True)
own_info = await self.client.fetch_thread_info([self.fbid]).__anext__()
puppet = pu.Puppet.get_by_fbid(self.fbid, create=True)
- await puppet.update_info(source=self, info=own_info)
- await self.sync_contacts()
- await self.sync_threads()
+ await puppet.update_info(source=self, info=cast(fbchat.UserData, own_info))
+ await asyncio.gather(self.sync_contacts(), self.sync_threads())
async def _create_community(self) -> None:
template = config["bridge.community_template"]
@@ -544,6 +544,9 @@ class User(BaseUser):
except Exception:
self.log.exception(f"Failed to handle {type(event)} event from Facebook")
+ async def on_unknown_event(self, evt: fbchat.UnknownEvent) -> None:
+ self.log.debug(f"Unknown event %s: %s", evt.source, evt.data)
+
async def on_connect(self, evt: fbchat.Connect) -> None:
now = time.monotonic()
disconnected_at = self._connection_time
--
GitLab