Package ai.pipeline.connector.intake.service

Class DocumentProcessor

java.lang.Object

ai.pipeline.connector.intake.service.DocumentProcessor

@ApplicationScoped
public class DocumentProcessor
extends Object

Simplified Document Processor. Logic for enriching and wrapping documents before sending to Repo. DB tracking and SHA calculation moved to async Kafka handlers (post-upload).

Constructor Summary

Constructors

Constructor	Description
DocumentProcessor()	Default constructor for CDI.

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Void>	processBlob(UploadBlobRequest request)	Process a Blob upload request.
io.smallrye.mutiny.Uni<Void>	processPipeDoc(UploadPipeDocRequest request)	Process a PipeDoc upload request.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DocumentProcessor

public DocumentProcessor()

Default constructor for CDI.

Method Details

processPipeDoc

public io.smallrye.mutiny.Uni<Void> processPipeDoc(UploadPipeDocRequest request)

Process a PipeDoc upload request. Currently a pass-through, but placeholder for future pre-upload validation/enrichment.

Parameters:

request - the inbound PipeDoc request to process

Returns:

a Uni<Void> that completes when processing finishes

processBlob

public io.smallrye.mutiny.Uni<Void> processBlob(UploadBlobRequest request)

Process a Blob upload request. Currently a pass-through, but placeholder for future pre-upload validation/enrichment.

Parameters:

request - the inbound Blob request to process

Returns:

a Uni<Void> that completes when processing finishes