+ @Test
+ public void testGetStatus() {
+ SdncOscAdapterInput inputParams = ImmutableSdncOscAdapterInput.builder() //
+ .nearRtRicUrl(RIC_1_URL) //
+ .policyId(POLICY_1_ID) //
+ .build();
+ String inputJsonString = A1ClientHelper.createInputJsonString(inputParams);
+
+ String status = "STATUS";
+ Mono<String> policyStatusResp = A1ClientHelper.createOutputJsonResponse("policy-status", status);
+ whenAsyncPostThenReturn(policyStatusResp);
+
+ Policy policy = A1ClientHelper.createPolicy(RIC_1_URL, POLICY_1_ID, POLICY_JSON_VALID, POLICY_TYPE_1_ID);
+
+ String returnedStatus = clientUnderTest.getPolicyStatus(policy).block();
+
+ assertEquals(status, returnedStatus, "unexpexted status");
+
+ final String expectedUrl = "/A1-ADAPTER-API:getPolicyStatus";
+ verify(asyncRestClientMock).postWithAuthHeader(expectedUrl, inputJsonString, CONTROLLER_USERNAME,
+ CONTROLLER_PASSWORD);
+ }
+