Update subsquid/src/processor.ts

ComposableFi · Jun 10, 2022 · 0305c67 · 0305c67
1 parent 24613b0
commit 0305c67
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 4 deletions.
diff --git a/.maintain/playbooks/templates/systemd/dali-subsquid-processor.service.j2 b/.maintain/playbooks/templates/systemd/dali-subsquid-processor.service.j2
@@ -6,6 +6,7 @@ After=network.target
 [Service]
 ExecStart=node -r dotenv/config lib/processor.js
 
+Environment="ENV=dali"
 WorkingDirectory={{ work_dir }}/subsquid
 StandardOutput=syslog
 StandardError=syslog

diff --git a/subsquid/src/processor.ts b/subsquid/src/processor.ts
@@ -22,12 +22,25 @@ import {
 
 const processor = new SubstrateProcessor("composable_dali_dev");
 
+const chain = (): string => {
+  switch(process.env.ENV) {
+    case 'dali':
+      return 'wss://dali.devnets.composablefinance.ninja/parachain/alice'
+    default:
+      return 'ws://localhost:9997'
+  }
+};
+
+const chain_connection_string = chain();
+const archive_connection_string = 'http://localhost:8080/v1/graphql';
+
+console.log(`Chain ${chain_connection_string}`);
+console.log(`Archive ${archive_connection_string}`);
+
 processor.setBatchSize(500);
 processor.setDataSource({
-  archive: `http://localhost:8080/v1/graphql`,
-  // archive: `http://localhost:4010/v1/graphql`,
-  chain: "ws://localhost:9997",
-  // chain: "wss://dali.devnets.composablefinance.ninja/parachain/alice",
+  archive: archive_connection_string,
+  chain: chain_connection_string,
 });
 
 processor.addEventHandler('pablo.PoolCreated', async (ctx) => {