"""
Copyright (c) Microsoft Corporation. All rights reserved.
Licensed under the MIT License.
"""

from typing import List, Optional

from microsoft_teams.common.http import Client

from ...models import TeamsChannelAccount
from ...models.conversation import PagedMembersResult
from ..api_client_settings import ApiClientSettings
from ..base_client import BaseClient


class ConversationMemberClient(BaseClient):
    """
    Client for managing members in a Teams conversation.
    """

    def __init__(
        self,
        service_url: str,
        http_client: Optional[Client] = None,
        api_client_settings: Optional[ApiClientSettings] = None,
    ):
        """
        Initialize the conversation member client.

        Args:
            service_url: The base URL for the Teams service
            http_client: Optional HTTP client to use. If not provided, a new one will be created.
            api_client_settings: Optional API client settings.
        """
        super().__init__(http_client, api_client_settings)
        self.service_url = service_url.rstrip("/")

    async def get(self, conversation_id: str) -> List[TeamsChannelAccount]:
        """
        Get all members in a conversation.

        Args:
            conversation_id: The ID of the conversation

        Returns:
            List of TeamsChannelAccount objects representing the conversation members
        """
        response = await self.http.get(f"{self.service_url}/v3/conversations/{conversation_id}/members")
        return [TeamsChannelAccount.model_validate(member) for member in response.json()]

    async def get_paged(
        self,
        conversation_id: str,
        page_size: Optional[int] = None,
        continuation_token: Optional[str] = None,
    ) -> PagedMembersResult:
        """
        Get a page of members in a conversation.

        Args:
            conversation_id: The ID of the conversation.
            page_size: Optional maximum number of members to return per page.
            continuation_token: Optional token from a previous call to fetch the next page.

        Returns:
            PagedMembersResult containing the members and an optional continuation token
            for fetching subsequent pages.
        """
        url = f"{self.service_url}/v3/conversations/{conversation_id}/pagedMembers"
        response = await self.http.get(url, params={"pageSize": page_size, "continuationToken": continuation_token})
        return PagedMembersResult.model_validate(response.json())

    async def get_by_id(self, conversation_id: str, member_id: str) -> TeamsChannelAccount:
        """
        Get a specific member in a conversation.

        Args:
            conversation_id: The ID of the conversation
            member_id: The ID of the member to get

        Returns:
            TeamsChannelAccount object representing the conversation member
        """
        response = await self.http.get(f"{self.service_url}/v3/conversations/{conversation_id}/members/{member_id}")
        return TeamsChannelAccount.model_validate(response.json())