CLI (#145)

.gitignore

@@ -2,6 +2,6 @@ target
 .vscode
 _data
 guest_local_storage
-crates/flow-server/local_storage/*
+local_storage
 config.toml
 .env

Cargo.toml

@@ -1,6 +1,6 @@
 [workspace]
 members = ["lib/*", "crates/*"]
-exclude = ["crates/space-wasm/tests"]
+exclude = ["crates/space-wasm/tests", "lib/space-operator-cli"]
 resolver = "2"
 
 [patch.crates-io]
@@ -44,3 +44,4 @@ serde = { version = "1", features = ["derive"] }
 serde_json = { version = "1", features = ["preserve_order"] }
 anyhow = "1"
 bs58 = "0.4"
+postgrest = { package = "spo-postgrest", version = "1.6.0" }

crates/cmds-std/Cargo.toml

@@ -23,7 +23,7 @@ rust_decimal = { version = "1.32.0", features = ["serde-with-float"] }
 tracing = "0.1.40"
 bytes = "1.5.0"
 mime_guess = "2.0.4"
-postgrest = { git = "https://github.com/space-operator/postgrest-rs", branch = "dev" }
+postgrest = { workspace = true }
 tokio = "1.33.0"
 once_cell = "1.17"
 url = { version = "2.5.0", features = ["serde"] }

crates/command-rpc/src/server.rs

@@ -27,13 +27,12 @@ pub enum Error {
 pub type WsStream =
     tokio_tungstenite::WebSocketStream<tokio_tungstenite::MaybeTlsStream<tokio::net::TcpStream>>;
 
+#[allow(dead_code)]
 pub struct CommandHost {
     natives: BTreeMap<Cow<'static, str>, CommandDescription>,
     stream: WsStream,
 }
 
-async fn send() {}
-
 impl CommandHost {
     pub async fn connect(url: &str) -> Result<Self, Error> {
         let (stream, _) = tokio_tungstenite::connect_async(url).await?;

crates/pdg-common/src/nft_metadata/generate.rs

@@ -480,10 +480,7 @@ impl RenderParams {
 
 #[cfg(test)]
 mod tests {
-    use std::{
-        collections::{HashMap, HashSet},
-        vec,
-    };
+    use std::collections::{HashMap, HashSet};
 
     use serde_json::json;
     use strum::IntoEnumIterator;

lib/client/src/types.rs

@@ -11,14 +11,12 @@ use std::collections::HashMap;
 
 #[derive(Serialize, Deserialize, Debug)]
 #[serde(untagged)]
-
 pub enum RestResult<T> {
     Error(ErrorBody),
     Success(T),
 }
 
 #[derive(Debug)]
-
 pub struct True;
 
 impl Serialize for True {

lib/flow-lib/src/command/builder.rs

@@ -226,7 +226,7 @@ impl CmdBuilder {
                     optional: x.optional,
                 })
                 .collect(),
-            instruction_info: None,
+            instruction_info: self.def.data.instruction_info,
             permissions: self.def.permissions,
         };
 

lib/flow-lib/src/command/mod.rs

@@ -29,14 +29,17 @@ pub mod prelude {
         },
         config::{client::NodeData, node::Permissions},
         context::Context,
+        solana::Instructions,
         CmdInputDescription as Input, CmdOutputDescription as Output, FlowId, Name, ValueSet,
         ValueType,
     };
     pub use async_trait::async_trait;
+    pub use bytes::Bytes;
     pub use serde::{Deserialize, Serialize};
     pub use serde_json::Value as JsonValue;
+    pub use solana_sdk::{pubkey::Pubkey, signature::Signature, signer::keypair::Keypair};
     pub use thiserror::Error as ThisError;
-    pub use value::{self, Value};
+    pub use value::{self, Decimal, Value};
 }
 
 /// Error type of commmands.

lib/flow-lib/src/config/node.rs

@@ -1,4 +1,5 @@
 //! Note: only add fields that are needed in backend.
+use crate::command::InstructionInfo;
 use serde::{Deserialize, Serialize};
 
 #[derive(Deserialize, Serialize, Debug, Clone)]
@@ -20,6 +21,7 @@ pub struct Permissions {
 #[derive(Deserialize, Serialize, Debug, Clone)]
 pub struct Data {
     pub node_id: String,
+    pub instruction_info: Option<InstructionInfo>,
 }
 
 #[derive(Deserialize, Serialize, Debug, Clone)]