fix: sql types

Author: EvolveArt

pragma-entities/migrations/2023-10-25-134954_add_currencies_table/up.sql

@@ -7,3 +7,17 @@ CREATE TABLE currencies (
     ethereum_address VARCHAR,
     PRIMARY KEY (id)
 );
+
+-- initialize
+INSERT INTO public.currencies (name, decimals, abstract, ethereum_address) VALUES
+('BTC', 8, true, NULL),
+('ETH', 18, false, NULL),
+('USD', 8, true, NULL),
+('EUR', 8, true, NULL),
+('WBTC', 8, false, '0x2260FAC5E5542A773AA44FBCFEDF7C193BC2C599'),
+('USDC', 6, false, '0xA0B86991C6218B36C1D19D4A2E9EB0CE3606EB48'),
+('USDT', 6, false, '0xDAC17F958D2EE523A2206206994597C13D831EC7'),
+('DAI', 18, false, '0x6B175474E89094C44DA98B954EEDEAC495271D0F'),
+('LORDS', 18, false, '0x686F2404E77AB0D9070A46CDFB0B7FECDD2318B0'),
+('R', 18, false, '0x183015A9BA6FF60230FDEADC3F43B3D788B13E21'),
+('WSTETH', 18, false, '0x7F39C581F595B53C5CB19BD0B3F8DA6C935E2CA0');

pragma-entities/migrations/2024-01-11-123510_add_continuous_aggregates/up.sql

@@ -4,7 +4,7 @@ WITH (timescaledb.continuous, timescaledb.materialized_only = true)
 AS SELECT 
     pair_id,
     time_bucket('1 min'::interval, timestamp) as bucket,
-    approx_percentile(0.5, percentile_agg(price)) AS median_price,
+    approx_percentile(0.5, percentile_agg(price))::numeric AS median_price,
     COUNT(DISTINCT source) as num_sources
 FROM entries
 GROUP BY bucket, pair_id
@@ -20,7 +20,7 @@ WITH (timescaledb.continuous, timescaledb.materialized_only = true)
 AS SELECT 
     pair_id,
     time_bucket('15 min'::interval, timestamp) as bucket,
-    approx_percentile(0.5, percentile_agg(price)) AS median_price,
+    approx_percentile(0.5, percentile_agg(price))::numeric AS median_price,
     COUNT(DISTINCT source) as num_sources
 FROM entries
 GROUP BY bucket, pair_id
@@ -36,7 +36,7 @@ WITH (timescaledb.continuous, timescaledb.materialized_only = true)
 AS SELECT 
     pair_id,
     time_bucket('1 hour'::interval, timestamp) as bucket,
-    approx_percentile(0.5, percentile_agg(price)) AS median_price,
+    approx_percentile(0.5, percentile_agg(price))::numeric AS median_price,
     COUNT(DISTINCT source) as num_sources
 FROM entries
 GROUP BY bucket, pair_id

pragma-entities/src/schema.rs

@@ -33,8 +33,4 @@ diesel::table! {
     }
 }
 
-diesel::allow_tables_to_appear_in_same_query!(
-    currencies,
-    entries,
-    publishers,
-);
+diesel::allow_tables_to_appear_in_same_query!(currencies, entries, publishers,);

pragma-node/src/infra/repositories/entry_repository.rs

@@ -66,17 +66,17 @@ pub async fn _get_all(
 pub struct MedianEntry {
     pub time: NaiveDateTime,
     pub median_price: BigDecimal,
-    pub num_sources: i32,
+    pub num_sources: i64,
 }
 
-#[derive(Serialize, QueryableByName)]
+#[derive(Serialize, QueryableByName, Clone, Debug)]
 pub struct MedianEntryRaw {
-    #[diesel(sql_type = diesel::sql_types::Timestamp)]
+    #[diesel(sql_type = diesel::sql_types::Timestamptz)]
     pub time: NaiveDateTime,
     #[diesel(sql_type = diesel::sql_types::Numeric)]
     pub median_price: BigDecimal,
-    #[diesel(sql_type = diesel::sql_types::Integer)]
-    pub num_sources: i32,
+    #[diesel(sql_type = diesel::sql_types::BigInt)]
+    pub num_sources: i64,
 }
 
 pub async fn get_median_price(