Fix issues with duplicated created_at stats, use effect_id for WHERE clause

Author: chr4

db/migrations/0004_add_payments_to_asset_stats.down.sql

@@ -12,7 +12,7 @@ BEGIN
     FOR t_row in SELECT * FROM effects LOOP
       INSERT INTO asset_stats(paging_token, asset_code, asset_issuer, asset_type, created_at, total_amount, num_accounts, num_effects)
           VALUES (t_row.paging_token, t_row.asset_code, t_row.asset_issuer, t_row.asset_type, t_row.created_at,
-              (SELECT SUM(amount) FROM effects WHERE type='account_debited' AND account=t_row.asset_issuer AND created_at <= t_row.created_at),
+              (SELECT SUM(amount) FROM effects WHERE type='account_debited' AND account=t_row.asset_issuer AND effect_id <= t_row.effect_id),
               (SELECT COUNT(DISTINCT account) FROM effects WHERE effect_id <= t_row.effect_id),
               (SELECT COUNT(*) FROM effects WHERE type='account_debited' AND effect_id <= t_row.effect_id),
               (SELECT COUNT(*) FROM effects WHERE effect_id <= t_row.effect_id)

db/migrations/0004_add_payments_to_asset_stats.up.sql

@@ -12,7 +12,7 @@ BEGIN
     FOR t_row in SELECT * FROM effects LOOP
       INSERT INTO asset_stats(paging_token, asset_code, asset_issuer, asset_type, created_at, total_amount, num_accounts, payments)
           VALUES (t_row.paging_token, t_row.asset_code, t_row.asset_issuer, t_row.asset_type, t_row.created_at,
-              (SELECT SUM(amount) FROM effects WHERE type='account_debited' AND account=t_row.asset_issuer AND created_at <= t_row.created_at),
+              (SELECT SUM(amount) FROM effects WHERE type='account_debited' AND account=t_row.asset_issuer AND effect_id <= t_row.effect_id),
               (SELECT COUNT(DISTINCT account) FROM effects WHERE account != t_row.asset_issuer AND effect_id <= t_row.effect_id),
               (SELECT COUNT(*) FROM effects WHERE type='account_debited' AND account != t_row.asset_issuer AND effect_id <= t_row.effect_id)
           );

db/migrations/0005_materialized_view.down.sql

@@ -21,7 +21,7 @@ BEGIN
     FOR t_row in SELECT * FROM effects LOOP
       INSERT INTO asset_stats(paging_token, asset_code, asset_issuer, asset_type, created_at, total_amount, num_accounts, payments)
           VALUES (t_row.paging_token, t_row.asset_code, t_row.asset_issuer, t_row.asset_type, t_row.created_at,
-              (SELECT SUM(amount) FROM effects WHERE type='account_debited' AND account=t_row.asset_issuer AND created_at <= t_row.created_at),
+              (SELECT SUM(amount) FROM effects WHERE type='account_debited' AND account=t_row.asset_issuer AND effect_id <= t_row.effect_id),
               (SELECT COUNT(DISTINCT account) FROM effects WHERE account != t_row.asset_issuer AND effect_id <= t_row.effect_id),
               (SELECT COUNT(*) FROM effects WHERE type='account_debited' AND account != t_row.asset_issuer AND effect_id <= t_row.effect_id)
           );

db/migrations/0005_materialized_view.up.sql

@@ -21,7 +21,7 @@ BEGIN
     asset_code   := t_row.asset_code;
     asset_issuer := t_row.asset_issuer;
     created_at   := t_row.created_at;
-    total_amount := (SELECT SUM(amount) FROM effects WHERE type='account_debited' AND account=t_row.asset_issuer AND created_at <= t_row.created_at);
+    total_amount := (SELECT SUM(amount) FROM effects WHERE type='account_debited' AND account=t_row.asset_issuer AND effect_id <= t_row.effect_id);
     num_accounts := (SELECT COUNT(DISTINCT account) FROM effects WHERE account != t_row.asset_issuer AND effect_id <= t_row.effect_id);
     payments     := (SELECT COUNT(*) FROM effects WHERE type='account_debited' AND account != t_row.asset_issuer AND effect_id <= t_row.effect_id);
     RETURN NEXT;