refactor: break up the common crate into smaller ones

Cargo.toml

@@ -1,15 +1,18 @@
 [workspace]
 resolver = "2"
 members = [
-  "src/common",
   "src/meta-cli",
   "src/metagen",
   "src/metagen/src/fdk_rs/static",
   "src/mt_deno",
   "src/typegate/engine",
   "src/typegate/standalone",
+  "src/typegate_api",
   "src/typegraph/core",
+  "src/typegraph/schema",
   "src/xtask",
+  "src/utils/grpc",
+  "src/utils/archive",
   "src/substantial",
   "src/metagen-client-rs",
   "tests/metagen/typegraphs/sample/rs",
@@ -31,12 +34,15 @@ edition = "2021"
 
 # internal crates
 mt_deno = { path = "src/mt_deno/" }
-common = { path = "src/common/" }
+tg_schema = { path = "src/typegraph/schema" }
+typegraph_core = { path = "src/typegraph/core" }
 substantial = { path = "src/substantial/" }
 metagen = { path = "src/metagen/" }
 metagen-client = { path = "src/metagen-client-rs" }
 typegate_engine = { path = "src/typegate/engine" }
-typegraph_core = { path = "src/typegraph/core" }
+typegate_api = { path = "src/typegate_api" }
+grpc_utils = { path = "src/utils/grpc" }
+archive_utils = { path = "src/utils/archive" }
 
 # cli
 clap = "=4.5.13"

src/meta-cli/Cargo.toml

@@ -32,9 +32,11 @@ typegate = ["dep:typegate_engine"]
 
 # internal
 typegraph_core.workspace = true
+tg_schema.workspace = true
 typegate_engine = { workspace = true, optional = true }
-common.workspace = true
+typegate_api.workspace = true
 metagen.workspace = true
+archive_utils.workspace = true
 
 # data structures
 chrono = { workspace = true, features = ["serde"] }

src/meta-cli/src/cli/deploy.rs

@@ -10,7 +10,7 @@ use crate::deploy::actors::console::ConsoleActor;
 use crate::interlude::*;
 use crate::secrets::{RawSecrets, Secrets};
 use clap::Parser;
-use common::node::Node;
+use typegate_api::Node;
 
 #[derive(Parser, Debug)]
 pub struct DeploySubcommand {

src/meta-cli/src/cli/gen.rs

@@ -12,10 +12,10 @@ use crate::interlude::*;
 use crate::{config::Config, deploy::actors::console::ConsoleActor};
 use actix::Actor;
 use clap::Parser;
-use common::typegraph::Typegraph;
 use dashmap::DashMap;
 use futures_concurrency::future::FutureGroup;
 use metagen::*;
+use tg_schema::Typegraph;
 
 #[derive(Parser, Debug, Clone)]
 pub struct Gen {
@@ -105,7 +105,7 @@ impl Action for Gen {
 #[derive(Debug)]
 struct MetagenCtx {
     config: Arc<Config>,
-    typegate: Arc<common::node::Node>,
+    typegate: Arc<typegate_api::Node>,
     dir: PathBuf,
     typegraph_cache: DashMap<String, Arc<Typegraph>>,
 }

src/meta-cli/src/cli/list.rs

@@ -11,10 +11,9 @@ use crate::interlude::*;
 use anyhow::Result;
 use async_trait::async_trait;
 use clap::Parser;
-use common::graphql::Query;
-use common::node::Node;
 use serde::Deserialize;
 use tabled::{settings::Style, Table, Tabled};
+use typegate_api::{graphql::Query, Node};
 
 #[derive(Parser, Debug)]
 pub struct List {

src/meta-cli/src/cli/serialize.rs

@@ -9,9 +9,9 @@ use crate::deploy::actors::task::TaskFinishStatus;
 use crate::deploy::actors::task_manager::{Report, StopReason, TaskManagerInit, TaskSource};
 use crate::interlude::*;
 use clap::Parser;
-use common::typegraph::Typegraph;
 use core::fmt::Debug;
 use std::io::{self, Write};
+use tg_schema::Typegraph;
 use tokio::io::AsyncWriteExt;
 
 #[derive(Parser, Debug)]

src/meta-cli/src/config.rs

@@ -6,13 +6,13 @@ use crate::interlude::*;
 use crate::cli::NodeArgs;
 use crate::fs::find_in_parents;
 use crate::utils::BasicAuth;
-use common::node::Node;
 use globset::{Glob, GlobSet, GlobSetBuilder};
 use reqwest::Url;
 use std::fs::{self, File};
 use std::io;
 use std::slice;
 use std::str::FromStr;
+use typegate_api::Node;
 
 pub const METATYPE_FILES: &[&str] = &["metatype.yml", "metatype.yaml"];
 pub const VENV_FOLDERS: &[&str] = &[".venv"];

src/meta-cli/src/deploy/actors/task.rs

@@ -27,11 +27,11 @@ use crate::deploy::actors::task_io::TaskIoActor;
 use crate::interlude::*;
 use action::{get_typegraph_name, TaskActionGenerator};
 use colored::OwoColorize;
-use common::typegraph::Typegraph;
 use indexmap::IndexMap;
 use process_wrap::tokio::TokioChildWrapper;
 use serde::Deserialize;
 use std::time::Duration;
+use tg_schema::Typegraph;
 use tokio::process::Command;
 
 pub mod message {

src/meta-cli/src/deploy/actors/task/deploy.rs

@@ -17,12 +17,12 @@ use crate::typegraph::rpc::{RpcCall as TypegraphRpcCall, RpcDispatch};
 use artifacts::ArtifactUploader;
 use base64::prelude::*;
 use color_eyre::owo_colors::OwoColorize;
-use common::node::Node;
 use reqwest::header::{self, HeaderMap, HeaderValue};
 use reqwest::Client;
 use serde::Deserialize;
 use std::{path::Path, sync::Arc};
 use tokio::process::Command;
+use typegate_api::Node;
 use typegraph_core::sdk::core::{Artifact, Handler as _, PrismaMigrationConfig, SerializeParams};
 use typegraph_core::sdk::utils::{Handler as _, QueryDeployParams};
 use typegraph_core::Lib;

src/meta-cli/src/deploy/actors/task/deploy/migrations.rs

@@ -64,7 +64,7 @@ impl DeployActionInner {
 
         for migration in migrations.iter() {
             let dest = migdir.join(&migration.runtime);
-            if let Err(err) = common::archive::unpack(&dest, Some(&migration.archive)) {
+            if let Err(err) = archive_utils::unpack(&dest, Some(&migration.archive)) {
                 ctx.console.error(format!(
                     "{scope} error while unpacking migrations into {:?}",
                     migdir

src/meta-cli/src/deploy/actors/task/serialize.rs

@@ -12,9 +12,9 @@ use crate::deploy::actors::task_manager::TaskRef;
 use crate::interlude::*;
 use crate::typegraph::rpc::{RpcCall as TypegraphRpcCall, RpcDispatch};
 use color_eyre::owo_colors::OwoColorize;
-use common::typegraph::Typegraph;
 use serde::Deserialize;
 use std::sync::Arc;
+use tg_schema::Typegraph;
 use tokio::process::Command;
 use typegraph_core::sdk::core::{Handler, SerializeParams};
 use typegraph_core::Lib;

src/meta-cli/src/typegraph/rpc/mod.rs

@@ -20,8 +20,8 @@ pub trait RpcDispatch {
 #[enum_dispatch(RpcDispatch)]
 #[serde(untagged)]
 pub enum RpcCall {
-    Aws(aws::RpcCall),
+    Utils(utils::RpcCall),
     Core(core::RpcCall),
+    Aws(aws::RpcCall),
     Runtimes(runtimes::RpcCall),
-    Utils(utils::RpcCall),
 }