Support cluster-based driver updates

Author: farost

Cargo.lock

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

Cargo.toml

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

dependencies/typedb/repositories.bzl

@@ -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/constants.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,
@@ -114,9 +114,9 @@ fn main() {
     let runtime = BackgroundRuntime::new();
     let tls_root_ca_path = args.tls_root_ca.as_ref().map(|value| Path::new(value));
     let driver = match runtime.run(TypeDBDriver::new(
-        args.address,
+        Addresses::try_from_address_str(args.address).unwrap(),
         Credentials::new(&args.username, args.password.as_ref().unwrap()),
-        DriverOptions::new(!args.tls_disabled, tls_root_ca_path).unwrap(),
+        DriverOptions::new().is_tls_enabled(!args.tls_disabled).tls_root_ca(tls_root_ca_path).unwrap(),
     )) {
         Ok(driver) => Arc::new(driver),
         Err(err) => {

src/main.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(())
@@ -175,7 +175,7 @@ pub(crate) fn user_update_password(context: &mut ConsoleContext, input: &[String
             .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.");