Node: Deserialize the receipt

jstz_node/Cargo.toml

@@ -10,9 +10,11 @@ repository.workspace = true
 [dependencies]
 actix-web = "4.4.0"
 anyhow = "1.0.75"
+bincode = "1.3.3"
 clap = { version = "^4.0", features = ["derive"] }
 env_logger = "0.10.0"
 hex = "0.4.3"
+jstz_proto.workspace = true
 reqwest = { version = "0.11.22", features = ["json"] }
 serde = { version = "1.0.183", features = ["derive"] }
 thiserror = "1.0.50"

jstz_node/src/services/operations.rs

@@ -3,6 +3,8 @@ use actix_web::{
     web::{Data, Path, ServiceConfig},
     HttpResponse, Responder, Scope,
 };
+use anyhow::anyhow;
+use jstz_proto::receipt::Receipt;
 
 use crate::{rollup::RollupClient, Result};
 
@@ -15,7 +17,13 @@ async fn receipt(
 
     let value = rollup_client.get_value(&key).await?;
 
-    Ok(HttpResponse::Ok().json(value))
+    let receipt = match value {
+        Some(value) => bincode::deserialize::<Receipt>(&value)
+            .map_err(|_| anyhow!("Failed to deserialize receipt"))?,
+        None => return Ok(HttpResponse::NotFound().finish()),
+    };
+
+    Ok(HttpResponse::Ok().json(receipt))
 }
 
 pub struct OperationsService;

jstz_proto/src/error.rs

@@ -1,6 +1,5 @@
 use boa_engine::{JsError, JsNativeError};
 use derive_more::{Display, Error, From};
-use serde::Serialize;
 
 #[derive(Display, Debug, Error, From)]
 pub enum Error {
@@ -13,15 +12,6 @@ pub enum Error {
 }
 pub type Result<T> = std::result::Result<T, Error>;
 
-impl Serialize for Error {
-    fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
-    where
-        S: serde::Serializer,
-    {
-        serializer.serialize_str(&format!("{}", self))
-    }
-}
-
 impl From<Error> for JsError {
     fn from(value: Error) -> Self {
         match value {

jstz_proto/src/receipt.rs

@@ -1,17 +1,20 @@
 use http::{HeaderMap, StatusCode};
 use jstz_api::http::body::HttpBody;
-use serde::Serialize;
+use serde::{Deserialize, Serialize};
 
 use crate::{context::account::Address, operation::OperationHash, Result};
 
-#[derive(Debug, Serialize)]
+pub type ReceiptResult<T> = std::result::Result<T, String>;
+
+#[derive(Debug, Serialize, Deserialize)]
 pub struct Receipt {
     hash: OperationHash,
-    pub inner: Result<Content>,
+    pub inner: ReceiptResult<Content>,
 }
 
 impl Receipt {
     pub fn new(hash: OperationHash, inner: Result<Content>) -> Self {
+        let inner = inner.map_err(|e| e.to_string());
         Self { hash, inner }
     }
 
@@ -20,18 +23,12 @@ impl Receipt {
     }
 }
 
-impl AsRef<Result<Content>> for Receipt {
-    fn as_ref(&self) -> &Result<Content> {
-        &self.inner
-    }
-}
-
-#[derive(Debug, Serialize)]
+#[derive(Debug, Serialize, Deserialize)]
 pub struct DeployContract {
     pub contract_address: Address,
 }
 
-#[derive(Debug, Serialize)]
+#[derive(Debug, Serialize, Deserialize)]
 pub struct RunContract {
     pub body: HttpBody,
     #[serde(with = "http_serde::status_code")]
@@ -40,7 +37,7 @@ pub struct RunContract {
     pub headers: HeaderMap,
 }
 
-#[derive(Debug, Serialize)]
+#[derive(Debug, Serialize, Deserialize)]
 pub enum Content {
     DeployContract(DeployContract),
     RunContract(RunContract),