feat(uniswap_v2): encode attribute values with big endian encoding

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",

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]

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:

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 {

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(),
                 },
             );