X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Ftest%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Fclients%2FSdncOscA1ClientTest.java;h=f5b3b25187c02b62259dc7511f6178440466d15c;hb=444d11bb9de7be056d7609c395f3ef191c3c1702;hp=57d809e3f0655e3daf6eb4fb7936439073e1c1f4;hpb=7619c78eac9c8a1ad1e17e0a74d93acd04238ce8;p=nonrtric.git diff --git a/policy-agent/src/test/java/org/oransc/policyagent/clients/SdncOscA1ClientTest.java b/policy-agent/src/test/java/org/oransc/policyagent/clients/SdncOscA1ClientTest.java index 57d809e3..f5b3b251 100644 --- a/policy-agent/src/test/java/org/oransc/policyagent/clients/SdncOscA1ClientTest.java +++ b/policy-agent/src/test/java/org/oransc/policyagent/clients/SdncOscA1ClientTest.java @@ -44,9 +44,9 @@ public class SdncOscA1ClientTest { private static final String CONTROLLER_USERNAME = "username"; private static final String CONTROLLER_PASSWORD = "password"; private static final String RIC_1_URL = "RicUrl"; - private static final String POLICYTYPES_IDENTITIES_URL = "/A1-ADAPTER-API:getPolicyTypeIdentities"; - private static final String POLICIES_IDENTITIES_URL = "/A1-ADAPTER-API:getPolicyIdentities"; - private static final String POLICYTYPES_URL = "/A1-ADAPTER-API:getPolicyType"; + private static final String POLICY_TYPES_IDENTITIES_URL = "/A1-ADAPTER-API:getPolicyTypeIdentities"; + private static final String POLICY_IDENTITIES_URL = "/A1-ADAPTER-API:getPolicyIdentities"; + private static final String POLICY_TYPES_URL = "/A1-ADAPTER-API:getPolicyType"; private static final String PUT_POLICY_URL = "/A1-ADAPTER-API:putPolicy"; private static final String DELETE_POLICY_URL = "/A1-ADAPTER-API:deletePolicy"; @@ -83,8 +83,9 @@ public class SdncOscA1ClientTest { whenAsyncPostThenReturn(policyTypeIdsResp); Mono> returnedMono = clientUnderTest.getPolicyTypeIdentities(); - verify(asyncRestClientMock).postWithAuthHeader(POLICYTYPES_IDENTITIES_URL, inputJsonString, CONTROLLER_USERNAME, - CONTROLLER_PASSWORD); + + verify(asyncRestClientMock).postWithAuthHeader(POLICY_TYPES_IDENTITIES_URL, inputJsonString, + CONTROLLER_USERNAME, CONTROLLER_PASSWORD); StepVerifier.create(returnedMono).expectNext(policyTypeIds).expectComplete().verify(); } @@ -100,7 +101,8 @@ public class SdncOscA1ClientTest { whenAsyncPostThenReturn(policyIdsResp); Mono> returnedMono = clientUnderTest.getPolicyIdentities(); - verify(asyncRestClientMock).postWithAuthHeader(POLICIES_IDENTITIES_URL, inputJsonString, CONTROLLER_USERNAME, + + verify(asyncRestClientMock).postWithAuthHeader(POLICY_IDENTITIES_URL, inputJsonString, CONTROLLER_USERNAME, CONTROLLER_PASSWORD); StepVerifier.create(returnedMono).expectNext(policyIds).expectComplete().verify(); } @@ -118,7 +120,8 @@ public class SdncOscA1ClientTest { whenAsyncPostThenReturn(policyTypeResp); Mono returnedMono = clientUnderTest.getPolicyTypeSchema(POLICY_TYPE_1_ID); - verify(asyncRestClientMock).postWithAuthHeader(POLICYTYPES_URL, inputJsonString, CONTROLLER_USERNAME, + + verify(asyncRestClientMock).postWithAuthHeader(POLICY_TYPES_URL, inputJsonString, CONTROLLER_USERNAME, CONTROLLER_PASSWORD); StepVerifier.create(returnedMono).expectNext(POLICY_TYPE_SCHEMA_VALID).expectComplete().verify(); } @@ -136,7 +139,8 @@ public class SdncOscA1ClientTest { whenAsyncPostThenReturn(policyTypeResp); Mono returnedMono = clientUnderTest.getPolicyTypeSchema(POLICY_TYPE_1_ID); - verify(asyncRestClientMock).postWithAuthHeader(POLICYTYPES_URL, inputJsonString, CONTROLLER_USERNAME, + + verify(asyncRestClientMock).postWithAuthHeader(POLICY_TYPES_URL, inputJsonString, CONTROLLER_USERNAME, CONTROLLER_PASSWORD); StepVerifier.create(returnedMono).expectErrorMatches(throwable -> throwable instanceof JSONException).verify(); } @@ -156,6 +160,7 @@ public class SdncOscA1ClientTest { Mono returnedMono = clientUnderTest .putPolicy(A1ClientHelper.createPolicy(RIC_1_URL, POLICY_1_ID, POLICY_JSON_VALID, POLICY_TYPE_1_ID)); + verify(asyncRestClientMock).postWithAuthHeader(PUT_POLICY_URL, inputJsonString, CONTROLLER_USERNAME, CONTROLLER_PASSWORD); StepVerifier.create(returnedMono).expectNext(POLICY_JSON_VALID).expectComplete().verify(); @@ -176,6 +181,7 @@ public class SdncOscA1ClientTest { Mono returnedMono = clientUnderTest .putPolicy(A1ClientHelper.createPolicy(RIC_1_URL, POLICY_1_ID, POLICY_JSON_VALID, POLICY_TYPE_1_ID)); + verify(asyncRestClientMock).postWithAuthHeader(PUT_POLICY_URL, inputJsonString, CONTROLLER_USERNAME, CONTROLLER_PASSWORD); StepVerifier.create(returnedMono).expectErrorMatches(throwable -> throwable instanceof JSONException).verify(); @@ -193,6 +199,7 @@ public class SdncOscA1ClientTest { Mono returnedMono = clientUnderTest .deletePolicy(A1ClientHelper.createPolicy(RIC_1_URL, POLICY_1_ID, POLICY_JSON_VALID, POLICY_TYPE_1_ID)); + verify(asyncRestClientMock).postWithAuthHeader(DELETE_POLICY_URL, inputJsonString, CONTROLLER_USERNAME, CONTROLLER_PASSWORD); StepVerifier.create(returnedMono).expectComplete().verify(); @@ -220,8 +227,9 @@ public class SdncOscA1ClientTest { whenAsyncPostThenReturn(policyIdsResp).thenReturn(Mono.empty()); Flux returnedFlux = clientUnderTest.deleteAllPolicies(); + StepVerifier.create(returnedFlux).expectComplete().verify(); - verify(asyncRestClientMock).postWithAuthHeader(POLICIES_IDENTITIES_URL, inputJsonStringGetIds, + verify(asyncRestClientMock).postWithAuthHeader(POLICY_IDENTITIES_URL, inputJsonStringGetIds, CONTROLLER_USERNAME, CONTROLLER_PASSWORD); verify(asyncRestClientMock).postWithAuthHeader(DELETE_POLICY_URL, inputJsonStringDeletePolicy1, CONTROLLER_USERNAME, CONTROLLER_PASSWORD);