Class UploadStatusGrpcService

java.lang.Object
ai.pipestream.connector.intake.status.UploadStatusGrpcService

@ApplicationScoped public class UploadStatusGrpcService extends Object
gRPC handler for GetUploadStatus — the parity of GET /uploads/status/{token}. The signed token is the capability; a tampered/invalid/missing token maps to INVALID_ARGUMENT (the gRPC analogue of the HTTP 400) with a curated message, never internal detail. A valid token whose document is not yet projected reports PENDING.
  • Constructor Details

    • UploadStatusGrpcService

      public UploadStatusGrpcService()
  • Method Details

    • getUploadStatus

      public void getUploadStatus(ai.pipestream.connector.intake.v1.GetUploadStatusRequest request, io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.GetUploadStatusResponse> responseObserver)