feat: implemented binary bundling

Author: raphael-goetz

cli/src/command/bundle.rs

@@ -0,0 +1,48 @@
+use std::fs;
+use std::io::Write;
+use prost::Message;
+use code0_definition_reader::parser::Parser;
+
+pub fn bundle(path: Option<String>, out: Option<String>) {
+    let dir_path = path.unwrap_or_else(|| "./definitions".to_string());
+    let out_path = out.unwrap_or_else(|| "./bundles".to_string());
+    match fs::create_dir_all(&out_path) {
+        Ok(_) => {}
+        Err(err) => {
+            panic!("Error creating output directory: {:?}", err);
+        }
+    }
+
+    let parser = match Parser::from_path(dir_path.as_str()) {
+        Some(reader) => reader,
+        None => {
+            panic!("Error reading definitions");
+        }
+    };
+
+    for feature in parser.features {
+        feature.data_types.iter().for_each(|data_type| {
+            let mut buf = Vec::new();
+            if let Ok(_) = data_type.encode(&mut buf) {
+                let path = format!("{}/{}_{}_{}.pb",&out_path,  feature.name, "data_type", data_type.identifier.to_lowercase());
+                fs::File::create(&path).expect("abc").write_all(&buf).expect("a");
+            }
+        });
+
+        feature.flow_types.iter().for_each(|flow_type| {
+            let mut buf = Vec::new();
+            if let Ok(_) = flow_type.encode(&mut buf) {
+                let path = format!("{}/{}_{}_{}.pb",&out_path, feature.name, "flow_type", flow_type.identifier.to_lowercase());
+                fs::File::create(&path).expect("abc").write_all(&buf).expect("a");
+            }
+        });
+
+        feature.runtime_functions.iter().for_each(|function| {
+            let mut buf = Vec::new();
+            if let Ok(_) = function.encode(&mut buf) {
+                let path = format!("{}/{}_{}_{}.pb",&out_path, feature.name, "function", function.runtime_name.to_lowercase());
+                fs::File::create(&path).expect("abc").write_all(&buf).expect("a");
+            }
+        });
+    }
+}

cli/src/command/definition.rs

@@ -1,6 +1,8 @@
 use crate::formatter::{info, success};
 use code0_definition_reader::parser::Parser;
 use colored::Colorize;
+use prost::Message;
+use tucana::shared::DefinitionDataType;
 
 pub fn search_definition(name: String, path: Option<String>) {
     let dir_path = path.unwrap_or_else(|| "./definitions".to_string());

cli/src/command/mod.rs

@@ -3,3 +3,4 @@ pub mod download;
 pub mod feature;
 pub mod report;
 pub mod watch;
+pub mod bundle;

cli/src/main.rs

@@ -53,13 +53,20 @@ enum Commands {
         #[clap(short, long, value_parser, num_args = 1.., value_delimiter = ' ')]
         features: Option<Vec<String>>,
     },
+    Bundle {
+        #[arg(short, long)]
+        path: Option<String>,
+        #[arg(short, long)]
+        out: Option<String>,
+    }
 }
 
 #[tokio::main]
 async fn main() {
     let cli = Cli::parse();
 
     match cli.command {
+        Commands::Bundle {path, out} => command::bundle::bundle(path, out),
         Commands::Report { path } => command::report::report_errors(path),
         Commands::Feature { name, path } => command::feature::search_feature(name, path),
         Commands::Definition { name, path } => command::definition::search_definition(name, path),