feat(engine): update MVT handling and add error types

engine/Cargo.toml

@@ -78,6 +78,7 @@ async-stream = "0.3.6"
 async-trait = "0.1.83"
 async_zip = { version = "0.0.17", features = ["full"] }
 base64 = "0.22.1"
+bincode = { version = "2.0.0-rc.3", default-features = false, features = ["serde", "std"] }
 byteorder = "1.5.0"
 bytes = { version = "1.7.2", features = ["serde"] }
 chrono = { version = "0.4.38", features = ["serde"] }

engine/runtime/action-sink/Cargo.toml

@@ -20,6 +20,7 @@ reearth-flow-state.workspace = true
 reearth-flow-storage.workspace = true
 reearth-flow-types.workspace = true
 
+kv-extsort = { git = "https://github.com/MIERUNE/kv-extsort-rs.git" }
 nusamai-citygml.workspace = true
 nusamai-geometry.workspace = true
 nusamai-gltf.workspace = true
@@ -29,6 +30,7 @@ nusamai-projection.workspace = true
 
 ahash.workspace = true
 async-trait.workspace = true
+bincode.workspace = true
 byteorder.workspace = true
 bytes.workspace = true
 cesiumtiles.workspace = true

engine/runtime/action-sink/src/errors.rs

@@ -14,10 +14,14 @@ pub enum SinkError {
     GeoJsonWriterFactory(String),
     #[error("GeoJson Writer error: {0}")]
     GeoJsonWriter(String),
+    #[error("Mvt Writer error: {0}")]
+    MvtWriter(String),
 }
 
 impl SinkError {
     pub fn file_writer<T: ToString>(message: T) -> Self {
         Self::FileWriter(message.to_string())
     }
 }
+
+pub type Result<T, E = SinkError> = std::result::Result<T, E>;

engine/runtime/action-sink/src/file.rs

@@ -5,5 +5,4 @@ mod gltf;
 pub(crate) mod mvt;
 pub(super) mod types;
 mod util;
-mod vector_tile;
 pub(crate) mod writer;