chore: updated deno dependence

Cargo.toml

@@ -11,7 +11,6 @@ readme = "README.md"
 authors = ["Santiago Carmuega <[email protected]>"]
 
 [features]
-default = ["deno"]
 deno = ["deno_runtime"]
 sink-file-rotate = ["file-rotate"]
 sink-webhook = ["reqwest"]
@@ -72,7 +71,6 @@ google-cloud-pubsub = { version = "0.16.0", optional = true }
 google-cloud-googleapis = { version = "0.10.0", optional = true }
 google-cloud-default = { version = "0.4.0", optional = true, features = ["pubsub"] }
 r2d2_redis = { version = "0.14.0", optional = true }
-deno_core = { version = "0.208.0", optional = true }
 deno_runtime = { version = "0.126.0", optional = true }
 jsonwebtoken = { version = "8.3.0", optional = true }
 file-rotate = { version = "0.7.5", optional = true }

src/filters/deno/mod.rs

@@ -1,7 +1,6 @@
 //! A mapper with custom logic from using the Deno runtime
 
-use deno_runtime::deno_core;
-use deno_runtime::deno_core::{op, ModuleSpecifier, OpState};
+use deno_runtime::deno_core::{self, op2, ModuleSpecifier, OpState};
 use deno_runtime::permissions::PermissionsContainer;
 use deno_runtime::worker::{MainWorker as DenoWorker, WorkerOptions};
 use gasket::framework::*;
@@ -17,18 +16,18 @@ pub type WrappedRuntime = DenoWorker;
 
 deno_core::extension!(deno_filter, ops = [op_pop_record, op_put_record]);
 
-#[op]
-fn op_pop_record(state: &mut OpState) -> Result<serde_json::Value, deno_core::error::AnyError> {
+#[op2]
+#[serde]
+pub fn op_pop_record(state: &mut OpState) -> Result<serde_json::Value, deno_core::error::AnyError> {
     let r: Record = state.take();
     let j = serde_json::Value::from(r);
-
     Ok(j)
 }
 
-#[op]
-fn op_put_record(
+#[op2]
+pub fn op_put_record(
     state: &mut OpState,
-    value: serde_json::Value,
+    #[serde] value: serde_json::Value,
 ) -> Result<(), deno_core::error::AnyError> {
     match value {
         serde_json::Value::Null => (),