feat: better timeout error

l3s-learnweb · Oct 2, 2023 · a799666 · a799666
1 parent 4add768
commit a799666
Showing 1 changed file with 8 additions and 7 deletions.
diff --git a/interweb-server/src/main/java/de/l3s/interweb/server/search/SearchService.java b/interweb-server/src/main/java/de/l3s/interweb/server/search/SearchService.java
@@ -68,13 +68,14 @@ public Uni<SearchResults> search(SearchQuery query) {
 
     private Uni<SearchConnectorResults> searchIn(SearchQuery query, SearchConnector connector, Duration timeout) {
         long start = System.currentTimeMillis();
-        return searchWithCache(query, connector).ifNoItem().after(timeout).failWith(new ConnectorException("Timeout"))
-                .onFailure(ConnectorException.class).recoverWithItem(failure -> {
-                    log.error("Error in search connector " + connector.getId(), failure);
-                    SearchConnectorResults results = new SearchConnectorResults();
-                    results.setError((ConnectorException) failure);
-                    return results;
-                }).onItem().invoke(conRes -> connector.fillResult(conRes, System.currentTimeMillis() - start));
+        return searchWithCache(query, connector)
+            .ifNoItem().after(timeout).failWith(new ConnectorException(connector.getName() + " reached timeout after " + timeout.toMillis() + "ms"))
+            .onFailure(ConnectorException.class).recoverWithItem(failure -> {
+                log.error("Error in search connector " + connector.getId(), failure);
+                SearchConnectorResults results = new SearchConnectorResults();
+                results.setError((ConnectorException) failure);
+                return results;
+            }).onItem().invoke(conRes -> connector.fillResult(conRes, System.currentTimeMillis() - start));
     }
 
     private Uni<SearchConnectorResults> searchWithCache(SearchQuery query, SearchConnector connector) {