Introduce database export and import (#292)

## Usage and product changes
Add database export and database import operations. 

Database export saves the database information (its schema and data) on
the client machine as two files at provided locations:
```
# database export <name> <schema file location> <data file location>
database export my-database export/my-database.typeql export/my-database.typedb
```

Database import uses the exported files to create a new database with
equivalent schema and data:
```
# database export <name> <schema file location> <data file location>
database import their-database export/my-database.typeql export/my-database.typedb
```

## Implementation
Add new commands similar to other `database` interfaces. Prepare data to
call the respective [typedb-driver
APIs](typedb/typedb-driver#758).

Author: farost

Cargo.lock

@@ -20,7 +20,7 @@ features = {}
 
 	[dependencies.tokio]
 		features = ["bytes", "default", "fs", "full", "io-std", "io-util", "libc", "macros", "mio", "net", "parking_lot", "process", "rt", "rt-multi-thread", "signal", "signal-hook-registry", "socket2", "sync", "time", "tokio-macros"]
-		version = "1.44.2"
+		version = "1.45.0"
 		default-features = false
 
 	[dependencies.rustyline]
@@ -30,7 +30,7 @@ features = {}
 
 	[dependencies.clap]
 		features = ["color", "default", "derive", "error-context", "help", "std", "suggestions", "usage", "wrap_help"]
-		version = "4.5.36"
+		version = "4.5.38"
 		default-features = false
 
 	[dependencies.glob]
@@ -46,8 +46,8 @@ features = {}
 
 	[dependencies.typedb-driver]
 		features = []
+		rev = "6db6f947bbc8f47181f81f458f1f09e1985fb514"
 		git = "https://github.com/typedb/typedb-driver"
-		tag = "3.2.0"
 		default-features = false
 
 	[dependencies.futures]
@@ -62,7 +62,7 @@ features = {}
 
 	[dependencies.rpassword]
 		features = []
-		version = "7.3.1"
+		version = "7.4.0"
 		default-features = false
 
 	[dependencies.home]

Cargo.toml

@@ -8,14 +8,14 @@ def typedb_dependencies():
     git_repository(
         name = "typedb_dependencies",
         remote = "https://github.com/typedb/typedb-dependencies",
-        commit = "ab777bf067b1930e35146fd8e25a76a4a360aa74", # sync-marker: do not remove this comment, this is used for sync-dependencies by @typedb_dependencies
+        commit = "4ffeaabde31c41cee271cbb563f17168f4229a93", # sync-marker: do not remove this comment, this is used for sync-dependencies by @typedb_dependencies
     )
 
 def typedb_driver():
     git_repository(
         name = "typedb_driver",
         remote = "https://github.com/typedb/typedb-driver",
-        tag = "3.2.0",  # sync-marker: do not remove this comment, this is used for sync-dependencies by @typedb_driver
+        commit = "6db6f947bbc8f47181f81f458f1f09e1985fb514",  # sync-marker: do not remove this comment, this is used for sync-dependencies by @typedb_driver
     )
 
 def typeql():

dependencies/typedb/repositories.bzl

@@ -28,9 +28,10 @@ use crate::{
     cli::Args,
     completions::{database_name_completer_fn, file_completer},
     operations::{
-        database_create, database_delete, database_list, database_schema, transaction_close, transaction_commit,
-        transaction_query, transaction_read, transaction_rollback, transaction_schema, transaction_source,
-        transaction_write, user_create, user_delete, user_list, user_update_password,
+        database_create, database_delete, database_export, database_import, database_list, database_schema,
+        transaction_close, transaction_commit, transaction_query, transaction_read, transaction_rollback,
+        transaction_schema, transaction_source, transaction_write, user_create, user_delete, user_list,
+        user_update_password,
     },
     repl::{
         command::{get_word, parse_one_query, CommandInput, CommandLeaf, Subcommand},
@@ -293,6 +294,31 @@ fn entry_repl(driver: Arc<TypeDBDriver>, runtime: BackgroundRuntime) -> Repl<Con
             "Retrieve the TypeQL representation of a database's schema.",
             CommandInput::new("db", get_word, None, Some(database_name_completer_fn(driver.clone(), runtime.clone()))),
             database_schema,
+        ))
+        .add(CommandLeaf::new_with_inputs(
+            "import",
+            "Create a database with the given name based on another previously exported database.",
+            vec![
+                CommandInput::new("db", get_word, None, None),
+                CommandInput::new("schema file path", get_word, None, None),
+                CommandInput::new("data file path", get_word, None, None),
+            ],
+            database_import,
+        ))
+        .add(CommandLeaf::new_with_inputs(
+            "export",
+            "Export a database into a schema definition and a data files.",
+            vec![
+                CommandInput::new(
+                    "db",
+                    get_word,
+                    None,
+                    Some(database_name_completer_fn(driver.clone(), runtime.clone())),
+                ),
+                CommandInput::new("schema file path", get_word, None, None),
+                CommandInput::new("data file path", get_word, None, None),
+            ],
+            database_export,
         ));
 
     let user_commands = Subcommand::new("user")

src/main.rs

@@ -52,6 +52,36 @@ pub(crate) fn database_create(context: &mut ConsoleContext, input: &[String]) ->
     Ok(())
 }
 
+pub(crate) fn database_import(context: &mut ConsoleContext, input: &[String]) -> CommandResult {
+    let driver = context.driver.clone();
+    let db_name = input[0].clone();
+    let schema =
+        read_to_string(context.convert_path(&input[1])).map_err(|err| Box::new(err) as Box<dyn Error + Send>)?;
+    let data_file_path: PathBuf = context.convert_path(&input[2]);
+    context
+        .background_runtime
+        .run(async move { driver.databases().import_from_file(db_name, schema, data_file_path).await })
+        .map_err(|err| Box::new(err) as Box<dyn Error + Send>)?;
+    println!("Successfully imported database.");
+    Ok(())
+}
+
+pub(crate) fn database_export(context: &mut ConsoleContext, input: &[String]) -> CommandResult {
+    let driver = context.driver.clone();
+    let db_name = input[0].clone();
+    let schema_file_path: PathBuf = context.convert_path(&input[1]);
+    let data_file_path: PathBuf = context.convert_path(&input[2]);
+    context
+        .background_runtime
+        .run(async move {
+            let db = driver.databases().get(db_name).await?;
+            db.export_to_file(schema_file_path, data_file_path).await
+        })
+        .map_err(|err| Box::new(err) as Box<dyn Error + Send>)?;
+    println!("Successfully exported database.");
+    Ok(())
+}
+
 pub(crate) fn database_delete(context: &mut ConsoleContext, input: &[String]) -> CommandResult {
     let driver = context.driver.clone();
     let db_name = input[0].clone();

src/operations.rs

@@ -16,7 +16,7 @@ features = {}
 
 	[dependencies.clap]
 		features = ["color", "default", "derive", "error-context", "help", "std", "suggestions", "usage", "wrap_help"]
-		version = "4.5.36"
+		version = "4.5.38"
 		default-features = false
 
 	[dependencies.tempdir]