fix: json-sql update from deprecated api

infinyon · May 8, 2024 · 04a6d33 · 04a6d33
1 parent 28777e2
commit 04a6d33
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/crates/json-sql/SmartModule.toml b/crates/json-sql/SmartModule.toml
@@ -1,7 +1,7 @@
 [package]
 name = "json-sql"
 group = "infinyon"
-version = "0.2.1"
+version = "0.2.2"
 apiVersion = "0.1.0"
 description = "JSON to SQL transformation Smartmodule"
 license = "Apache-2.0"

diff --git a/crates/json-sql/src/lib.rs b/crates/json-sql/src/lib.rs
@@ -7,7 +7,8 @@ use once_cell::sync::OnceCell;
 use crate::mapping::Mapping;
 use eyre::ContextCompat;
 use fluvio_smartmodule::{
-    dataplane::smartmodule::SmartModuleExtraParams, smartmodule, Record, RecordData, Result,
+    dataplane::smartmodule::SmartModuleExtraParams, smartmodule, RecordData, Result,
+    SmartModuleRecord,
 };
 
 static MAPPING: OnceCell<Mapping> = OnceCell::new();
@@ -33,7 +34,7 @@ fn init(params: SmartModuleExtraParams) -> Result<()> {
 }
 
 #[smartmodule(map)]
-pub fn map(record: &Record) -> Result<(Option<RecordData>, RecordData)> {
+pub fn map(record: &SmartModuleRecord) -> Result<(Option<RecordData>, RecordData)> {
     let mapping = MAPPING
         .get()
         .wrap_err("json-sql mapping is not initialized")?;