update find_all

Author: wj-Mcat

src/wechaty/user/contact.py

@@ -251,33 +251,13 @@ async def find_all(cls: Type[Contact],
         """
         log.info('find_all() <%s, %s>', cls, query)
 
-        # 0. load from local cache file
-        if config.cache_contacts and os.path.exists(config.cache_contact_path):
-            contact_payloads = load_pickle_data(config.cache_contact_path)
-            assert isinstance(contact_payloads, list)
-            assert isinstance(contact_payloads[0], ContactPayload)
-
-            contact_payloads: List[ContactPayload] = contact_payloads
-            contacts = []
-            for contact_payload in contact_payloads:
-                contact = cls.load(contact_payload.id)
-
-                # type: ignore
-                contact._payload = contact_payload
-                contacts.append(contact)
-            return contacts
-
         # 1. load contacts with concurrent tasks
         contact_ids: List[str] = await cls.get_puppet().contact_list()
 
         contacts: List[Contact] = [cls.load(contact_id) for contact_id in contact_ids]
         tasks: List[Task] = [asyncio.create_task(contact.ready()) for contact in contacts]
         await gather_with_concurrency(PARALLEL_TASK_NUM, tasks)
 
-        if config.cache_contacts:
-            contact_payloads = [contact.payload for contact in contacts if contact.payload is not None]
-            save_pickle_data(contact_payloads, config.cache_contact_path)
-
         # 2. filter contacts
         if not query:
             return contacts

src/wechaty/user/room.py

@@ -225,32 +225,12 @@ async def find_all(cls,
         """
         log.info('Room find_all <%s>', query)
 
-        # 0. load from local cache file
-        if config.cache_rooms and os.path.exists(config.cache_room_path):
-            room_payloads = load_pickle_data(config.cache_room_path)
-            assert isinstance(room_payloads, list)
-            assert isinstance(room_payloads[0], RoomPayload)
-
-            room_payloads: List[RoomPayload] = room_payloads
-            rooms = []
-            for room_payload in room_payloads:
-                room = cls.load(room_payload.id)
-
-                # type: ignore
-                room._payload = room_payload
-                rooms.append(room)
-        else:
-
-            # 1. load rooms with concurrent tasks
-            room_ids = await cls.get_puppet().room_search()
-            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)
+        # 1. load rooms with concurrent tasks
+        room_ids = await cls.get_puppet().room_search()
+        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)
 
-        if config.cache_rooms:
-            room_payloads = [room.payload for room in rooms if room.payload is not None]
-            save_pickle_data(room_payloads, config.cache_contact_path)
-
         # 2. filter the rooms
         if not query:
             return rooms