From b8b2baea0177be0d70d871bdca9eac4c5056dcdc Mon Sep 17 00:00:00 2001 From: William Chong Date: Fri, 28 Nov 2025 17:05:23 +0800 Subject: [PATCH] likecollective-indexer: fix invalid number_of_stakers in materialized view --- .../20250923132313_Add book nft delta time bucket.sql | 8 ++++---- .../ent_timescale/schema/booknftdeltatimebucket.sql | 6 +++--- 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/likecollective-indexer/ent_timescale/migrate/migrations/20250923132313_Add book nft delta time bucket.sql b/likecollective-indexer/ent_timescale/migrate/migrations/20250923132313_Add book nft delta time bucket.sql index 322f7ddb..f642c8a5 100644 --- a/likecollective-indexer/ent_timescale/migrate/migrations/20250923132313_Add book nft delta time bucket.sql +++ b/likecollective-indexer/ent_timescale/migrate/migrations/20250923132313_Add book nft delta time bucket.sql @@ -2,13 +2,13 @@ CREATE MATERIALIZED VIEW book_nft_delta_time_bucket_7d WITH (timescaledb.continuous) AS -SELECT +SELECT nft_class_address || '_' || time_bucket(INTERVAL '7 day', datetime) as id, nft_class_address as evm_address, time_bucket(INTERVAL '7 day', datetime) AS bucket, sum(staked_amount_added) as staked_amount, max(datetime) as last_staked_at, - count(distinct nft_class_address) as number_of_stakers + count(distinct account_evm_address) as number_of_stakers FROM staking_events_hyper_table WHERE event_type = 'staked' GROUP BY nft_class_address, bucket; @@ -33,7 +33,7 @@ SELECT time_bucket(INTERVAL '30 day', datetime) AS bucket, sum(staked_amount_added) as staked_amount, max(datetime) as last_staked_at, - count(distinct nft_class_address) as number_of_stakers + count(distinct account_evm_address) as number_of_stakers FROM staking_events_hyper_table WHERE event_type = 'staked' GROUP BY nft_class_address, bucket; @@ -58,7 +58,7 @@ SELECT time_bucket(INTERVAL '1 year', datetime) AS bucket, sum(staked_amount_added) as staked_amount, max(datetime) as last_staked_at, - count(distinct nft_class_address) as number_of_stakers + count(distinct account_evm_address) as number_of_stakers FROM staking_events_hyper_table WHERE event_type = 'staked' GROUP BY nft_class_address, bucket; diff --git a/likecollective-indexer/ent_timescale/schema/booknftdeltatimebucket.sql b/likecollective-indexer/ent_timescale/schema/booknftdeltatimebucket.sql index 322f7ddb..ca2ae546 100644 --- a/likecollective-indexer/ent_timescale/schema/booknftdeltatimebucket.sql +++ b/likecollective-indexer/ent_timescale/schema/booknftdeltatimebucket.sql @@ -8,7 +8,7 @@ SELECT time_bucket(INTERVAL '7 day', datetime) AS bucket, sum(staked_amount_added) as staked_amount, max(datetime) as last_staked_at, - count(distinct nft_class_address) as number_of_stakers + count(distinct account_evm_address) as number_of_stakers FROM staking_events_hyper_table WHERE event_type = 'staked' GROUP BY nft_class_address, bucket; @@ -33,7 +33,7 @@ SELECT time_bucket(INTERVAL '30 day', datetime) AS bucket, sum(staked_amount_added) as staked_amount, max(datetime) as last_staked_at, - count(distinct nft_class_address) as number_of_stakers + count(distinct account_evm_address) as number_of_stakers FROM staking_events_hyper_table WHERE event_type = 'staked' GROUP BY nft_class_address, bucket; @@ -58,7 +58,7 @@ SELECT time_bucket(INTERVAL '1 year', datetime) AS bucket, sum(staked_amount_added) as staked_amount, max(datetime) as last_staked_at, - count(distinct nft_class_address) as number_of_stakers + count(distinct account_evm_address) as number_of_stakers FROM staking_events_hyper_table WHERE event_type = 'staked' GROUP BY nft_class_address, bucket;