async def _generate_conversation_entities(
        self, client: httpx.AsyncClient
    ) -> AsyncGenerator[ChunkEntity, None]:
        """Generate Conversation entities from Intercom.

        Using the Conversations endpoint:
          GET https://api.intercom.io/conversations
        """
        url = "https://api.intercom.io/conversations"
        while url:
            data = await self._get_with_auth(client, url)
            for convo in data.get("data", []):
                yield IntercomConversationEntity(
                    entity_id=convo.get("id"),
                    conversation_id=convo.get("id", ""),
                    title=convo.get("title"),
                    state=convo.get("state"),
                    created_at=convo.get("created_at"),
                    updated_at=convo.get("updated_at"),
                    archived=convo.get("archived", False),
                )

            # Handle pagination
            pages = data.get("pages", {})
            next_link = pages.get("next")
            url = next_link if next_link else None
Generate Conversation entities from Intercom.

        Using the Conversations endpoint:
          GET https://api.intercom.io/conversations
        
backend/airweave/platform/sources/intercom.py