Increase transaction timeout (#289)

## Usage and product changes
Set transaction timeout for opened transactions to 1 hour.

This change significantly lowers the impact of
#287.

## Implementation
Use the new `transaction_with_options` interface of the Rust driver to
pass configured transaction options.

Author: farost

src/constants.rs

@@ -0,0 +1,17 @@
+/*
+ * This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at https://mozilla.org/MPL/2.0/.
+ */
+
+use std::time::Duration;
+
+use crate::constants::common::SECONDS_IN_HOUR;
+
+pub mod common {
+    pub const SECONDS_IN_MINUTE: u64 = 60;
+    pub const MINUTES_IN_HOUR: u64 = 60;
+    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);

src/main.rs

@@ -41,6 +41,7 @@ use crate::{
 
 mod cli;
 mod completions;
+mod constants;
 mod operations;
 mod printer;
 mod repl;

src/operations.rs

@@ -9,10 +9,11 @@ use std::{error::Error, fs::read_to_string, path::Path, process::exit, rc::Rc};
 use futures::stream::StreamExt;
 use typedb_driver::{
     answer::{QueryAnswer, QueryType},
-    TransactionType,
+    TransactionOptions, TransactionType,
 };
 
 use crate::{
+    constants::DEFAULT_TRANSACTION_TIMEOUT,
     printer::{print_document, print_row},
     repl::command::{parse_one_query, CommandResult, ReplError},
     transaction_repl, ConsoleContext,
@@ -155,7 +156,9 @@ pub(crate) fn transaction_read(context: &mut ConsoleContext, input: &[String]) -
     let db_name_owned = db_name.clone();
     let transaction = context
         .background_runtime
-        .run(async move { driver.transaction(db_name_owned, TransactionType::Read).await })
+        .run(async move {
+            driver.transaction_with_options(db_name_owned, TransactionType::Read, default_transaction_options()).await
+        })
         .map_err(|err| Box::new(err) as Box<dyn Error + Send>)?;
     context.transaction = Some((transaction, false));
     let repl = transaction_repl(db_name, TransactionType::Read);
@@ -169,7 +172,9 @@ pub(crate) fn transaction_write(context: &mut ConsoleContext, input: &[String])
     let db_name_owned = db_name.clone();
     let transaction = context
         .background_runtime
-        .run(async move { driver.transaction(db_name_owned, TransactionType::Write).await })
+        .run(async move {
+            driver.transaction_with_options(db_name_owned, TransactionType::Write, default_transaction_options()).await
+        })
         .map_err(|err| Box::new(err) as Box<dyn Error + Send>)?;
     context.transaction = Some((transaction, false));
     let repl = transaction_repl(db_name, TransactionType::Write);
@@ -183,7 +188,9 @@ pub(crate) fn transaction_schema(context: &mut ConsoleContext, input: &[String])
     let db_name_owned = db_name.clone();
     let transaction = context
         .background_runtime
-        .run(async move { driver.transaction(db_name_owned, TransactionType::Schema).await })
+        .run(async move {
+            driver.transaction_with_options(db_name_owned, TransactionType::Schema, default_transaction_options()).await
+        })
         .map_err(|err| Box::new(err) as Box<dyn Error + Send>)?;
     context.transaction = Some((transaction, false));
     let repl = transaction_repl(db_name, TransactionType::Schema);
@@ -307,6 +314,10 @@ pub(crate) fn transaction_query(context: &mut ConsoleContext, input: &[impl AsRe
     }
 }
 
+fn default_transaction_options() -> TransactionOptions {
+    TransactionOptions::new().transaction_timeout(DEFAULT_TRANSACTION_TIMEOUT)
+}
+
 const QUERY_TYPE_TEMPLATE: &'static str = "<QUERY TYPE>";
 const QUERY_COMPILATION_SUCCESS: &'static str = "Finished <QUERY TYPE> query validation and compilation...";
 const QUERY_WRITE_FINISHED_STREAMING_ROWS: &'static str = "Finished writes. Streaming rows...";