+ @Test
+ public void givenTwoRequestIdHeader_onapHeaderValueIsUsed() throws IOException, ServletException {
+
+ final String onapTxId = "863850e2-8545-4efd-94b8-AFBA5F52B3D5"; // note mixed case
+ final String ecompTxId = "6e8ff89e-88a4-4977-b63f-3142892b6e08";
+
+ final ImmutableMap<String, String> incomingRequestHeaders = ImmutableMap.of(
+ anotherHeader, anotherValue,
+ ECOMP_REQUEST_ID, ecompTxId,
+ onapRequestIdHeader, onapTxId
+ );
+
+ buildRequestThenRunThroughFilterAndAssertResultRequestHeaders(incomingRequestHeaders, specificTxId(onapTxId));
+ }
+
+ @Test
+ public void givenTwoRequestIdHeaderAndHigherPriorityIsMalformed_headerValueIsGenerated() throws IOException, ServletException {
+
+ final String malformedTxId = "6e8ff89e-88a4-4977-b63f-3142892b6e08-";
+ final String anotherTxId = "863850e2-8545-4efd-94b8-afba5f52b3d5";
+
+ final ImmutableMap<String, String> incomingRequestHeaders = ImmutableMap.of(
+ anotherHeader, anotherValue,
+ requestIdHeader, malformedTxId, // requestIdHeader as higher priority than transactionIdHeader
+ transactionIdHeader, anotherTxId
+ );
+
+ HttpServletRequest wrappedRequest =
+ buildRequestThenRunThroughFilterAndAssertResultRequestHeaders(incomingRequestHeaders, UserUtils::getRequestId);
+
+ assertThat(UserUtils.getRequestId(wrappedRequest),
+ not(anyOf(equalTo(malformedTxId), equalTo(anotherTxId)))
+ );
+ }
+
+
+ @Test
+ public void toUuidOrElse_givenValid_yieldSame() {
+ final String someTxId = "729bbd8d-b0c2-4809-a794-DCCCD9CDA2C0"; // note mixed case
+ UUID unexpected = UUID.randomUUID();
+ assertThat(promiseRequestIdFilter.toUuidOrElse(someTxId, () -> unexpected), is(UUID.fromString(someTxId)));
+ }
+
+ @Test
+ public void toUuidOrElse_givenNull_yieldSupplier() {
+ UUID expected = UUID.fromString("729bbd8d-b0c2-4809-a794-dcccd9cda2c0");
+ assertThat(promiseRequestIdFilter.toUuidOrElse(null, () -> expected), is(expected));
+ }
+
+ @Test
+ public void toUuidOrElse_givenMalformed_yieldSupplier() {
+ UUID expected = UUID.fromString("729bbd8d-b0c2-4809-a794-dcccd9cda2c0");
+ assertThat(promiseRequestIdFilter.toUuidOrElse("malformed uuid", () -> expected), is(expected));
+ }
+
+ @DataProvider
+ public static Object[][] severalRequestIdHeaders() {
+ String someTxId = "69fa2575-d7f2-482c-ad1b-53a63ca03617";
+ String anotherTxId = "06de373b-7e19-4357-9bd1-ed95682ae3a4";
+
+ return new Object[][]{
+ {
+ "header is selected when single", transactionIdHeader,
+ ImmutableMap.of(
+ transactionIdHeader, someTxId
+ )
+ }, {
+ "header is selected when first", onapRequestIdHeader,
+ ImmutableMap.of(
+ onapRequestIdHeader, someTxId,
+ "noise-header", anotherTxId,
+ ECOMP_REQUEST_ID, anotherTxId
+ )
+ }, {
+ "header is selected when last", onapRequestIdHeader,
+ ImmutableMap.of(
+ ECOMP_REQUEST_ID, anotherTxId,
+ "noise-header", anotherTxId,
+ onapRequestIdHeader, someTxId
+ )
+ }, {
+ "header is selected when value is invalid uuid", onapRequestIdHeader,
+ ImmutableMap.of(
+ onapRequestIdHeader, "invalid-uuid"
+ )
+ }, {
+ "header is selected when no ecomp-request-id", onapRequestIdHeader,
+ ImmutableMap.of(
+ requestIdHeader, anotherTxId,
+ onapRequestIdHeader, someTxId
+ )
+ }, {
+ "ECOMP_REQUEST_ID is returned when no request-id header", ECOMP_REQUEST_ID,
+ ImmutableMap.of(
+ "tsamina-mina", anotherTxId,
+ "waka-waka", anotherTxId
+ )
+ },
+ };
+ }
+
+ @Test(dataProvider = "severalRequestIdHeaders")
+ public void highestPriorityHeader_givenSeveralRequestIdHeaders_correctHeaderIsUsed(String description, String expectedHeader, Map<String, String> incomingRequestHeaders) {
+ PromiseRequestIdFilter testSubject = promiseRequestIdFilter;
+
+ HttpServletRequest mockedHttpServletRequest = createMockedHttpServletRequest(incomingRequestHeaders);
+
+ assertThat(description,
+ testSubject.highestPriorityHeader(mockedHttpServletRequest), equalToIgnoringCase(expectedHeader));
+ }
+
+
+ private HttpServletRequest buildRequestThenRunThroughFilterAndAssertResultRequestHeaders(