forked from Azure/azure-sdk-for-python
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request Azure#10 from beltr0n/bertong-extract-identity
Bertong extract identity
- Loading branch information
Showing
10 changed files
with
184 additions
and
10 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
81 changes: 81 additions & 0 deletions
81
sdk/communication/azure-communication-identity/samples/identity_samples.py
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,81 @@ | ||
# coding: utf-8 | ||
|
||
# ------------------------------------------------------------------------- | ||
# Copyright (c) Microsoft Corporation. All rights reserved. | ||
# Licensed under the MIT License. See License.txt in the project root for | ||
# license information. | ||
# -------------------------------------------------------------------------- | ||
|
||
""" | ||
FILE: identity_sample.py | ||
DESCRIPTION: | ||
These samples demonstrate identity client samples. | ||
///authenticating a client via a connection string | ||
USAGE: | ||
python identity_samples.py | ||
""" | ||
import os | ||
|
||
class CommunicationIdentityClientSamples(object): | ||
|
||
def __init__(self): | ||
self.connection_string = os.getenv('AZURE_COMMUNICATION_SERVICE_CONNECTION_STRING') | ||
self.endpoint = os.getenv('AZURE_COMMUNICATION_SERVICE_ENDPOINT') | ||
self.client_id = os.getenv('AZURE_CLIENT_ID') | ||
self.client_secret = os.getenv('AZURE_CLIENT_SECRET') | ||
self.tenant_id = os.getnenv('AZURE_TENANT_ID') | ||
|
||
def issue_token(self): | ||
from azure.communication.identity import CommunicationIdentityClient | ||
|
||
if self.client_id is not None and self.client_secret is not None and self.tenant_id is not None: | ||
from azure.identity import DefaultAzureCredential | ||
identity_client = CommunicationIdentityClient(self.endpoint, DefaultAzureCredential()) | ||
else: | ||
identity_client = CommunicationIdentityClient.from_connection_string(self.connection_string) | ||
user = identity_client.create_user() | ||
tokenresponse = identity_client.issue_token(user, scopes=["chat"]) | ||
print(tokenresponse) | ||
|
||
def revoke_tokens(self): | ||
from azure.communication.identity import CommunicationIdentityClient | ||
|
||
if self.client_id is not None and self.client_secret is not None and self.tenant_id is not None: | ||
from azure.identity import DefaultAzureCredential | ||
identity_client = CommunicationIdentityClient(self.endpoint, DefaultAzureCredential()) | ||
else: | ||
identity_client = CommunicationIdentityClient.from_connection_string(self.connection_string) | ||
user = identity_client.create_user() | ||
tokenresponse = identity_client.issue_token(user, scopes=["chat"]) | ||
identity_client.revoke_tokens(user) | ||
print(tokenresponse) | ||
|
||
def create_user(self): | ||
from azure.communication.identity import CommunicationIdentityClient | ||
|
||
if self.client_id is not None and self.client_secret is not None and self.tenant_id is not None: | ||
from azure.identity import DefaultAzureCredential | ||
identity_client = CommunicationIdentityClient(self.endpoint, DefaultAzureCredential()) | ||
else: | ||
identity_client = CommunicationIdentityClient.from_connection_string(self.connection_string) | ||
user = identity_client.create_user() | ||
print(user.identifier) | ||
|
||
def delete_user(self): | ||
from azure.communication.identity import CommunicationIdentityClient | ||
|
||
if self.client_id is not None and self.client_secret is not None and self.tenant_id is not None: | ||
from azure.identity import DefaultAzureCredential | ||
identity_client = CommunicationIdentityClient(self.endpoint, DefaultAzureCredential()) | ||
else: | ||
identity_client = CommunicationIdentityClient.from_connection_string(self.connection_string) | ||
user = identity_client.create_user() | ||
identity_client.delete_user(user) | ||
|
||
if __name__ == '__main__': | ||
sample = CommunicationIdentityClientSamples() | ||
sample.create_user() | ||
sample.delete_user() | ||
sample.issue_token() | ||
sample.revoke_tokens() |
93 changes: 93 additions & 0 deletions
93
sdk/communication/azure-communication-identity/samples/identity_samples_async.py
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,93 @@ | ||
# coding: utf-8 | ||
|
||
# ------------------------------------------------------------------------- | ||
# Copyright (c) Microsoft Corporation. All rights reserved. | ||
# Licensed under the MIT License. See License.txt in the project root for | ||
# license information. | ||
# -------------------------------------------------------------------------- | ||
|
||
""" | ||
FILE: identity_sample_async.py | ||
DESCRIPTION: | ||
These samples demonstrate async identity client samples. | ||
///authenticating a client via a connection string | ||
USAGE: | ||
python identity_samples_async.py | ||
""" | ||
|
||
import asyncio | ||
import os | ||
|
||
|
||
class CommunicationIdentityClientSamples(object): | ||
|
||
def __init__(self): | ||
self.connection_string = os.getenv('AZURE_COMMUNICATION_SERVICE_CONNECTION_STRING') | ||
self.endpoint = os.getenv('AZURE_COMMUNICATION_SERVICE_ENDPOINT') | ||
self.client_id = os.getenv('AZURE_CLIENT_ID') | ||
self.client_secret = os.getenv('AZURE_CLIENT_SECRET') | ||
self.tenant_id = os.getnenv('AZURE_TENANT_ID') | ||
|
||
async def issue_token(self): | ||
from azure.communication.identity.aio import CommunicationIdentityClient | ||
if self.client_id is not None and self.client_secret is not None and self.tenant_id is not None: | ||
from azure.identity import DefaultAzureCredential | ||
identity_client = CommunicationIdentityClient(self.endpoint, DefaultAzureCredential()) | ||
else: | ||
identity_client = CommunicationIdentityClient.from_connection_string(self.connection_string) | ||
|
||
async with identity_client: | ||
user = await identity_client.create_user() | ||
print(user.identifier) | ||
tokenresponse = await identity_client.issue_token(user, scopes=["chat"]) | ||
print(tokenresponse) | ||
|
||
async def revoke_tokens(self): | ||
from azure.communication.identity.aio import CommunicationIdentityClient | ||
if self.client_id is not None and self.client_secret is not None and self.tenant_id is not None: | ||
from azure.identity import DefaultAzureCredential | ||
identity_client = CommunicationIdentityClient(self.endpoint, DefaultAzureCredential()) | ||
else: | ||
identity_client = CommunicationIdentityClient.from_connection_string(self.connection_string) | ||
|
||
async with identity_client: | ||
user = await identity_client.create_user() | ||
tokenresponse = await identity_client.issue_token(user, scopes=["chat"]) | ||
await identity_client.revoke_tokens(user) | ||
print(tokenresponse) | ||
|
||
async def create_user(self): | ||
from azure.communication.identity.aio import CommunicationIdentityClient | ||
if self.client_id is not None and self.client_secret is not None and self.tenant_id is not None: | ||
from azure.identity import DefaultAzureCredential | ||
identity_client = CommunicationIdentityClient(self.endpoint, DefaultAzureCredential()) | ||
else: | ||
identity_client = CommunicationIdentityClient.from_connection_string(self.connection_string) | ||
|
||
async with identity_client: | ||
user = await identity_client.create_user() | ||
print(user.identifier) | ||
|
||
async def delete_user(self): | ||
from azure.communication.identity.aio import CommunicationIdentityClient | ||
if self.client_id is not None and self.client_secret is not None and self.tenant_id is not None: | ||
from azure.identity import DefaultAzureCredential | ||
identity_client = CommunicationIdentityClient(self.endpoint, DefaultAzureCredential()) | ||
else: | ||
identity_client = CommunicationIdentityClient.from_connection_string(self.connection_string) | ||
|
||
async with identity_client: | ||
user = await identity_client.create_user() | ||
await identity_client.delete_user(user) | ||
|
||
async def main(): | ||
sample = CommunicationIdentityClientSamples() | ||
await sample.create_user() | ||
await sample.delete_user() | ||
await sample.issue_token() | ||
await sample.revoke_tokens() | ||
|
||
if __name__ == '__main__': | ||
loop = asyncio.get_event_loop() | ||
loop.run_until_complete(main()) |