feat(orap): add disabled options for event crosscheck

Author: murongg

packages/orap/src/flow/event.ts

@@ -3,7 +3,7 @@ import type { Context } from '../task'
 import type { TaskFlowParams } from '../flow/task'
 import { TaskFlow } from '../flow/task'
 import { StoreManager } from '../store'
-import type { EventSignalRegisterParams } from '../signal'
+import type { CrosscheckOptions, EventSignalRegisterParams } from '../signal'
 import { EventVerse } from '../verse/event'
 import type { TaskVerse } from '../verse/task'
 import type { Flow, HandleFn } from './interface'
@@ -33,7 +33,7 @@ export class EventFlow implements Flow {
     return this._taskFlows
   }
 
-  crosscheck(options?: Omit<AutoCrossCheckParam, 'address' | 'topics' | 'onMissingLog'>) {
+  crosscheck(options?: CrosscheckOptions) {
     this.partialCrosscheckOptions = options
     return this
   }

packages/orap/src/signal/event.ts

@@ -12,6 +12,15 @@ export interface EventSignalRegisterParams {
   // esig?: string,
 }
 
+export interface CrosscheckParams {
+  /**
+   * Disable crosscheck
+   */
+  disabled?: boolean
+}
+
+export type CrosscheckOptions = CrosscheckParams & Omit<AutoCrossCheckParam, 'address' | 'topics' | 'onMissingLog'>
+
 export type EventSignalCallback = ethers.Listener
 
 export class EventSignal implements Signal {
@@ -25,11 +34,12 @@ export class EventSignal implements Signal {
 
   crosschecker?: AutoCrossChecker
   crosscheckerOptions?: AutoCrossCheckParam
+  crosscheckerParams?: CrosscheckParams
 
   constructor(
     public params: EventSignalRegisterParams,
     public callback: EventSignalCallback,
-    crosscheckOptions?: Omit<AutoCrossCheckParam, 'address' | 'topics' | 'onMissingLog'>,
+    crosscheckOptions?: CrosscheckOptions,
   ) {
     this.contract = new ethers.Contract(
       params.address,
@@ -69,7 +79,7 @@ export class EventSignal implements Signal {
     return new ContractUnknownEventPayload(this.contract, this.subscribeCallback, this.params.eventName, log)
   }
 
-  private _setCrosscheckOptions(options: Omit<AutoCrossCheckParam, 'address' | 'topics' | 'onMissingLog'>) {
+  private _setCrosscheckOptions(options: CrosscheckOptions) {
     const {
       pollingInterval = ONE_MINUTE_MS * 60,
       ignoreLogs = [],
@@ -83,6 +93,9 @@ export class EventSignal implements Signal {
       pollingInterval,
       ignoreLogs,
     }
+    this.crosscheckerParams = {
+      disabled: options?.disabled,
+    }
   }
 
   // TODO: should be wsProvider only?
@@ -114,6 +127,9 @@ export class EventSignal implements Signal {
   }
 
   async startCrossChecker(provider?: Providers) {
+    if (this.crosscheckerParams?.disabled)
+      return
+
     if (!this.crosscheckerOptions)
       return
     if (!provider)