Active waiting in case when Polygon didn't give a correct API respons…

…e added
perveevm · Apr 24, 2022 · 3e4931a · 3e4931a
1 parent 14c9f44
commit 3e4931a
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 2 deletions.
diff --git a/pom.xml b/pom.xml
@@ -6,7 +6,7 @@
 
     <groupId>ru.perveevm</groupId>
     <artifactId>polygon-api</artifactId>
-    <version>0.6</version>
+    <version>0.6.1</version>
 
     <properties>
         <maven.compiler.source>15</maven.compiler.source>

diff --git a/src/main/java/ru/perveevm/polygon/api/PolygonSession.java b/src/main/java/ru/perveevm/polygon/api/PolygonSession.java
@@ -818,7 +818,22 @@ private JsonElement sendAPIRequest(final String methodName, final List<NameValue
             throws PolygonSessionException {
         String json = sendAPIRequestPlain(methodName, parameters);
 
-        JSONResponse jsonResponse = gson.fromJson(json, JSONResponse.class);
+        JSONResponse jsonResponse;
+        long timeout = 100;
+        while (true) {
+            try {
+                jsonResponse = gson.fromJson(json, JSONResponse.class);
+                break;
+            } catch (JsonSyntaxException e) {
+                try {
+                    Thread.currentThread().wait(timeout);
+                } catch (InterruptedException ie) {
+                    throw new PolygonSessionException("Session thread was interrupted", e);
+                }
+                timeout *= 2;
+            }
+        }
+
         if (jsonResponse.getStatus() == JSONResponseStatus.FAILED) {
             throw new PolygonSessionFailedRequestException(BASE_URL + methodName, parameters,
                     jsonResponse.getComment());