Class TestProcessorServer

constructor

• new TestProcessorServer(loader, httpEndpoints?): TestProcessorServer

• Parameters

  • loader: (() => Promise<any>)
    • • (): Promise<any>

      • Returns Promise<any>

  • httpEndpoints: Record<string, string> = {}

  Returns TestProcessorServer

accountConfigs

aptos

btc

contractConfigs

cosmos

eth

fuel

service

solana

starknet

sui

getConfig

• getConfig(request, context?): Promise<ProcessConfigResponse>

• Parameters

  • request: ProcessConfigRequest
  • context: CallContext = TEST_CONTEXT

  Returns Promise<ProcessConfigResponse>

preprocessBindingsStream

• preprocessBindingsStream(requests, context): ServerStreamingMethodResult<{
      dbRequest?: {
          delete?: {
              entity?: string[];
              id?: string[];
          };
          get?: {
              entity?: string;
              id?: string;
          };
          list?: {
              cursor?: string;
              entity?: string;
              filters?: {
                  field?: string;
                  op?: DBRequest_DBOperator;
                  value?: {
                      values?: ...;
                  };
              }[];
              pageSize?: number;
          };
          opId?: bigint;
          upsert?: {
              data?: {}[];
              entity?: string[];
              entityData?: {
                  fields?: {};
              }[];
              id?: string[];
          };
      };
      processId?: number;
  }>

• Parameters

  • requests: AsyncIterable<PreprocessStreamRequest>
  • context: CallContext

  Returns ServerStreamingMethodResult<{
      dbRequest?: {
          delete?: {
              entity?: string[];
              id?: string[];
          };
          get?: {
              entity?: string;
              id?: string;
          };
          list?: {
              cursor?: string;
              entity?: string;
              filters?: {
                  field?: string;
                  op?: DBRequest_DBOperator;
                  value?: {
                      values?: ...;
                  };
              }[];
              pageSize?: number;
          };
          opId?: bigint;
          upsert?: {
              data?: {}[];
              entity?: string[];
              entityData?: {
                  fields?: {};
              }[];
              id?: string[];
          };
      };
      processId?: number;
  }>

processBinding

• processBinding(request, context?): Promise<ProcessBindingResponse>

• Parameters

  • request: DataBinding
  • context: CallContext = TEST_CONTEXT

  Returns Promise<ProcessBindingResponse>

processBindings

• processBindings(request, context?): Promise<ProcessBindingResponse>

• Parameters

  • request: ProcessBindingsRequest
  • context: CallContext = TEST_CONTEXT

  Returns Promise<ProcessBindingResponse>

processBindingsStream

• processBindingsStream(requests, context): ServerStreamingMethodResult<{
      dbRequest?: {
          delete?: {
              entity?: string[];
              id?: string[];
          };
          get?: {
              entity?: string;
              id?: string;
          };
          list?: {
              cursor?: string;
              entity?: string;
              filters?: {
                  field?: string;
                  op?: DBRequest_DBOperator;
                  value?: {
                      values?: ...;
                  };
              }[];
              pageSize?: number;
          };
          opId?: bigint;
          upsert?: {
              data?: {}[];
              entity?: string[];
              entityData?: {
                  fields?: {};
              }[];
              id?: string[];
          };
      };
      processId?: number;
      result?: {
          counters?: {
              add?: boolean;
              metadata?: {
                  address?: string;
                  blockNumber?: bigint;
                  chainId?: string;
                  contractName?: string;
                  labels?: {};
                  logIndex?: number;
                  name?: string;
                  transactionHash?: string;
                  transactionIndex?: number;
              };
              metricValue?: {
                  bigDecimal?: string;
                  bigInteger?: {
                      data?: ...;
                      negative?: ...;
                  };
                  doubleValue?: number;
              };
              runtimeInfo?: {
                  from?: HandlerType;
              };
          }[];
          events?: {
              attributes?: {};
              distinctEntityId?: string;
              message?: string;
              metadata?: {
                  address?: string;
                  blockNumber?: bigint;
                  chainId?: string;
                  contractName?: string;
                  labels?: {};
                  logIndex?: number;
                  name?: string;
                  transactionHash?: string;
                  transactionIndex?: number;
              };
              noMetric?: boolean;
              runtimeInfo?: {
                  from?: HandlerType;
              };
              severity?: LogLevel;
          }[];
          exports?: {
              metadata?: {
                  address?: string;
                  blockNumber?: bigint;
                  chainId?: string;
                  contractName?: string;
                  labels?: {};
                  logIndex?: number;
                  name?: string;
                  transactionHash?: string;
                  transactionIndex?: number;
              };
              payload?: string;
              runtimeInfo?: {
                  from?: HandlerType;
              };
          }[];
          gauges?: {
              metadata?: {
                  address?: string;
                  blockNumber?: bigint;
                  chainId?: string;
                  contractName?: string;
                  labels?: {};
                  logIndex?: number;
                  name?: string;
                  transactionHash?: string;
                  transactionIndex?: number;
              };
              metricValue?: {
                  bigDecimal?: string;
                  bigInteger?: {
                      data?: ...;
                      negative?: ...;
                  };
                  doubleValue?: number;
              };
              runtimeInfo?: {
                  from?: HandlerType;
              };
          }[];
          states?: {
              configUpdated?: boolean;
              error?: string;
          };
      };
  }>

• Parameters

  • requests: AsyncIterable<ProcessStreamRequest>
  • context: CallContext

  Returns ServerStreamingMethodResult<{
      dbRequest?: {
          delete?: {
              entity?: string[];
              id?: string[];
          };
          get?: {
              entity?: string;
              id?: string;
          };
          list?: {
              cursor?: string;
              entity?: string;
              filters?: {
                  field?: string;
                  op?: DBRequest_DBOperator;
                  value?: {
                      values?: ...;
                  };
              }[];
              pageSize?: number;
          };
          opId?: bigint;
          upsert?: {
              data?: {}[];
              entity?: string[];
              entityData?: {
                  fields?: {};
              }[];
              id?: string[];
          };
      };
      processId?: number;
      result?: {
          counters?: {
              add?: boolean;
              metadata?: {
                  address?: string;
                  blockNumber?: bigint;
                  chainId?: string;
                  contractName?: string;
                  labels?: {};
                  logIndex?: number;
                  name?: string;
                  transactionHash?: string;
                  transactionIndex?: number;
              };
              metricValue?: {
                  bigDecimal?: string;
                  bigInteger?: {
                      data?: ...;
                      negative?: ...;
                  };
                  doubleValue?: number;
              };
              runtimeInfo?: {
                  from?: HandlerType;
              };
          }[];
          events?: {
              attributes?: {};
              distinctEntityId?: string;
              message?: string;
              metadata?: {
                  address?: string;
                  blockNumber?: bigint;
                  chainId?: string;
                  contractName?: string;
                  labels?: {};
                  logIndex?: number;
                  name?: string;
                  transactionHash?: string;
                  transactionIndex?: number;
              };
              noMetric?: boolean;
              runtimeInfo?: {
                  from?: HandlerType;
              };
              severity?: LogLevel;
          }[];
          exports?: {
              metadata?: {
                  address?: string;
                  blockNumber?: bigint;
                  chainId?: string;
                  contractName?: string;
                  labels?: {};
                  logIndex?: number;
                  name?: string;
                  transactionHash?: string;
                  transactionIndex?: number;
              };
              payload?: string;
              runtimeInfo?: {
                  from?: HandlerType;
              };
          }[];
          gauges?: {
              metadata?: {
                  address?: string;
                  blockNumber?: bigint;
                  chainId?: string;
                  contractName?: string;
                  labels?: {};
                  logIndex?: number;
                  name?: string;
                  transactionHash?: string;
                  transactionIndex?: number;
              };
              metricValue?: {
                  bigDecimal?: string;
                  bigInteger?: {
                      data?: ...;
                      negative?: ...;
                  };
                  doubleValue?: number;
              };
              runtimeInfo?: {
                  from?: HandlerType;
              };
          }[];
          states?: {
              configUpdated?: boolean;
              error?: string;
          };
      };
  }>

start

• start(request?, context?): Promise<Empty>

• Parameters

  • request: StartRequest = ...
  • context: CallContext = TEST_CONTEXT

  Returns Promise<Empty>

stop

• stop(request, context?): Promise<Empty>

• Parameters

  • request: Empty
  • context: CallContext = TEST_CONTEXT

  Returns Promise<Empty>