fix(swaps): status is expired field

src/mappings/index.ts

@@ -8,6 +8,7 @@ import * as a from './assets'
 import * as n from './nfts'
 import * as u from './uniques'
 import { BatchContext, Context, SelectedEvent } from './utils/types'
+import { ParachainSystemCall } from '../processable'
 import { updateSwapsCache } from './utils/cache'
 
 type HandlerFunction = <T extends SelectedEvent>(item: T, ctx: Context) => Promise<void>
@@ -215,6 +216,14 @@ export async function mainFrame(ctx: BatchContext<Store>): Promise<void> {
   )
 
   for (const block of ctx.blocks) {
+    let relayParentNumber: number | undefined
+
+    const validationCall = block.calls?.find((c) => c.name === ParachainSystemCall.setValidationData)
+
+    if (validationCall) {
+      relayParentNumber = validationCall.args?.data?.validationData?.relayParentNumber as number | undefined
+    }
+
     for (let event of block.events) {
       logger.debug(`Processing ${event.name}`)
       const [pallet] = event.name.split('.')
@@ -228,6 +237,7 @@ export async function mainFrame(ctx: BatchContext<Store>): Promise<void> {
         store: ctx.store,
         extrinsic: event.extrinsic,
         call: event.call,
+        relayParentNumber,
       })
       // const item = event
     }

src/mappings/nfts/createSwap.ts

@@ -48,7 +48,7 @@ export async function handleCreateSwap(context: Context): Promise<void> {
   if (!offer) {
     (final as Swap).surcharge = event.surcharge || null
   }
-  final.status = final.blockNumber >= deadline ? TradeStatus.EXPIRED : TradeStatus.ACTIVE
+  final.status = (context.relayParentNumber || final.blockNumber) >= deadline ? TradeStatus.EXPIRED : TradeStatus.ACTIVE
   final.updatedAt = event.timestamp
 
   await context.store.save(final)

src/mappings/utils/types.ts

@@ -125,6 +125,8 @@ export type Context<S = Store>  = {
   event: SelectedEvent
   extrinsic: SelectedExtrinsic | undefined
   call: SelectedCall | undefined
+  /** Relay chain block number */
+  relayParentNumber: number | undefined
   // log: Logger
 }
 

src/processable.ts

@@ -109,6 +109,14 @@ export enum NonFungibleCall {
   claimSwap = 'Nfts.claim_swap',
 }
 
+/**
+ * Parachain System Calls
+ * Used to extract relay chain context (e.g., relay parent block number)
+ */
+export enum ParachainSystemCall {
+  setValidationData = 'ParachainSystem.set_validation_data',
+}
+
 /**
  * Assets Pallet Events
  * @enum {string}

src/processor.ts

@@ -3,7 +3,7 @@ import {
 } from '@subsquid/substrate-processor'
 import { TypeormDatabase as Database } from '@subsquid/typeorm-store'
 import logger from './mappings/utils/logger'
-import { Asset, NewNonFungible, NonFungible, NonFungibleCall, Unique } from './processable'
+import { Asset, NewNonFungible, NonFungible, NonFungibleCall, ParachainSystemCall, Unique } from './processable'
 
 import { CHAIN, getArchiveUrl, getNodeUrl, UNIQUES_ENABLED } from './environment'
 import { mainFrame } from './mappings'
@@ -93,6 +93,9 @@ processor.addEvent({ name: [NewNonFungible.claimSwap], call: true, extrinsic: tr
 // IMPORTANT: THIS IS CALL NOT EVENT!
 processor.addCall({ name: [NonFungibleCall.updateMintSettings], extrinsic: true })
 
+// Capture relay chain context from inherent call
+processor.addCall({ name: [ParachainSystemCall.setValidationData] })
+
 processor.setFields(fieldSelection)
 
 /**