[dag block scan-api] fixed if getBlocksByHeight throw exception

starcoinorg · Jun 26, 2024 · 62b1f1d · 62b1f1d
1 parent 94e4f3e
commit 62b1f1d
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/starcoin-scan-api/src/main/java/org/starcoin/scan/service/DagInspectorService.java b/starcoin-scan-api/src/main/java/org/starcoin/scan/service/DagInspectorService.java
@@ -1,6 +1,7 @@
 package org.starcoin.scan.service;
 
 import com.alibaba.fastjson.JSONObject;
+import org.elasticsearch.ElasticsearchException;
 import org.elasticsearch.action.search.SearchRequest;
 import org.elasticsearch.action.search.SearchResponse;
 import org.elasticsearch.client.RequestOptions;
@@ -105,7 +106,7 @@ public DIBlocksAndEdgesAndHeightGroupsVo getHead(String network, Long heightDiff
      * @param endHeight
      * @return
      */
-    private List<DagInspectorBlock> getBlockList(String network, Long startHeight, Long endHeight) throws IOException {
+    private List<DagInspectorBlock> getBlockList(String network, Long startHeight, Long endHeight) throws ElasticsearchException, IOException {
         SearchRequest searchRequest = new SearchRequest(getIndex(network, Constant.DAG_INSPECTOR_BLOCK));
         SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
         sourceBuilder.query(QueryBuilders.boolQuery().must(QueryBuilders.rangeQuery("height").gte(startHeight).lte(endHeight)));
@@ -251,7 +252,7 @@ public List<DagInspectorBlock> getBlocksByHeight(String network, Long height) {
         SearchResponse searchResponse;
         try {
             searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
-        } catch (IOException e) {
+        } catch (IOException | org.elasticsearch.ElasticsearchStatusException e) {
             logger.error("getBlocksByHeight failed, blockHash: {}", height, e);
             return null;
         }