Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Angiurgiu/add missing chat thread async client options methods #21939

Merged
merged 11 commits into from
Jun 1, 2021
Merged

Angiurgiu/add missing chat thread async client options methods #21939

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
e20a252
Removed the item return check on listReadReceipts for Live/Record tes…
Oct 7, 2020
3ecc384
Merge branch 'master' of https://github.com/Azure/azure-sdk-for-java
Oct 8, 2020
5386378
Merge branch 'master' of https://github.com/Azure/azure-sdk-for-java
Oct 26, 2020
2aa285f
Merge branch 'master' of https://github.com/Azure/azure-sdk-for-java
Nov 30, 2020
1aecafb
Merge branch 'master' of https://github.com/Azure/azure-sdk-for-java
Dec 7, 2020
17daef5
Merge branch 'master' of https://github.com/Azure/azure-sdk-for-java
Dec 22, 2020
3ff1c0d
Merge branch 'master' of https://github.com/Azure/azure-sdk-for-java
May 26, 2021
44c2fe1
Merge branch 'master' of https://github.com/Azure/azure-sdk-for-java
May 27, 2021
0a8e11e
Added missing Options methods in ChatThreadAsyncClient
May 28, 2021
6f5bec8
Updated incorrect test name used for logging
May 28, 2021
eae3a33
Merge branch 'master' into angiurgiu/AddMissingChatThreadAsyncClientO…
angiurgiu May 28, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions sdk/communication/azure-communication-chat/CHANGELOG.md
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
# Release History

## 1.1.0-beta.1 (Unreleased)
- Added method `ChatThreadAsyncClient.listParticipants(ListParticipantsOptions listParticipantsOptions)`
- Added method `ChatThreadAsyncClient.listReadReceipts(ListReadReceiptOptions listReadReceiptOptions)`

## 1.0.1 (2021-05-27)
- Dependency versions updated.
Expand Down
57 changes: 57 additions & 0 deletions ...-communication-chat/src/main/java/com/azure/communication/chat/ChatThreadAsyncClient.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -345,6 +345,35 @@ public PagedFlux<ChatParticipant> listParticipants() {
return listParticipants(listParticipantsOptions, Context.NONE);
}

/**
* Gets the participants of a thread.
*
* @param listParticipantsOptions The request options.
* @return the participants of a thread.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedFlux<ChatParticipant> listParticipants(ListParticipantsOptions listParticipantsOptions) {
final ListParticipantsOptions serviceListParticipantsOptions =
listParticipantsOptions == null ? new ListParticipantsOptions() : listParticipantsOptions;

try {
return pagedFluxConvert(new PagedFlux<>(
() -> withContext(context ->
this.chatThreadClient.listChatParticipantsSinglePageAsync(
chatThreadId,
serviceListParticipantsOptions.getMaxPageSize(),
serviceListParticipantsOptions.getSkip(),
context)
.onErrorMap(CommunicationErrorResponseException.class, e -> translateException(e))),
nextLink -> withContext(context ->
this.chatThreadClient.listChatParticipantsNextSinglePageAsync(nextLink, context)
.onErrorMap(CommunicationErrorResponseException.class, e -> translateException(e)))),
f -> ChatParticipantConverter.convert(f));
} catch (RuntimeException ex) {
return new PagedFlux<>(() -> monoError(logger, ex));
}
}

/**
* Gets the participants of a thread.
*
Expand Down Expand Up @@ -821,6 +850,34 @@ public PagedFlux<ChatMessageReadReceipt> listReadReceipts() {
}
}

/**
* Gets read receipts for a thread.
*
* @param listReadReceiptOptions The additional options for this operation.
* @return read receipts for a thread.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedFlux<ChatMessageReadReceipt> listReadReceipts(ListReadReceiptOptions listReadReceiptOptions) {
final ListReadReceiptOptions serviceListReadReceiptOptions =
listReadReceiptOptions == null ? new ListReadReceiptOptions() : listReadReceiptOptions;

try {
return pagedFluxConvert(new PagedFlux<>(
() -> withContext(context -> this.chatThreadClient.listChatReadReceiptsSinglePageAsync(
chatThreadId,
serviceListReadReceiptOptions.getMaxPageSize(),
serviceListReadReceiptOptions.getSkip(),
context)
.onErrorMap(CommunicationErrorResponseException.class, e -> translateException(e))),
nextLink -> withContext(context -> this.chatThreadClient.listChatReadReceiptsNextSinglePageAsync(
nextLink, context)
.onErrorMap(CommunicationErrorResponseException.class, e -> translateException(e)))),
f -> ChatMessageReadReceiptConverter.convert(f));
} catch (RuntimeException ex) {
return new PagedFlux<>(() -> monoError(logger, ex));
}
}

/**
* Gets read receipts for a thread.
*
Expand Down
71 changes: 71 additions & 0 deletions ...munication-chat/src/test/java/com/azure/communication/chat/ChatThreadAsyncClientTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -195,6 +195,43 @@ public void canAddListAndRemoveMembersAsync(HttpClient httpClient) throws Interr
}
}

@ParameterizedTest
@MethodSource("com.azure.core.test.TestBase#getHttpClients")
public void canAddListAndRemoveMembersWithOptionsAsync(HttpClient httpClient) throws InterruptedException {
// Arrange
setupTest(httpClient, "canAddListAndRemoveMembersWithOptionsAsync");
firstAddedParticipant = communicationClient.createUser();
secondAddedParticipant = communicationClient.createUser();

Iterable<ChatParticipant> participants = ChatOptionsProvider.addParticipantsOptions(
firstAddedParticipant.getId(), secondAddedParticipant.getId());

// Act & Assert
StepVerifier.create(chatThreadClient.addParticipants(participants))
.assertNext(noResp -> {
PagedIterable<ChatParticipant> participantsResponse =
new PagedIterable<>(chatThreadClient.listParticipants(new ListParticipantsOptions().setMaxPageSize(2)));

// process the iterableByPage
List<ChatParticipant> returnedParticipants = new ArrayList<ChatParticipant>();
participantsResponse.iterableByPage().forEach(resp -> {
assertEquals(200, resp.getStatusCode());
resp.getItems().forEach(item -> returnedParticipants.add(item));
});

for (ChatParticipant participant : participants) {
assertTrue(checkParticipantsListContainsParticipantId(returnedParticipants,
((CommunicationUserIdentifier) participant.getCommunicationIdentifier()).getId()));
}
assertTrue(returnedParticipants.size() == 4);
});

for (ChatParticipant participant : participants) {
StepVerifier.create(chatThreadClient.removeParticipant(participant.getCommunicationIdentifier()))
.verifyComplete();
}
}

@ParameterizedTest
@MethodSource("com.azure.core.test.TestBase#getHttpClients")
public void canAddListWithContextAndRemoveMembersAsync(HttpClient httpClient) throws InterruptedException {
Expand Down Expand Up @@ -754,6 +791,40 @@ public void canSendThenListReadReceipts(HttpClient httpClient) throws Interrupte
});
}

@ParameterizedTest
@MethodSource("com.azure.core.test.TestBase#getHttpClients")
@DisabledIfEnvironmentVariable(
named = "SKIP_LIVE_TEST",
matches = "(?i)(true)")
public void canSendThenListReadReceiptsWithOptions(HttpClient httpClient) throws InterruptedException {
// Arrange
setupTest(httpClient, "canSendThenListReadReceiptsWithOptions");
SendChatMessageOptions messageRequest = ChatOptionsProvider.sendMessageOptions();
AtomicReference<String> messageResponseRef = new AtomicReference<>();

// Action & Assert
StepVerifier.create(
chatThreadClient.sendMessage(messageRequest)
.flatMap(response -> {
messageResponseRef.set(response.getId());
return chatThreadClient.sendReadReceipt(response.getId());
})
)
.assertNext(noResp -> {
PagedIterable<ChatMessageReadReceipt> readReceiptsResponse = new PagedIterable<ChatMessageReadReceipt>(
chatThreadClient.listReadReceipts(new ListReadReceiptOptions().setMaxPageSize(1)));

// process the iterableByPage
List<ChatMessageReadReceipt> returnedReadReceipts = new ArrayList<>();
readReceiptsResponse.iterableByPage().forEach(resp -> {
assertEquals(200, resp.getStatusCode());
resp.getItems().forEach(item -> returnedReadReceipts.add(item));
});
assertTrue(returnedReadReceipts.size() > 0);
checkReadReceiptListContainsMessageId(returnedReadReceipts, messageResponseRef.get());
});
}

@ParameterizedTest
@MethodSource("com.azure.core.test.TestBase#getHttpClients")
@DisabledIfEnvironmentVariable(
Expand Down
185 changes: 185 additions & 0 deletions ...sion-records/ChatThreadAsyncClientTest.canAddListAndRemoveMembersWithOptionsAsync[1].json
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,185 @@
{
"networkCallRecords" : [ {
"Method" : "POST",
"Uri" : "https://REDACTED.communication.azure.com/identities?api-version=2021-03-07",
"Headers" : {
"User-Agent" : "azsdk-java-azure-communication-identity/1.1.0 (1.8.0_262; Windows 10; 10.0)",
"Content-Type" : "application/json"
},
"Response" : {
"Transfer-Encoding" : "chunked",
"X-Cache" : "CONFIG_NOCACHE",
"api-supported-versions" : "2020-07-20-preview2, 2021-02-22-preview1, 2021-03-07, 2021-03-31-preview1",
"retry-after" : "0",
"StatusCode" : "201",
"Date" : "Thu, 27 May 2021 23:51:46 GMT",
"Strict-Transport-Security" : "max-age=2592000",
"X-Processing-Time" : "65ms",
"MS-CV" : "hqKed1k7x0S/mm6LYGzcSw.0",
"X-Azure-Ref" : "0kzCwYAAAAAChuA8zcmkMQYT4vvdf/WISV1NURURHRTA4MDYAOWZjN2I1MTktYThjYy00Zjg5LTkzNWUtYzkxNDhhZTA5ZTgx",
"Body" : "{\"identity\":{\"id\":\"8:acs:fa5c4fc3-a269-43e2-9eb6-0ca17b388993_0000000a-501f-6485-ceb1-a43a0d0027ee\"}}",
"x-ms-client-request-id" : "1fb6a2f3-9d13-44dd-9825-9aa4b6f8b89f",
"Content-Type" : "application/json; charset=utf-8",
"Request-Context" : "appId="
},
"Exception" : null
}, {
"Method" : "POST",
"Uri" : "https://REDACTED.communication.azure.com/identities?api-version=2021-03-07",
"Headers" : {
"User-Agent" : "azsdk-java-azure-communication-identity/1.1.0 (1.8.0_262; Windows 10; 10.0)",
"Content-Type" : "application/json"
},
"Response" : {
"Transfer-Encoding" : "chunked",
"X-Cache" : "CONFIG_NOCACHE",
"api-supported-versions" : "2020-07-20-preview2, 2021-02-22-preview1, 2021-03-07, 2021-03-31-preview1",
"retry-after" : "0",
"StatusCode" : "201",
"Date" : "Thu, 27 May 2021 23:51:47 GMT",
"Strict-Transport-Security" : "max-age=2592000",
"X-Processing-Time" : "111ms",
"MS-CV" : "Je2DwMX8yk6PS/W8Qa0JtQ.0",
"X-Azure-Ref" : "0kzCwYAAAAABI9YzwMZsyQ7RZMB7krrLBV1NURURHRTA4MDgAOWZjN2I1MTktYThjYy00Zjg5LTkzNWUtYzkxNDhhZTA5ZTgx",
"Body" : "{\"identity\":{\"id\":\"8:acs:fa5c4fc3-a269-43e2-9eb6-0ca17b388993_0000000a-501f-6519-740a-113a0d0032ad\"}}",
"x-ms-client-request-id" : "fa3f8778-a7de-4f26-8c66-8437cd626f60",
"Content-Type" : "application/json; charset=utf-8",
"Request-Context" : "appId="
},
"Exception" : null
}, {
"Method" : "POST",
"Uri" : "https://REDACTED.communication.azure.com/identities/8:acs:fa5c4fc3-a269-43e2-9eb6-0ca17b388993_0000000a-501f-6485-ceb1-a43a0d0027ee/:issueAccessToken?api-version=2021-03-07",
"Headers" : {
"User-Agent" : "azsdk-java-azure-communication-identity/1.1.0 (1.8.0_262; Windows 10; 10.0)",
"Content-Type" : "application/json"
},
"Response" : {
"Transfer-Encoding" : "chunked",
"X-Cache" : "CONFIG_NOCACHE",
"api-supported-versions" : "2020-07-20-preview2, 2021-02-22-preview1, 2021-03-07, 2021-03-31-preview1",
"retry-after" : "0",
"StatusCode" : "200",
"Date" : "Thu, 27 May 2021 23:51:47 GMT",
"Strict-Transport-Security" : "max-age=2592000",
"X-Processing-Time" : "125ms",
"MS-CV" : "YjGZ7mhh8E6Rucg6dPGMAA.0",
"X-Azure-Ref" : "0kzCwYAAAAABYIwc+TdlCSLiyjspz8M40V1NURURHRTA4MDYAOWZjN2I1MTktYThjYy00Zjg5LTkzNWUtYzkxNDhhZTA5ZTgx",
"Body" : "{\"token\":\"REDACTED\",\"expiresOn\":\"2021-05-28T23:51:46.9935327+00:00\"}",
"x-ms-client-request-id" : "c8500a20-706c-4282-ae3f-43b4cf963cf8",
"Content-Type" : "application/json; charset=utf-8",
"Request-Context" : "appId="
},
"Exception" : null
}, {
"Method" : "POST",
"Uri" : "https://REDACTED.communication.azure.com/chat/threads?api-version=2021-03-07",
"Headers" : {
"User-Agent" : "azsdk-java-azure-communication-chat/1.0.1 (1.8.0_262; Windows 10; 10.0)",
"Content-Type" : "application/json"
},
"Response" : {
"Transfer-Encoding" : "chunked",
"X-Cache" : "CONFIG_NOCACHE",
"api-supported-versions" : "2020-09-21-preview2, 2020-11-01-preview3, 2021-01-27-preview4, 2021-03-01-preview5, 2021-03-07, 2021-04-05-preview6",
"retry-after" : "0",
"StatusCode" : "201",
"Date" : "Thu, 27 May 2021 23:51:48 GMT",
"Strict-Transport-Security" : "max-age=2592000",
"X-Processing-Time" : "831ms",
"MS-CV" : "iLFmwh1kIEihViH/5X/rxA.0",
"X-Azure-Ref" : "0lDCwYAAAAAAaoMb88uUqRL44OB6f0ZNCV1NURURHRTA4MDgAOWZjN2I1MTktYThjYy00Zjg5LTkzNWUtYzkxNDhhZTA5ZTgx",
"Body" : "{\"chatThread\":{\"id\":\"19:eXCI9r5t4PcEHdHM4pZi4mjbmVpQsF5gATSJIxz_mL41@thread.v2\",\"topic\":\"Test\",\"createdOn\":\"2021-05-27T23:51:48Z\",\"createdByCommunicationIdentifier\":{\"rawId\":\"8:acs:fa5c4fc3-a269-43e2-9eb6-0ca17b388993_0000000a-501f-6485-ceb1-a43a0d0027ee\",\"communicationUser\":{\"id\":\"8:acs:fa5c4fc3-a269-43e2-9eb6-0ca17b388993_0000000a-501f-6485-ceb1-a43a0d0027ee\"}}}}",
"Content-Type" : "application/json; charset=utf-8",
"Location" : "https://chat-prod-e2e.communication.azure.com/chat/threads/19%3AeXCI9r5t4PcEHdHM4pZi4mjbmVpQsF5gATSJIxz_mL41@thread.v2"
},
"Exception" : null
}, {
"Method" : "POST",
"Uri" : "https://REDACTED.communication.azure.com/identities?api-version=2021-03-07",
"Headers" : {
"User-Agent" : "azsdk-java-azure-communication-identity/1.1.0 (1.8.0_262; Windows 10; 10.0)",
"Content-Type" : "application/json"
},
"Response" : {
"Transfer-Encoding" : "chunked",
"X-Cache" : "CONFIG_NOCACHE",
"api-supported-versions" : "2020-07-20-preview2, 2021-02-22-preview1, 2021-03-07, 2021-03-31-preview1",
"retry-after" : "0",
"StatusCode" : "201",
"Date" : "Thu, 27 May 2021 23:51:48 GMT",
"Strict-Transport-Security" : "max-age=2592000",
"X-Processing-Time" : "62ms",
"MS-CV" : "RXFlmlhlMUGIlISTXhYtpQ.0",
"X-Azure-Ref" : "0lDCwYAAAAAAd6CZA9n1KR6EvuE7we8DcV1NURURHRTA4MDYAOWZjN2I1MTktYThjYy00Zjg5LTkzNWUtYzkxNDhhZTA5ZTgx",
"Body" : "{\"identity\":{\"id\":\"8:acs:fa5c4fc3-a269-43e2-9eb6-0ca17b388993_0000000a-501f-69c0-ceb1-a43a0d0027ef\"}}",
"x-ms-client-request-id" : "ec9d25d1-bc5e-4723-ab47-5a3aca20234b",
"Content-Type" : "application/json; charset=utf-8",
"Request-Context" : "appId="
},
"Exception" : null
}, {
"Method" : "POST",
"Uri" : "https://REDACTED.communication.azure.com/identities?api-version=2021-03-07",
"Headers" : {
"User-Agent" : "azsdk-java-azure-communication-identity/1.1.0 (1.8.0_262; Windows 10; 10.0)",
"Content-Type" : "application/json"
},
"Response" : {
"Transfer-Encoding" : "chunked",
"X-Cache" : "CONFIG_NOCACHE",
"api-supported-versions" : "2020-07-20-preview2, 2021-02-22-preview1, 2021-03-07, 2021-03-31-preview1",
"retry-after" : "0",
"StatusCode" : "201",
"Date" : "Thu, 27 May 2021 23:51:48 GMT",
"Strict-Transport-Security" : "max-age=2592000",
"X-Processing-Time" : "86ms",
"MS-CV" : "KVZRWdzijkCUR9JK1DndPg.0",
"X-Azure-Ref" : "0lTCwYAAAAACiK5KHtP2BSoA+i+C3ZzNxV1NURURHRTA4MDgAOWZjN2I1MTktYThjYy00Zjg5LTkzNWUtYzkxNDhhZTA5ZTgx",
"Body" : "{\"identity\":{\"id\":\"8:acs:fa5c4fc3-a269-43e2-9eb6-0ca17b388993_0000000a-501f-6a40-740a-113a0d0032af\"}}",
"x-ms-client-request-id" : "f00f8a1f-f26c-4a6e-ad26-8fe31ad313e5",
"Content-Type" : "application/json; charset=utf-8",
"Request-Context" : "appId="
},
"Exception" : null
}, {
"Method" : "POST",
"Uri" : "https://REDACTED.communication.azure.com/chat/threads/19:eXCI9r5t4PcEHdHM4pZi4mjbmVpQsF5gATSJIxz_mL41@thread.v2/participants/:remove?api-version=2021-03-07",
"Headers" : {
"User-Agent" : "azsdk-java-azure-communication-chat/1.0.1 (1.8.0_262; Windows 10; 10.0)",
"Content-Type" : "application/json"
},
"Response" : {
"X-Cache" : "CONFIG_NOCACHE",
"Strict-Transport-Security" : "max-age=2592000",
"api-supported-versions" : "2020-11-01-preview3, 2021-01-27-preview4, 2021-03-01-preview5, 2021-03-07, 2021-04-05-preview6",
"X-Processing-Time" : "176ms",
"MS-CV" : "h6KGMwolGk6sV5PEJpf/jg.0",
"retry-after" : "0",
"X-Azure-Ref" : "0lTCwYAAAAAA3yWMV3OwYT6KImV3TNXrZV1NURURHRTA4MDYAOWZjN2I1MTktYThjYy00Zjg5LTkzNWUtYzkxNDhhZTA5ZTgx",
"StatusCode" : "204",
"Date" : "Thu, 27 May 2021 23:51:48 GMT"
},
"Exception" : null
}, {
"Method" : "POST",
"Uri" : "https://REDACTED.communication.azure.com/chat/threads/19:eXCI9r5t4PcEHdHM4pZi4mjbmVpQsF5gATSJIxz_mL41@thread.v2/participants/:remove?api-version=2021-03-07",
"Headers" : {
"User-Agent" : "azsdk-java-azure-communication-chat/1.0.1 (1.8.0_262; Windows 10; 10.0)",
"Content-Type" : "application/json"
},
"Response" : {
"X-Cache" : "CONFIG_NOCACHE",
"Strict-Transport-Security" : "max-age=2592000",
"api-supported-versions" : "2020-11-01-preview3, 2021-01-27-preview4, 2021-03-01-preview5, 2021-03-07, 2021-04-05-preview6",
"X-Processing-Time" : "403ms",
"MS-CV" : "spA6zr1ZB0OHd9VnV0/K2g.0",
"retry-after" : "0",
"X-Azure-Ref" : "0lTCwYAAAAACNNOLqovnwRoHfm01ydwNXV1NURURHRTA4MDgAOWZjN2I1MTktYThjYy00Zjg5LTkzNWUtYzkxNDhhZTA5ZTgx",
"StatusCode" : "204",
"Date" : "Thu, 27 May 2021 23:51:49 GMT"
},
"Exception" : null
} ],
"variables" : [ ]
}
Loading