-
Notifications
You must be signed in to change notification settings - Fork 22
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #11237 from vegaprotocol/fix/distinct-game-id
Ensure we dedup the game IDs
- Loading branch information
Showing
3 changed files
with
162 additions
and
6 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
154 changes: 154 additions & 0 deletions
154
datanode/sqlstore/migrations/0107_ensure_distinct_game_id.sql
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,154 @@ | ||
| -- +goose Up | ||
|
|
||
| drop materialized view if exists game_stats; | ||
| drop materialized view if exists game_stats_current; | ||
| drop view if exists game_individual_rankings; | ||
|
|
||
| create view game_individual_rankings as | ||
| with individual_games as ( | ||
| -- get the games where the entity scope is individuals | ||
| select distinct game_id | ||
| from transfers | ||
| where dispatch_strategy ->> 'entity_scope' = '1' | ||
| and game_id is not null), | ||
| individual_totals as ( | ||
| -- calculate the total rewards for each individual in each individual entity scoped game | ||
| select t.game_id, | ||
| t.epoch_id, | ||
| t.asset_id, | ||
| t.party_id, | ||
| sum(t.total_rewards) as total_rewards, | ||
| sum(total_rewards_quantum) as total_rewards_quantum | ||
| from game_reward_totals t | ||
| join individual_games i on t.game_id = i.game_id | ||
| group by t.game_id, t.epoch_id, t.asset_id, t.party_id), | ||
| individual_rankings as ( | ||
| -- rank the individuals for each game at each epoch | ||
| select game_id, | ||
| epoch_id, | ||
| party_id, | ||
| total_rewards_quantum, | ||
| rank() over ( | ||
| partition by game_id, epoch_id order by total_rewards_quantum desc | ||
| ) as rank | ||
| from individual_totals) | ||
| select it.game_id, | ||
| it.epoch_id, | ||
| it.party_id, | ||
| it.total_rewards, | ||
| ir.total_rewards_quantum, | ||
| ir.rank | ||
| from individual_totals it | ||
| join individual_rankings ir | ||
| on it.game_id = ir.game_id and it.epoch_id = ir.epoch_id and it.party_id = ir.party_id; | ||
|
|
||
| create materialized view game_stats as | ||
| with | ||
| game_epochs as ( | ||
| select distinct | ||
| game_id, epoch_id | ||
| from rewards | ||
| where | ||
| game_id is not null | ||
| ), | ||
| dispatch_strategies AS ( | ||
| SELECT DISTINCT | ||
| ON (game_id) game_id, dispatch_strategy | ||
| FROM transfers | ||
| WHERE | ||
| transfer_type = 'Recurring' | ||
| ORDER BY game_id, vega_time DESC | ||
| ), | ||
| game_rewards as ( | ||
| select | ||
| r.*, t.dispatch_strategy, tm.team_id, tmr.rank as member_rank, tr.rank as team_rank, tmr.total_rewards, tmr.total_rewards_quantum, | ||
| tr.total_rewards as team_total_rewards, tr.total_rewards_quantum as team_total_rewards_quantum, 'ENTITY_SCOPE_TEAMS' as entity_scope | ||
| from | ||
| rewards r | ||
| join game_epochs ge on r.game_id = ge.game_id | ||
| and r.epoch_id = ge.epoch_id | ||
| JOIN dispatch_strategies t ON r.game_id = t.game_id | ||
| AND t.dispatch_strategy ->> 'entity_scope' = '2' | ||
| join team_members tm on r.party_id = tm.party_id | ||
| left join game_team_rankings tr on r.game_id = tr.game_id | ||
| and r.epoch_id = tr.epoch_id | ||
| and tm.team_id = tr.team_id | ||
| left join game_team_member_rankings tmr on r.game_id = tmr.game_id | ||
| and r.epoch_id = tmr.epoch_id | ||
| and tm.team_id = tmr.team_id | ||
| and r.party_id = tmr.party_id | ||
| union all | ||
| select | ||
| r.*, t.dispatch_strategy, null as team_id, tmr.rank as member_rank, null as team_rank, tmr.total_rewards, tmr.total_rewards_quantum, | ||
| null as team_total_rewards, null as team_total_rewards_quantum, 'ENTITY_SCOPE_INDIVIDUALS' as entity_scope | ||
| from | ||
| rewards r | ||
| join game_epochs ge on r.game_id = ge.game_id | ||
| and r.epoch_id = ge.epoch_id | ||
| JOIN dispatch_strategies t ON r.game_id = t.game_id | ||
| AND t.dispatch_strategy ->> 'entity_scope' = '1' | ||
| left join game_individual_rankings tmr on r.game_id = tmr.game_id | ||
| and r.epoch_id = tmr.epoch_id | ||
| and r.party_id = tmr.party_id | ||
| ) | ||
| select * | ||
| from game_rewards | ||
| with data; | ||
|
|
||
| create materialized view game_stats_current as | ||
| with | ||
| game_epochs as ( | ||
| select game_id, max(epoch_id) as epoch_id | ||
| from rewards | ||
| where | ||
| game_id is not null | ||
| group by | ||
| game_id | ||
| ), | ||
| dispatch_strategies AS ( | ||
| SELECT DISTINCT | ||
| ON (game_id) game_id, dispatch_strategy | ||
| FROM transfers | ||
| WHERE | ||
| transfer_type = 'Recurring' | ||
| ORDER BY game_id, vega_time DESC | ||
| ), | ||
| game_rewards as ( | ||
| select | ||
| r.*, t.dispatch_strategy, tm.team_id, tmr.rank as member_rank, tr.rank as team_rank, tmr.total_rewards, tmr.total_rewards_quantum, | ||
| tr.total_rewards as team_total_rewards, tr.total_rewards_quantum as team_total_rewards_quantum, 'ENTITY_SCOPE_TEAMS' as entity_scope | ||
| from | ||
| rewards r | ||
| join game_epochs ge on r.game_id = ge.game_id | ||
| and r.epoch_id = ge.epoch_id | ||
| JOIN dispatch_strategies t ON r.game_id = t.game_id | ||
| AND t.dispatch_strategy ->> 'entity_scope' = '2' | ||
| join team_members tm on r.party_id = tm.party_id | ||
| left join game_team_rankings tr on r.game_id = tr.game_id | ||
| and r.epoch_id = tr.epoch_id | ||
| and tm.team_id = tr.team_id | ||
| left join game_team_member_rankings tmr on r.game_id = tmr.game_id | ||
| and r.epoch_id = tmr.epoch_id | ||
| and tm.team_id = tmr.team_id | ||
| and r.party_id = tmr.party_id | ||
| union all | ||
| select | ||
| r.*, t.dispatch_strategy, null as team_id, tmr.rank as member_rank, null as team_rank, tmr.total_rewards, tmr.total_rewards_quantum, | ||
| null as team_total_rewards, null as team_total_rewards_quantum, 'ENTITY_SCOPE_INDIVIDUALS' as entity_scope | ||
| from | ||
| rewards r | ||
| join game_epochs ge on r.game_id = ge.game_id | ||
| and r.epoch_id = ge.epoch_id | ||
| JOIN dispatch_strategies t ON r.game_id = t.game_id | ||
| AND t.dispatch_strategy ->> 'entity_scope' = '1' | ||
| left join game_individual_rankings tmr on r.game_id = tmr.game_id | ||
| and r.epoch_id = tmr.epoch_id | ||
| and r.party_id = tmr.party_id | ||
| ) | ||
| select * | ||
| from game_rewards | ||
| with data; | ||
|
|
||
| -- +goose Down | ||
|
|
||
| -- We are fixing a bug, and there is no point of reinstating a bug, we do nothing. |