perf: perfomance comparison with cbor and bson (#8)

* wip: perfom comparison with cbor and bson

* lint

Author: HideBa

src/rust/Cargo.toml

@@ -44,4 +44,8 @@ serde-wasm-bindgen = "0.6.5"
 console_error_panic_hook = "0.1.7"
 console_log = "0.2"
 
+#---Performance evaluation---
+bson = "2.13.0"
+serde_cbor = "0.10"
+
 [dependencies]

src/rust/cli/Cargo.toml

@@ -10,4 +10,6 @@ clap = { workspace = true }
 anyhow = { workspace = true }
 serde = { workspace = true }
 serde_json = { workspace = true }
+bson = { workspace = true }
+serde_cbor = { workspace = true }
 thiserror = { workspace = true }

src/rust/cli/src/main.rs

@@ -1,4 +1,4 @@
-use cjseq::{CityJSONFeature, Transform as CjTransform};
+use cjseq::{CityJSON, CityJSONFeature, Transform as CjTransform};
 use clap::{Parser, Subcommand};
 use fcb_core::error::Error;
 use fcb_core::{
@@ -12,7 +12,6 @@ use std::{
     io::{self, BufReader, BufWriter, Read, Write},
     path::PathBuf,
 };
-
 #[derive(Parser)]
 #[command(author, version, about = "CLI tool for CityJSON <-> FCB conversion")]
 struct Cli {
@@ -56,6 +55,26 @@ enum Commands {
         output: String,
     },
 
+    /// Convert CityJSON to CBOR
+    Cbor {
+        /// Input file (use '-' for stdin)
+        #[arg(short, long)]
+        input: String,
+        /// Output file (use '-' for stdout)
+        #[arg(short, long)]
+        output: String,
+    },
+
+    /// Convert CityJSON to BSON
+    Bson {
+        /// Input file (use '-' for stdin)
+        #[arg(short, long)]
+        input: String,
+        /// Output file (use '-' for stdout)
+        #[arg(short, long)]
+        output: String,
+    },
+
     /// Show info about FCB file
     Info {
         /// Input FCB file
@@ -323,6 +342,55 @@ fn deserialize(input: &str, output: &str) -> Result<(), Error> {
     Ok(())
 }
 
+fn encode_cbor(input: &str, output: &str) -> Result<(), Error> {
+    let reader = BufReader::new(get_reader(input)?);
+    let writer = BufWriter::new(get_writer(output)?);
+
+    let value: serde_json::Value = serde_json::from_reader(reader)?;
+    serde_cbor::to_writer(writer, &value).map_err(|e| {
+        Error::IoError(std::io::Error::new(
+            std::io::ErrorKind::Other,
+            format!("failed to encode to cbor: {}", e),
+        ))
+    })?;
+
+    if output != "-" {
+        eprintln!("successfully encoded to cbor");
+    }
+    Ok(())
+}
+
+fn encode_bson(input: &str, output: &str) -> Result<(), Error> {
+    let mut reader = BufReader::new(get_reader(input)?);
+    let json_str = {
+        let mut s = String::new();
+        reader.read_to_string(&mut s)?;
+        s
+    };
+
+    let cityjson: CityJSON = serde_json::from_str(&json_str)?;
+    let bson = bson::to_bson(&cityjson).map_err(|e| {
+        Error::IoError(std::io::Error::new(
+            std::io::ErrorKind::Other,
+            format!("failed to encode to bson: {}", e),
+        ))
+    })?;
+    let doc = bson.as_document().unwrap();
+
+    let mut writer = get_writer(output)?;
+    doc.to_writer(&mut writer).map_err(|e| {
+        Error::IoError(std::io::Error::new(
+            std::io::ErrorKind::Other,
+            format!("failed to encode to bson: {}", e),
+        ))
+    })?;
+
+    if output != "-" {
+        eprintln!("successfully encoded to bson");
+    }
+    Ok(())
+}
+
 fn show_info(input: PathBuf) -> Result<(), Error> {
     let reader = BufReader::new(File::open(input)?);
     let metadata = reader.get_ref().metadata()?.len() / 1024 / 1024; // show in megabytes
@@ -386,6 +454,8 @@ fn main() -> Result<(), Error> {
             ge,
         } => serialize(&input, &output, attr_index, bbox, ge),
         Commands::Deser { input, output } => deserialize(&input, &output),
+        Commands::Cbor { input, output } => encode_cbor(&input, &output),
+        Commands::Bson { input, output } => encode_bson(&input, &output),
         Commands::Info { input } => show_info(input),
     }
 }

src/rust/fcb_core/Cargo.toml

@@ -61,6 +61,14 @@ path = "src/lib.rs"
 name = "read"
 path = "src/bin/read.rs"
 
+[[bin]]
+name = "read_profile"
+path = "benches/read_profile.rs"
+
+[[bin]]
+name = "read_benches"
+path = "benches/read_profile.rs"
+
 
 [[bin]]
 name = "read_cj"
@@ -80,3 +88,5 @@ memory-stats = { workspace = true }
 pretty_assertions = { workspace = true }
 criterion = { workspace = true, features = ["async_tokio", "html_reports"] }
 tokio = { workspace = true, features = ["macros", "rt-multi-thread"] }
+bson = { workspace = true }
+serde_cbor = { workspace = true }