Class BatchReportClientRest
- java.lang.Object
-
- fr.gouv.vitam.common.client.DefaultClient
-
- fr.gouv.vitam.batch.report.client.BatchReportClientRest
-
- All Implemented Interfaces:
BatchReportClient
,BasicClient
,MockOrRestClient
,BasicClient
,VitamAutoCloseable
,java.lang.AutoCloseable
public class BatchReportClientRest extends DefaultClient implements BatchReportClient
-
-
Field Summary
-
Fields inherited from interface fr.gouv.vitam.common.client.BasicClient
STATUS_URL
-
Fields inherited from interface fr.gouv.vitam.common.external.client.BasicClient
STATUS_URL
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
appendReportEntries(ReportBody reportBody)
Append report entriesvoid
checkStatus()
Check the status from the servicevoid
checkStatus(javax.ws.rs.core.MultivaluedHashMap<java.lang.String,java.lang.Object> headers)
Check the status from the service used to passe "X-SSL-CLIENT-CERT" header that contain a pem certificatevoid
cleanupReport(java.lang.String processId, ReportType reportType)
Clean all entries with the given process Id tenant and reportTypevoid
close()
Close the underneath http clientvoid
consumeAnyEntityAndClose(javax.ws.rs.core.Response response)
Helper when an error occurs on client usage side to consume response howevervoid
createExtractedMetadataDistributionFileForAu(java.lang.String processId)
void
exportUnitsToInvalidate(java.lang.String processId, ReportExportRequest reportExportRequest)
Generate units to invalidate by process Id.void
generatePurgeAccessionRegisterReport(java.lang.String processId, ReportExportRequest reportExportRequest)
Generate elimination action accession register for deleted units by status and process Id.void
generatePurgeDistinctObjectGroupInUnitReport(java.lang.String processId, ReportExportRequest reportExportRequest)
Generate purge district object groups for units by status and process Id.javax.ws.rs.client.Client
getChunkedClient()
javax.ws.rs.client.Client
getClient()
VitamClientFactory<?>
getClientFactory()
java.lang.String
getResourcePath()
Get the resource path of the server.java.lang.String
getServiceUrl()
Get the service URLjavax.ws.rs.core.Response
make(VitamRequestBuilder request)
javax.ws.rs.core.Response
makeSpecifyingUrl(VitamRequestBuilder request)
static void
staticConsumeAnyEntityAndClose(javax.ws.rs.core.Response response)
This method consume everything (in particular InputStream) and close the response.void
storeExtractedMetadataForAu(java.util.List<ExtractedMetadata> extractedMetadata)
void
storeReportToWorkspace(Report reportInfo)
java.lang.String
toString()
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface fr.gouv.vitam.common.client.MockOrRestClient
checkStatus, checkStatus, close, consumeAnyEntityAndClose, getResourcePath, getServiceUrl
-
-
-
-
Method Detail
-
generatePurgeDistinctObjectGroupInUnitReport
public void generatePurgeDistinctObjectGroupInUnitReport(java.lang.String processId, ReportExportRequest reportExportRequest) throws VitamClientInternalException
Description copied from interface:BatchReportClient
Generate purge district object groups for units by status and process Id. Report is stored in JSONL format in workspace.- Specified by:
generatePurgeDistinctObjectGroupInUnitReport
in interfaceBatchReportClient
reportExportRequest
- report export request- Throws:
VitamClientInternalException
-
appendReportEntries
public void appendReportEntries(ReportBody reportBody) throws VitamClientInternalException
Description copied from interface:BatchReportClient
Append report entries- Specified by:
appendReportEntries
in interfaceBatchReportClient
- Parameters:
reportBody
- the given entry document.- Throws:
VitamClientInternalException
-
storeReportToWorkspace
public void storeReportToWorkspace(Report reportInfo) throws VitamClientInternalException
- Specified by:
storeReportToWorkspace
in interfaceBatchReportClient
- Throws:
VitamClientInternalException
-
exportUnitsToInvalidate
public void exportUnitsToInvalidate(java.lang.String processId, ReportExportRequest reportExportRequest) throws VitamClientInternalException
Description copied from interface:BatchReportClient
Generate units to invalidate by process Id. Report is stored in JSONL format without duplicates.- Specified by:
exportUnitsToInvalidate
in interfaceBatchReportClient
- Throws:
VitamClientInternalException
-
generatePurgeAccessionRegisterReport
public void generatePurgeAccessionRegisterReport(java.lang.String processId, ReportExportRequest reportExportRequest) throws VitamClientInternalException
Description copied from interface:BatchReportClient
Generate elimination action accession register for deleted units by status and process Id. Report is stored in JSONL format in workspace ORDERED BY opi.- Specified by:
generatePurgeAccessionRegisterReport
in interfaceBatchReportClient
reportExportRequest
- report export request- Throws:
VitamClientInternalException
-
cleanupReport
public void cleanupReport(java.lang.String processId, ReportType reportType) throws VitamClientInternalException
Description copied from interface:BatchReportClient
Clean all entries with the given process Id tenant and reportType- Specified by:
cleanupReport
in interfaceBatchReportClient
- Parameters:
processId
- the given process IdreportType
- report type- Throws:
VitamClientInternalException
-
storeExtractedMetadataForAu
public void storeExtractedMetadataForAu(java.util.List<ExtractedMetadata> extractedMetadata) throws VitamClientInternalException
- Specified by:
storeExtractedMetadataForAu
in interfaceBatchReportClient
- Throws:
VitamClientInternalException
-
createExtractedMetadataDistributionFileForAu
public void createExtractedMetadataDistributionFileForAu(java.lang.String processId) throws java.lang.Exception
- Specified by:
createExtractedMetadataDistributionFileForAu
in interfaceBatchReportClient
- Throws:
java.lang.Exception
-
staticConsumeAnyEntityAndClose
public static void staticConsumeAnyEntityAndClose(javax.ws.rs.core.Response response)
This method consume everything (in particular InputStream) and close the response.- Parameters:
response
-
-
consumeAnyEntityAndClose
public final void consumeAnyEntityAndClose(javax.ws.rs.core.Response response)
Description copied from interface:MockOrRestClient
Helper when an error occurs on client usage side to consume response however- Specified by:
consumeAnyEntityAndClose
in interfaceMockOrRestClient
-
checkStatus
public void checkStatus() throws VitamApplicationServerException
Description copied from interface:MockOrRestClient
Check the status from the service- Specified by:
checkStatus
in interfaceMockOrRestClient
- Throws:
VitamApplicationServerException
- if the Server is unavailable
-
checkStatus
public void checkStatus(javax.ws.rs.core.MultivaluedHashMap<java.lang.String,java.lang.Object> headers) throws VitamApplicationServerException
Description copied from interface:MockOrRestClient
Check the status from the service used to passe "X-SSL-CLIENT-CERT" header that contain a pem certificate- Specified by:
checkStatus
in interfaceMockOrRestClient
- Throws:
VitamApplicationServerException
- if the Server is unavailable
-
getResourcePath
public java.lang.String getResourcePath()
Description copied from interface:MockOrRestClient
Get the resource path of the server.- Specified by:
getResourcePath
in interfaceMockOrRestClient
- Returns:
- the resource path as string
-
getServiceUrl
public java.lang.String getServiceUrl()
Description copied from interface:MockOrRestClient
Get the service URL- Specified by:
getServiceUrl
in interfaceMockOrRestClient
- Returns:
- the service URL
-
close
public void close()
Description copied from interface:MockOrRestClient
Close the underneath http client- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfaceMockOrRestClient
- Specified by:
close
in interfaceVitamAutoCloseable
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
makeSpecifyingUrl
public javax.ws.rs.core.Response makeSpecifyingUrl(VitamRequestBuilder request) throws VitamClientInternalException
- Throws:
VitamClientInternalException
-
make
public javax.ws.rs.core.Response make(VitamRequestBuilder request) throws VitamClientInternalException
- Throws:
VitamClientInternalException
-
getClientFactory
public VitamClientFactory<?> getClientFactory()
-
getClient
public javax.ws.rs.client.Client getClient()
-
getChunkedClient
public javax.ws.rs.client.Client getChunkedClient()
-
-