Class TestProcessorServer

constructor

• new TestProcessorServer(
      loader: () => Promise<any>,
      httpEndpoints?: Record<string, string>,
  ): TestProcessorServer

  Parameters

  • loader: () => Promise<any>
  • httpEndpoints: Record<string, string> = {}

  Returns TestProcessorServer

_db

accountConfigs

aptos

contractConfigs

cosmos

eth

fuel

iota

service

solana

storeContext

sui

db

• get db(): MemoryDatabase

  Returns MemoryDatabase

store

• get store(): Store

  Returns Store

getConfig

• getConfig(
      request?: MessageInit<Message<"processor.ProcessConfigRequest">>,
      context?: HandlerContext,
  ): Promise<ProcessConfigResponse>

  Parameters

  • request: MessageInit<Message<"processor.ProcessConfigRequest">> = {}
  • context: HandlerContext = TEST_CONTEXT

  Returns Promise<ProcessConfigResponse>

processBinding

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

  Parameters

  • request: DataBinding
  • context: HandlerContext = TEST_CONTEXT

  Returns Promise<ProcessBindingResponse>

processBindings

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

  Parameters

  • request: MessageInit<ProcessBindingsRequest>
  • context: HandlerContext = TEST_CONTEXT

  Returns Promise<ProcessBindingResponse>

processBindingsStream

• processBindingsStream(
      requests: AsyncIterable<ProcessStreamRequest>,
      context: HandlerContext,
  ): AsyncGenerator<
      | ProcessStreamResponseV3
      | {
          $typeName?: undefined;
          processId?: number;
          value?: | { case: undefined; value?: undefined }
          | {
              case: "partitions";
              value:
                  | ProcessStreamResponse_Partitions
                  | {
                      $typeName?: undefined;
                      partitions?: {
                          [key: string]: | ProcessStreamResponse_Partitions_Partition
                          | { $typeName?: ...; value?: ... };
                          [key: number]:
                              | ProcessStreamResponse_Partitions_Partition
                              | { $typeName?: ...; value?: ... };
                      };
                  };
          }
          | {
              case: "dbRequest";
              value: | DBRequest
              | {
                  $typeName?: undefined;
                  op?: | { case: undefined; value?: undefined }
                  | {
                      case: "get";
                      value: DBRequest_DBGet | { $typeName?: ...; entity?: ...; id?: ... };
                  }
                  | {
                      case: "upsert";
                      value: | DBRequest_DBUpsert
                      | { $typeName?: ...; entity?: ...; entityData?: ...; id?: ... };
                  }
                  | {
                      case: "update";
                      value: | DBRequest_DBUpdate
                      | { $typeName?: ...; entity?: ...; entityData?: ...; id?: ... };
                  }
                  | {
                      case: "delete";
                      value: DBRequest_DBDelete
                      | { $typeName?: ...; entity?: ...; id?: ... };
                  }
                  | {
                      case: "list";
                      value: | DBRequest_DBList
                      | {
                          $typeName?: ...;
                          cursor?: ...;
                          entity?: ...;
                          filters?: ...;
                          pageSize?: ...;
                      };
                  };
                  opId?: bigint;
              };
          }
          | {
              case: "tsRequest";
              value: | TSRequest
              | {
                  $typeName?: undefined;
                  data?: (
                      | TimeseriesResult
                      | {
                          $typeName?: ...;
                          data?: ...;
                          metadata?: ...;
                          runtimeInfo?: ...;
                          type?: ...;
                      }
                  )[];
              };
          }
          | {
              case: "tplRequest";
              value: | TPLRequest
              | {
                  $typeName?: undefined;
                  remove?: boolean;
                  templates?: (
                      | TemplateInstance
                      | {
                          $typeName?: ...;
                          baseLabels?: ...;
                          contract?: ...;
                          endBlock?: ...;
                          startBlock?: ...;
                          templateId?: ...;
                      }
                  )[];
              };
          }
          | {
              case: "result";
              value: | ProcessResult
              | {
                  $typeName?: undefined;
                  exports?: (
                      | ExportResult
                      | { $typeName?: ...; metadata?: ...; payload?: ...; runtimeInfo?: ... }
                  )[];
                  states?: StateResult | { $typeName?: undefined; error?: string };
                  timeseriesResult?: (
                      | TimeseriesResult
                      | {
                          $typeName?: ...;
                          data?: ...;
                          metadata?: ...;
                          runtimeInfo?: ...;
                          type?: ...;
                      }
                  )[];
              };
          };
      },
      void,
      any,
  >

  Parameters

  • requests: AsyncIterable<ProcessStreamRequest>
  • context: HandlerContext

  Returns AsyncGenerator<
      | ProcessStreamResponseV3
      | {
          $typeName?: undefined;
          processId?: number;
          value?: | { case: undefined; value?: undefined }
          | {
              case: "partitions";
              value:
                  | ProcessStreamResponse_Partitions
                  | {
                      $typeName?: undefined;
                      partitions?: {
                          [key: string]: | ProcessStreamResponse_Partitions_Partition
                          | { $typeName?: ...; value?: ... };
                          [key: number]:
                              | ProcessStreamResponse_Partitions_Partition
                              | { $typeName?: ...; value?: ... };
                      };
                  };
          }
          | {
              case: "dbRequest";
              value: | DBRequest
              | {
                  $typeName?: undefined;
                  op?: | { case: undefined; value?: undefined }
                  | {
                      case: "get";
                      value: DBRequest_DBGet | { $typeName?: ...; entity?: ...; id?: ... };
                  }
                  | {
                      case: "upsert";
                      value: | DBRequest_DBUpsert
                      | { $typeName?: ...; entity?: ...; entityData?: ...; id?: ... };
                  }
                  | {
                      case: "update";
                      value: | DBRequest_DBUpdate
                      | { $typeName?: ...; entity?: ...; entityData?: ...; id?: ... };
                  }
                  | {
                      case: "delete";
                      value: DBRequest_DBDelete
                      | { $typeName?: ...; entity?: ...; id?: ... };
                  }
                  | {
                      case: "list";
                      value: | DBRequest_DBList
                      | {
                          $typeName?: ...;
                          cursor?: ...;
                          entity?: ...;
                          filters?: ...;
                          pageSize?: ...;
                      };
                  };
                  opId?: bigint;
              };
          }
          | {
              case: "tsRequest";
              value: | TSRequest
              | {
                  $typeName?: undefined;
                  data?: (
                      | TimeseriesResult
                      | {
                          $typeName?: ...;
                          data?: ...;
                          metadata?: ...;
                          runtimeInfo?: ...;
                          type?: ...;
                      }
                  )[];
              };
          }
          | {
              case: "tplRequest";
              value: | TPLRequest
              | {
                  $typeName?: undefined;
                  remove?: boolean;
                  templates?: (
                      | TemplateInstance
                      | {
                          $typeName?: ...;
                          baseLabels?: ...;
                          contract?: ...;
                          endBlock?: ...;
                          startBlock?: ...;
                          templateId?: ...;
                      }
                  )[];
              };
          }
          | {
              case: "result";
              value: | ProcessResult
              | {
                  $typeName?: undefined;
                  exports?: (
                      | ExportResult
                      | { $typeName?: ...; metadata?: ...; payload?: ...; runtimeInfo?: ... }
                  )[];
                  states?: StateResult | { $typeName?: undefined; error?: string };
                  timeseriesResult?: (
                      | TimeseriesResult
                      | {
                          $typeName?: ...;
                          data?: ...;
                          metadata?: ...;
                          runtimeInfo?: ...;
                          type?: ...;
                      }
                  )[];
              };
          };
      },
      void,
      any,
  >

start

• start(
      request?: MessageInit<StartRequest>,
      context?: HandlerContext,
  ): Promise<Message<"google.protobuf.Empty">>

  Parameters

  • request: MessageInit<StartRequest> = ...
  • context: HandlerContext = TEST_CONTEXT

  Returns Promise<Message<"google.protobuf.Empty">>

stop

• stop(
      request?: Message,
      context?: HandlerContext,
  ): Message<"google.protobuf.Empty">

  Parameters

  • request: Message = ...
  • context: HandlerContext = TEST_CONTEXT

  Returns Message<"google.protobuf.Empty">