feat: watch register behalf (#41)

justfile

@@ -66,7 +66,7 @@ fmt:
 
   if command -v cargo-fmt >/dev/null; then
     echo '==> Running rustfmt'
-    cargo +nightly fmt --all -- --check
+    cargo +nightly fmt --all
   else
     echo '==> rustfmt not found in PATH, skipping'
     echo '    ^^^^^^ To install `rustup component add rustfmt`, see https://github.com/rust-lang/rustfmt for details'

relay_client/src/http.rs

@@ -36,8 +36,8 @@ pub enum HttpClientError {
     #[error("Invalid response")]
     InvalidResponse,
 
-    #[error("Invalid HTTP status: {0}")]
-    InvalidHttpCode(StatusCode),
+    #[error("Invalid HTTP status: {0}, body: {1:?}")]
+    InvalidHttpCode(StatusCode, reqwest::Result<String>),
 
     #[error("JWT error: {0}")]
     Jwt(#[from] JwtError),
@@ -187,6 +187,14 @@ impl Client {
         self.request(payload).await
     }
 
+    /// Registers a webhook to watch messages on behalf of another client.
+    pub async fn watch_register_behalf(
+        &self,
+        register_auth: String,
+    ) -> Response<rpc::WatchRegister> {
+        self.request(rpc::WatchRegister { register_auth }).await
+    }
+
     /// Unregisters a webhook to watch messages.
     pub async fn watch_unregister(
         &self,
@@ -280,7 +288,8 @@ impl Client {
         let status = result.status();
 
         if !status.is_success() {
-            return Err(HttpClientError::InvalidHttpCode(status).into());
+            let body = result.text().await;
+            return Err(HttpClientError::InvalidHttpCode(status, body).into());
         }
 
         let response = result

relay_rpc/src/rpc/msg_id.rs

@@ -9,18 +9,17 @@ pub trait MsgId {
 
 impl MsgId for rpc::Publish {
     fn msg_id(&self) -> String {
-        let msg_id = Sha256::new()
-            .chain_update(self.message.as_ref().as_bytes())
-            .finalize();
-        format!("{msg_id:x}")
+        get_message_id(&self.message)
     }
 }
 
 impl MsgId for rpc::Subscription {
     fn msg_id(&self) -> String {
-        let msg_id = Sha256::new()
-            .chain_update(self.data.message.as_ref().as_bytes())
-            .finalize();
-        format!("{msg_id:x}")
+        get_message_id(&self.data.message)
     }
 }
+
+pub fn get_message_id(message: &str) -> String {
+    let msg_id = Sha256::new().chain_update(message.as_bytes()).finalize();
+    format!("{msg_id:x}")
+}