Move core methods into lib

Cargo.toml

@@ -1,16 +1,21 @@
 [package]
 name = "fishy"
 version = "0.1.0"
-authors = [
-  "adz <[email protected]>",
-  "sandreae <[email protected]>",
-]
+authors = ["adz <[email protected]>", "sandreae <[email protected]>"]
 edition = "2021"
 description = "Create, manage and deploy p2panda schemas"
 repository = "https://github.com/p2panda/fishy"
 license = "AGPL-3.0-or-later"
 readme = "README.md"
 
+[[bin]]
+name = "fishy"
+path = "src/main.rs"
+
+[lib]
+name = "fishy"
+path = "src/lib/lib.rs"
+
 [profile.release]
 strip = true
 opt-level = "z"

src/commands/build/mod.rs → src/commands/build.rs

@@ -1,28 +1,19 @@
 // SPDX-License-Identifier: AGPL-3.0-or-later
 
-mod current;
-mod diff;
-mod executor;
-mod previous;
-mod print;
-mod write;
-
 use std::path::PathBuf;
 
 use anyhow::{bail, Context, Result};
 use dialoguer::Confirm;
+use fishy::build::{
+    execute_plan, get_current_schemas, get_diff, get_previous_schemas, write_to_lock_file,
+};
+use fishy::lock_file::LockFile;
+use fishy::schema_file::SchemaFile;
+use fishy::utils::files::absolute_path;
+use fishy::utils::key_pair;
 use p2panda_rs::test_utils::memory_store::MemoryStore;
 
-use crate::commands::build::current::get_current_schemas;
-use crate::commands::build::diff::get_diff;
-use crate::commands::build::executor::execute_plan;
-use crate::commands::build::previous::get_previous_schemas;
-use crate::commands::build::print::print_plan;
-use crate::commands::build::write::write_to_lock_file;
-use crate::lock_file::LockFile;
-use crate::schema_file::SchemaFile;
-use crate::utils::files::absolute_path;
-use crate::utils::key_pair;
+use crate::utils::print::print_plan;
 use crate::utils::terminal::{print_title, print_variable};
 
 /// Automatically creates and signs p2panda data from a key pair and the defined schemas.

src/commands/deploy.rs

@@ -2,18 +2,13 @@
 
 use std::path::PathBuf;
 
-use anyhow::{anyhow, bail, Context, Result};
-use gql_client::Client;
+use anyhow::{bail, Context, Result};
+use fishy::lock_file::LockFile;
+use fishy::Client;
 use indicatif::ProgressBar;
-use p2panda_rs::entry::decode::decode_entry;
-use p2panda_rs::entry::traits::AsEntry;
-use p2panda_rs::entry::{LogId, SeqNum};
-use p2panda_rs::hash::Hash;
-use serde::Deserialize;
 
-use crate::lock_file::LockFile;
-use crate::utils::files::absolute_path;
 use crate::utils::terminal::{print_title, print_variable};
+use fishy::utils::files::absolute_path;
 
 /// Deploy created schemas on a node.
 pub async fn deploy(lock_path: PathBuf, endpoint: &str) -> Result<()> {
@@ -41,61 +36,12 @@ pub async fn deploy(lock_path: PathBuf, endpoint: &str) -> Result<()> {
     let client = Client::new(endpoint);
 
     for commit in commits {
-        let entry = decode_entry(&commit.entry).unwrap();
+        let published = client.publish(commit).await?;
 
-        let query = format!(
-            r#"
-            {{
-                nextArgs(publicKey: "{}", viewId: "{}") {{
-                    logId
-                    seqNum
-                    skiplink
-                    backlink
-                }}
-            }}
-            "#,
-            entry.public_key(),
-            commit.entry_hash,
-        );
-
-        let response = client.query_unwrap::<NextArgsResponse>(&query).await;
-
-        if let Ok(result) = response {
-            let args = result.next_args;
-
-            if entry.log_id() != &args.log_id {
-                bail!("Inconsistency between local commits and node detected");
-            }
-
-            // Check if node already knows about this commit
-            if entry.seq_num() < &args.seq_num {
-                skipped += 1;
-                progress.inc(1);
-
-                // Skip this one
-                continue;
-            }
+        if !published {
+            skipped += 1;
         }
 
-        let query = format!(
-            r#"
-            mutation Publish {{
-                publish(entry: "{}", operation: "{}") {{
-                    logId
-                    seqNum
-                    skiplink
-                    backlink
-                }}
-            }}
-            "#,
-            commit.entry, commit.operation
-        );
-
-        client
-            .query_unwrap::<PublishResponse>(&query)
-            .await
-            .map_err(|err| anyhow!("GraphQL request to node failed: {err}"))?;
-
         progress.inc(1);
     }
 
@@ -113,27 +59,3 @@ pub async fn deploy(lock_path: PathBuf, endpoint: &str) -> Result<()> {
 
     Ok(())
 }
-
-#[derive(Deserialize, Debug)]
-#[serde(rename_all = "camelCase")]
-#[allow(dead_code)]
-struct NextArguments {
-    log_id: LogId,
-    seq_num: SeqNum,
-    skiplink: Option<Hash>,
-    backlink: Option<Hash>,
-}
-
-/// GraphQL response for `nextArgs` query.
-#[derive(Deserialize, Debug)]
-#[serde(rename_all = "camelCase")]
-struct NextArgsResponse {
-    next_args: NextArguments,
-}
-
-#[derive(Deserialize, Debug)]
-#[serde(rename_all = "camelCase")]
-#[allow(dead_code)]
-struct PublishResponse {
-    publish: NextArguments,
-}

src/commands/init.rs

@@ -4,12 +4,12 @@ use std::path::{Path, PathBuf};
 
 use anyhow::{bail, Result};
 use dialoguer::Input;
+use fishy::utils::files::{absolute_path, write_file};
+use fishy::utils::key_pair::write_key_pair;
 use p2panda_rs::identity::KeyPair;
 use p2panda_rs::schema::validate::validate_name;
 
 use crate::constants::{PRIVATE_KEY_FILE_NAME, SCHEMA_FILE_NAME};
-use crate::utils::files::{absolute_path, write_file};
-use crate::utils::key_pair::write_key_pair;
 use crate::utils::terminal::{print_title, print_variable};
 
 /// Initialises all files for a new fishy project in a given folder.

src/commands/build/executor.rs → src/lib/build/executor.rs

@@ -16,8 +16,8 @@ use p2panda_rs::schema::{FieldType as PandaFieldType, Schema, SchemaId};
 use p2panda_rs::test_utils::memory_store::helpers::send_to_store;
 use p2panda_rs::test_utils::memory_store::MemoryStore;
 
-use crate::lock_file::Commit;
 use crate::schema_file::{FieldType, RelationType};
+use crate::lock_file::Commit;
 
 use super::diff::{FieldDiff, FieldTypeDiff, SchemaDiff};
 

src/lib/build/mod.rs

@@ -0,0 +1,14 @@
+// SPDX-License-Identifier: AGPL-3.0-or-later
+
+mod current;
+mod diff;
+mod executor;
+mod previous;
+mod write;
+
+pub use current::get_current_schemas;
+pub use diff::{get_diff, FieldTypeDiff};
+pub use executor::{execute_plan, Plan};
+pub use previous::get_previous_schemas;
+pub use previous::PreviousSchemas;
+pub use write::write_to_lock_file;

src/commands/build/write.rs → src/lib/build/write.rs

@@ -4,8 +4,8 @@ use std::path::PathBuf;
 
 use anyhow::Result;
 
-use crate::lock_file::{Commit, LockFile};
 use crate::utils::files::{self};
+use crate::lock_file::{Commit, LockFile};
 
 /// Write commits to lock file.
 pub fn write_to_lock_file(

src/lib/client.rs

@@ -0,0 +1,99 @@
+// SPDX-License-Identifier: AGPL-3.0-or-later
+
+use anyhow::{anyhow, bail, Result};
+use gql_client::Client as GQLClient;
+use p2panda_rs::entry::decode::decode_entry;
+use p2panda_rs::entry::traits::AsEntry;
+use p2panda_rs::entry::{LogId, SeqNum};
+use p2panda_rs::hash::Hash;
+use serde::Deserialize;
+
+use crate::lock_file::Commit;
+
+#[derive(Deserialize, Debug)]
+#[serde(rename_all = "camelCase")]
+#[allow(dead_code)]
+struct NextArguments {
+    log_id: LogId,
+    seq_num: SeqNum,
+    skiplink: Option<Hash>,
+    backlink: Option<Hash>,
+}
+
+/// GraphQL response for `nextArgs` query.
+#[derive(Deserialize, Debug)]
+#[serde(rename_all = "camelCase")]
+struct NextArgsResponse {
+    next_args: NextArguments,
+}
+
+#[derive(Deserialize, Debug)]
+#[serde(rename_all = "camelCase")]
+#[allow(dead_code)]
+struct PublishResponse {
+    publish: NextArguments,
+}
+
+pub struct Client(GQLClient);
+
+impl Client {
+    pub fn new(endpoint: &str) -> Self {
+        Self(GQLClient::new(endpoint))
+    }
+
+    pub async fn publish(&self, commit: Commit) -> Result<bool> {
+        let entry = decode_entry(&commit.entry).unwrap();
+
+        let query = format!(
+            r#"
+            {{
+                nextArgs(publicKey: "{}", viewId: "{}") {{
+                    logId
+                    seqNum
+                    skiplink
+                    backlink
+                }}
+            }}
+            "#,
+            entry.public_key(),
+            commit.entry_hash,
+        );
+
+        let response = self.0.query_unwrap::<NextArgsResponse>(&query).await;
+
+        if let Ok(result) = response {
+            let args = result.next_args;
+
+            if entry.log_id() != &args.log_id {
+                bail!("Inconsistency between local commits and node detected");
+            }
+
+            // Check if node already knows about this commit
+            if entry.seq_num() < &args.seq_num {
+                // Skip this one
+                return Ok(false);
+            }
+        }
+
+        let query = format!(
+            r#"
+            mutation Publish {{
+                publish(entry: "{}", operation: "{}") {{
+                    logId
+                    seqNum
+                    skiplink
+                    backlink
+                }}
+            }}
+            "#,
+            commit.entry, commit.operation
+        );
+
+        self.0
+            .query_unwrap::<PublishResponse>(&query)
+            .await
+            .map_err(|err| anyhow!("GraphQL request to node failed: {err}"))?;
+
+        return Ok(true);
+    }
+}

src/lib/lib.rs

@@ -0,0 +1,7 @@
+pub mod build;
+mod client;
+pub mod lock_file;
+pub mod schema_file;
+pub mod utils;
+
+pub use client::Client;

src/lib/utils/mod.rs

@@ -0,0 +1,4 @@
+// SPDX-License-Identifier: AGPL-3.0-or-later
+
+pub mod files;
+pub mod key_pair;

src/main.rs

@@ -2,8 +2,6 @@
 
 mod commands;
 mod constants;
-mod lock_file;
-mod schema_file;
 mod utils;
 
 use std::path::PathBuf;

src/utils/mod.rs

@@ -1,5 +1,4 @@
 // SPDX-License-Identifier: AGPL-3.0-or-later
 
-pub mod files;
-pub mod key_pair;
 pub mod terminal;
+pub mod print;

src/commands/build/print.rs → src/utils/print.rs

@@ -12,13 +12,13 @@ use p2panda_rs::schema::{
     FieldName, FieldType as PandaFieldType, SchemaDescription, SchemaId, SchemaName,
 };
 
-use crate::schema_file::{
+use fishy::schema_file::{
     FieldType, RelationId, RelationSchema, RelationType, SchemaField, SchemaFields,
 };
 
-use super::diff::FieldTypeDiff;
-use super::executor::Plan;
-use super::previous::PreviousSchemas;
+use fishy::build::FieldTypeDiff;
+use fishy::build::Plan;
+use fishy::build::PreviousSchemas;
 
 /// Shows the execution plan to the user.
 pub fn print_plan(