getAccessibleDatabasesFor user

Author: Mark

src/main/java/com/arangodb/ArangoDB.java

@@ -231,7 +231,7 @@ public ArangoDatabase db(final String name) {
 	}
 
 	/**
-	 * creates a new database
+	 * Creates a new database
 	 * 
 	 * @see <a href="https://docs.arangodb.com/current/HTTP/Database/DatabaseManagement.html#create-database">API
 	 *      Documentation</a>
@@ -245,6 +245,8 @@ public Boolean createDatabase(final String name) throws ArangoDBException {
 	}
 
 	/**
+	 * Retrieves a list of all existing databases
+	 * 
 	 * @see <a href="https://docs.arangodb.com/current/HTTP/Database/DatabaseManagement.html#list-of-databases">API
 	 *      Documentation</a>
 	 * @return a list of all existing databases
@@ -255,6 +257,8 @@ public Collection<String> getDatabases() throws ArangoDBException {
 	}
 
 	/**
+	 * Retrieves a list of all databases the current user can access
+	 * 
 	 * @see <a href=
 	 *      "https://docs.arangodb.com/current/HTTP/Database/DatabaseManagement.html#list-of-accessible-databases">API
 	 *      Documentation</a>
@@ -265,6 +269,22 @@ public Collection<String> getAccessibleDatabases() throws ArangoDBException {
 		return executor.execute(getAccessibleDatabasesRequest(db().name()), getDatabaseResponseDeserializer());
 	}
 
+	/**
+	 * List available database to the specified user
+	 * 
+	 * @see <a href=
+	 *      "https://docs.arangodb.com/current/HTTP/UserManagement/index.html#list-the-databases-available-to-a-user">API
+	 *      Documentation</a>
+	 * @param user
+	 *            The name of the user for which you want to query the databases
+	 * @return
+	 * @throws ArangoDBException
+	 */
+	public Collection<String> getAccessibleDatabasesFor(final String user) throws ArangoDBException {
+		return executor.execute(getAccessibleDatabasesForRequest(db().name(), user),
+			getAccessibleDatabasesForResponseDeserializer());
+	}
+
 	/**
 	 * Returns the server name and version number.
 	 * 

src/main/java/com/arangodb/internal/InternalArangoDB.java

@@ -20,7 +20,10 @@
 
 package com.arangodb.internal;
 
+import java.util.ArrayList;
 import java.util.Collection;
+import java.util.Iterator;
+import java.util.Map.Entry;
 
 import com.arangodb.entity.LogLevelEntity;
 import com.arangodb.entity.UserEntity;
@@ -87,6 +90,26 @@ protected Request getAccessibleDatabasesRequest(final String database) {
 				executor.createPath(ArangoDBConstants.PATH_API_DATABASE, ArangoDBConstants.USER));
 	}
 
+	protected Request getAccessibleDatabasesForRequest(final String database, final String user) {
+		return new Request(database, RequestType.GET,
+				executor.createPath(ArangoDBConstants.PATH_API_USER, user, ArangoDBConstants.DATABASE));
+	}
+
+	protected ResponseDeserializer<Collection<String>> getAccessibleDatabasesForResponseDeserializer() {
+		return new ResponseDeserializer<Collection<String>>() {
+			@Override
+			public Collection<String> deserialize(final Response response) throws VPackException {
+				final VPackSlice result = response.getBody().get(ArangoDBConstants.RESULT);
+				final Collection<String> dbs = new ArrayList<String>();
+				for (final Iterator<Entry<String, VPackSlice>> iterator = result.objectIterator(); iterator
+						.hasNext();) {
+					dbs.add(iterator.next().getKey());
+				}
+				return dbs;
+			}
+		};
+	}
+
 	protected Request getVersionRequest() {
 		return new Request(ArangoDBConstants.SYSTEM, RequestType.GET, ArangoDBConstants.PATH_API_VERSION);
 	}
@@ -160,4 +183,5 @@ protected Request setLogLevelRequest(final LogLevelEntity entity) {
 		return new Request(ArangoDBConstants.SYSTEM, RequestType.PUT, ArangoDBConstants.PATH_API_ADMIN_LOG_LEVEL)
 				.setBody(executor.serialize(entity));
 	}
+
 }

src/test/java/com/arangodb/ArangoDBTest.java

@@ -118,6 +118,15 @@ public void getAccessibleDatabases() {
 		assertThat(dbs, hasItem("_system"));
 	}
 
+	@Test
+	public void getAccessibleDatabasesFor() {
+		final ArangoDB arangoDB = new ArangoDB.Builder().build();
+		final Collection<String> dbs = arangoDB.getAccessibleDatabasesFor("root");
+		assertThat(dbs, is(notNullValue()));
+		assertThat(dbs.size(), greaterThan(0));
+		assertThat(dbs, hasItem("_system"));
+	}
+
 	@Test
 	public void createUser() {
 		final ArangoDB arangoDB = new ArangoDB.Builder().build();

src/test/java/com/arangodb/util/ArangoUtilTest.java

@@ -31,10 +31,14 @@
 
 import com.arangodb.ArangoDB;
 import com.arangodb.entity.BaseDocument;
+import com.arangodb.internal.ArangoExecutorSync;
+import com.arangodb.internal.InternalArangoDB;
+import com.arangodb.internal.velocystream.ConnectionSync;
 import com.arangodb.velocypack.Type;
 import com.arangodb.velocypack.VPackBuilder;
 import com.arangodb.velocypack.VPackSlice;
 import com.arangodb.velocypack.ValueType;
+import com.arangodb.velocystream.Response;
 
 /**
  * @author Mark - mark at arangodb.com
@@ -46,7 +50,7 @@ public class ArangoUtilTest {
 
 	@BeforeClass
 	public static void setup() {
-		final ArangoDB arangoDB = new ArangoDB.Builder().build();
+		final InternalArangoDB<ArangoExecutorSync, Response, ConnectionSync> arangoDB = new ArangoDB.Builder().build();
 		util = arangoDB.util();
 	}
 

tests/travis/setup_arangodb.sh

@@ -29,9 +29,8 @@ echo "Starting ArangoDB '${ARANGOD}'"
 ${ARANGOD} \
     --database.directory ${TMP_DIR} \
     --configuration none \
-    --server.endpoint vpp+tcp://127.0.0.1:8529 \
-    --server.endpoint vpp+ssl://127.0.0.1:8530 \
-    --server.endpoint tcp://127.0.0.1:8531 \
+    --server.endpoint tcp://127.0.0.1:8529 \
+    --server.endpoint ssl://127.0.0.1:8530 \
     --ssl.keyfile ./server.pem \
     --javascript.app-path ${ARANGODB_DIR}/js/apps \
     --javascript.startup-directory ${ARANGODB_DIR}/js \