Feature/stream tx graph (#310)

* streamTx: createVertex

* streamTx: vertex operations

* streamTx: edges operations

* documentation streamTx on graphs

* catchGetDocumentExceptions for async graph APIs

* async StreamTransactionGraphTest

* changelog upd

* bugfix ArangoDatabaseTest

* updated CI matrix

* code inspection fixes

Author: rashtao

.github/workflows/maven.yml

@@ -31,9 +31,9 @@ jobs:
         docker-img:
           - docker.io/arangodb:3.3.23
           - docker.io/arangodb:3.4.8
-          - docker.io/arangodb:3.5.0
+          - docker.io/arangodb:3.5.1
           - docker.io/arangodb/enterprise:3.4.8
-          - docker.io/arangodb/enterprise:3.5.0
+          - docker.io/arangodb/enterprise:3.5.1
         topology:
           - single
           - cluster

ChangeLog.md

@@ -6,6 +6,14 @@ The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/) a
 
 ## [Unreleased]
 
+### Added
+
+- Stream Transactions support for graph APIs
+
+### Fixed
+
+- `catchExceptions` option in async `getEdge` and `getVertex`
+
 ## [6.3.0] - 2019-09-16
 
 ### Added

docker/start_db_cluster.sh

@@ -5,7 +5,7 @@
 #   ./start_db_cluster.sh <dockerImage>
 
 # EXAMPLE:
-#   ./start_db_cluster.sh docker.io/arangodb:3.5.0
+#   ./start_db_cluster.sh docker.io/arangodb/arangodb:3.5.1
 
 docker pull "$1"
 

docker/start_db_single.sh

@@ -5,7 +5,7 @@
 #   ./start_db_single.sh <dockerImage>
 
 # EXAMPLE:
-#   ./start_db_single.sh docker.io/arangodb:3.5.0
+#   ./start_db_single.sh docker.io/arangodb/arangodb:3.5.1
 
 docker pull "$1"
 

docs/Drivers/Java/Reference/Graph/Edges.md

@@ -30,6 +30,10 @@ Retrieves the edge document with the given `key` from the collection.
 
     Whether or not catch possible thrown exceptions
 
+  - **streamTransactionId**: `String`
+
+    If set, the operation will be executed within the transaction
+
 ## ArangoEdgeCollection.insertEdge
 
 `ArangoEdgeCollection.insertEdge(T value, EdgeCreateOptions options) : EdgeEntity`
@@ -88,6 +92,10 @@ a edge and no precondition is violated.
 
     Replace a document based on target revision
 
+  - **streamTransactionId**: `String`
+
+    If set, the operation will be executed within the transaction
+
 **Examples**
 
 ```Java
@@ -135,6 +143,10 @@ edge and no precondition is violated.
     from the existing document that are contained in the patch document with an
     attribute value of null.
 
+  - **streamTransactionId**: `String`
+
+    If set, the operation will be executed within the transaction
+
 **Examples**
 
 ```Java
@@ -169,6 +181,10 @@ Deletes the edge with the given _key_ from the collection.
 
     Remove a document based on target revision
 
+  - **streamTransactionId**: `String`
+
+    If set, the operation will be executed within the transaction
+
 **Examples**
 
 ```Java

docs/Drivers/Java/Reference/Graph/Vertices.md

@@ -30,6 +30,10 @@ Retrieves the vertex document with the given `key` from the collection.
 
     Whether or not catch possible thrown exceptions
 
+  - **streamTransactionId**: `String`
+
+    If set, the operation will be executed within the transaction
+
 ## ArangoVertexCollection.insertVertex
 
 `ArangoVertexCollection.insertVertex(T value, VertexCreateOptions options) : VertexEntity`
@@ -48,6 +52,14 @@ Creates a new vertex in the collection.
 
     Wait until document has been synced to disk.
 
+  - **streamTransactionId**: `String`
+
+    If set, the operation will be executed within the transaction
+
+  - **streamTransactionId**: `String`
+
+    If set, the operation will be executed within the transaction
+
 **Examples**
 
 ```Java
@@ -88,6 +100,10 @@ a vertex and no precondition is violated.
 
     Replace a document based on target revision
 
+  - **streamTransactionId**: `String`
+
+    If set, the operation will be executed within the transaction
+
 **Examples**
 
 ```Java
@@ -135,6 +151,10 @@ a vertex and no precondition is violated.
     from the existing document that are contained in the patch document with
     an attribute value of null.
 
+  - **streamTransactionId**: `String`
+
+    If set, the operation will be executed within the transaction
+
 **Examples**
 
 ```Java
@@ -169,6 +189,10 @@ Deletes the vertex with the given _key_ from the collection.
 
     Remove a document based on target revision
 
+  - **streamTransactionId**: `String`
+
+    If set, the operation will be executed within the transaction
+
 **Examples**
 
 ```Java

src/main/java/com/arangodb/async/internal/ArangoCollectionAsyncImpl.java

@@ -30,8 +30,6 @@
 import java.util.Collection;
 import java.util.Objects;
 import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.CompletionException;
-import java.util.function.Function;
 
 /**
  * @author Mark Vollmary
@@ -116,29 +114,7 @@ public <T> CompletableFuture<T> getDocument(
         DocumentUtil.validateDocumentKey(key);
         boolean isCatchException = options != null ? options.isCatchException() : new DocumentReadOptions().isCatchException();
         return (CompletableFuture<T>) executor.execute(getDocumentRequest(key, options), type)
-                .exceptionally(handleGetDocumentExceptions(isCatchException));
-    }
-
-    private <T> Function<Throwable, T> handleGetDocumentExceptions(Boolean isCatchException) {
-        return throwable -> {
-            if (throwable instanceof CompletionException) {
-                if (throwable.getCause() instanceof ArangoDBException) {
-                    ArangoDBException arangoDBException = (ArangoDBException) throwable.getCause();
-
-                    // handle Response: 404, Error: 1655 - transaction not found
-                    if (arangoDBException.getErrorNum() != null && arangoDBException.getErrorNum() == 1655) {
-                        throw (CompletionException) throwable;
-                    }
-
-                    if ((arangoDBException.getResponseCode() != null && (arangoDBException.getResponseCode() == 404 || arangoDBException.getResponseCode() == 304
-                            || arangoDBException.getResponseCode() == 412)) && isCatchException) {
-                        return null;
-                    }
-                }
-                throw (CompletionException) throwable;
-            }
-            throw new CompletionException(throwable);
-        };
+                .exceptionally(ExceptionUtil.catchGetDocumentExceptions(isCatchException));
     }
 
     @Override
@@ -260,7 +236,7 @@ public CompletableFuture<Boolean> documentExists(final String key) {
     public CompletableFuture<Boolean> documentExists(final String key, final DocumentExistsOptions options) {
         boolean isCatchException = options != null ? options.isCatchException() : new DocumentExistsOptions().isCatchException();
         return executor.execute(documentExistsRequest(key, options), response -> response)
-                .exceptionally(handleGetDocumentExceptions(isCatchException))
+                .exceptionally(ExceptionUtil.catchGetDocumentExceptions(isCatchException))
                 .thenApply(Objects::nonNull);
     }
 

src/main/java/com/arangodb/async/internal/ArangoEdgeCollectionAsyncImpl.java

@@ -52,12 +52,14 @@ public <T> CompletableFuture<EdgeEntity> insertEdge(final T value, final EdgeCre
 
     @Override
     public <T> CompletableFuture<T> getEdge(final String key, final Class<T> type) {
-        return executor.execute(getEdgeRequest(key, new GraphDocumentReadOptions()), getEdgeResponseDeserializer(type));
+        return getEdge(key, type, null);
     }
 
     @Override
     public <T> CompletableFuture<T> getEdge(final String key, final Class<T> type, final GraphDocumentReadOptions options) {
-        return executor.execute(getEdgeRequest(key, options), getEdgeResponseDeserializer(type));
+        boolean isCatchException = options != null ? options.isCatchException() : new GraphDocumentReadOptions().isCatchException();
+        return executor.execute(getEdgeRequest(key, options), getEdgeResponseDeserializer(type))
+                .exceptionally(ExceptionUtil.catchGetDocumentExceptions(isCatchException));
     }
 
     @Override

src/main/java/com/arangodb/async/internal/ArangoVertexCollectionAsyncImpl.java

@@ -57,15 +57,17 @@ public <T> CompletableFuture<VertexEntity> insertVertex(final T value, final Ver
 
     @Override
     public <T> CompletableFuture<T> getVertex(final String key, final Class<T> type) {
-        return executor.execute(getVertexRequest(key, new GraphDocumentReadOptions()), getVertexResponseDeserializer(type));
+        return getVertex(key, type, null);
     }
 
     @Override
     public <T> CompletableFuture<T> getVertex(
             final String key,
             final Class<T> type,
             final GraphDocumentReadOptions options) {
-        return executor.execute(getVertexRequest(key, options), getVertexResponseDeserializer(type));
+        boolean isCatchException = options != null ? options.isCatchException() : new GraphDocumentReadOptions().isCatchException();
+        return executor.execute(getVertexRequest(key, options), getVertexResponseDeserializer(type))
+                .exceptionally(ExceptionUtil.catchGetDocumentExceptions(isCatchException));
     }
 
     @Override

src/main/java/com/arangodb/async/internal/ExceptionUtil.java

@@ -0,0 +1,52 @@
+package com.arangodb.async.internal;/*
+ * DISCLAIMER
+ *
+ * Copyright 2016 ArangoDB GmbH, Cologne, Germany
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ * Copyright holder is ArangoDB GmbH, Cologne, Germany
+ */
+
+
+import com.arangodb.ArangoDBException;
+
+import java.util.concurrent.CompletionException;
+import java.util.function.Function;
+
+/**
+ * @author Michele Rastelli
+ */
+class ExceptionUtil {
+    static <T> Function<Throwable, T> catchGetDocumentExceptions(Boolean isCatchException) {
+        return throwable -> {
+            if (throwable instanceof CompletionException) {
+                if (throwable.getCause() instanceof ArangoDBException) {
+                    ArangoDBException arangoDBException = (ArangoDBException) throwable.getCause();
+
+                    // handle Response: 404, Error: 1655 - transaction not found
+                    if (arangoDBException.getErrorNum() != null && arangoDBException.getErrorNum() == 1655) {
+                        throw (CompletionException) throwable;
+                    }
+
+                    if ((arangoDBException.getResponseCode() != null && (arangoDBException.getResponseCode() == 404 || arangoDBException.getResponseCode() == 304
+                            || arangoDBException.getResponseCode() == 412)) && isCatchException) {
+                        return null;
+                    }
+                }
+                throw (CompletionException) throwable;
+            }
+            throw new CompletionException(throwable);
+        };
+    }
+}