Support cluster-based driver updates

Author: farost

Cargo.toml

@@ -46,8 +46,8 @@ features = {}
 
 	[dependencies.typedb-driver]
 		features = []
+		rev = "d2ce9ab4f85f8316a9087c130a20c7b1e731e8c4"
 		git = "https://github.com/typedb/typedb-driver"
-		tag = "3.4.4"
 		default-features = false
 
 	[dependencies.futures]

dependencies/typedb/repositories.bzl

@@ -12,10 +12,11 @@ def typedb_dependencies():
     )
 
 def typedb_driver():
+    # TODO: Return typedb
     git_repository(
         name = "typedb_driver",
-        remote = "https://github.com/typedb/typedb-driver",
-        tag = "3.4.4",  # sync-marker: do not remove this comment, this is used for sync-dependencies by @typedb_driver
+        remote = "https://github.com/farost/typedb-driver",
+        commit = "d2ce9ab4f85f8316a9087c130a20c7b1e731e8c4",  # sync-marker: do not remove this comment, this is used for sync-dependencies by @typedb_driver
     )
 
 def typeql():

src/constants.rs

@@ -14,4 +14,4 @@ pub mod common {
     pub const SECONDS_IN_HOUR: u64 = SECONDS_IN_MINUTE * MINUTES_IN_HOUR;
 }
 
-pub const DEFAULT_TRANSACTION_TIMEOUT: Duration = Duration::from_secs(1 * SECONDS_IN_HOUR);
+pub const DEFAULT_TRANSACTION_TIMEOUT: Duration = Duration::from_secs(10);

src/main.rs

@@ -22,7 +22,7 @@ use clap::Parser;
 use home::home_dir;
 use rustyline::error::ReadlineError;
 use sentry::ClientOptions;
-use typedb_driver::{Credentials, DriverOptions, Transaction, TransactionType, TypeDBDriver};
+use typedb_driver::{Addresses, Credentials, DriverOptions, Transaction, TransactionType, TypeDBDriver};
 
 use crate::{
     cli::{Args, ADDRESS_VALUE_NAME, USERNAME_VALUE_NAME},
@@ -165,9 +165,9 @@ fn main() {
 
     let runtime = BackgroundRuntime::new();
     let driver = match runtime.run(TypeDBDriver::new(
-        address,
+        Addresses::try_from_address_str(&address).unwrap(),
         Credentials::new(&username, args.password.as_ref().unwrap()),
-        DriverOptions::new(!args.tls_disabled, tls_root_ca_path).unwrap(),
+        DriverOptions::new().tls_enabled(!args.tls_disabled).tls_root_ca(tls_root_ca_path).unwrap(),
     )) {
         Ok(driver) => Arc::new(driver),
         Err(err) => {

src/operations.rs

@@ -117,7 +117,7 @@ pub(crate) fn user_list(context: &mut ConsoleContext, _input: &[String]) -> Comm
         println!("No users are present.");
     } else {
         for user in users {
-            println!("{}", user.name);
+            println!("{}", user.name());
         }
     }
     Ok(())
@@ -169,13 +169,13 @@ pub(crate) fn user_update_password(context: &mut ConsoleContext, input: &[String
             };
         let current_user = driver
             .users()
-            .get_current_user()
+            .get_current()
             .await
             .map_err(|err| Box::new(err) as Box<dyn Error + Send>)?
             .expect("Could not fetch currently logged in user.");
 
         user.update_password(new_password).await.map_err(|err| Box::new(err) as Box<dyn Error + Send>)?;
-        Ok(current_user.name == username)
+        Ok(current_user.name() == username)
     })?;
     if updated_current_user {
         println!("Successfully updated current user's password, exiting console. Please log in with the updated credentials.");