Added publisher_signature to offchain entries (#53)

* feat(store_publisher_signature): Added publisher_signature * feat(store_publisher_signature): Revert compose change 🤡🤡🤡🤡 * feat(store_publisher_signature): Down SQL * feat(store_publisher_signature): publisher_signature can be NULL
astraly-labs · Jun 7, 2024 · 5073e69 · 5073e69
1 parent 14f6182
commit 5073e69
Show file tree

Hide file tree

Showing 5 changed files with 17 additions and 10 deletions.
diff --git a/pragma-entities/migrations/2024-06-07-130038_add_publisher_signature/down.sql b/pragma-entities/migrations/2024-06-07-130038_add_publisher_signature/down.sql
@@ -0,0 +1,3 @@
+-- This file should undo anything in `up.sql`
+ALTER TABLE entries
+DROP COLUMN publisher_signature;
diff --git a/pragma-entities/migrations/2024-06-07-130038_add_publisher_signature/up.sql b/pragma-entities/migrations/2024-06-07-130038_add_publisher_signature/up.sql
@@ -0,0 +1,3 @@
+-- Your SQL goes here
+ALTER TABLE entries
+ADD COLUMN publisher_signature VARCHAR;
diff --git a/pragma-entities/src/models/entry.rs b/pragma-entities/src/models/entry.rs
@@ -20,6 +20,7 @@ pub struct Entry {
     pub publisher: String,
     pub source: String,
     pub timestamp: NaiveDateTime,
+    pub publisher_signature: Option<String>,
     pub price: BigDecimal,
 }
 
@@ -30,6 +31,7 @@ pub struct NewEntry {
     pub publisher: String,
     pub source: String,
     pub timestamp: NaiveDateTime,
+    pub publisher_signature: String,
     pub price: BigDecimal,
 }
 
@@ -51,6 +53,7 @@ impl Entry {
                 entries::pair_id.eq(excluded(entries::pair_id)),
                 entries::publisher.eq(excluded(entries::publisher)),
                 entries::source.eq(excluded(entries::source)),
+                entries::publisher_signature.eq(excluded(entries::publisher_signature)),
                 entries::timestamp.eq(excluded(entries::timestamp)),
                 entries::price.eq(excluded(entries::price)),
             ))

diff --git a/pragma-entities/src/schema.rs b/pragma-entities/src/schema.rs
@@ -19,6 +19,7 @@ diesel::table! {
         timestamp -> Timestamptz,
         price -> Numeric,
         source -> Varchar,
+        publisher_signature -> Nullable<Varchar>,
     }
 }
 

diff --git a/pragma-node/src/handlers/entries/create_entry.rs b/pragma-node/src/handlers/entries/create_entry.rs
@@ -125,16 +125,12 @@ pub async fn create_entries(
     );
 
     let message_hash = build_publish_message(&new_entries.entries)?.message_hash(account_address);
-
-    if !ecdsa_verify(
-        &public_key,
-        &message_hash,
-        &Signature {
-            r: new_entries.signature[0],
-            s: new_entries.signature[1],
-        },
-    )
-    .map_err(EntryError::InvalidSignature)?
+    let signature = Signature {
+        r: new_entries.signature[0],
+        s: new_entries.signature[1],
+    };
+    if !ecdsa_verify(&public_key, &message_hash, &signature)
+        .map_err(EntryError::InvalidSignature)?
     {
         tracing::error!("Invalid signature for message hash {:?}", &message_hash);
         return Err(EntryError::Unauthorized);
@@ -154,6 +150,7 @@ pub async fn create_entries(
                 publisher: entry.base.publisher.clone(),
                 source: entry.base.source.clone(),
                 timestamp: dt,
+                publisher_signature: format!("0x{}", signature),
                 price: entry.price.into(),
             })
         })