Stanislav Hejny
39 lines
1.2 KiB
Python
39 lines
1.2 KiB
Python
import asyncio
|
|
|
|
from amqp.config.amq_configuration import AMQConfiguration
|
|
from amqp.rabbitmq.user_management import get_user_info_from_token
|
|
from amqp.rabbitmq.user_management_service_client import (
|
|
UserManagementServiceClient,
|
|
UserManagementServiceException,
|
|
)
|
|
|
|
|
|
async def main():
|
|
# Initialize configuration
|
|
config = AMQConfiguration("")
|
|
|
|
# Create client
|
|
client = UserManagementServiceClient(config)
|
|
|
|
try:
|
|
# Sample JWT token (replace with actual token)
|
|
token = "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJzdWIiOiIxMjM0NTY3ODkwIiwibmFtZSI6IkpvaG4gRG9lIiwiaWF0IjoxNTE2MjM5MDIyfQ.SflKxwRJSMeKKF2QT4fwpMeJf36POk6yJV_adQssw5c"
|
|
|
|
# Get user information
|
|
user_info = await get_user_info_from_token(client, token)
|
|
print(f"User information: {user_info}")
|
|
|
|
except UserManagementServiceException as e:
|
|
print(f"Error: {e.exception_type}: {e.message}")
|
|
if e.additional_info:
|
|
print(f"Additional info: {e.additional_info}")
|
|
except Exception as e:
|
|
print(f"Unexpected error: {e}")
|
|
finally:
|
|
# Close client
|
|
await client.close()
|
|
|
|
|
|
if __name__ == "__main__":
|
|
asyncio.run(main())
|