# -------------------------------------------------------------------------
# Copyright (c) Microsoft Corporation. All rights reserved.
# Licensed under the MIT License. See License.txt in the project root for
# license information.
# --------------------------------------------------------------------------

"""
FILE: user_credential_sample_async.py
DESCRIPTION:
    These samples demonstrate creating a `CommunicationTokenCredential` object.
    The `CommunicationTokenCredential` object is used to authenticate a user with Communication Services,
    such as Chat or Calling. It optionally provides an auto-refresh mechanism to ensure a continuously
    stable authentication state during communications.

USAGE:
    python user_credential_sample_async.py
    Set the environment variables with your own values before running the sample:
    1) COMMUNICATION_SAMPLES_CONNECTION_STRING - the connection string in your Communication Services resource
"""


import os
import asyncio
from azure.communication.chat.aio import CommunicationTokenCredential
from azure.communication.identity import CommunicationIdentityClient


class CommunicationTokenCredentialSamples(object):

    connection_string = os.environ.get("COMMUNICATION_SAMPLES_CONNECTION_STRING", None)
    if not connection_string:
        raise ValueError("Set COMMUNICATION_SAMPLES_CONNECTION_STRING env before running this sample.")

    identity_client = CommunicationIdentityClient.from_connection_string(connection_string)
    user = identity_client.create_user()
    token_response = identity_client.get_token(user, scopes=["chat"])
    token = token_response.token

    async def create_credential_with_static_token(self):
        # For short-lived clients, refreshing the token upon expiry is not necessary
        # and `CommunicationTokenCredential` may be instantiated with a static token.
        async with CommunicationTokenCredential(self.token) as credential:
            token_response = await credential.get_token()
            print("Token issued with value: " + token_response.token)

    async def create_credential_with_refreshing_callback(self):
        # Alternatively, for long-lived clients, you can create a `CommunicationTokenCredential` with a callback to renew tokens if expired.
        # Here we assume that we have a function `fetch_token_from_server` that makes a network request to retrieve a token string for a user.
        # It's necessary that the `fetch_token_from_server` function returns a valid token (with an expiration date set in the future) at all times.
        fetch_token_from_server = lambda: None
        async with CommunicationTokenCredential(self.token, token_refresher=fetch_token_from_server) as credential:
            token_response = await credential.get_token()
            print("Token issued with value: " + token_response.token)

    async def create_credential_with_proactive_refreshing_callback(self):
        # Optionally, you can enable proactive token refreshing where a fresh token will be acquired as soon as the
        # previous token approaches expiry. Using this method, your requests are less likely to be blocked to acquire a fresh token
        fetch_token_from_server = lambda: None
        async with CommunicationTokenCredential(
            self.token, token_refresher=fetch_token_from_server, proactive_refresh=True
        ) as credential:
            token_response = await credential.get_token()
            print("Token issued with value: " + token_response.token)

    def clean_up(self):
        print("cleaning up: deleting created user.")
        self.identity_client.delete_user(self.user)


async def main():
    sample = CommunicationTokenCredentialSamples()
    await sample.create_credential_with_static_token()
    await sample.create_credential_with_refreshing_callback()
    await sample.create_credential_with_proactive_refreshing_callback()
    sample.clean_up()


if __name__ == "__main__":
    asyncio.run(main())