修改群修改topic后，本地缓存未更新的bug

Author: 1914049892

src/wechaty/user/room.py

@@ -167,9 +167,10 @@ def filter_func(room: Room) -> bool:
                 payload = room.payload
                 if not payload:
                     return False
-                if query == payload.id or (query.lower() in payload.topic.lower()): # type: ignore
+                if query == payload.id or (query.lower() in payload.topic.lower()):  # type: ignore
                     return True
                 return False
+
             func = filter_func
         elif isinstance(query, RoomQueryFilter):
             def filter_func(room: Room) -> bool:
@@ -179,9 +180,10 @@ def filter_func(room: Room) -> bool:
                 if not payload:
                     return False
 
-                if query.id == payload.id or (query.topic.lower() in payload.topic.lower()): # noqa
+                if query.id == payload.id or (query.topic.lower() in payload.topic.lower()):  # noqa
                     return True
                 return False
+
             func = filter_func
         elif isinstance(query, types.FunctionType):
             func = query
@@ -230,7 +232,7 @@ async def find_all(cls,
         rooms: List[Room] = [cls.load(room_id) for room_id in room_ids]
         tasks: List[Task] = [asyncio.create_task(room.ready()) for room in rooms]
         await gather_with_concurrency(PARALLEL_TASK_NUM, tasks)
-        
+
         # 2. filter the rooms
         if not query:
             return rooms
@@ -290,6 +292,15 @@ def load(cls, room_id: str) -> Room:
         cls._pool[room_id] = room
         return room
 
+    @classmethod
+    def upload_cache(cls, room_id: str)->None:
+        """
+        dynamic upload
+        clear the room_id of _pool and upload it use load
+        """
+        cls._pool[room_id] = None
+        cls.load(room_id)
+
     def __str__(self) -> str:
         """
         string format for room instance
@@ -349,7 +360,7 @@ async def ready(self, force_sync: bool = False, load_members: bool = False) -> N
 
     async def say(self,
                   some_thing: Union[str, Contact,
-                                    FileBox, MiniProgram, UrlLink],
+                  FileBox, MiniProgram, UrlLink],
                   mention_ids: Optional[List[str]] = None
                   ) -> Union[None, Message]:
         """

src/wechaty/wechaty.py

@@ -713,7 +713,7 @@ async def room_leave_listener(payload: EventRoomLeavePayload) -> None:
                 async def room_topic_listener(payload: EventRoomTopicPayload) -> None:
                     log.info('receive <room-topic> event <%s>', payload)
 
-                    room: Room = self.Room.load(payload.room_id)
+                    room: Room = self.Room.upload_cache(payload.room_id)
                     await room.ready()
 
                     changer = self.Contact.load(payload.changer_id)