Index xcm tasks

mixer/src/etl/index.ts

@@ -114,8 +114,11 @@ export const populateTask = async() => {
     inner join events on extrinsics.id = events.extrinsic_id
     where events.data->>'taskId' is not null
             and events.method = 'TaskScheduled'
-            and extrinsics.module = 'automationTime'
-            and extrinsics.method  like 'schedule%'
+            and (
+                (extrinsics.module = 'automationTime' and extrinsics.method  like 'schedule%')
+                -- this is XCM task
+                or (extrinsics.module = 'parachainSystem' and extrinsics.method = 'setValidationData')
+            )
     order by events.block_height asc, idx asc
     )
 

mixer/src/migrate/index.ts

@@ -13,6 +13,7 @@ export const migrate = async () => {
     client.query('alter table turing.tasks  add column if not exists scheduled_start_at timestamp'),
     client.query('alter table turing.tasks  add column if not exists scheduled_end_at timestamp'),
     client.query('alter table turing.tasks  add column if not exists executed_count integer default(0)'),
+    client.query('alter table turing.tasks  alter column executed_count set default(0)'),
   ])
 
   // column need to be create before commit

project-production.yaml

@@ -19,6 +19,7 @@ network:
   genesisHash: '0x0f62b701fb12d02237a33b84818c11f621653d2b1614c777973babf4652b535d'
   chaintypes:
     file: ./dist/chaintypes.js
+  dictionary: "https://api.subquery.network/sq/subquery/kusama-dictionary"
 dataSources:
   - kind: substrate/Runtime
     startBlock: 1

project.yaml

@@ -18,7 +18,8 @@ schema:
 network:
   endpoint: 'wss://rpc.turing-staging.oak.tech'
   chainId: '0xd54f0988402deb4548538626ce37e4a318441ea0529ca369400ebec4e04dfe4b'
-  #dictionary: "https://api.subquery.network/sq/subquery/kusama-dictionary"
+
+  dictionary: "https://api.subquery.network/sq/subquery/kusama-dictionary"
   chaintypes:
     file: ./dist/chaintypes.js
 

src/mappings/common/index.ts

@@ -115,15 +115,23 @@ export async function findOrCreateEvent(substrateEvent: SubstrateEvent): Promise
   const blockHeight = block.block.header.number;
 
   let callId = null;
+
   if (typeof extrinsic !== 'undefined') {
     const { section: extrinsicModule, method: extrinsicMethod } = extrinsic.extrinsic.method;
 
     // Skip indexing events for mandatory system extrinsics
-    if ((extrinsicModule === 'parachainSystem' && extrinsicMethod === 'setValidationData') ||
-      (extrinsicModule === 'timestamp' && extrinsicMethod === 'set')) {
+    if (extrinsicModule === 'timestamp' && extrinsicMethod === 'set') {
       return;
     }
 
+    if (extrinsicModule === 'parachainSystem' && extrinsicMethod === 'setValidationData') {
+        if ((event.section !== 'automationTime') && (event.section !== 'xcmpQueue')) {
+            // we want to track anything related to our time/price automation,
+            // adn xcmp so we can cross check the schedule from other chain
+            return;
+        }
+    }
+
     callId = canonicalExtrinsicID(extrinsic);
   }