Class LogbookOperationsClientMock
- java.lang.Object
-
- fr.gouv.vitam.common.client.AbstractMockClient
-
- fr.gouv.vitam.logbook.operations.client.LogbookOperationsClientMock
-
- All Implemented Interfaces:
BasicClient
,MockOrRestClient
,VitamAutoCloseable
,LogbookOperationsClient
,java.lang.AutoCloseable
public class LogbookOperationsClientMock extends AbstractMockClient implements LogbookOperationsClient
Mock client implementation for logbook operation
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class fr.gouv.vitam.common.client.AbstractMockClient
AbstractMockClient.FakeInboundResponse
-
-
Field Summary
-
Fields inherited from interface fr.gouv.vitam.common.client.BasicClient
STATUS_URL
-
-
Constructor Summary
Constructors Constructor Description LogbookOperationsClientMock()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
bulkCreate(java.lang.String eventIdProc, java.lang.Iterable<LogbookOperationParameters> queue)
Bulk Create
To be used ONLY once at top level of process startup (where eventIdentifierProcess is set for the first time).void
bulkUpdate(java.lang.String eventIdProc, java.lang.Iterable<LogbookOperationParameters> queue)
Bulk Update
To be used everywhere except very first time (when eventIdentifierProcess already used once)LifecycleTraceabilityStatus
checkLifecycleTraceabilityWorkflowStatus(java.lang.String operationId)
Check life cycle traceability status (unit / got)LogbookCheckResult
checkLogbookCoherence()
checkLogbookCoherencevoid
close()
Close the underneath http clientvoid
commitCreateDelegate(java.lang.String eventIdProc)
Finalize logbook entry using delegation
To be used ONLY once at top level of process startup (where eventIdentifierProcess is set for the first time).void
commitUpdateDelegate(java.lang.String eventIdProc)
Finalize logbook entry using delegation
To be used everywhere except very first time (when eventIdentifierProcess already used once)void
create(LogbookOperationParameters parameters)
Create logbook entry
To be used ONLY once at top level of process startup (where eventIdentifierProcess is set for the first time).void
createDelegate(LogbookOperationParameters parameters)
Create logbook entry using delegation
To be used ONLY once at top level of process startup (where eventIdentifierProcess is set for the first time).RequestResponse<com.fasterxml.jackson.databind.JsonNode>
getLastOperationByType(java.lang.String operationType)
void
reconstructCollection(java.util.List<ReconstructionRequestItem> reconstructionItems)
ReindexationResult
reindex(IndexParameters indexParam)
Reindex a collection with parameterscom.fasterxml.jackson.databind.JsonNode
selectOperation(com.fasterxml.jackson.databind.JsonNode select)
com.fasterxml.jackson.databind.JsonNode
selectOperation(com.fasterxml.jackson.databind.JsonNode select, boolean isSliced, boolean isCrossTenant)
com.fasterxml.jackson.databind.JsonNode
selectOperationById(java.lang.String id)
com.fasterxml.jackson.databind.JsonNode
selectOperationById(java.lang.String processId, com.fasterxml.jackson.databind.JsonNode query, boolean isSliced, boolean isCrossTenant)
SwitchIndexResult
switchIndexes(SwitchIndexParameters switchIndexParam)
Switch indexesRequestResponseOK<TenantLogbookOperationTraceabilityResult>
traceability(java.util.List<java.lang.Integer> tenants)
Call traceability logbook operation for requested tenantsvoid
traceabilityAudit(int tenant, AuditLogbookOptions options)
RequestResponseOK<java.lang.String>
traceabilityLfcObjectGroup()
Starts Object Group logbook lifecycle traceabilityRequestResponseOK<java.lang.String>
traceabilityLfcUnit()
Starts Unit logbook lifecycle traceabilityvoid
update(LogbookOperationParameters parameters)
Update logbook entry
To be used everywhere except very first time (when eventIdentifierProcess already used once)void
updateDelegate(LogbookOperationParameters parameters)
Update logbook entry using delegation
To be used everywhere except very first time (when eventIdentifierProcess already used once)-
Methods inherited from class fr.gouv.vitam.common.client.AbstractMockClient
checkStatus, checkStatus, 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, consumeAnyEntityAndClose, getResourcePath, getServiceUrl
-
-
-
-
Method Detail
-
create
public void create(LogbookOperationParameters parameters) throws LogbookClientBadRequestException, LogbookClientAlreadyExistsException, LogbookClientServerException
Description copied from interface:LogbookOperationsClient
Create logbook entry
To be used ONLY once at top level of process startup (where eventIdentifierProcess is set for the first time).- Specified by:
create
in interfaceLogbookOperationsClient
- Parameters:
parameters
- the entry parameters- Throws:
LogbookClientBadRequestException
- if the argument is incorrectLogbookClientAlreadyExistsException
- if the element already existsLogbookClientServerException
- if the Server got an internal error
-
update
public void update(LogbookOperationParameters parameters) throws LogbookClientBadRequestException, LogbookClientNotFoundException, LogbookClientServerException
Description copied from interface:LogbookOperationsClient
Update logbook entry
To be used everywhere except very first time (when eventIdentifierProcess already used once)- Specified by:
update
in interfaceLogbookOperationsClient
- Parameters:
parameters
- the entry parameters- Throws:
LogbookClientBadRequestException
- if the argument is incorrectLogbookClientNotFoundException
- if the element was not created beforeLogbookClientServerException
- if the Server got an internal error
-
selectOperation
public com.fasterxml.jackson.databind.JsonNode selectOperation(com.fasterxml.jackson.databind.JsonNode select) throws LogbookClientException, InvalidParseOperationException
- Specified by:
selectOperation
in interfaceLogbookOperationsClient
- Returns:
- logbook operation as JsonNode
- Throws:
LogbookClientException
InvalidParseOperationException
-
selectOperation
public com.fasterxml.jackson.databind.JsonNode selectOperation(com.fasterxml.jackson.databind.JsonNode select, boolean isSliced, boolean isCrossTenant) throws LogbookClientException, InvalidParseOperationException
- Specified by:
selectOperation
in interfaceLogbookOperationsClient
- Throws:
LogbookClientException
InvalidParseOperationException
-
selectOperationById
public com.fasterxml.jackson.databind.JsonNode selectOperationById(java.lang.String processId, com.fasterxml.jackson.databind.JsonNode query, boolean isSliced, boolean isCrossTenant) throws LogbookClientException, InvalidParseOperationException
- Specified by:
selectOperationById
in interfaceLogbookOperationsClient
- Throws:
LogbookClientException
InvalidParseOperationException
-
selectOperationById
public com.fasterxml.jackson.databind.JsonNode selectOperationById(java.lang.String id) throws LogbookClientException, InvalidParseOperationException
- Specified by:
selectOperationById
in interfaceLogbookOperationsClient
- Parameters:
id
- identifier- Returns:
- logbook operation as String
- Throws:
LogbookClientException
- LogbookClientExceptionInvalidParseOperationException
- InvalidParseOperationException
-
traceability
public RequestResponseOK<TenantLogbookOperationTraceabilityResult> traceability(java.util.List<java.lang.Integer> tenants)
Description copied from interface:LogbookOperationsClient
Call traceability logbook operation for requested tenants- Specified by:
traceability
in interfaceLogbookOperationsClient
- Returns:
- logbook operation result per tenant
-
createDelegate
public void createDelegate(LogbookOperationParameters parameters) throws LogbookClientAlreadyExistsException
Description copied from interface:LogbookOperationsClient
Create logbook entry using delegation
To be used ONLY once at top level of process startup (where eventIdentifierProcess is set for the first time).- Specified by:
createDelegate
in interfaceLogbookOperationsClient
- Parameters:
parameters
- the entry parameters (can be reused and modified after without impacting the one created)- Throws:
LogbookClientAlreadyExistsException
- if the element already exists
-
updateDelegate
public void updateDelegate(LogbookOperationParameters parameters) throws LogbookClientNotFoundException
Description copied from interface:LogbookOperationsClient
Update logbook entry using delegation
To be used everywhere except very first time (when eventIdentifierProcess already used once)- Specified by:
updateDelegate
in interfaceLogbookOperationsClient
- Parameters:
parameters
- the entry parameters (can be reused and modified after without impacting the one updated)- Throws:
LogbookClientNotFoundException
- if the element does not yet exists (createDeletage not called before)
-
bulkCreate
public void bulkCreate(java.lang.String eventIdProc, java.lang.Iterable<LogbookOperationParameters> queue) throws LogbookClientBadRequestException
Description copied from interface:LogbookOperationsClient
Bulk Create
To be used ONLY once at top level of process startup (where eventIdentifierProcess is set for the first time).- Specified by:
bulkCreate
in interfaceLogbookOperationsClient
- Parameters:
eventIdProc
- event Process Identifierqueue
- queue of LogbookOperationParameters to create- Throws:
LogbookClientBadRequestException
- if the argument is incorrect
-
bulkUpdate
public void bulkUpdate(java.lang.String eventIdProc, java.lang.Iterable<LogbookOperationParameters> queue) throws LogbookClientBadRequestException
Description copied from interface:LogbookOperationsClient
Bulk Update
To be used everywhere except very first time (when eventIdentifierProcess already used once)- Specified by:
bulkUpdate
in interfaceLogbookOperationsClient
- Parameters:
eventIdProc
- event Process Identifierqueue
- queue of LogbookOperationParameters to update- Throws:
LogbookClientBadRequestException
- if the argument is incorrect
-
commitCreateDelegate
public void commitCreateDelegate(java.lang.String eventIdProc) throws LogbookClientBadRequestException
Description copied from interface:LogbookOperationsClient
Finalize logbook entry using delegation
To be used ONLY once at top level of process startup (where eventIdentifierProcess is set for the first time).- Specified by:
commitCreateDelegate
in interfaceLogbookOperationsClient
- Parameters:
eventIdProc
- event Process Identifier- Throws:
LogbookClientBadRequestException
- if the argument is incorrect
-
commitUpdateDelegate
public void commitUpdateDelegate(java.lang.String eventIdProc) throws LogbookClientBadRequestException
Description copied from interface:LogbookOperationsClient
Finalize logbook entry using delegation
To be used everywhere except very first time (when eventIdentifierProcess already used once)- Specified by:
commitUpdateDelegate
in interfaceLogbookOperationsClient
- Parameters:
eventIdProc
- event Process Identifier- Throws:
LogbookClientBadRequestException
- if the argument is incorrect
-
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
- Overrides:
close
in classAbstractMockClient
-
traceabilityLfcUnit
public RequestResponseOK<java.lang.String> traceabilityLfcUnit()
Description copied from interface:LogbookOperationsClient
Starts Unit logbook lifecycle traceability- Specified by:
traceabilityLfcUnit
in interfaceLogbookOperationsClient
- Returns:
- logbook lifecycles as String
-
traceabilityLfcObjectGroup
public RequestResponseOK<java.lang.String> traceabilityLfcObjectGroup()
Description copied from interface:LogbookOperationsClient
Starts Object Group logbook lifecycle traceability- Specified by:
traceabilityLfcObjectGroup
in interfaceLogbookOperationsClient
- Returns:
- logbook lifecycles as String
-
reindex
public ReindexationResult reindex(IndexParameters indexParam) throws InvalidParseOperationException
Description copied from interface:LogbookOperationsClient
Reindex a collection with parameters- Specified by:
reindex
in interfaceLogbookOperationsClient
- Parameters:
indexParam
- reindexation parameters- Returns:
- JsonObject containing information about the newly created index
- Throws:
InvalidParseOperationException
-
switchIndexes
public SwitchIndexResult switchIndexes(SwitchIndexParameters switchIndexParam) throws InvalidParseOperationException
Description copied from interface:LogbookOperationsClient
Switch indexes- Specified by:
switchIndexes
in interfaceLogbookOperationsClient
- Parameters:
switchIndexParam
- switch index parameters- Returns:
- JsonObject containing information about the newly created index
- Throws:
InvalidParseOperationException
-
traceabilityAudit
public void traceabilityAudit(int tenant, AuditLogbookOptions options)
- Specified by:
traceabilityAudit
in interfaceLogbookOperationsClient
-
checkLogbookCoherence
public LogbookCheckResult checkLogbookCoherence()
Description copied from interface:LogbookOperationsClient
checkLogbookCoherence- Specified by:
checkLogbookCoherence
in interfaceLogbookOperationsClient
- Returns:
- result
-
getLastOperationByType
public RequestResponse<com.fasterxml.jackson.databind.JsonNode> getLastOperationByType(java.lang.String operationType)
- Specified by:
getLastOperationByType
in interfaceLogbookOperationsClient
-
reconstructCollection
public void reconstructCollection(java.util.List<ReconstructionRequestItem> reconstructionItems) throws LogbookClientServerException
- Specified by:
reconstructCollection
in interfaceLogbookOperationsClient
- Throws:
LogbookClientServerException
-
checkLifecycleTraceabilityWorkflowStatus
public LifecycleTraceabilityStatus checkLifecycleTraceabilityWorkflowStatus(java.lang.String operationId)
Description copied from interface:LogbookOperationsClient
Check life cycle traceability status (unit / got)- Specified by:
checkLifecycleTraceabilityWorkflowStatus
in interfaceLogbookOperationsClient
- Parameters:
operationId
- the process id- Returns:
- lifecycle traceability status
-
-