@Test public void downloadIngestManifestsAsStream() throws Exception { RestAssured.given() .header(GlobalDataRest.X_TENANT_ID, TENANT_ID) .header(GlobalDataRest.X_CONTEXT_ID, Contexts.DEFAULT_WORKFLOW) .when().get(INGEST_URI + "/1/" + IngestCollection.MANIFESTS.getCollectionName()) .then().statusCode(Status.OK.getStatusCode()); }
@GET @Path("/ingests/{objectId}/manifests") @Produces(MediaType.APPLICATION_OCTET_STREAM) @Secured(permission = "ingests:id:manifests:read", description = "Récupérer le bordereau de versement pour une opération d'entrée donnée") public Response downloadIngestManifestsAsStream(@PathParam("objectId") String objectId) { return downloadObjectAsync(objectId, IngestCollection.MANIFESTS); }
IngestExternalResource extends ApplicationStatusResource { @GET @Path("/ingests/{objectId}/manifests") @Produces(MediaType.APPLICATION_OCTET_STREAM) @Secured(permission = "ingests:id:manifests:read", description = "Récupérer le bordereau de versement pour une opération d'entrée donnée") public Response downloadIngestManifestsAsStream(@PathParam("objectId") String objectId) { return downloadObjectAsync(objectId, IngestCollection.MANIFESTS); } }
IngestExternalResource extends ApplicationStatusResource { @GET @Path("/ingests/{objectId}/manifests") @Produces(MediaType.APPLICATION_OCTET_STREAM) @Secured(permission = "ingests:id:manifests:read", description = "Récupérer le bordereau de versement pour une opération d'entrée donnée") public Response downloadIngestManifestsAsStream(@PathParam("objectId") String objectId) { return downloadObjectAsync(objectId, IngestCollection.MANIFESTS); } IngestExternalResource(
        IngestExternalConfiguration ingestExternalConfiguration,
        SecureEndpointRegistry secureEndpointRegistry,
        FormatIdentifierFactory formatIdentifierFactory,
        IngestInternalClientFactory ingestInternalClientFactory); }
IngestExternalResource extends ApplicationStatusResource { @GET @Path("/ingests/{objectId}/manifests") @Produces(MediaType.APPLICATION_OCTET_STREAM) @Secured(permission = "ingests:id:manifests:read", description = "Récupérer le bordereau de versement pour une opération d'entrée donnée") public Response downloadIngestManifestsAsStream(@PathParam("objectId") String objectId) { return downloadObjectAsync(objectId, IngestCollection.MANIFESTS); } IngestExternalResource(
        IngestExternalConfiguration ingestExternalConfiguration,
        SecureEndpointRegistry secureEndpointRegistry,
        FormatIdentifierFactory formatIdentifierFactory,
        IngestInternalClientFactory ingestInternalClientFactory); @Path("/") @OPTIONS @Produces(MediaType.APPLICATION_JSON) @Unsecured() Response listResourceEndpoints(); @Path("ingests") @POST @Consumes(MediaType.APPLICATION_OCTET_STREAM) @Secured(permission = "ingests:create", description = "Envoyer un SIP à Vitam afin qu'il en réalise l'entrée") void upload(
        @HeaderParam(GlobalDataRest.X_CONTEXT_ID) String contextId,
        @HeaderParam(GlobalDataRest.X_ACTION) String action,
        @HeaderParam(GlobalDataRest.X_MANIFEST_DIGEST_ALGORITHM) String manifestDigestAlgo,
        @HeaderParam(GlobalDataRest.X_MANIFEST_DIGEST_VALUE) String manifestDigestValue,
        InputStream uploadedInputStream,
        @Suspended final AsyncResponse asyncResponse); @Path("ingests") @POST @Consumes(MediaType.APPLICATION_JSON) @Secured(permission = "ingests:local:create", description = "Envoyer un SIP en local à Vitam afin qu'il en réalise l'entrée") void uploadLocal(
        @HeaderParam(GlobalDataRest.X_CONTEXT_ID) String contextId,
        @HeaderParam(GlobalDataRest.X_ACTION) String action,
        @HeaderParam(GlobalDataRest.X_MANIFEST_DIGEST_ALGORITHM) String manifestDigestAlgo,
        @HeaderParam(GlobalDataRest.X_MANIFEST_DIGEST_VALUE) String manifestDigestValue,
        LocalFile localFile,
        @Suspended final AsyncResponse asyncResponse); @GET @Path("/ingests/{objectId}/archivetransferreply") @Produces(MediaType.APPLICATION_OCTET_STREAM) @Secured(permission = "ingests:id:archivetransfertreply:read", description = "Récupérer l'accusé de récéption pour une opération d'entrée donnée") Response downloadArchiveTransferReplyAsStream(@PathParam("objectId") String objectId); @GET @Path("/ingests/{objectId}/manifests") @Produces(MediaType.APPLICATION_OCTET_STREAM) @Secured(permission = "ingests:id:manifests:read", description = "Récupérer le bordereau de versement pour une opération d'entrée donnée") Response downloadIngestManifestsAsStream(@PathParam("objectId") String objectId); }
IngestExternalResource extends ApplicationStatusResource { @GET @Path("/ingests/{objectId}/manifests") @Produces(MediaType.APPLICATION_OCTET_STREAM) @Secured(permission = "ingests:id:manifests:read", description = "Récupérer le bordereau de versement pour une opération d'entrée donnée") public Response downloadIngestManifestsAsStream(@PathParam("objectId") String objectId) { return downloadObjectAsync(objectId, IngestCollection.MANIFESTS); } IngestExternalResource(
        IngestExternalConfiguration ingestExternalConfiguration,
        SecureEndpointRegistry secureEndpointRegistry,
        FormatIdentifierFactory formatIdentifierFactory,
        IngestInternalClientFactory ingestInternalClientFactory); @Path("/") @OPTIONS @Produces(MediaType.APPLICATION_JSON) @Unsecured() Response listResourceEndpoints(); @Path("ingests") @POST @Consumes(MediaType.APPLICATION_OCTET_STREAM) @Secured(permission = "ingests:create", description = "Envoyer un SIP à Vitam afin qu'il en réalise l'entrée") void upload(
        @HeaderParam(GlobalDataRest.X_CONTEXT_ID) String contextId,
        @HeaderParam(GlobalDataRest.X_ACTION) String action,
        @HeaderParam(GlobalDataRest.X_MANIFEST_DIGEST_ALGORITHM) String manifestDigestAlgo,
        @HeaderParam(GlobalDataRest.X_MANIFEST_DIGEST_VALUE) String manifestDigestValue,
        InputStream uploadedInputStream,
        @Suspended final AsyncResponse asyncResponse); @Path("ingests") @POST @Consumes(MediaType.APPLICATION_JSON) @Secured(permission = "ingests:local:create", description = "Envoyer un SIP en local à Vitam afin qu'il en réalise l'entrée") void uploadLocal(
        @HeaderParam(GlobalDataRest.X_CONTEXT_ID) String contextId,
        @HeaderParam(GlobalDataRest.X_ACTION) String action,
        @HeaderParam(GlobalDataRest.X_MANIFEST_DIGEST_ALGORITHM) String manifestDigestAlgo,
        @HeaderParam(GlobalDataRest.X_MANIFEST_DIGEST_VALUE) String manifestDigestValue,
        LocalFile localFile,
        @Suspended final AsyncResponse asyncResponse); @GET @Path("/ingests/{objectId}/archivetransferreply") @Produces(MediaType.APPLICATION_OCTET_STREAM) @Secured(permission = "ingests:id:archivetransfertreply:read", description = "Récupérer l'accusé de récéption pour une opération d'entrée donnée") Response downloadArchiveTransferReplyAsStream(@PathParam("objectId") String objectId); @GET @Path("/ingests/{objectId}/manifests") @Produces(MediaType.APPLICATION_OCTET_STREAM) @Secured(permission = "ingests:id:manifests:read", description = "Récupérer le bordereau de versement pour une opération d'entrée donnée") Response downloadIngestManifestsAsStream(@PathParam("objectId") String objectId);  }