Skip to content

Commit

Permalink
Removed ChatUserCredentialPolicy
Browse files Browse the repository at this point in the history
  • Loading branch information
jorge-beauregard committed Nov 10, 2020
1 parent 7ff99e8 commit b665cab
Show file tree
Hide file tree
Showing 3 changed files with 18 additions and 69 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -168,7 +168,8 @@ public ChatAsyncClient buildAsyncClient() {
} else {
Objects.requireNonNull(communicationUserCredential);
Objects.requireNonNull(httpClient);
CommunicationTokenCredential tokenCredential = new CommunicationTokenCredential(communicationUserCredential);
CommunicationTokenCredential tokenCredential =
new CommunicationTokenCredential(communicationUserCredential);

pipeline = createHttpPipeline(httpClient,
new BearerTokenAuthenticationPolicy(tokenCredential, ""),
Expand Down

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -11,19 +11,28 @@

import reactor.core.publisher.Mono;

/**
* This class serves as a CommunicationUserCredential wrapper that
* allows using BearerAuthenticationPolicy in different clients
*/
public class CommunicationTokenCredential implements TokenCredential {
private CommunicationUserCredential credential;
private final CommunicationUserCredential credential;

public CommunicationTokenCredential(CommunicationUserCredential communicationUserCrendential){
credential = communicationUserCrendential;
/**
* Creates a CommunicationTokenCredential
*
* @param communicationUserCredential The {@link CommunicationUserCredential} to use
* in the BearerAuthenticationPolicy.
*/
public CommunicationTokenCredential(CommunicationUserCredential communicationUserCredential) {
credential = communicationUserCredential;
}

@Override
public Mono<AccessToken> getToken(TokenRequestContext request){
try{
public Mono<AccessToken> getToken(TokenRequestContext request) {
try {
return Mono.just(credential.getToken().get());
}
catch (InterruptedException ex) {
} catch (InterruptedException ex) {
return Mono.error(ex);
} catch (ExecutionException ex) {
return Mono.error(ex);
Expand Down

0 comments on commit b665cab

Please sign in to comment.