Class TestProcessorHelper

java.lang.Object
ai.pipestream.module.pipelineprobe.TestProcessorHelper
public class TestProcessorHelper extends Object
Helper class for building test requests to the TestProcessor. This makes it easier to test different scenarios with the test module.

  • Method Details

    • toPipeStream

      public static ai.pipestream.data.v1.PipeStream toPipeStream(ai.pipestream.data.module.v1.ProcessDataRequest request)
      Converts a legacy ProcessDataRequest fixture into the PipeStream the demand-pull TestProcessor consumes.
      Parameters:
      request - the request fixture to convert
      Returns:
      the equivalent PipeStream, carrying the stream id, hop count, current node id, graph id, config params (including string/boolean JSON-config fields as context params), and document

    • documentBuilder

      public static TestProcessorHelper.TestDocumentBuilder documentBuilder()
      Creates a builder for test documents.
      Returns:
      a new TestProcessorHelper.TestDocumentBuilder

    • requestBuilder

      public static TestProcessorHelper.TestRequestBuilder requestBuilder()
      Creates a builder for test requests.
      Returns:
      a new TestProcessorHelper.TestRequestBuilder

    • createValidDocument

      public static ai.pipestream.data.v1.PipeDoc createValidDocument()
      Creates a valid document with all required fields for schema validation.
      Returns:
      a document with a title, body, and source custom field

    • createDocumentWithoutTitle

      public static ai.pipestream.data.v1.PipeDoc createDocumentWithoutTitle()
      Creates a document missing the title field (invalid for schema validation).
      Returns:
      a document with a body and source custom field but no title

    • createDocumentWithoutBody

      public static ai.pipestream.data.v1.PipeDoc createDocumentWithoutBody()
      Creates a document missing the body field (invalid for schema validation).
      Returns:
      a document with a title and source custom field but no body

    • createSimpleRequest

      public static ai.pipestream.data.module.v1.ProcessDataRequest createSimpleRequest()
      Creates a simple test request with a valid document.
      Returns:
      a request wrapping a valid document with default config

    • createSchemaValidationRequest

      public static ai.pipestream.data.module.v1.ProcessDataRequest createSchemaValidationRequest(ai.pipestream.data.v1.PipeDoc document)
      Creates a request configured for schema validation mode.
      Parameters:
      document - the document to validate
      Returns:
      a request wrapping the document in TestProcessorHelper.ProcessingMode.VALIDATE mode

    • createErrorRequest

      public static ai.pipestream.data.module.v1.ProcessDataRequest createErrorRequest()
      Creates a request configured to simulate an error.
      Returns:
      a request wrapping a valid document with simulateError enabled