feat(lazer) Add response messages for lazer transactions

Author: bplatak

lazer/Cargo.lock

@@ -88,3 +88,26 @@ message LazerTransaction {
         GovernanceInstruction governance_instruction = 2;
     }
 }
+
+// Response to SignedLazerTransactionResponse from the relayer
+message SignedLazerTransactionResponse {
+    // [required] The ID of a transaction derived as sha256 of the payload.
+    optional bytes transaction_id = 1;
+
+    // [required] Status of the transaction received by the relayer
+    oneof status {
+        // The transaction was accepted by the relayer
+        SignedLazerTransactionAccepted accepted = 2;
+        // The transaction was rejected by the relayer
+        SignedLazerTransactionRejected rejected = 3;
+    }
+
+    // Message containing additional details for accepted transactions
+    message SignedLazerTransactionAccepted {}
+
+    // Message containing details why the transaction was rejected
+    message SignedLazerTransactionRejected {
+        // [required] Human readable error message
+        optional string message = 1;
+    }
+}

lazer/publisher_sdk/proto/pyth_lazer_transaction.proto

@@ -11,8 +11,8 @@ pyth-lazer-protocol = { version = "0.7.2", path = "../../sdk/rust/protocol" }
 anyhow = "1.0.98"
 protobuf = "3.7.2"
 serde-value = "0.7.0"
+ sha2 = "0.10.9"
 humantime = "2.2.0"
-tracing = "0.1.41"
 
 [build-dependencies]
 fs-err = "3.1.0"

lazer/publisher_sdk/rust/Cargo.toml

@@ -1,10 +1,12 @@
 use std::{collections::BTreeMap, time::Duration};
 
-use ::protobuf::MessageField;
+use crate::transaction::SignedLazerTransaction;
+use ::protobuf::{Message, MessageField};
 use anyhow::{bail, ensure, Context};
 use humantime::format_duration;
 use protobuf::dynamic_value::{dynamic_value, DynamicValue};
 use pyth_lazer_protocol::router::TimestampUs;
+use sha2::{Digest, Sha256};
 
 pub mod transaction_envelope {
     pub use crate::protobuf::transaction_envelope::*;
@@ -160,3 +162,23 @@ impl TryFrom<DynamicValue> for serde_value::Value {
         }
     }
 }
+
+impl SignedLazerTransaction {
+    // The id of a SignedLazerTransaction is calculated as sha256 of its entire payload. This is
+    // an unstable ID (sensitive to any proto changes) are should only be used to correlate
+    //  immediate responses sent from the relayer
+    pub fn id(&self) -> anyhow::Result<[u8; 32]> {
+        let mut hasher = Sha256::new();
+        self.write_to_writer(&mut hasher)?;
+        hasher
+            .finalize()
+            .try_into()
+            .context("failed to calculate the sha256 as transaction id")
+    }
+
+    pub fn calculate_id_from_bytes(payload: &Vec<u8>) -> anyhow::Result<[u8; 32]> {
+        Ok(Sha256::digest(payload)
+            .try_into()
+            .context("failed to calculate the sha256 as transaction id")?)
+    }
+}