SIP2-309: Fix doPinCheck failing when FOLIO returns 200 without Content-Type header

NEWS.md

@@ -6,6 +6,7 @@
 * Fix misleading log messages when token refresh fails and recovery login is used([SIP2-316](https://folio-org.atlassian.net/browse/SIP2-316))
 * Fix locale agnostic number formatting ([SIP2-300](https://folio-org.atlassian.net/browse/SIP2-300))
 * Add automated patron blocks support to patron status/information response ([SIP2-313](https://folio-org.atlassian.net/browse/SIP2-313))
+* Fix doPinCheck failing when FOLIO returns 200 without Content-Type header([SIP2-309](https://folio-org.atlassian.net/browse/SIP2-309))
 
 ---
 

src/main/java/org/folio/edge/sip2/repositories/FolioResourceProvider.java

@@ -83,7 +83,8 @@ public Future<Boolean> doPinCheck(IRequestData requestData) {
     log.debug(sessionData, "Doing pin verification at {}", requestData::getPath);
     return initHttpRequest(POST, requestData)
         .flatMap(request -> request.sendJsonObject(requestData.getBody()))
-        .expecting(getHttpRequestExpectations(sessionData, SC_SUCCESS))
+        .expecting(SC_SUCCESS.wrappingFailure(
+            (head, err) -> getHttpRequestError(sessionData, head, err)))
         .map(Boolean.TRUE)
         .onFailure(e -> log.error(sessionData, "Pin check failed", e));
   }

src/test/java/org/folio/edge/sip2/api/PatronInformationIT.java

@@ -221,6 +221,86 @@ void getPatronInformation_withAutomatedBorrowingBlock_allStatusFlagsSetAndMessag
         ));
   }
 
+  @Test
+  @WiremockStubs({
+      "/wiremock/stubs/mod-settings/200-get-locale.json",
+      "/wiremock/stubs/mod-settings/200-get-settings(pin-validation).json",
+      "/wiremock/stubs/mod-login/201-post-acs-login.json",
+      "/wiremock/stubs/mod-users/200-get-user-by-patron-identifier.json",
+      "/wiremock/stubs/mod-users/200-post-patron-pin.json",
+      "/wiremock/stubs/mod-users-bl/200-get-user-by-id.json",
+      "/wiremock/stubs/mod-circulation/200-get-circulation-open-loans.json",
+      "/wiremock/stubs/mod-circulation/200-get-circulation-open-loans-by-due-date.json",
+      "/wiremock/stubs/mod-circulation/200-get-circulation-requests-hold.json",
+      "/wiremock/stubs/mod-circulation/200-get-circulation-requests-recall.json",
+      "/wiremock/stubs/mod-fee-fines/200-get-accounts.json",
+      "/wiremock/stubs/mod-fee-fines/200-get-manualblocks.json",
+      "/wiremock/stubs/mod-fee-fines/200-get-feefines-empty.json",
+      "/wiremock/stubs/mod-fee-fines/200-get-automated-patron-blocks-with-borrowing-block.json",
+  })
+  void getPatronInformation_positive_pinVerificationEnabled() throws Throwable {
+    executeInSession(
+        successLoginExchange(),
+        sip2Exchange(
+            PatronInformationCommand.builder()
+                .patronIdentifier(PATRON_BARCODE)
+                .languageCode(LanguageMapper.ENGLISH)
+                .summary(HOLD_ITEMS)
+                .patronPassword("132456")
+                .build(),
+            sip2Result -> {
+              assertSuccessfulExchange(sip2Result);
+
+              var respMsg = sip2Result.getResponseMessage();
+              assertThat(respMsg).startsWith("64");
+
+              var patronInfo = parseResponse(respMsg);
+              assertThat(patronInfo.getValidPatron()).isTrue();
+              assertThat(patronInfo.getValidPatronPassword()).isTrue();
+            }
+        ));
+  }
+
+  @Test
+  @WiremockStubs({
+      "/wiremock/stubs/mod-settings/200-get-locale.json",
+      "/wiremock/stubs/mod-settings/200-get-settings(pin-validation).json",
+      "/wiremock/stubs/mod-login/201-post-acs-login.json",
+      "/wiremock/stubs/mod-users/200-get-user-by-patron-identifier.json",
+      "/wiremock/stubs/mod-users/422-post-patron-pin.json",
+      "/wiremock/stubs/mod-users-bl/200-get-user-by-id.json",
+      "/wiremock/stubs/mod-circulation/200-get-circulation-open-loans.json",
+      "/wiremock/stubs/mod-circulation/200-get-circulation-open-loans-by-due-date.json",
+      "/wiremock/stubs/mod-circulation/200-get-circulation-requests-hold.json",
+      "/wiremock/stubs/mod-circulation/200-get-circulation-requests-recall.json",
+      "/wiremock/stubs/mod-fee-fines/200-get-accounts.json",
+      "/wiremock/stubs/mod-fee-fines/200-get-manualblocks.json",
+      "/wiremock/stubs/mod-fee-fines/200-get-feefines-empty.json",
+      "/wiremock/stubs/mod-fee-fines/200-get-automated-patron-blocks-with-borrowing-block.json",
+  })
+  void getPatronInformation_negative_pinVerificationEnabledWithInvalidPin() throws Throwable {
+    executeInSession(
+        successLoginExchange(),
+        sip2Exchange(
+            PatronInformationCommand.builder()
+                .patronIdentifier(PATRON_BARCODE)
+                .languageCode(LanguageMapper.ENGLISH)
+                .summary(HOLD_ITEMS)
+                .patronPassword("132456")
+                .build(),
+            sip2Result -> {
+              assertSuccessfulExchange(sip2Result);
+
+              var respMsg = sip2Result.getResponseMessage();
+              assertThat(respMsg).startsWith("64");
+
+              var patronInfo = parseResponse(respMsg);
+              assertThat(patronInfo.getValidPatron()).isTrue();
+              assertThat(patronInfo.getValidPatronPassword()).isFalse();
+            }
+        ));
+  }
+
   private static PatronInformationResponse parseResponse(String respMsg) {
     return new PatronInformationResponseParser(delimiter, TIMEZONE).parse(respMsg);
   }

src/test/java/org/folio/edge/sip2/repositories/FolioResourceProviderTest.java

@@ -22,6 +22,7 @@
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.when;
 
+import io.vertx.core.Vertx;
 import io.vertx.core.buffer.Buffer;
 import io.vertx.core.http.HttpClientResponse;
 import io.vertx.core.http.HttpMethod;
@@ -228,6 +229,48 @@ void doPinCheck_positive(VertxTestContext testContext) {
     }));
   }
 
+  @Test
+  void doPinCheck_positive_missingContentTypeHeader(VertxTestContext testContext) {
+    var requestData = testRequestDataWithBody("/patron-pin/verify",
+        new JsonObject().put("pin", "1234"));
+    var httpResponse = httpResponseNoBody(200, "OK");
+
+    prepareRequestMocks(POST, requestData);
+    when(jsonRequest.sendJsonObject(any())).thenReturn(succeededFuture(httpResponse));
+    when(loginRepository.getSessionAccessToken(any(SessionData.class)))
+        .thenReturn(succeededFuture(ACCESS_TOKEN));
+
+    var resultFuture = provider.doPinCheck(requestData);
+
+    resultFuture.onComplete(testContext.succeeding(result -> {
+      assertTrue(result);
+      testContext.completeNow();
+    }));
+  }
+
+  @Test
+  void doPinCheck_realHttp_200WithoutContentType(Vertx vertx, VertxTestContext testContext) {
+    var realClient = WebClient.create(vertx);
+    var requestData = testRequestDataWithBody("/patron-pin/verify",
+        new JsonObject().put("id", "user-id").put("pin", "1234"));
+    when(loginRepository.getSessionAccessToken(any(SessionData.class)))
+        .thenReturn(succeededFuture(ACCESS_TOKEN));
+
+    vertx.createHttpServer()
+        .requestHandler(req -> req.response().setStatusCode(200).end())
+        .listen(0)
+        .compose(server -> {
+          var realProvider = new FolioResourceProvider(
+              loginRepository, "http://localhost:" + server.actualPort(), realClient);
+          return realProvider.doPinCheck(requestData)
+              .compose(result -> server.close().map(result));
+        })
+        .onComplete(testContext.succeeding(result -> {
+          assertTrue(result);
+          testContext.completeNow();
+        }));
+  }
+
   @Test
   void doPinCheck_negative_accessTokenMissing(VertxTestContext testContext) {
     var requestData = testRequestDataWithBody("/pin-verify", new JsonObject());
@@ -306,6 +349,11 @@ private static HttpResponse<JsonObject> httpResponse(
         headers, caseInsensitiveMultiMap(), emptyList(), body, emptyList());
   }
 
+  private static HttpResponse<JsonObject> httpResponseNoBody(int statusCode, String statusMessage) {
+    return new HttpResponseImpl<>(HTTP_1_1, statusCode, statusMessage,
+        httpHeaders(), caseInsensitiveMultiMap(), emptyList(), null, emptyList());
+  }
+
   private static class TestRequestData implements IRequestData {
     private final String path;
     private final JsonObject body;

src/test/resources/wiremock/stubs/mod-users/200-post-patron-pin.json

@@ -22,9 +22,6 @@
   },
   "response": {
     "status": 200,
-    "body": "",
-    "headers": {
-      "Content-Type": "application/json"
-    }
+    "body": ""
   }
 }