Interface ProcessorClient<CallOptionsExt>

interface ProcessorClient<CallOptionsExt = {}> {
    getConfig(
        request: {},
        options?: CallOptions & CallOptionsExt,
    ): Promise<ProcessConfigResponse>;
    preprocessBindingsStream(
        request: AsyncIterable<
            {
                bindings?: {
                    bindings?: {
                        data?: {
                            aptCall?: { rawTransaction?: ... };
                            aptEvent?: { eventIndex?: ...; rawEvent?: ...; rawTransaction?: ... };
                            aptResource?: {
                                rawResources?: ...;
                                timestampMicros?: ...;
                                version?: ...;
                            };
                            btcBlock?: { block?: ...; timestamp?: ... };
                            btcTransaction?: { timestamp?: ...; transaction?: ... };
                            cosmosCall?: { timestamp?: ...; transaction?: ... };
                            ethBlock?: { block?: ... };
                            ethLog?: {
                                block?: ...;
                                log?: ...;
                                rawBlock?: ...;
                                rawLog?: ...;
                                rawTransaction?: ...;
                                rawTransactionReceipt?: ...;
                                timestamp?: ...;
                                transaction?: ...;
                                transactionReceipt?: ...;
                            };
                            ethTrace?: {
                                block?: ...;
                                timestamp?: ...;
                                trace?: ...;
                                transaction?: ...;
                                transactionReceipt?: ...;
                            };
                            ethTransaction?: {
                                block?: ...;
                                rawBlock?: ...;
                                rawTrace?: ...;
                                rawTransaction?: ...;
                                rawTransactionReceipt?: ...;
                                timestamp?: ...;
                                trace?: ...;
                                transaction?: ...;
                                transactionReceipt?: ...;
                            };
                            fuelBlock?: { block?: ...; timestamp?: ... };
                            fuelLog?: { receiptIndex?: ...; timestamp?: ...; transaction?: ... };
                            fuelTransaction?: { timestamp?: ...; transaction?: ... };
                            solInstruction?: {
                                accounts?: ...;
                                instructionData?: ...;
                                parsed?: ...;
                                programAccountId?: ...;
                                slot?: ...;
                            };
                            starknetEvents?: { result?: ...; timestamp?: ... };
                            suiCall?: { rawTransaction?: ...; slot?: ...; timestamp?: ... };
                            suiEvent?: {
                                rawEvent?: ...;
                                rawTransaction?: ...;
                                slot?: ...;
                                timestamp?: ...;
                            };
                            suiObject?: {
                                objectDigest?: ...;
                                objectId?: ...;
                                objectVersion?: ...;
                                rawObjects?: ...;
                                rawSelf?: ...;
                                slot?: ...;
                                timestamp?: ...;
                            };
                            suiObjectChange?: {
                                rawChanges?: ...;
                                slot?: ...;
                                timestamp?: ...;
                                txDigest?: ...;
                            };
                        };
                        handlerIds?: number[];
                        handlerType?: HandlerType;
                    }[];
                };
                dbResult?: {
                    data?: { [key: string]: any };
                    entities?: { entities?: { fields?: { [key: ...]: ... } }[] };
                    entityList?: {
                        entities?: {
                            data?: { fields?: ... };
                            entity?: string;
                            genBlockChain?: string;
                            genBlockNumber?: bigint;
                            genBlockTime?: Date;
                        }[];
                    };
                    error?: string;
                    list?: any[];
                    nextCursor?: string;
                    opId?: bigint;
                };
                processId?: number;
            },
        >,
        options?: CallOptions & CallOptionsExt,
    ): AsyncIterable<PreprocessStreamResponse>;
    processBindings(
        request: {
            bindings?: {
                data?: {
                    aptCall?: { rawTransaction?: string };
                    aptEvent?: {
                        eventIndex?: number;
                        rawEvent?: string;
                        rawTransaction?: string;
                    };
                    aptResource?: {
                        rawResources?: string[];
                        timestampMicros?: bigint;
                        version?: bigint;
                    };
                    btcBlock?: { block?: { [key: string]: any }; timestamp?: Date };
                    btcTransaction?: {
                        timestamp?: Date;
                        transaction?: { [key: string]: any };
                    };
                    cosmosCall?: { timestamp?: Date; transaction?: { [key: string]: any } };
                    ethBlock?: { block?: { [key: string]: any } };
                    ethLog?: {
                        block?: { [key: string]: any };
                        log?: { [key: string]: any };
                        rawBlock?: string;
                        rawLog?: string;
                        rawTransaction?: string;
                        rawTransactionReceipt?: string;
                        timestamp?: Date;
                        transaction?: { [key: string]: any };
                        transactionReceipt?: { [key: string]: any };
                    };
                    ethTrace?: {
                        block?: { [key: string]: any };
                        timestamp?: Date;
                        trace?: { [key: string]: any };
                        transaction?: { [key: string]: any };
                        transactionReceipt?: { [key: string]: any };
                    };
                    ethTransaction?: {
                        block?: { [key: string]: any };
                        rawBlock?: string;
                        rawTrace?: string;
                        rawTransaction?: string;
                        rawTransactionReceipt?: string;
                        timestamp?: Date;
                        trace?: { [key: string]: any };
                        transaction?: { [key: string]: any };
                        transactionReceipt?: { [key: string]: any };
                    };
                    fuelBlock?: { block?: { [key: string]: any }; timestamp?: Date };
                    fuelLog?: {
                        receiptIndex?: bigint;
                        timestamp?: Date;
                        transaction?: { [key: string]: any };
                    };
                    fuelTransaction?: {
                        timestamp?: Date;
                        transaction?: { [key: string]: any };
                    };
                    solInstruction?: {
                        accounts?: string[];
                        instructionData?: string;
                        parsed?: { [key: string]: any };
                        programAccountId?: string;
                        slot?: bigint;
                    };
                    starknetEvents?: { result?: { [key: string]: any }; timestamp?: Date };
                    suiCall?: { rawTransaction?: string; slot?: bigint; timestamp?: Date };
                    suiEvent?: {
                        rawEvent?: string;
                        rawTransaction?: string;
                        slot?: bigint;
                        timestamp?: Date;
                    };
                    suiObject?: {
                        objectDigest?: string;
                        objectId?: string;
                        objectVersion?: bigint;
                        rawObjects?: string[];
                        rawSelf?: string;
                        slot?: bigint;
                        timestamp?: Date;
                    };
                    suiObjectChange?: {
                        rawChanges?: string[];
                        slot?: bigint;
                        timestamp?: Date;
                        txDigest?: string;
                    };
                };
                handlerIds?: number[];
                handlerType?: HandlerType;
            }[];
        },
        options?: CallOptions & CallOptionsExt,
    ): Promise<ProcessBindingResponse>;
    processBindingsStream(
        request: AsyncIterable<
            {
                binding?: {
                    data?: {
                        aptCall?: { rawTransaction?: string };
                        aptEvent?: {
                            eventIndex?: number;
                            rawEvent?: string;
                            rawTransaction?: string;
                        };
                        aptResource?: {
                            rawResources?: string[];
                            timestampMicros?: bigint;
                            version?: bigint;
                        };
                        btcBlock?: { block?: { [key: string]: any }; timestamp?: Date };
                        btcTransaction?: {
                            timestamp?: Date;
                            transaction?: { [key: string]: any };
                        };
                        cosmosCall?: {
                            timestamp?: Date;
                            transaction?: { [key: string]: any };
                        };
                        ethBlock?: { block?: { [key: string]: any } };
                        ethLog?: {
                            block?: { [key: string]: any };
                            log?: { [key: string]: any };
                            rawBlock?: string;
                            rawLog?: string;
                            rawTransaction?: string;
                            rawTransactionReceipt?: string;
                            timestamp?: Date;
                            transaction?: { [key: string]: any };
                            transactionReceipt?: { [key: string]: any };
                        };
                        ethTrace?: {
                            block?: { [key: string]: any };
                            timestamp?: Date;
                            trace?: { [key: string]: any };
                            transaction?: { [key: string]: any };
                            transactionReceipt?: { [key: string]: any };
                        };
                        ethTransaction?: {
                            block?: { [key: string]: any };
                            rawBlock?: string;
                            rawTrace?: string;
                            rawTransaction?: string;
                            rawTransactionReceipt?: string;
                            timestamp?: Date;
                            trace?: { [key: string]: any };
                            transaction?: { [key: string]: any };
                            transactionReceipt?: { [key: string]: any };
                        };
                        fuelBlock?: { block?: { [key: string]: any }; timestamp?: Date };
                        fuelLog?: {
                            receiptIndex?: bigint;
                            timestamp?: Date;
                            transaction?: { [key: string]: any };
                        };
                        fuelTransaction?: {
                            timestamp?: Date;
                            transaction?: { [key: string]: any };
                        };
                        solInstruction?: {
                            accounts?: string[];
                            instructionData?: string;
                            parsed?: { [key: string]: any };
                            programAccountId?: string;
                            slot?: bigint;
                        };
                        starknetEvents?: { result?: { [key: string]: any }; timestamp?: Date };
                        suiCall?: { rawTransaction?: string; slot?: bigint; timestamp?: Date };
                        suiEvent?: {
                            rawEvent?: string;
                            rawTransaction?: string;
                            slot?: bigint;
                            timestamp?: Date;
                        };
                        suiObject?: {
                            objectDigest?: string;
                            objectId?: string;
                            objectVersion?: bigint;
                            rawObjects?: string[];
                            rawSelf?: string;
                            slot?: bigint;
                            timestamp?: Date;
                        };
                        suiObjectChange?: {
                            rawChanges?: string[];
                            slot?: bigint;
                            timestamp?: Date;
                            txDigest?: string;
                        };
                    };
                    handlerIds?: number[];
                    handlerType?: HandlerType;
                };
                dbResult?: {
                    data?: { [key: string]: any };
                    entities?: { entities?: { fields?: { [key: ...]: ... } }[] };
                    entityList?: {
                        entities?: {
                            data?: { fields?: ... };
                            entity?: string;
                            genBlockChain?: string;
                            genBlockNumber?: bigint;
                            genBlockTime?: Date;
                        }[];
                    };
                    error?: string;
                    list?: any[];
                    nextCursor?: string;
                    opId?: bigint;
                };
                processId?: number;
            },
        >,
        options?: CallOptions & CallOptionsExt,
    ): AsyncIterable<ProcessStreamResponse>;
    start(
        request: {
            templateInstances?: {
                baseLabels?: { [key: string]: any };
                contract?: {
                    abi?: string;
                    address?: string;
                    chainId?: string;
                    name?: string;
                };
                endBlock?: bigint;
                startBlock?: bigint;
                templateId?: number;
            }[];
        },
        options?: CallOptions & CallOptionsExt,
    ): Promise<Empty>;
    stop(request: {}, options?: CallOptions & CallOptionsExt): Promise<Empty>;
}

Type Parameters

  • CallOptionsExt = {}

Methods

  • Parameters

    • request: AsyncIterable<
          {
              bindings?: {
                  bindings?: {
                      data?: {
                          aptCall?: { rawTransaction?: ... };
                          aptEvent?: { eventIndex?: ...; rawEvent?: ...; rawTransaction?: ... };
                          aptResource?: {
                              rawResources?: ...;
                              timestampMicros?: ...;
                              version?: ...;
                          };
                          btcBlock?: { block?: ...; timestamp?: ... };
                          btcTransaction?: { timestamp?: ...; transaction?: ... };
                          cosmosCall?: { timestamp?: ...; transaction?: ... };
                          ethBlock?: { block?: ... };
                          ethLog?: {
                              block?: ...;
                              log?: ...;
                              rawBlock?: ...;
                              rawLog?: ...;
                              rawTransaction?: ...;
                              rawTransactionReceipt?: ...;
                              timestamp?: ...;
                              transaction?: ...;
                              transactionReceipt?: ...;
                          };
                          ethTrace?: {
                              block?: ...;
                              timestamp?: ...;
                              trace?: ...;
                              transaction?: ...;
                              transactionReceipt?: ...;
                          };
                          ethTransaction?: {
                              block?: ...;
                              rawBlock?: ...;
                              rawTrace?: ...;
                              rawTransaction?: ...;
                              rawTransactionReceipt?: ...;
                              timestamp?: ...;
                              trace?: ...;
                              transaction?: ...;
                              transactionReceipt?: ...;
                          };
                          fuelBlock?: { block?: ...; timestamp?: ... };
                          fuelLog?: { receiptIndex?: ...; timestamp?: ...; transaction?: ... };
                          fuelTransaction?: { timestamp?: ...; transaction?: ... };
                          solInstruction?: {
                              accounts?: ...;
                              instructionData?: ...;
                              parsed?: ...;
                              programAccountId?: ...;
                              slot?: ...;
                          };
                          starknetEvents?: { result?: ...; timestamp?: ... };
                          suiCall?: { rawTransaction?: ...; slot?: ...; timestamp?: ... };
                          suiEvent?: {
                              rawEvent?: ...;
                              rawTransaction?: ...;
                              slot?: ...;
                              timestamp?: ...;
                          };
                          suiObject?: {
                              objectDigest?: ...;
                              objectId?: ...;
                              objectVersion?: ...;
                              rawObjects?: ...;
                              rawSelf?: ...;
                              slot?: ...;
                              timestamp?: ...;
                          };
                          suiObjectChange?: {
                              rawChanges?: ...;
                              slot?: ...;
                              timestamp?: ...;
                              txDigest?: ...;
                          };
                      };
                      handlerIds?: number[];
                      handlerType?: HandlerType;
                  }[];
              };
              dbResult?: {
                  data?: { [key: string]: any };
                  entities?: { entities?: { fields?: { [key: ...]: ... } }[] };
                  entityList?: {
                      entities?: {
                          data?: { fields?: ... };
                          entity?: string;
                          genBlockChain?: string;
                          genBlockNumber?: bigint;
                          genBlockTime?: Date;
                      }[];
                  };
                  error?: string;
                  list?: any[];
                  nextCursor?: string;
                  opId?: bigint;
              };
              processId?: number;
          },
      >
    • Optionaloptions: CallOptions & CallOptionsExt

    Returns AsyncIterable<PreprocessStreamResponse>

  • Parameters

    • request: {
          bindings?: {
              data?: {
                  aptCall?: { rawTransaction?: string };
                  aptEvent?: {
                      eventIndex?: number;
                      rawEvent?: string;
                      rawTransaction?: string;
                  };
                  aptResource?: {
                      rawResources?: string[];
                      timestampMicros?: bigint;
                      version?: bigint;
                  };
                  btcBlock?: { block?: { [key: string]: any }; timestamp?: Date };
                  btcTransaction?: {
                      timestamp?: Date;
                      transaction?: { [key: string]: any };
                  };
                  cosmosCall?: { timestamp?: Date; transaction?: { [key: string]: any } };
                  ethBlock?: { block?: { [key: string]: any } };
                  ethLog?: {
                      block?: { [key: string]: any };
                      log?: { [key: string]: any };
                      rawBlock?: string;
                      rawLog?: string;
                      rawTransaction?: string;
                      rawTransactionReceipt?: string;
                      timestamp?: Date;
                      transaction?: { [key: string]: any };
                      transactionReceipt?: { [key: string]: any };
                  };
                  ethTrace?: {
                      block?: { [key: string]: any };
                      timestamp?: Date;
                      trace?: { [key: string]: any };
                      transaction?: { [key: string]: any };
                      transactionReceipt?: { [key: string]: any };
                  };
                  ethTransaction?: {
                      block?: { [key: string]: any };
                      rawBlock?: string;
                      rawTrace?: string;
                      rawTransaction?: string;
                      rawTransactionReceipt?: string;
                      timestamp?: Date;
                      trace?: { [key: string]: any };
                      transaction?: { [key: string]: any };
                      transactionReceipt?: { [key: string]: any };
                  };
                  fuelBlock?: { block?: { [key: string]: any }; timestamp?: Date };
                  fuelLog?: {
                      receiptIndex?: bigint;
                      timestamp?: Date;
                      transaction?: { [key: string]: any };
                  };
                  fuelTransaction?: {
                      timestamp?: Date;
                      transaction?: { [key: string]: any };
                  };
                  solInstruction?: {
                      accounts?: string[];
                      instructionData?: string;
                      parsed?: { [key: string]: any };
                      programAccountId?: string;
                      slot?: bigint;
                  };
                  starknetEvents?: { result?: { [key: string]: any }; timestamp?: Date };
                  suiCall?: { rawTransaction?: string; slot?: bigint; timestamp?: Date };
                  suiEvent?: {
                      rawEvent?: string;
                      rawTransaction?: string;
                      slot?: bigint;
                      timestamp?: Date;
                  };
                  suiObject?: {
                      objectDigest?: string;
                      objectId?: string;
                      objectVersion?: bigint;
                      rawObjects?: string[];
                      rawSelf?: string;
                      slot?: bigint;
                      timestamp?: Date;
                  };
                  suiObjectChange?: {
                      rawChanges?: string[];
                      slot?: bigint;
                      timestamp?: Date;
                      txDigest?: string;
                  };
              };
              handlerIds?: number[];
              handlerType?: HandlerType;
          }[];
      }
    • Optionaloptions: CallOptions & CallOptionsExt

    Returns Promise<ProcessBindingResponse>

  • Parameters

    • request: AsyncIterable<
          {
              binding?: {
                  data?: {
                      aptCall?: { rawTransaction?: string };
                      aptEvent?: {
                          eventIndex?: number;
                          rawEvent?: string;
                          rawTransaction?: string;
                      };
                      aptResource?: {
                          rawResources?: string[];
                          timestampMicros?: bigint;
                          version?: bigint;
                      };
                      btcBlock?: { block?: { [key: string]: any }; timestamp?: Date };
                      btcTransaction?: {
                          timestamp?: Date;
                          transaction?: { [key: string]: any };
                      };
                      cosmosCall?: { timestamp?: Date; transaction?: { [key: string]: any } };
                      ethBlock?: { block?: { [key: string]: any } };
                      ethLog?: {
                          block?: { [key: string]: any };
                          log?: { [key: string]: any };
                          rawBlock?: string;
                          rawLog?: string;
                          rawTransaction?: string;
                          rawTransactionReceipt?: string;
                          timestamp?: Date;
                          transaction?: { [key: string]: any };
                          transactionReceipt?: { [key: string]: any };
                      };
                      ethTrace?: {
                          block?: { [key: string]: any };
                          timestamp?: Date;
                          trace?: { [key: string]: any };
                          transaction?: { [key: string]: any };
                          transactionReceipt?: { [key: string]: any };
                      };
                      ethTransaction?: {
                          block?: { [key: string]: any };
                          rawBlock?: string;
                          rawTrace?: string;
                          rawTransaction?: string;
                          rawTransactionReceipt?: string;
                          timestamp?: Date;
                          trace?: { [key: string]: any };
                          transaction?: { [key: string]: any };
                          transactionReceipt?: { [key: string]: any };
                      };
                      fuelBlock?: { block?: { [key: string]: any }; timestamp?: Date };
                      fuelLog?: {
                          receiptIndex?: bigint;
                          timestamp?: Date;
                          transaction?: { [key: string]: any };
                      };
                      fuelTransaction?: {
                          timestamp?: Date;
                          transaction?: { [key: string]: any };
                      };
                      solInstruction?: {
                          accounts?: string[];
                          instructionData?: string;
                          parsed?: { [key: string]: any };
                          programAccountId?: string;
                          slot?: bigint;
                      };
                      starknetEvents?: { result?: { [key: string]: any }; timestamp?: Date };
                      suiCall?: { rawTransaction?: string; slot?: bigint; timestamp?: Date };
                      suiEvent?: {
                          rawEvent?: string;
                          rawTransaction?: string;
                          slot?: bigint;
                          timestamp?: Date;
                      };
                      suiObject?: {
                          objectDigest?: string;
                          objectId?: string;
                          objectVersion?: bigint;
                          rawObjects?: string[];
                          rawSelf?: string;
                          slot?: bigint;
                          timestamp?: Date;
                      };
                      suiObjectChange?: {
                          rawChanges?: string[];
                          slot?: bigint;
                          timestamp?: Date;
                          txDigest?: string;
                      };
                  };
                  handlerIds?: number[];
                  handlerType?: HandlerType;
              };
              dbResult?: {
                  data?: { [key: string]: any };
                  entities?: { entities?: { fields?: { [key: ...]: ... } }[] };
                  entityList?: {
                      entities?: {
                          data?: { fields?: ... };
                          entity?: string;
                          genBlockChain?: string;
                          genBlockNumber?: bigint;
                          genBlockTime?: Date;
                      }[];
                  };
                  error?: string;
                  list?: any[];
                  nextCursor?: string;
                  opId?: bigint;
              };
              processId?: number;
          },
      >
    • Optionaloptions: CallOptions & CallOptionsExt

    Returns AsyncIterable<ProcessStreamResponse>

  • Parameters

    • request: {
          templateInstances?: {
              baseLabels?: { [key: string]: any };
              contract?: {
                  abi?: string;
                  address?: string;
                  chainId?: string;
                  name?: string;
              };
              endBlock?: bigint;
              startBlock?: bigint;
              templateId?: number;
          }[];
      }
    • Optionaloptions: CallOptions & CallOptionsExt

    Returns Promise<Empty>

  • Parameters

    Returns Promise<Empty>

MMNEPVFCICPMFPCPTTAAATR