change sig from &In to In

src/cli/javascript/request_filter.rs

@@ -52,7 +52,7 @@ impl RequestFilter {
     async fn on_request(&self, mut request: reqwest::Request) -> anyhow::Result<Response<Bytes>> {
         let js_request = WorkerRequest::try_from(&request)?;
         let event = Event::Request(js_request);
-        let command = self.worker.call("onRequest", &event).await?;
+        let command = self.worker.call("onRequest", event).await?;
         match command {
             Some(command) => match command {
                 Command::Request(js_request) => {

src/cli/javascript/runtime.rs

@@ -82,14 +82,9 @@ impl Drop for Runtime {
 
 #[async_trait::async_trait]
 impl WorkerIO<Event, Command> for Runtime {
-    async fn call(
-        &self,
-        name: &'async_trait str,
-        event: &'async_trait Event,
-    ) -> anyhow::Result<Option<Command>> {
+    async fn call(&self, name: &'async_trait str, event: Event) -> anyhow::Result<Option<Command>> {
         let script = self.script.clone();
         let name = name.to_string(); // TODO
-        let event = event.clone(); // TODO
         if let Some(runtime) = &self.tokio_runtime {
             runtime
                 .spawn(async move {
@@ -108,11 +103,11 @@ impl WorkerIO<ConstValue, ConstValue> for Runtime {
     async fn call(
         &self,
         name: &'async_trait str,
-        input: &'async_trait ConstValue,
+        input: ConstValue,
     ) -> anyhow::Result<Option<ConstValue>> {
         let script = self.script.clone();
         let name = name.to_string();
-        let value = serde_json::to_string(input)?;
+        let value = serde_json::to_string(&input)?;
         if let Some(runtime) = &self.tokio_runtime {
             runtime
                 .spawn(async move {

src/core/lambda/io.rs

@@ -141,7 +141,7 @@ impl IO {
                     Ok(res.body)
                 }
                 IO::Js { name: method } => {
-                    let value = ctx.value().unwrap_or(&ConstValue::Null);
+                    let value = ctx.value().cloned().unwrap_or(ConstValue::Null);
                     let value = ctx
                         .request_ctx
                         .runtime

src/core/mod.rs

@@ -84,11 +84,7 @@ pub type EntityCache = dyn Cache<Key = u64, Value = ConstValue>;
 #[async_trait::async_trait]
 pub trait WorkerIO<In, Out>: Send + Sync + 'static {
     /// Calls a global JS function
-    async fn call(
-        &self,
-        name: &'async_trait str,
-        input: &'async_trait In,
-    ) -> anyhow::Result<Option<Out>>;
+    async fn call(&self, name: &'async_trait str, input: In) -> anyhow::Result<Option<Out>>;
 }
 
 pub fn is_default<T: Default + Eq>(val: &T) -> bool {

src/core/worker.rs

@@ -4,7 +4,7 @@ pub struct DefaultJsRuntime;
 
 #[async_trait::async_trait]
 impl<A: Send + Sync + 'static, B> WorkerIO<A, B> for DefaultJsRuntime {
-    async fn call(&self, _: &'async_trait str, _: &'async_trait A) -> anyhow::Result<Option<B>> {
+    async fn call(&self, _: &'async_trait str, _: A) -> anyhow::Result<Option<B>> {
         anyhow::bail!("JavaScript runtime is not supported in this build")
     }
 }
@@ -15,13 +15,7 @@ pub struct WorkerResponse(pub Response<String>);
 #[derive(Debug)]
 pub struct WorkerRequest(pub reqwest::Request);
 
-impl Clone for WorkerRequest {
-    fn clone(&self) -> Self {
-        WorkerRequest(self.0.try_clone().unwrap())
-    }
-}
-
-#[derive(Debug, Clone)]
+#[derive(Debug)]
 pub enum Event {
     Request(WorkerRequest),
 }