fr.gouv.vitam.ingest.internal.client

Class IngestInternalClientMock

java.lang.Object

fr.gouv.vitam.common.client.AbstractMockClient

fr.gouv.vitam.ingest.internal.client.IngestInternalClientMock

All Implemented Interfaces:

MockOrRestClient, VitamAutoCloseable, IngestInternalClient, AutoCloseable

public class IngestInternalClientMock
extends AbstractMockClient
implements IngestInternalClient

Mock client implementation for Ingest Internal

Nested Class Summary

Nested classes/interfaces inherited from class fr.gouv.vitam.common.client.AbstractMockClient

AbstractMockClient.FakeInboundResponse

Field Summary

Fields

Modifier and Type	Field and Description
static String	ID identifier of execution
static String	MOCK_INGEST_INTERNAL_RESPONSE_STREAM mock ingest response

Fields inherited from class fr.gouv.vitam.common.client.AbstractMockClient

INTERNAL_SERVER_ERROR

Constructor Summary

Constructors

Constructor and Description
IngestInternalClientMock()

Method Summary

Modifier and Type	Method and Description
RequestResponse<ItemStatus>	cancelOperationProcessExecution(String id) cancelOperationProcessExecution : cancel processing operation
javax.ws.rs.core.Response	downloadObjectAsync(String objectId, IngestCollection type) Download object stored by ingest operation
RequestResponse<ItemStatus>	getOperationProcessExecutionDetails(String id) getOperationProcessExecutionDetails : get operation processing execution details
ItemStatus	getOperationProcessStatus(String id) getOperationProcessStatus: get operation process status**
RequestResponse<WorkFlow>	getWorkflowDefinitions() Retrieve all the workflow definitions.
Optional<WorkFlow>	getWorkflowDetails(String WorkflowIdentifier)
void	initWorkflow(WorkFlow contextId) initWorkflow : init workFlow Process
RequestResponse<ProcessDetail>	listOperationsDetails(ProcessQuery query) Retrieve all the workflow operations
void	storeATR(GUID guid, InputStream input) Store ATR in storage
RequestResponse<ItemStatus>	updateOperationActionProcess(String actionId, String operationId) updateOperationActionProcess : update operation processing status
void	upload(InputStream inputStream, javax.ws.rs.core.MediaType archiveType, WorkFlow workflowIdentifier, String action) Upload compressed SIP as stream
void	uploadFinalLogbook(Iterable<LogbookOperationParameters> logbookParametersList) Finalize the ingest operation by sending back the final Logbook Operation entries from Ingest external
void	uploadInitialLogbook(Iterable<LogbookOperationParameters> logbookParametersList) Create only Logbook

Methods inherited from class fr.gouv.vitam.common.client.AbstractMockClient

checkStatus, checkStatus, close, consumeAnyEntityAndClose, getResourcePath, getServiceUrl

Methods inherited from class java.lang.Object

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

Methods inherited from interface fr.gouv.vitam.common.client.MockOrRestClient

checkStatus, checkStatus, close, consumeAnyEntityAndClose, getResourcePath, getServiceUrl

Field Detail

MOCK_INGEST_INTERNAL_RESPONSE_STREAM

public static final String MOCK_INGEST_INTERNAL_RESPONSE_STREAM

mock ingest response

See Also:

Constant Field Values

ID

public static final String ID

identifier of execution

See Also:

Constant Field Values

Constructor Detail

IngestInternalClientMock

public IngestInternalClientMock()

Method Detail

upload

public void upload(InputStream inputStream,
                   javax.ws.rs.core.MediaType archiveType,
                   WorkFlow workflowIdentifier,
                   String action)

Description copied from interface: IngestInternalClient

Upload compressed SIP as stream

Specified by:

upload in interface IngestInternalClient

Parameters:

inputStream - SIP

archiveType - is a format (mime type) of SIP (should be zip ,tar, tar.gz or tar.bz2)

workflowIdentifier - workflow information

action - Identifier

uploadInitialLogbook

public void uploadInitialLogbook(Iterable<LogbookOperationParameters> logbookParametersList)

Description copied from interface: IngestInternalClient

Create only Logbook

Specified by:

uploadInitialLogbook in interface IngestInternalClient

uploadFinalLogbook

public void uploadFinalLogbook(Iterable<LogbookOperationParameters> logbookParametersList)

Description copied from interface: IngestInternalClient

Finalize the ingest operation by sending back the final Logbook Operation entries from Ingest external

Specified by:

uploadFinalLogbook in interface IngestInternalClient

downloadObjectAsync

public javax.ws.rs.core.Response downloadObjectAsync(String objectId,
                                                     IngestCollection type)

Description copied from interface: IngestInternalClient

Download object stored by ingest operation

Specified by:

downloadObjectAsync in interface IngestInternalClient

Returns:

object as stream

storeATR

public void storeATR(GUID guid,
                     InputStream input)

Description copied from interface: IngestInternalClient

Store ATR in storage

Specified by:

storeATR in interface IngestInternalClient

getOperationProcessStatus

public ItemStatus getOperationProcessStatus(String id)

Description copied from interface: IngestInternalClient

getOperationProcessStatus: get operation process status**

Specified by:

getOperationProcessStatus in interface IngestInternalClient

Parameters:

id - : operation identifier*

Returns:

ItemStatus response containing message and status*

getOperationProcessExecutionDetails

public RequestResponse<ItemStatus> getOperationProcessExecutionDetails(String id)

Description copied from interface: IngestInternalClient

getOperationProcessExecutionDetails : get operation processing execution details

Specified by:

getOperationProcessExecutionDetails in interface IngestInternalClient

Parameters:

id - : operation identifier

Returns:

Engine response containing message and status

cancelOperationProcessExecution

public RequestResponse<ItemStatus> cancelOperationProcessExecution(String id)

Description copied from interface: IngestInternalClient

cancelOperationProcessExecution : cancel processing operation

Specified by:

cancelOperationProcessExecution in interface IngestInternalClient

Parameters:

id - : operation identifier

Returns:

ItemStatus response containing message and status

updateOperationActionProcess

public RequestResponse<ItemStatus> updateOperationActionProcess(String actionId,
                                                                String operationId)

Description copied from interface: IngestInternalClient

updateOperationActionProcess : update operation processing status

Specified by:

updateOperationActionProcess in interface IngestInternalClient

Parameters:

actionId - : identify the action to be executed by the workflow(next , pause,resume)

operationId - : operation identifier

Returns:

Response containing message and status

initWorkflow

public void initWorkflow(WorkFlow contextId)

Description copied from interface: IngestInternalClient

initWorkflow : init workFlow Process

Specified by:

initWorkflow in interface IngestInternalClient

Parameters:

contextId - information

listOperationsDetails

public RequestResponse<ProcessDetail> listOperationsDetails(ProcessQuery query)

Description copied from interface: IngestInternalClient

Retrieve all the workflow operations

Specified by:

listOperationsDetails in interface IngestInternalClient

Parameters:

query - Query model

Returns:

All details of the operations

getWorkflowDefinitions

public RequestResponse<WorkFlow> getWorkflowDefinitions()

Description copied from interface: IngestInternalClient

Retrieve all the workflow definitions.

Specified by:

getWorkflowDefinitions in interface IngestInternalClient

Returns:

workflow definitions

getWorkflowDetails

public Optional<WorkFlow> getWorkflowDetails(String WorkflowIdentifier)

Specified by:

getWorkflowDetails in interface IngestInternalClient

Returns: