Interface ProcessorClient<CallOptionsExt>

interface ProcessorClient<CallOptionsExt = {}> {
    getConfig(
        request: {},
        options?: CallOptions & CallOptionsExt,
    ): Promise<ProcessConfigResponse>;
    preprocessBindingsStream(
        request: AsyncIterable<
            {
                bindings?: {
                    bindings?: {
                        data?: {
                            aptCall?: { rawTransaction?: ...; transaction?: ... };
                            aptEvent?: { rawTransaction?: ...; transaction?: ... };
                            aptResource?: {
                                rawResources?: ...;
                                resources?: ...;
                                timestampMicros?: ...;
                                version?: ...;
                            };
                            btcBlock?: { block?: ...; timestamp?: ... };
                            btcTransaction?: { timestamp?: ...; transaction?: ... };
                            cosmosCall?: { timestamp?: ...; transaction?: ... };
                            ethBlock?: { block?: ... };
                            ethLog?: {
                                block?: ...;
                                log?: ...;
                                timestamp?: ...;
                                transaction?: ...;
                                transactionReceipt?: ...;
                            };
                            ethTrace?: {
                                block?: ...;
                                timestamp?: ...;
                                trace?: ...;
                                transaction?: ...;
                                transactionReceipt?: ...;
                            };
                            ethTransaction?: {
                                block?: ...;
                                timestamp?: ...;
                                trace?: ...;
                                transaction?: ...;
                                transactionReceipt?: ...;
                            };
                            fuelBlock?: { block?: ...; timestamp?: ... };
                            fuelCall?: { timestamp?: ...; transaction?: ... };
                            solInstruction?: {
                                accounts?: ...;
                                instructionData?: ...;
                                parsed?: ...;
                                programAccountId?: ...;
                                slot?: ...;
                            };
                            starknetEvents?: { result?: ...; timestamp?: ... };
                            suiCall?: { slot?: ...; timestamp?: ...; transaction?: ... };
                            suiEvent?: { slot?: ...; timestamp?: ...; transaction?: ... };
                            suiObject?: {
                                objectDigest?: ...;
                                objectId?: ...;
                                objects?: ...;
                                objectVersion?: ...;
                                self?: ...;
                                slot?: ...;
                                timestamp?: ...;
                            };
                            suiObjectChange?: {
                                changes?: ...;
                                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;
                        transaction?: { [key: string]: any };
                    };
                    aptEvent?: {
                        rawTransaction?: string;
                        transaction?: { [key: string]: any };
                    };
                    aptResource?: {
                        rawResources?: string[];
                        resources?: { [key: ...]: ... }[];
                        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 };
                        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 };
                        timestamp?: Date;
                        trace?: { [key: string]: any };
                        transaction?: { [key: string]: any };
                        transactionReceipt?: { [key: string]: any };
                    };
                    fuelBlock?: { block?: { [key: string]: any }; timestamp?: Date };
                    fuelCall?: { 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?: {
                        slot?: bigint;
                        timestamp?: Date;
                        transaction?: { [key: string]: any };
                    };
                    suiEvent?: {
                        slot?: bigint;
                        timestamp?: Date;
                        transaction?: { [key: string]: any };
                    };
                    suiObject?: {
                        objectDigest?: string;
                        objectId?: string;
                        objects?: { [key: ...]: ... }[];
                        objectVersion?: bigint;
                        self?: { [key: string]: any };
                        slot?: bigint;
                        timestamp?: Date;
                    };
                    suiObjectChange?: {
                        changes?: { [key: ...]: ... }[];
                        slot?: bigint;
                        timestamp?: Date;
                        txDigest?: string;
                    };
                };
                handlerIds?: number[];
                handlerType?: HandlerType;
            }[];
        },
        options?: CallOptions & CallOptionsExt,
    ): Promise<ProcessBindingResponse>;
    processBindingsStream(
        request: AsyncIterable<
            {
                binding?: {
                    data?: {
                        aptCall?: {
                            rawTransaction?: string;
                            transaction?: { [key: string]: any };
                        };
                        aptEvent?: {
                            rawTransaction?: string;
                            transaction?: { [key: string]: any };
                        };
                        aptResource?: {
                            rawResources?: string[];
                            resources?: { [key: ...]: ... }[];
                            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 };
                            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 };
                            timestamp?: Date;
                            trace?: { [key: string]: any };
                            transaction?: { [key: string]: any };
                            transactionReceipt?: { [key: string]: any };
                        };
                        fuelBlock?: { block?: { [key: string]: any }; timestamp?: Date };
                        fuelCall?: { 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?: {
                            slot?: bigint;
                            timestamp?: Date;
                            transaction?: { [key: string]: any };
                        };
                        suiEvent?: {
                            slot?: bigint;
                            timestamp?: Date;
                            transaction?: { [key: string]: any };
                        };
                        suiObject?: {
                            objectDigest?: string;
                            objectId?: string;
                            objects?: { [key: ...]: ... }[];
                            objectVersion?: bigint;
                            self?: { [key: string]: any };
                            slot?: bigint;
                            timestamp?: Date;
                        };
                        suiObjectChange?: {
                            changes?: { [key: ...]: ... }[];
                            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?: ...; transaction?: ... };
                          aptEvent?: { rawTransaction?: ...; transaction?: ... };
                          aptResource?: {
                              rawResources?: ...;
                              resources?: ...;
                              timestampMicros?: ...;
                              version?: ...;
                          };
                          btcBlock?: { block?: ...; timestamp?: ... };
                          btcTransaction?: { timestamp?: ...; transaction?: ... };
                          cosmosCall?: { timestamp?: ...; transaction?: ... };
                          ethBlock?: { block?: ... };
                          ethLog?: {
                              block?: ...;
                              log?: ...;
                              timestamp?: ...;
                              transaction?: ...;
                              transactionReceipt?: ...;
                          };
                          ethTrace?: {
                              block?: ...;
                              timestamp?: ...;
                              trace?: ...;
                              transaction?: ...;
                              transactionReceipt?: ...;
                          };
                          ethTransaction?: {
                              block?: ...;
                              timestamp?: ...;
                              trace?: ...;
                              transaction?: ...;
                              transactionReceipt?: ...;
                          };
                          fuelBlock?: { block?: ...; timestamp?: ... };
                          fuelCall?: { timestamp?: ...; transaction?: ... };
                          solInstruction?: {
                              accounts?: ...;
                              instructionData?: ...;
                              parsed?: ...;
                              programAccountId?: ...;
                              slot?: ...;
                          };
                          starknetEvents?: { result?: ...; timestamp?: ... };
                          suiCall?: { slot?: ...; timestamp?: ...; transaction?: ... };
                          suiEvent?: { slot?: ...; timestamp?: ...; transaction?: ... };
                          suiObject?: {
                              objectDigest?: ...;
                              objectId?: ...;
                              objects?: ...;
                              objectVersion?: ...;
                              self?: ...;
                              slot?: ...;
                              timestamp?: ...;
                          };
                          suiObjectChange?: {
                              changes?: ...;
                              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;
                      transaction?: { [key: string]: any };
                  };
                  aptEvent?: {
                      rawTransaction?: string;
                      transaction?: { [key: string]: any };
                  };
                  aptResource?: {
                      rawResources?: string[];
                      resources?: { [key: ...]: ... }[];
                      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 };
                      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 };
                      timestamp?: Date;
                      trace?: { [key: string]: any };
                      transaction?: { [key: string]: any };
                      transactionReceipt?: { [key: string]: any };
                  };
                  fuelBlock?: { block?: { [key: string]: any }; timestamp?: Date };
                  fuelCall?: { 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?: {
                      slot?: bigint;
                      timestamp?: Date;
                      transaction?: { [key: string]: any };
                  };
                  suiEvent?: {
                      slot?: bigint;
                      timestamp?: Date;
                      transaction?: { [key: string]: any };
                  };
                  suiObject?: {
                      objectDigest?: string;
                      objectId?: string;
                      objects?: { [key: ...]: ... }[];
                      objectVersion?: bigint;
                      self?: { [key: string]: any };
                      slot?: bigint;
                      timestamp?: Date;
                  };
                  suiObjectChange?: {
                      changes?: { [key: ...]: ... }[];
                      slot?: bigint;
                      timestamp?: Date;
                      txDigest?: string;
                  };
              };
              handlerIds?: number[];
              handlerType?: HandlerType;
          }[];
      }
    • Optionaloptions: CallOptions & CallOptionsExt

    Returns Promise<ProcessBindingResponse>

  • Parameters

    • request: AsyncIterable<
          {
              binding?: {
                  data?: {
                      aptCall?: {
                          rawTransaction?: string;
                          transaction?: { [key: string]: any };
                      };
                      aptEvent?: {
                          rawTransaction?: string;
                          transaction?: { [key: string]: any };
                      };
                      aptResource?: {
                          rawResources?: string[];
                          resources?: { [key: ...]: ... }[];
                          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 };
                          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 };
                          timestamp?: Date;
                          trace?: { [key: string]: any };
                          transaction?: { [key: string]: any };
                          transactionReceipt?: { [key: string]: any };
                      };
                      fuelBlock?: { block?: { [key: string]: any }; timestamp?: Date };
                      fuelCall?: { 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?: {
                          slot?: bigint;
                          timestamp?: Date;
                          transaction?: { [key: string]: any };
                      };
                      suiEvent?: {
                          slot?: bigint;
                          timestamp?: Date;
                          transaction?: { [key: string]: any };
                      };
                      suiObject?: {
                          objectDigest?: string;
                          objectId?: string;
                          objects?: { [key: ...]: ... }[];
                          objectVersion?: bigint;
                          self?: { [key: string]: any };
                          slot?: bigint;
                          timestamp?: Date;
                      };
                      suiObjectChange?: {
                          changes?: { [key: ...]: ... }[];
                          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