Merge pull request #3095 from bozana/6887-3_3_1

pkp/pkp-lib#6887 fix crossref errors handling
pkp · Apr 3, 2021 · a09964a · a09964a
2 parents 9bf928e + 676df27
commit a09964a
Showing 1 changed file with 41 additions and 22 deletions.
diff --git a/plugins/importexport/crossref/CrossRefExportPlugin.inc.php b/plugins/importexport/crossref/CrossRefExportPlugin.inc.php
@@ -26,7 +26,7 @@
 //TESTING
 define('CROSSREF_API_URL_DEV', 'https://test.crossref.org/v2/deposits');
 
-define('CROSSREF_API_STATUS_URL', 'https://api.crossref.org/servlet/submissionDownload');
+define('CROSSREF_API_STATUS_URL', 'https://doi.crossref.org/servlet/submissionDownload');
 //TESTING
 define('CROSSREF_API_STATUS_URL_DEV', 'https://test.crossref.org/servlet/submissionDownload');
 
@@ -117,22 +117,27 @@ function getStatusMessage($request) {
 		$context = $request->getContext();
 
 		$httpClient = Application::get()->getHttpClient();
-		$response = $httpClient->request(
-			'POST',
-			$this->isTestMode($context) ? CROSSREF_API_STATUS_URL_DEV : CROSSREF_API_STATUS_URL,
-			[
-				'form_params' => [
-					'doi_batch_id' => $request->getUserVar('batchId'),
-					'type' => 'result',
-					'usr' => $this->getSetting($context->getId(), 'username'),
-					'pwd' => $this->getSetting($context->getId(), 'password'),
+		try {
+			$response = $httpClient->request(
+				'POST',
+				$this->isTestMode($context) ? CROSSREF_API_STATUS_URL_DEV : CROSSREF_API_STATUS_URL,
+				[
+					'form_params' => [
+						'doi_batch_id' => $request->getUserVar('batchId'),
+						'type' => 'result',
+						'usr' => $this->getSetting($context->getId(), 'username'),
+						'pwd' => $this->getSetting($context->getId(), 'password'),
+					]
 				]
-			]
-		);
-
-		if ($response->getStatusCode() != 200) {
-			return __('plugins.importexport.common.register.error.mdsError', array('param' => 'No response from server.'));
+			);
+		} catch (GuzzleHttp\Exception\RequestException $e) {
+			$returnMessage = $e->getMessage();
+			if ($e->hasResponse()) {
+				$returnMessage = $e->getResponse()->getBody(true) . ' (' .$e->getResponse()->getStatusCode() . ' ' . $e->getResponse()->getReasonPhrase() . ')';
+			}
+			return __('plugins.importexport.common.register.error.mdsError', array('param' => $returnMessage));
 		}
+
 		return (string) $response->getBody();
 	}
 
@@ -267,7 +272,7 @@ function executeExportAction($request, $objects, $filter, $tab, $objectsFileName
 	 */
 	function depositXML($objects, $context, $filename) {
 		$status = null;
-		$msg = null;
+		$msgSave = null;
 
 		$httpClient = Application::get()->getHttpClient();
 		assert(is_readable($filename));
@@ -296,12 +301,26 @@ function depositXML($objects, $context, $filename) {
 					]
 				]
 			);
-		} catch (GuzzleHttp\Exception\RequestException $e) {
-			if ($e->getResponse()->getStatusCode() != CROSSREF_API_DEPOSIT_ERROR_FROM_CROSSREF) {
-				return [['plugins.importexport.common.register.error.mdsError', 'No response from server.']];
+		 } catch (GuzzleHttp\Exception\RequestException $e) {
+			$returnMessage = $e->getMessage();
+			if ($e->hasResponse()) {
+				$eResponseBody = $e->getResponse()->getBody(true);
+				$eStatusCode = $e->getResponse()->getStatusCode();
+				if ($eStatusCode == CROSSREF_API_DEPOSIT_ERROR_FROM_CROSSREF) {
+					$xmlDoc = new DOMDocument();
+					$xmlDoc->loadXML($eResponseBody);
+					$batchIdNode = $xmlDoc->getElementsByTagName('batch_id')->item(0);
+					$msg = $xmlDoc->getElementsByTagName('msg')->item(0)->nodeValue;
+					$msgSave = $msg . PHP_EOL . $eResponseBody;
+					$status = CROSSREF_STATUS_FAILED;
+					$this->updateDepositStatus($context, $objects, $status, $batchIdNode->nodeValue, $msgSave);
+					$this->updateObject($objects);
+					$returnMessage = $msg . ' (' .$eStatusCode . ' ' . $e->getResponse()->getReasonPhrase() . ')';
+				} else {
+					$returnMessage = $eResponseBody . ' (' .$eStatusCode . ' ' . $e->getResponse()->getReasonPhrase() . ')';
+				}
 			}
-
-			$response = $e->getResponse();
+			return [['plugins.importexport.common.register.error.mdsError', $returnMessage]];
 		}
 
 		// Get DOMDocument from the response XML string
@@ -333,7 +352,7 @@ function depositXML($objects, $context, $filename) {
 
 		// Update the status
 		if ($status) {
-			$this->updateDepositStatus($context, $objects, $status, $batchIdNode->nodeValue, $msg);
+			$this->updateDepositStatus($context, $objects, $status, $batchIdNode->nodeValue, $msgSave);
 			$this->updateObject($objects);
 		}