upgrade to ddex api v3 (#1507)

1 files changed, 21 insertions, 0 deletions

diff --git a/packages/pipeline/migrations/1547153875669-UpdateDDexAPIToV3.ts b/packages/pipeline/migrations/1547153875669-UpdateDDexAPIToV3.ts
new file mode 100644
index 000000000..957af4941
--- /dev/null
+++ b/packages/pipeline/migrations/1547153875669-UpdateDDexAPIToV3.ts
@@ -0,0 +1,21 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class UpdateDDexAPIToV31547153875669 implements MigrationInterface {
+    public async up(queryRunner: QueryRunner): Promise<any> {
+        await queryRunner.query(`
+        UPDATE raw.token_orderbook_snapshots
+        SET quote_asset_symbol='WETH'
+        WHERE quote_asset_symbol='ETH' AND
+        source='ddex';
+        `);
+    }
+
+    public async down(queryRunner: QueryRunner): Promise<any> {
+        await queryRunner.query(`
+        UPDATE raw.token_orderbook_snapshots
+        SET quote_asset_symbol='ETH'
+        WHERE quote_asset_symbol='WETH' AND
+        source='ddex';
+        `);
+    }
+}