Azure Communication Chat Java

import com.azure.communication.chat.ChatClient;import com.azure.communication.chat.ChatClientBuilder;import com.azure.communication.chat.ChatThreadClient;import com.azure.communication.common.CommunicationTokenCredential;
// ChatClient requires a CommunicationTokenCredential (user access token)String endpoint = "https://<resource>.communication.azure.com";String userAccessToken = "<user-access-token>";
CommunicationTokenCredential credential = new CommunicationTokenCredential(userAccessToken);
ChatClient chatClient = new ChatClientBuilder()    .endpoint(endpoint)    .credential(credential)    .buildClient();
// Async clientChatAsyncClient chatAsyncClient = new ChatClientBuilder()    .endpoint(endpoint)    .credential(credential)    .buildAsyncClient();

import com.azure.communication.chat.models.*;import com.azure.communication.common.CommunicationUserIdentifier;import java.util.ArrayList;import java.util.List;
// Define participantsList<ChatParticipant> participants = new ArrayList<>();
ChatParticipant participant1 = new ChatParticipant()    .setCommunicationIdentifier(new CommunicationUserIdentifier("<user-id-1>"))    .setDisplayName("Alice");
ChatParticipant participant2 = new ChatParticipant()    .setCommunicationIdentifier(new CommunicationUserIdentifier("<user-id-2>"))    .setDisplayName("Bob");
participants.add(participant1);participants.add(participant2);
// Create threadCreateChatThreadOptions options = new CreateChatThreadOptions("Project Discussion")    .setParticipants(participants);
CreateChatThreadResult result = chatClient.createChatThread(options);String threadId = result.getChatThread().getId();
// Get thread client for operationsChatThreadClient threadClient = chatClient.getChatThreadClient(threadId);

// Send text messageSendChatMessageOptions messageOptions = new SendChatMessageOptions()    .setContent("Hello, team!")    .setSenderDisplayName("Alice")    .setType(ChatMessageType.TEXT);
SendChatMessageResult sendResult = threadClient.sendMessage(messageOptions);String messageId = sendResult.getId();
// Send HTML messageSendChatMessageOptions htmlOptions = new SendChatMessageOptions()    .setContent("<strong>Important:</strong> Meeting at 3pm")    .setType(ChatMessageType.HTML);
threadClient.sendMessage(htmlOptions);

import com.azure.core.util.paging.PagedIterable;
// List all messagesPagedIterable<ChatMessage> messages = threadClient.listMessages();
for (ChatMessage message : messages) {    System.out.println("ID: " + message.getId());    System.out.println("Type: " + message.getType());    System.out.println("Content: " + message.getContent().getMessage());    System.out.println("Sender: " + message.getSenderDisplayName());    System.out.println("Created: " + message.getCreatedOn());        // Check if edited or deleted    if (message.getEditedOn() != null) {        System.out.println("Edited: " + message.getEditedOn());    }    if (message.getDeletedOn() != null) {        System.out.println("Deleted: " + message.getDeletedOn());    }}
// Get specific messageChatMessage message = threadClient.getMessage(messageId);

// Update messageUpdateChatMessageOptions updateOptions = new UpdateChatMessageOptions()    .setContent("Updated message content");
threadClient.updateMessage(messageId, updateOptions);
// Delete messagethreadClient.deleteMessage(messageId);

// List participantsPagedIterable<ChatParticipant> participants = threadClient.listParticipants();
for (ChatParticipant participant : participants) {    CommunicationUserIdentifier user =         (CommunicationUserIdentifier) participant.getCommunicationIdentifier();    System.out.println("User: " + user.getId());    System.out.println("Display Name: " + participant.getDisplayName());}
// Add participantsList<ChatParticipant> newParticipants = new ArrayList<>();newParticipants.add(new ChatParticipant()    .setCommunicationIdentifier(new CommunicationUserIdentifier("<new-user-id>"))    .setDisplayName("Charlie")    .setShareHistoryTime(OffsetDateTime.now().minusDays(7))); // Share last 7 days
threadClient.addParticipants(newParticipants);
// Remove participantCommunicationUserIdentifier userToRemove = new CommunicationUserIdentifier("<user-id>");threadClient.removeParticipant(userToRemove);

// Send read receiptthreadClient.sendReadReceipt(messageId);
// Get read receiptsPagedIterable<ChatMessageReadReceipt> receipts = threadClient.listReadReceipts();
for (ChatMessageReadReceipt receipt : receipts) {    System.out.println("Message ID: " + receipt.getChatMessageId());    System.out.println("Read by: " + receipt.getSenderCommunicationIdentifier());    System.out.println("Read at: " + receipt.getReadOn());}

import com.azure.communication.chat.models.TypingNotificationOptions;
// Send typing notificationTypingNotificationOptions typingOptions = new TypingNotificationOptions()    .setSenderDisplayName("Alice");
threadClient.sendTypingNotificationWithResponse(typingOptions, Context.NONE);
// Simple typing notificationthreadClient.sendTypingNotification();

// Get thread propertiesChatThreadProperties properties = threadClient.getProperties();System.out.println("Topic: " + properties.getTopic());System.out.println("Created: " + properties.getCreatedOn());
// Update topicthreadClient.updateTopic("New Project Discussion Topic");
// Delete threadchatClient.deleteChatThread(threadId);

// List all chat threads for the userPagedIterable<ChatThreadItem> threads = chatClient.listChatThreads();
for (ChatThreadItem thread : threads) {    System.out.println("Thread ID: " + thread.getId());    System.out.println("Topic: " + thread.getTopic());    System.out.println("Last message: " + thread.getLastMessageReceivedOn());}

import com.azure.core.http.rest.PagedResponse;
// Paginate through messagesint maxPageSize = 10;ListChatMessagesOptions listOptions = new ListChatMessagesOptions()    .setMaxPageSize(maxPageSize);
PagedIterable<ChatMessage> pagedMessages = threadClient.listMessages(listOptions);
pagedMessages.iterableByPage().forEach(page -> {    System.out.println("Page status code: " + page.getStatusCode());    page.getElements().forEach(msg ->         System.out.println("Message: " + msg.getContent().getMessage()));});

import com.azure.core.exception.HttpResponseException;
try {    threadClient.sendMessage(messageOptions);} catch (HttpResponseException e) {    switch (e.getResponse().getStatusCode()) {        case 401:            System.out.println("Unauthorized - check token");            break;        case 403:            System.out.println("Forbidden - user not in thread");            break;        case 404:            System.out.println("Thread not found");            break;        default:            System.out.println("Error: " + e.getMessage());    }}