feat(sdk): serialize (wip)

Author: michael-0acf4

meta-cli/src/cli/deploy.rs

@@ -5,6 +5,7 @@ use std::path::{Path, PathBuf};
 use std::sync::{Arc, Mutex};
 
 use super::{Action, CommonArgs, GenArgs};
+use crate::com::store::{Command, ServerStore};
 use crate::config::Config;
 use crate::deploy::actors;
 use crate::deploy::actors::console::{Console, ConsoleActor};
@@ -143,6 +144,12 @@ impl Action for DeploySubcommand {
         if !self.options.allow_dirty {
             let repo = git2::Repository::discover(&deploy.config.base_dir).ok();
 
+            // Hint the server what state we are globally in
+            ServerStore::with(
+                Some(Command::Deploy),
+                Some(deploy.config.as_ref().to_owned()),
+            );
+
             if let Some(repo) = repo {
                 let dirty = repo.statuses(None)?.iter().any(|s| {
                     // git2::Status::CURRENT.bits() == 0
@@ -310,6 +317,8 @@ mod watch_mode {
             let secrets =
                 lade_sdk::hydrate(deploy.node.env.clone(), deploy.base_dir.to_path_buf()).await?;
 
+            ServerStore::set_secrets(secrets.clone());
+
             let (loader_event_tx, loader_event_rx) = mpsc::unbounded_channel();
 
             let loader = LoaderActor::new(

meta-cli/src/cli/serialize.rs

@@ -143,8 +143,6 @@ impl Action for Serialize {
 
 impl Serialize {
     async fn write(&self, contents: &str) -> Result<()> {
-        println!("Output {:?}", contents);
-
         if let Some(path) = self.out.as_ref() {
             tokio::fs::OpenOptions::new()
                 .truncate(true)

meta-cli/src/cli/undeploy.rs

@@ -1,7 +1,10 @@
 // Copyright Metatype OÜ, licensed under the Mozilla Public License Version 2.0.
 // SPDX-License-Identifier: MPL-2.0
 
-use crate::config::Config;
+use crate::{
+    com::store::{Command, ServerStore},
+    config::Config,
+};
 use anyhow::Result;
 use async_trait::async_trait;
 use clap::Parser;
@@ -29,8 +32,11 @@ impl Action for Undeploy {
         let config = Config::load_or_find(config_path, &dir)?;
         let node_config = config.node(&self.node, &self.target);
         let node = node_config.build(&dir).await?;
-        node.try_undeploy(&self.typegraphs).await?;
 
+        // Hint the server what state we are globally in
+        ServerStore::with(Some(Command::Undeploy), Some(config.clone()));
+
+        node.try_undeploy(&self.typegraphs).await?;
         Ok(())
     }
 }

meta-cli/src/com/server.rs

@@ -3,10 +3,15 @@
 
 use crate::com::store::ServerStore;
 use actix_web::{get, post, App, HttpResponse, HttpServer, Responder};
+use lazy_static::lazy_static;
 use reqwest::StatusCode;
 use serde::Serialize;
 use serde_json::{json, Value};
 
+lazy_static! {
+    pub static ref SERVER_PORT: u16 = 1234;
+}
+
 #[derive(Serialize)]
 struct ResponseSuccess {
     data: Value,
@@ -21,27 +26,21 @@ struct ResponseError {
 async fn config() -> impl Responder {
     match ServerStore::get_config() {
         Some(config) => {
-            let endpoints = config
-                .typegates
-                .iter()
-                .map(|(k, v)| serde_json::to_value((k, v)).unwrap())
-                .collect::<Vec<_>>();
-
             let data = json!({
-                "endpoints": endpoints,
+                "typegates": config.typegates,
+                "secrets": ServerStore::get_secrets(),
                 "artifactsConfig": json!({
                     "dir": config.base_dir.display().to_string(),
-                    "prismaMigration": json!({
+                    "prismaMigration": {
+                        // TODO:
                         "migrationDir": ".",
-                        "create": true,
-                        "action": json!({
+                        "action": {
+                            // TODO:
                             "create": true,
                             "reset": false,
-                        }),
-                    }),
+                        },
+                    },
                 }),
-                "secrets": json!({}),
-                "cliVersion": ""
             });
 
             HttpResponse::Ok()
@@ -85,7 +84,7 @@ pub async fn spawn_server() -> std::io::Result<()> {
             .service(command)
             .service(response)
     })
-    .bind(("127.0.0.1", 1234))?
+    .bind(("127.0.0.1", SERVER_PORT.to_owned()))?
     .run()
     .await
 }

meta-cli/src/com/store.rs

@@ -6,6 +6,7 @@ use lazy_static::lazy_static;
 use serde::Serialize;
 use std::{
     borrow::{Borrow, BorrowMut},
+    collections::HashMap,
     sync::Mutex,
 };
 
@@ -26,6 +27,7 @@ fn with_store_mut<T, F: FnOnce(&mut ServerStore) -> T>(f: F) -> T {
 
 #[allow(dead_code)]
 #[derive(Clone, Debug, Serialize)]
+#[serde(rename_all = "lowercase")]
 pub enum Command {
     Deploy,
     Undeploy,
@@ -36,6 +38,7 @@ pub enum Command {
 pub struct ServerStore {
     config: Option<Config>,
     command: Option<Command>,
+    secrets: HashMap<String, String>,
 }
 
 #[allow(dead_code)]
@@ -58,4 +61,12 @@ impl ServerStore {
     pub fn get_command() -> Option<Command> {
         with_store(|s| s.command.clone())
     }
+
+    pub fn set_secrets(secrets: HashMap<String, String>) {
+        with_store_mut(|s| s.secrets = secrets)
+    }
+
+    pub fn get_secrets() -> HashMap<String, String> {
+        with_store(|s| s.secrets.clone())
+    }
 }

meta-cli/src/main.rs

@@ -22,7 +22,7 @@ use clap::Parser;
 use cli::upgrade::upgrade_check;
 use cli::Action;
 use cli::Args;
-use com::server::spawn_server;
+use com::server::{spawn_server, SERVER_PORT};
 use futures::try_join;
 use futures::TryFutureExt;
 use log::{error, warn};
@@ -33,7 +33,7 @@ shadow!(build);
 fn main() -> Result<()> {
     setup_panic_hook();
     logger::init();
-    std::env::set_var("META_CLI_SERVER_PORT", "1234");
+    std::env::set_var("META_CLI_SERVER_PORT", SERVER_PORT.to_string());
 
     let _ = actix::System::with_tokio_rt(|| {
         tokio::runtime::Builder::new_multi_thread()