fix:修改workflows文件配置。python版本3.8->3.9

fix:优化wechaty.room.py中 upload_cache 逻辑。更规范

Author: 1914049892

.github/workflows/pypi.yml

@@ -10,7 +10,7 @@ jobs:
     - uses: actions/checkout@v2
     - uses: actions/setup-python@v1
       with:
-        python-version: 3.8
+        python-version: 3.9
     - name: Install dependencies
       run: |
         python -m pip install --upgrade pip
@@ -36,7 +36,7 @@ jobs:
       - uses: actions/checkout@v2
       - uses: actions/setup-python@v1
         with:
-          python-version: 3.8
+          python-version: 3.9
       - name: Install dependencies
         run: |
           python -m pip install --upgrade pip
@@ -57,7 +57,7 @@ jobs:
       - name: Set up Python
         uses: actions/setup-python@v1
         with:
-          python-version: 3.8
+          python-version: 3.9
       - name: Install dependencies
         run: |
           python -m pip install --upgrade pip
@@ -75,7 +75,7 @@ jobs:
       - uses: actions/setup-node@v3
         with:
           node-version: 16
-      - name: Building Wechaty-ui 
+      - name: Building Wechaty-ui
         id: build-ui
         run: |
           make ui

src/wechaty/user/room.py

@@ -293,13 +293,18 @@ def load(cls, room_id: str) -> Room:
         return room
 
     @classmethod
-    def upload_cache(cls, room_id: str)->None:
+    def upload_cache(cls, room_id: str) -> Room:
         """
         dynamic upload
-        clear the room_id of _pool and upload it use load
+        clear the room_id from _pool and re-upload it using load
+        Args:
+            room_id: The Roo ID to refresh
+        Return:
+            Room:The refreshed room instance
         """
-        cls._pool[room_id] = None
-        cls.load(room_id)
+        if room_id in cls._pool:
+            del cls._pool[room_id]
+        return cls.load(room_id)
 
     def __str__(self) -> str:
         """

src/wechaty/wechaty.py

@@ -99,7 +99,6 @@
 
 from wechaty.utils import timestamp_to_date, qr_terminal
 
-
 log: logging.Logger = get_logger('Wechaty')
 
 DEFAULT_TIMEOUT = 300
@@ -472,7 +471,7 @@ async def start(self) -> None:
             loop = asyncio.get_event_loop()
             loop.stop()
 
-        except Exception as e:      # pylint: disable=broad-except
+        except Exception as e:  # pylint: disable=broad-except
             print(e)
 
     async def restart(self) -> None:
@@ -713,7 +712,8 @@ 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.upload_cache(payload.room_id)
+                    self.Room.upload_cache(payload.room_id)
+                    room: Room = self.Room.load(payload.room_id)
                     await room.ready()
 
                     changer = self.Contact.load(payload.changer_id)