E2E: add (or expand) ingest/inspect/log/new/reset/search/etc command tests

CHANGELOG.md

@@ -19,6 +19,19 @@ Recommendation: for ease of reading, use the following order:
   - `kamu init` command
   - `kamu add` command
   - `kamu rename` command
+  - `kamu ingest` command
+  - `kamu inspect` command
+  - `kamu log` command
+  - `kamu new` command
+  - `kamu reset` command
+  - `kamu search` command
+  - `kamu sql` command
+  - `kamu system gc` command
+  - `kamu system info` command
+  - `kamu system diagnose` command
+  - `kamu tail` command
+  - `kamu login` command
+  - `kamu logout` command
 ### Changed
 - `kamu repo alias list`: added JSON output alongside with other formats mentioned in the command's help
 - Private Datasets, `DatasetEntry` integration that will allow us to build dataset indexing

resources/cli-reference.md

@@ -20,7 +20,7 @@ To regenerate this schema from existing code, use the following command:
 * `inspect` — Group of commands for exploring dataset metadata
 * `list [ls]` — List all datasets in the workspace
 * `log` — Shows dataset metadata history
-* `login` — Authentiates with a remote ODF server interactively
+* `login` — Authenticates with a remote ODF server interactively
 * `logout` — Logs out from a remote Kamu server
 * `new` — Creates a new dataset manifest from a template
 * `notebook` — Starts the notebook server for exploring the data in the workspace
@@ -508,7 +508,7 @@ Using a filter to inspect blocks containing query changes of a derivative datase
 
 ## `kamu login`
 
-Authentiates with a remote ODF server interactively
+Authenticates with a remote ODF server interactively
 
 **Usage:** `kamu login [OPTIONS] [SERVER] [COMMAND]`
 

src/adapter/graphql/src/mutations/datasets_mut.rs

@@ -110,6 +110,8 @@ impl DatasetsMut {
     }
 
     // TODO: Multi-tenancy
+    //       https://github.com/kamu-data/kamu-cli/issues/891
+
     // TODO: Multi-tenant resolution for derivative dataset inputs (should it only
     //       work by ID?)
     #[allow(unused_variables)]

src/app/cli/src/cli.rs

@@ -634,7 +634,7 @@ pub struct Log {
 
 ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
 
-/// Authentiates with a remote ODF server interactively
+/// Authenticates with a remote ODF server interactively
 #[derive(Debug, clap::Args)]
 pub struct Login {
     #[command(subcommand)]

src/app/cli/src/cli_commands.rs

@@ -127,7 +127,7 @@ pub fn get_command(
             }
         }
         cli::Command::Inspect(c) => match c.subcommand {
-            cli::InspectSubCommand::Lineage(sc) => Box::new(LineageCommand::new(
+            cli::InspectSubCommand::Lineage(sc) => Box::new(InspectLineageCommand::new(
                 cli_catalog.get_one()?,
                 cli_catalog.get_one()?,
                 cli_catalog.get_one()?,

src/app/cli/src/commands/ingest_command.rs

@@ -145,6 +145,8 @@ impl Command for IngestCommand {
             _ => Ok(()),
         }?;
 
+        // TODO: `kamu ingest`: implement `--recursive` mode
+        //        https://github.com/kamu-data/kamu-cli/issues/886
         if self.recursive {
             unimplemented!("Sorry, recursive ingest is not yet implemented")
         }

src/app/cli/src/commands/lineage_command.rs → src/app/cli/src/commands/inspect_lineage_command.rs

@@ -31,7 +31,7 @@ pub enum LineageOutputFormat {
 
 ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
 
-pub struct LineageCommand {
+pub struct InspectLineageCommand {
     dataset_repo: Arc<dyn DatasetRepository>,
     provenance_svc: Arc<dyn ProvenanceService>,
     workspace_layout: Arc<WorkspaceLayout>,
@@ -41,7 +41,7 @@ pub struct LineageCommand {
     output_config: Arc<OutputConfig>,
 }
 
-impl LineageCommand {
+impl InspectLineageCommand {
     pub fn new<I>(
         dataset_repo: Arc<dyn DatasetRepository>,
         provenance_svc: Arc<dyn ProvenanceService>,
@@ -94,7 +94,7 @@ impl LineageCommand {
 
 // TODO: Support temporality and evolution
 #[async_trait::async_trait(?Send)]
-impl Command for LineageCommand {
+impl Command for InspectLineageCommand {
     async fn run(&mut self) -> Result<(), CLIError> {
         use futures::{StreamExt, TryStreamExt};
         let mut dataset_handles: Vec<_> = if self.dataset_refs.is_empty() {

src/app/cli/src/commands/log_command.rs

@@ -29,6 +29,8 @@ use crate::output::OutputConfig;
 pub enum MetadataLogOutputFormat {
     Shell,
     Yaml,
+    // TODO: `kamu log`: support `--output-format json`
+    //       https://github.com/kamu-data/kamu-cli/issues/887
 }
 
 ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

src/app/cli/src/commands/login_silent_command.rs

@@ -16,16 +16,19 @@ use crate::{odf_server, CLIError, Command};
 
 ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
 
+#[derive(Debug)]
 pub enum LoginSilentMode {
     OAuth(LoginSilentModeOAuth),
     Password(LoginSilentModePassword),
 }
 
+#[derive(Debug)]
 pub struct LoginSilentModeOAuth {
     pub provider: String,
     pub access_token: String,
 }
 
+#[derive(Debug)]
 pub struct LoginSilentModePassword {
     pub login: String,
     pub password: String,

src/app/cli/src/commands/mod.rs

@@ -20,9 +20,9 @@ mod delete_command;
 mod gc_command;
 mod ingest_command;
 mod init_command;
+mod inspect_lineage_command;
 mod inspect_query_command;
 mod inspect_schema_command;
-mod lineage_command;
 mod list_command;
 mod log_command;
 mod login_command;
@@ -71,9 +71,9 @@ pub use delete_command::*;
 pub use gc_command::*;
 pub use ingest_command::*;
 pub use init_command::*;
+pub use inspect_lineage_command::*;
 pub use inspect_query_command::*;
 pub use inspect_schema_command::*;
-pub use lineage_command::*;
 pub use list_command::*;
 pub use log_command::*;
 pub use login_command::*;

src/app/cli/src/commands/reset_command.rs

@@ -15,6 +15,8 @@ use opendatafabric::*;
 use super::{CLIError, Command};
 use crate::Interact;
 
+////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
+
 pub struct ResetCommand {
     interact: Arc<Interact>,
     dataset_repo: Arc<dyn DatasetRepository>,
@@ -66,3 +68,5 @@ impl Command for ResetCommand {
         Ok(())
     }
 }
+
+////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

src/app/cli/src/commands/tail_command.rs

@@ -17,6 +17,8 @@ use opendatafabric::*;
 use super::{CLIError, Command};
 use crate::output::*;
 
+////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
+
 pub struct TailCommand {
     query_svc: Arc<dyn QueryService>,
     dataset_ref: DatasetRef,
@@ -93,3 +95,5 @@ impl Command for TailCommand {
         Ok(())
     }
 }
+
+////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

src/app/cli/src/services/gc_service.rs

@@ -9,11 +9,17 @@
 
 use std::sync::Arc;
 
-use chrono::{DateTime, Duration, Utc};
+use chrono::{DateTime, Duration, TimeDelta, Utc};
 use internal_error::{InternalError, ResultIntoInternal};
 
 use crate::WorkspaceLayout;
 
+////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
+
+const EVICTION_THRESHOLD: TimeDelta = Duration::hours(24);
+
+////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
+
 pub struct GcService {
     workspace_layout: Arc<WorkspaceLayout>,
 }
@@ -56,9 +62,6 @@ impl GcService {
     /// Evict stale entries to manage cache size
     #[tracing::instrument(level = "debug", skip_all)]
     pub fn evict_cache(&self) -> Result<GcResult, InternalError> {
-        // TODO: Make const after https://github.com/chronotope/chrono/issues/309
-        // Or make into a config option
-        let eviction_threshold: Duration = Duration::hours(24);
         let now = Utc::now();
         let mut entries_freed = 0;
         let mut bytes_freed = 0;
@@ -69,7 +72,7 @@ impl GcService {
                 let mtime: DateTime<Utc> =
                     chrono::DateTime::from(entry.metadata().int_err()?.modified().int_err()?);
 
-                if (now - mtime) > eviction_threshold {
+                if (now - mtime) > EVICTION_THRESHOLD {
                     if entry.path().is_dir() {
                         bytes_freed += fs_extra::dir::get_size(entry.path()).int_err()?;
                         std::fs::remove_dir_all(entry.path()).int_err()?;
@@ -93,7 +96,11 @@ impl GcService {
     }
 }
 
+////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
+
 pub struct GcResult {
     pub entries_freed: usize,
     pub bytes_freed: u64,
 }
+
+////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

src/domain/core/src/services/reset_service.rs

@@ -14,6 +14,8 @@ use thiserror::Error;
 use crate::entities::SetRefError;
 use crate::*;
 
+////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
+
 #[async_trait::async_trait]
 pub trait ResetService: Send + Sync {
     async fn reset_dataset(
@@ -103,3 +105,5 @@ pub struct OldHeadMismatchError {
     pub current_head: Multihash,
     pub old_head: Multihash,
 }
+
+////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

src/e2e/app/cli/common/src/e2e_harness.rs

@@ -9,7 +9,7 @@
 
 use std::future::Future;
 
-use chrono::{DateTime, NaiveTime, Utc};
+use chrono::{DateTime, NaiveTime, TimeZone, Utc};
 use kamu_cli_puppet::extensions::KamuCliPuppetExt;
 use kamu_cli_puppet::{KamuCliPuppet, NewWorkspaceOptions};
 use regex::Regex;
@@ -55,12 +55,18 @@ impl KamuCliApiServerHarnessOptions {
         self
     }
 
-    pub fn with_frozen_system_time(mut self, value: DateTime<Utc>) -> Self {
+    pub fn with_custom_frozen_system_time(mut self, value: DateTime<Utc>) -> Self {
         self.frozen_system_time = Some(value);
 
         self
     }
 
+    pub fn with_frozen_system_time(self) -> Self {
+        let t = Utc.with_ymd_and_hms(2050, 1, 2, 3, 4, 5).unwrap();
+
+        self.with_custom_frozen_system_time(t)
+    }
+
     pub fn with_today_as_frozen_system_time(self) -> Self {
         let today = {
             let now = Utc::now();
@@ -69,7 +75,7 @@ impl KamuCliApiServerHarnessOptions {
                 .unwrap()
         };
 
-        self.with_frozen_system_time(today)
+        self.with_custom_frozen_system_time(today)
     }
 
     pub fn with_kamu_config(mut self, content: &str) -> Self {