From 3639d8d7479fe00b48331610a31174f3a507fe73 Mon Sep 17 00:00:00 2001
From: Louise Poole <louise@datarevenue.com>
Date: Thu, 17 Oct 2024 15:58:26 +0200
Subject: [PATCH] feat(uniswap_v2): encode attribute values with big endian
 encoding

---
 substreams/Cargo.lock                                       | 2 +-
 substreams/ethereum-uniswap-v2/Cargo.toml                   | 2 +-
 substreams/ethereum-uniswap-v2/ethereum-uniswap-v2.yaml     | 2 +-
 .../ethereum-uniswap-v2/src/modules/1_map_pool_created.rs   | 6 +++---
 .../ethereum-uniswap-v2/src/modules/3_map_pool_events.rs    | 2 +-
 5 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/substreams/Cargo.lock b/substreams/Cargo.lock
index b65aee5..318a23e 100644
--- a/substreams/Cargo.lock
+++ b/substreams/Cargo.lock
@@ -1041,7 +1041,7 @@ dependencies = [
 
 [[package]]
 name = "substreams-ethereum-uniswap-v2"
-version = "0.2.1"
+version = "0.3.0"
 dependencies = [
  "anyhow",
  "ethabi 18.0.0",
diff --git a/substreams/ethereum-uniswap-v2/Cargo.toml b/substreams/ethereum-uniswap-v2/Cargo.toml
index 1979ddd..8cebfb1 100644
--- a/substreams/ethereum-uniswap-v2/Cargo.toml
+++ b/substreams/ethereum-uniswap-v2/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "substreams-ethereum-uniswap-v2"
-version = "0.2.1"
+version = "0.3.0"
 edition = "2021"
 
 [lib]
diff --git a/substreams/ethereum-uniswap-v2/ethereum-uniswap-v2.yaml b/substreams/ethereum-uniswap-v2/ethereum-uniswap-v2.yaml
index 3c247a6..4749c6a 100644
--- a/substreams/ethereum-uniswap-v2/ethereum-uniswap-v2.yaml
+++ b/substreams/ethereum-uniswap-v2/ethereum-uniswap-v2.yaml
@@ -1,7 +1,7 @@
 specVersion: v0.1.0
 package:
   name: "ethereum_uniswap_v2"
-  version: v0.2.1
+  version: v0.3.0
 
 protobuf:
   files:
diff --git a/substreams/ethereum-uniswap-v2/src/modules/1_map_pool_created.rs b/substreams/ethereum-uniswap-v2/src/modules/1_map_pool_created.rs
index 236a427..fe11ffe 100644
--- a/substreams/ethereum-uniswap-v2/src/modules/1_map_pool_created.rs
+++ b/substreams/ethereum-uniswap-v2/src/modules/1_map_pool_created.rs
@@ -46,12 +46,12 @@ fn get_pools(block: &eth::Block, new_pools: &mut Vec<TransactionChanges>, params
                 attributes: vec![
                     Attribute {
                         name: "reserve0".to_string(),
-                        value: BigInt::from(0).to_signed_bytes_le(),
+                        value: BigInt::from(0).to_signed_bytes_be(),
                         change: ChangeType::Creation.into(),
                     },
                     Attribute {
                         name: "reserve1".to_string(),
-                        value: BigInt::from(0).to_signed_bytes_le(),
+                        value: BigInt::from(0).to_signed_bytes_be(),
                         change: ChangeType::Creation.into(),
                     },
                 ],
@@ -64,7 +64,7 @@ fn get_pools(block: &eth::Block, new_pools: &mut Vec<TransactionChanges>, params
                     // Trading Fee is hardcoded to 0.3%, saved as int in bps (basis points)
                     Attribute {
                         name: "fee".to_string(),
-                        value: BigInt::from(30).to_signed_bytes_le(),
+                        value: BigInt::from(30).to_signed_bytes_be(),
                         change: ChangeType::Creation.into(),
                     },
                     Attribute {
diff --git a/substreams/ethereum-uniswap-v2/src/modules/3_map_pool_events.rs b/substreams/ethereum-uniswap-v2/src/modules/3_map_pool_events.rs
index 5c428fa..8584913 100644
--- a/substreams/ethereum-uniswap-v2/src/modules/3_map_pool_events.rs
+++ b/substreams/ethereum-uniswap-v2/src/modules/3_map_pool_events.rs
@@ -104,7 +104,7 @@ fn handle_sync(
                     name: attribute_name,
                     value: reserve_bytes
                         .clone()
-                        .to_signed_bytes_le(), //TODO: Unify bytes encoding (either be or le)
+                        .to_signed_bytes_be(),
                     change: ChangeType::Update.into(),
                 },
             );