fix: propper field names

Author: raphael-goetz

src/implementation/http.rs

@@ -56,10 +56,10 @@ fn respond(values: &[Value], _ctx: &mut Context) -> Signal {
         ));
     };
 
-    let Some(Kind::StringValue(_status_code_str)) = &status_code_val.kind else {
+    let Some(Kind::NumberValue(_status_code_str)) = &status_code_val.kind else {
         return Signal::Failure(RuntimeError::simple(
             "InvalidArgumentRuntimeError",
-            "Expected 'status_code' to be StringValue".to_string(),
+            "Expected 'status_code' to be NumberValue".to_string(),
         ));
     };
 
@@ -162,7 +162,7 @@ fn create_response(values: &[Value], _ctx: &mut Context) -> Signal {
             kind: Some(Kind::StructValue(headers.clone())),
         },
     );
-    fields.insert("body".to_string(), payload.clone());
+    fields.insert("payload".to_string(), payload.clone());
 
     Signal::Success(Value {
         kind: Some(Kind::StructValue(Struct { fields })),

src/main.rs

@@ -33,6 +33,10 @@ fn handle_message(flow: ExecutionFlow, store: &FunctionStore) -> Option<Value> {
     match executor.execute(flow.starting_node_id) {
         Signal::Success(v) => Some(v.clone()),
         Signal::Respond(v) => Some(v.clone()),
+        Signal::Failure(error ) => {
+            log::error!("{:?}", error);
+            None
+        }
         _ => None,
     }
 }
@@ -92,9 +96,18 @@ async fn main() {
                     }
                 };
 
-                let value = handle_message(flow, &store).unwrap_or_else(|| Value {
-                    kind: Some(Kind::NullValue(0)),
-                });
+                let value = match handle_message(flow, &store) {
+                    None => {
+                        log::error!("Failed to handle message");
+                        Value {
+                            kind: Some(Kind::NullValue(0)),
+                        }
+                    }
+                    Some(v) => {
+                        log::info!("Handled message successfully");
+                        v
+                    }
+                };
 
                 // Send a response to the reply subject
                 if let Some(reply) = msg.reply {