Add method to Cluster client to retrieve current user (#290)

## What is the goal of this PR?

Add an API to be able retrieve the currently authenticated user.

## What are the changes implemented in this PR?

Added functions:
* `user(self) -> User` to the `TypeDBClusterClient` abstract class.
* `user(self) -> User` to the `_ClusterClient` class.

Added user step: `get connected user`.

Author: James Williams

dependencies/vaticle/repositories.bzl

@@ -39,5 +39,5 @@ def vaticle_typedb_behaviour():
     git_repository(
         name = "vaticle_typedb_behaviour",
         remote = "https://github.com/vaticle/typedb-behaviour",
-        commit = "b4cbdd3aaf28428608fc88eae0852425df57fe25" # sync-marker: do not remove this comment, this is used for sync-dependencies by @vaticle_typedb_behaviour
+        commit = "fbba9fc19042460760b852b765d356c9b3f4ebf0" # sync-marker: do not remove this comment, this is used for sync-dependencies by @vaticle_typedb_behaviour
     )

tests/behaviour/connection/user/user_steps.py

@@ -32,6 +32,11 @@ def _get_client(context: Context):
     return client
 
 
+@step("get connected user")
+def step_impl(context: Context):
+    _get_client(context).user()
+
+
 @step("users contains: {username:Words}")
 def step_impl(context: Context, username: str):
     assert_that([u.username() for u in _get_client(context).users().all()], has_item(username))

typedb/api/connection/client.py

@@ -23,7 +23,7 @@
 from typedb.api.connection.database import DatabaseManager, ClusterDatabaseManager
 from typedb.api.connection.options import TypeDBOptions
 from typedb.api.connection.session import TypeDBSession, SessionType
-from typedb.api.connection.user import UserManager
+from typedb.api.connection.user import UserManager, User
 
 
 class TypeDBClient(ABC):
@@ -66,3 +66,7 @@ def databases(self) -> ClusterDatabaseManager:
     @abstractmethod
     def users(self) -> UserManager:
         pass
+
+    @abstractmethod
+    def user(self) -> User:
+        pass

typedb/connection/cluster/client.py

@@ -24,7 +24,7 @@
 from typedb.api.connection.credential import TypeDBCredential
 from typedb.api.connection.options import TypeDBOptions, TypeDBClusterOptions
 from typedb.api.connection.session import SessionType
-from typedb.api.connection.user import UserManager
+from typedb.api.connection.user import UserManager, User
 from typedb.connection.cluster.database import _ClusterDatabase, _FailsafeTask
 from typedb.connection.cluster.database_manager import _ClusterDatabaseManager
 from typedb.connection.cluster.server_client import _ClusterServerClient
@@ -78,6 +78,9 @@ def is_open(self) -> bool:
     def users(self) -> UserManager:
         return self._user_manager
 
+    def user(self) -> User:
+        return self.users().get(self._credential.username())
+
     def databases(self) -> _ClusterDatabaseManager:
         return self._database_managers
 

typedb/connection/cluster/user_manager.py

@@ -75,7 +75,7 @@ def contains(self, username: str) -> bool:
     def get(self, username: str) -> User:
         failsafe_task = _UserManagerFailsafeTask(
             self._client,
-            lambda replica: _ClusterUser.of(self._client._stub(replica.address()).users_get(cluster_user_manager_get_req(username)).get_user(), self._client)
+            lambda replica: _ClusterUser.of(self._client._stub(replica.address()).users_get(cluster_user_manager_get_req(username)).user, self._client)
         )
         return failsafe_task.run_primary_replica()