Merge pull request #313 from kaleido-io/balances

Additional cleanup to support tokens UI
hyperledger · Nov 9, 2021 · feac44a · feac44a
2 parents 90f0a6d + 3089b5f
commit feac44a
Show file tree

Hide file tree

Showing 42 changed files with 1,266 additions and 1,757 deletions.
diff --git a/db/migrations/postgres/000032_create_tokenaccount_table.up.sql b/db/migrations/postgres/000032_create_tokenaccount_table.up.sql
@@ -9,6 +9,6 @@ CREATE TABLE tokenaccount (
   balance          VARCHAR(65)
 );
 
-CREATE UNIQUE INDEX tokenaccount_pool ON tokenaccount(pool_protocol_id,token_index,identity);
+CREATE UNIQUE INDEX tokenaccount_pool ON tokenaccount(identity,pool_protocol_id,token_index);
 
 COMMIT;
diff --git a/db/migrations/postgres/000043_replace_token_poolprotocolid.down.sql b/db/migrations/postgres/000043_replace_token_poolprotocolid.down.sql
@@ -0,0 +1,24 @@
+BEGIN;
+DROP INDEX tokenbalance_pool;
+DROP INDEX tokentransfer_pool;
+
+ALTER TABLE tokenbalance ADD COLUMN pool_protocol_id VARCHAR(1024);
+ALTER TABLE tokentransfer ADD COLUMN pool_protocol_id VARCHAR(1024);
+
+UPDATE tokenbalance SET pool_protocol_id = pool.protocol_id
+  FROM (SELECT protocol_id, id FROM tokenpool) AS pool
+  WHERE tokenbalance.pool_id = pool.id;
+
+UPDATE tokentransfer SET pool_protocol_id = pool.protocol_id
+  FROM (SELECT protocol_id, id FROM tokenpool) AS pool
+  WHERE tokentransfer.pool_id = pool.id;
+
+ALTER TABLE tokenbalance DROP COLUMN pool_id;
+ALTER TABLE tokentransfer DROP COLUMN pool_id;
+
+ALTER TABLE tokenbalance ALTER COLUMN pool_protocol_id SET NOT NULL;
+ALTER TABLE tokentransfer ALTER COLUMN pool_protocol_id SET NOT NULL;
+
+CREATE UNIQUE INDEX tokenaccount_pool ON tokenbalance(key,pool_protocol_id,token_index);
+CREATE INDEX tokentransfer_pool ON tokentransfer(pool_protocol_id,token_index);
+COMMIT;
diff --git a/db/migrations/postgres/000043_replace_token_poolprotocolid.up.sql b/db/migrations/postgres/000043_replace_token_poolprotocolid.up.sql
@@ -0,0 +1,24 @@
+BEGIN;
+DROP INDEX tokenaccount_pool;
+DROP INDEX tokentransfer_pool;
+
+ALTER TABLE tokenbalance ADD COLUMN pool_id UUID;
+ALTER TABLE tokentransfer ADD COLUMN pool_id UUID;
+
+UPDATE tokenbalance SET pool_id = pool.id
+  FROM (SELECT protocol_id, id FROM tokenpool) AS pool
+  WHERE tokenbalance.pool_protocol_id = pool.protocol_id;
+
+UPDATE tokentransfer SET pool_id = pool.id
+  FROM (SELECT protocol_id, id FROM tokenpool) AS pool
+  WHERE tokentransfer.pool_protocol_id = pool.protocol_id;
+
+ALTER TABLE tokenbalance DROP COLUMN pool_protocol_id;
+ALTER TABLE tokentransfer DROP COLUMN pool_protocol_id;
+
+ALTER TABLE tokenbalance ALTER COLUMN pool_id SET NOT NULL;
+ALTER TABLE tokentransfer ALTER COLUMN pool_id SET NOT NULL;
+
+CREATE UNIQUE INDEX tokenbalance_pool ON tokenbalance(key,pool_id,token_index);
+CREATE INDEX tokentransfer_pool ON tokentransfer(pool_id,token_index);
+COMMIT;
diff --git a/db/migrations/sqlite/000032_create_tokenaccount_table.up.sql b/db/migrations/sqlite/000032_create_tokenaccount_table.up.sql
@@ -8,4 +8,4 @@ CREATE TABLE tokenaccount (
   balance          VARCHAR(65)
 );
 
-CREATE UNIQUE INDEX tokenaccount_pool ON tokenaccount(pool_protocol_id,token_index,identity);
+CREATE UNIQUE INDEX tokenaccount_pool ON tokenaccount(identity,pool_protocol_id,token_index);
diff --git a/db/migrations/sqlite/000043_replace_token_poolprotocolid.down.sql b/db/migrations/sqlite/000043_replace_token_poolprotocolid.down.sql
@@ -0,0 +1,19 @@
+DROP INDEX tokenbalance_pool;
+DROP INDEX tokentransfer_pool;
+
+ALTER TABLE tokenbalance ADD COLUMN pool_protocol_id VARCHAR(1024);
+ALTER TABLE tokentransfer ADD COLUMN pool_protocol_id VARCHAR(1024);
+
+UPDATE tokenbalance SET pool_protocol_id = pool.protocol_id
+  FROM (SELECT protocol_id, id FROM tokenpool) AS pool
+  WHERE tokenbalance.pool_id = pool.id;
+
+UPDATE tokentransfer SET pool_protocol_id = pool.protocol_id
+  FROM (SELECT protocol_id, id FROM tokenpool) AS pool
+  WHERE tokentransfer.pool_id = pool.id;
+
+ALTER TABLE tokenbalance DROP COLUMN pool_id;
+ALTER TABLE tokentransfer DROP COLUMN pool_id;
+
+CREATE UNIQUE INDEX tokenaccount_pool ON tokenbalance(key,pool_protocol_id,token_index);
+CREATE INDEX tokentransfer_pool ON tokentransfer(pool_protocol_id,token_index);
diff --git a/db/migrations/sqlite/000043_replace_token_poolprotocolid.up.sql b/db/migrations/sqlite/000043_replace_token_poolprotocolid.up.sql
@@ -0,0 +1,19 @@
+DROP INDEX tokenaccount_pool;
+DROP INDEX tokentransfer_pool;
+
+ALTER TABLE tokenbalance ADD COLUMN pool_id UUID;
+ALTER TABLE tokentransfer ADD COLUMN pool_id UUID;
+
+UPDATE tokenbalance SET pool_id = pool.id
+  FROM (SELECT protocol_id, id FROM tokenpool) AS pool
+  WHERE tokenbalance.pool_protocol_id = pool.protocol_id;
+
+UPDATE tokentransfer SET pool_id = pool.id
+  FROM (SELECT protocol_id, id FROM tokenpool) AS pool
+  WHERE tokentransfer.pool_protocol_id = pool.protocol_id;
+
+ALTER TABLE tokenbalance DROP COLUMN pool_protocol_id;
+ALTER TABLE tokentransfer DROP COLUMN pool_protocol_id;
+
+CREATE UNIQUE INDEX tokenbalance_pool ON tokenbalance(key,pool_id,token_index);
+CREATE INDEX tokentransfer_pool ON tokentransfer(pool_id,token_index);