|
29 | 29 |
|
30 | 30 | import io.quarkus.test.InjectMock;
|
31 | 31 | import io.quarkus.test.junit.QuarkusTest;
|
| 32 | +import io.smallrye.mutiny.Uni; |
32 | 33 | import io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
|
33 | 34 | import it.pagopa.swclient.mil.auth.AuthErrorCode;
|
34 | 35 | import it.pagopa.swclient.mil.auth.bean.ClaimName;
|
35 | 36 | import it.pagopa.swclient.mil.auth.bean.GetAccessTokenRequest;
|
| 37 | +import it.pagopa.swclient.mil.auth.bean.GetAccessTokenResponse; |
36 | 38 | import it.pagopa.swclient.mil.auth.bean.GrantType;
|
37 | 39 | import it.pagopa.swclient.mil.auth.bean.Scope;
|
38 | 40 | import it.pagopa.swclient.mil.auth.dao.ClientEntity;
|
@@ -145,7 +147,7 @@ void given_refreshToken_when_allGoesOk_then_getTokens() throws ParseException {
|
145 | 147 | .with(
|
146 | 148 | response -> {
|
147 | 149 | assertEquals(
|
148 |
| - "eyJraWQiOiJrZXlfbmFtZS9rZXlfdmVyc2lvbiIsImFsZyI6IlJTMjU2In0.eyJzdWIiOiJjbGllbnRfaWQiLCJjbGllbnRJZCI6ImNsaWVudF9pZCIsImNoYW5uZWwiOiJjaGFubmVsIiwiaXNzIjoiaHR0cHM6Ly9taWwtYXV0aCIsImdyb3VwcyI6InJvbGUiLCJ0ZXJtaW5hbElkIjoidGVybWluYWxfaWQiLCJhdWQiOiJodHRwczovL21pbCIsIm1lcmNoYW50SWQiOiJtZXJjaGFudF9pZCIsInNjb3BlIjoic2NvcGUiLCJmaXNjYWxDb2RlIjoiZW5jX2Zpc2NhbF9jb2RlIiwiZXhwIjoxNzE3NjUyLCJhY3F1aXJlcklkIjoiYWNxdWlyZXJfaWQiLCJpYXQiOjE3MTc1OTJ9.AA", |
| 150 | + signedJwt, |
149 | 151 | response.getAccessToken());
|
150 | 152 | },
|
151 | 153 | f -> fail(f));
|
@@ -211,7 +213,7 @@ void given_refreshCookie_when_allGoesOk_then_getTokens() throws ParseException {
|
211 | 213 | .with(
|
212 | 214 | response -> {
|
213 | 215 | assertEquals(
|
214 |
| - "eyJraWQiOiJrZXlfbmFtZS9rZXlfdmVyc2lvbiIsImFsZyI6IlJTMjU2In0.eyJzdWIiOiJjbGllbnRfaWQiLCJjbGllbnRJZCI6ImNsaWVudF9pZCIsImNoYW5uZWwiOiJjaGFubmVsIiwiaXNzIjoiaHR0cHM6Ly9taWwtYXV0aCIsImdyb3VwcyI6InJvbGUiLCJ0ZXJtaW5hbElkIjoidGVybWluYWxfaWQiLCJhdWQiOiJodHRwczovL21pbCIsIm1lcmNoYW50SWQiOiJtZXJjaGFudF9pZCIsInNjb3BlIjoic2NvcGUiLCJmaXNjYWxDb2RlIjoiZW5jX2Zpc2NhbF9jb2RlIiwiZXhwIjoxNzE3NjUyLCJhY3F1aXJlcklkIjoiYWNxdWlyZXJfaWQiLCJpYXQiOjE3MTc1OTJ9.AA", |
| 216 | + signedJwt, |
215 | 217 | response.getAccessToken());
|
216 | 218 | },
|
217 | 219 | f -> fail(f));
|
@@ -277,7 +279,7 @@ void given_refreshCookieAndRefreshToken_when_allGoesOk_then_getTokens() throws P
|
277 | 279 | .with(
|
278 | 280 | response -> {
|
279 | 281 | assertEquals(
|
280 |
| - "eyJraWQiOiJrZXlfbmFtZS9rZXlfdmVyc2lvbiIsImFsZyI6IlJTMjU2In0.eyJzdWIiOiJjbGllbnRfaWQiLCJjbGllbnRJZCI6ImNsaWVudF9pZCIsImNoYW5uZWwiOiJjaGFubmVsIiwiaXNzIjoiaHR0cHM6Ly9taWwtYXV0aCIsImdyb3VwcyI6InJvbGUiLCJ0ZXJtaW5hbElkIjoidGVybWluYWxfaWQiLCJhdWQiOiJodHRwczovL21pbCIsIm1lcmNoYW50SWQiOiJtZXJjaGFudF9pZCIsInNjb3BlIjoic2NvcGUiLCJmaXNjYWxDb2RlIjoiZW5jX2Zpc2NhbF9jb2RlIiwiZXhwIjoxNzE3NjUyLCJhY3F1aXJlcklkIjoiYWNxdWlyZXJfaWQiLCJpYXQiOjE3MTc1OTJ9.AA", |
| 282 | + signedJwt, |
281 | 283 | response.getAccessToken());
|
282 | 284 | },
|
283 | 285 | f -> fail(f));
|
@@ -346,15 +348,9 @@ void given_refreshCookieAndRefreshTokenBothNull_when_tokesRefreshIsRequested_the
|
346 | 348 | .setMerchantId("merchant_id")
|
347 | 349 | .setTerminalId("terminal_id");
|
348 | 350 |
|
349 |
| - assertThrows( |
350 |
| - NullPointerException.class, |
351 |
| - () -> refreshTokensService.process(request) |
352 |
| - .subscribe() |
353 |
| - .with( |
354 |
| - i -> { |
355 |
| - }, |
356 |
| - f -> { |
357 |
| - })); |
| 351 | + Uni<GetAccessTokenResponse> resp = refreshTokensService.process(request); |
| 352 | + |
| 353 | + assertThrows(NullPointerException.class, resp::await); |
358 | 354 | }
|
359 | 355 |
|
360 | 356 | /**
|
|
0 commit comments