get_all_conversations: add helper

Author: sumnerevans

linkedin_messaging/api_objects.py

@@ -89,13 +89,11 @@ class Picture:
 @dataclass_json(letter_case=LetterCase.CAMEL, undefined=Undefined.EXCLUDE)
 @dataclass
 class MiniProfile:
-    first_name: str
-    last_name: str
-    occupation: str
     entity_urn: URN
     public_identifier: str
-    tracking_id: str
-
+    first_name: Optional[str] = None
+    last_name: Optional[str] = None
+    occupation: Optional[str] = None
     memorialized: bool = False
     picture: Optional[Picture] = None
 
@@ -197,10 +195,11 @@ class ThirdPartyMedia:
 @dataclass_json(letter_case=LetterCase.CAMEL)
 @dataclass
 class MessageCustomContent:
-    third_party_media: ThirdPartyMedia = field(
+    third_party_media: Optional[ThirdPartyMedia] = field(
         metadata=config(
             field_name="com.linkedin.voyager.messaging.shared.ThirdPartyMedia"
-        )
+        ),
+        default=None,
     )
 
 

linkedin_messaging/linkedin.py

@@ -6,6 +6,7 @@
 from datetime import datetime
 from typing import (
     Any,
+    AsyncGenerator,
     Awaitable,
     Callable,
     DefaultDict,
@@ -19,6 +20,7 @@
 from bs4 import BeautifulSoup
 
 from .api_objects import (
+    Conversation,
     ConversationResponse,
     ConversationsResponse,
     MessageAttachmentCreate,
@@ -219,6 +221,25 @@ async def get_conversations(
         conversations_resp = await self._get("/messaging/conversations", params=params)
         return ConversationsResponse.from_json(await conversations_resp.text())
 
+    async def get_all_conversations(self) -> AsyncGenerator[Conversation, None]:
+        """
+        A generator of all of the user's conversations using paging.
+        """
+        last_activity_before = datetime.now()
+        while True:
+            conversations_response = await self.get_conversations(
+                last_activity_before=last_activity_before
+            )
+            for c in conversations_response.elements:
+                yield c
+
+            # The page size is 20, by default, so if we get less than 20, we are at the
+            # end of the list so we should stop.
+            if len(conversations_response.elements) < 20:
+                break
+
+            last_activity_before = conversations_response.elements[-1].last_activity_at
+
     async def get_conversation(
         self,
         conversation_urn: URN,