From 72c45d9ea90237d87053fd1ddc751fc699527937 Mon Sep 17 00:00:00 2001
From: Jake Ellowitz <jake.ellowitz@gmail.com>
Date: Mon, 19 Nov 2018 19:11:51 -0800
Subject: metadata and trusted sources in same raw table

---
 .../1542655823221-NewMetadataAndOHLCVTables.ts     | 22 ++++++++++++++++++++--
 1 file changed, 20 insertions(+), 2 deletions(-)

(limited to 'packages/pipeline/migrations')

diff --git a/packages/pipeline/migrations/1542655823221-NewMetadataAndOHLCVTables.ts b/packages/pipeline/migrations/1542655823221-NewMetadataAndOHLCVTables.ts
index 5c7ec6de7..8d131271b 100644
--- a/packages/pipeline/migrations/1542655823221-NewMetadataAndOHLCVTables.ts
+++ b/packages/pipeline/migrations/1542655823221-NewMetadataAndOHLCVTables.ts
@@ -2,17 +2,23 @@ import {MigrationInterface, QueryRunner} from 'typeorm';
 
 export class NewMetadataAndOHLCVTables1542655823221 implements MigrationInterface {
 
+    // tslint:disable-next-line
     public async up(queryRunner: QueryRunner): Promise<any> {
 
         await queryRunner.query(`
-            CREATE TABLE raw.trusted_tokens (
+            CREATE TABLE raw.token_metadata (
                 address VARCHAR NOT NULL,
                 authority VARCHAR NOT NULL,
+                decimals INT NULL,
+                symbol VARCHAR NULL,
+                name VARCHAR NULL,
 
                 PRIMARY KEY (address, authority)
             );
         `);
 
+        await queryRunner.dropTable('raw.token_on_chain_metadata');
+
         await queryRunner.query(`
             CREATE TABLE raw.ohlcv_external (
                 exchange VARCHAR NOT NULL,
@@ -36,9 +42,21 @@ export class NewMetadataAndOHLCVTables1542655823221 implements MigrationInterfac
         `);
     }
 
+    // tslint:disable-next-line
     public async down(queryRunner: QueryRunner): Promise<any> {
 
-        await queryRunner.dropTable('raw.trusted_tokens');
+        await queryRunner.query(`
+            CREATE TABLE raw.token_on_chain_metadata (
+                address VARCHAR NOT NULL,
+                decimals INT NULL,
+                symbol VARCHAR NULL,
+                name VARCHAR NULL,
+
+                PRIMARY KEY (address)
+            );
+        `);
+
+        await queryRunner.dropTable('raw.token_metadata');
 
         await queryRunner.dropTable('raw.ohlcv_external');
     }
-- 
cgit v1.2.3