Package io.clonecloudstore.accessor.server.application

Class AccessorObjectService

java.lang.Object

io.clonecloudstore.accessor.server.application.AccessorObjectService

All Implemented Interfaces:

AccessorObjectServiceInterface

@ApplicationScoped
public class AccessorObjectService
extends Object
implements AccessorObjectServiceInterface

Accessor Object Service

Constructor Summary

Constructors

Constructor	Description
AccessorObjectService(LocalReplicatorService localReplicatorService, jakarta.enterprise.inject.Instance<DaoAccessorBucketRepository> bucketRepositoryInstance, jakarta.enterprise.inject.Instance<DaoAccessorObjectRepository> objectRepositoryInstance, OwnershipApiClientFactory ownershipApiClientFactory, FilesystemHandler filesystemHandler)

Method Summary

Modifier and Type	Method	Description
ReplicatorResponse<AccessorObject>	checkPullable(String bucketName, String objectName, boolean external, String clientId, String opId)	Check from DB if Object is pullable
AccessorObject	createObject(AccessorObject accessorObject, String hash, long len, String clientId)	Before really creating Object, creates it in DB if possible
AccessorObject	createObjectFinalize(AccessorObject accessorObject, String hash, long len, String clientId, boolean external)	Once Object really created in Driver Storage, finalize the Object in DB and Replicator if needed
void	deleteObject(String bucketName, String objectName, String clientId, boolean external)	Delete object in DB and through Replicator if needed
InputStream	filterObjects(String bucketName, AccessorFilter filter, String clientId, boolean external)
void	generateReplicationOrderForObject(String bucketName, String objectOrDirectoryName, String clientId, String opId, String targetId, long len, String hash)
AccessorObject	getObjectInfo(String bucketName, String objectName, String clientId)	Get DB Object DTO
StorageObject	getObjectMetadata(String bucketName, String objectName)	Utility to get Object Metadata from Driver Storage
InputStreamBusinessOut<AccessorObject>	getRemotePullInputStream(String bucketName, String objectName, String clientId, String targetId, String opId)	When remote read is allowed, will try to read InputStream and DTO from remote
void	inError(String bucketName, String objectName)	Called only when QuarkusStreamHandler is in Error and Object in status UPLOAD or UNKNOWN
StorageType	objectOrDirectoryExists(String bucketName, String objectOrDirectoryName, boolean fullCheck, String clientId)	Check if object or directory exists (internal)
StorageType	objectOrDirectoryExists(String bucketName, String objectOrDirectoryName, boolean fullCheck, String clientId, String opId, boolean external)	Check if object or directory exists

Methods inherited from class java.lang.Object

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

Constructor Details

AccessorObjectService

public AccessorObjectService(LocalReplicatorService localReplicatorService,
 jakarta.enterprise.inject.Instance<DaoAccessorBucketRepository> bucketRepositoryInstance,
 jakarta.enterprise.inject.Instance<DaoAccessorObjectRepository> objectRepositoryInstance,
 OwnershipApiClientFactory ownershipApiClientFactory,
 FilesystemHandler filesystemHandler)

Method Details

objectOrDirectoryExists

public StorageType objectOrDirectoryExists(String bucketName,
 String objectOrDirectoryName,
 boolean fullCheck,
 String clientId)
                                    throws CcsOperationException

Check if object or directory exists (internal)

Specified by:

objectOrDirectoryExists in interface AccessorObjectServiceInterface

Parameters:

bucketName - bucket name

objectOrDirectoryName - prefix or full name

fullCheck - if True, and if Object, will check on Driver Storage

Returns:

the associated StorageType

Throws:

CcsOperationException

objectOrDirectoryExists

public StorageType objectOrDirectoryExists(String bucketName,
 String objectOrDirectoryName,
 boolean fullCheck,
 String clientId,
 String opId,
 boolean external)
                                    throws CcsOperationException

Check if object or directory exists

Specified by:

objectOrDirectoryExists in interface AccessorObjectServiceInterface

Throws:

CcsOperationException

generateReplicationOrderForObject

public void generateReplicationOrderForObject(String bucketName,
 String objectOrDirectoryName,
 String clientId,
 String opId,
 String targetId,
 long len,
 String hash)

filterObjects

public InputStream filterObjects(String bucketName,
 AccessorFilter filter,
 String clientId,
 boolean external)
                          throws CcsOperationException

Specified by:

filterObjects in interface AccessorObjectServiceInterface

Parameters:

bucketName - bucket name

filter - the filter to apply on Objects

external - True if bucket will be for external usage

Returns:

a stream (InputStream) of AccessorObject line by line (newline separated)

Throws:

CcsOperationException

checkPullable

public ReplicatorResponse<AccessorObject> checkPullable(String bucketName,
 String objectName,
 boolean external,
 String clientId,
 String opId)
                                                 throws CcsNotExistException,
CcsOperationException

Check from DB if Object is pullable

Throws:

CcsNotExistException

CcsOperationException

getRemotePullInputStream

public InputStreamBusinessOut<AccessorObject> getRemotePullInputStream(String bucketName,
 String objectName,
 String clientId,
 String targetId,
 String opId)
                                                                throws CcsNotExistException

When remote read is allowed, will try to read InputStream and DTO from remote

Throws:

CcsNotExistException

getObjectMetadata

public StorageObject getObjectMetadata(String bucketName,
 String objectName)
                                throws CcsNotExistException,
CcsOperationException

Utility to get Object Metadata from Driver Storage

Throws:

CcsNotExistException

CcsOperationException

getObjectInfo

public AccessorObject getObjectInfo(String bucketName,
 String objectName,
 String clientId)
                             throws CcsNotExistException,
CcsOperationException

Get DB Object DTO

Specified by:

getObjectInfo in interface AccessorObjectServiceInterface

Throws:

CcsNotExistException

CcsOperationException

createObject

public AccessorObject createObject(AccessorObject accessorObject,
 String hash,
 long len,
 String clientId)
                            throws CcsOperationException,
CcsAlreadyExistException,
CcsNotExistException,
CcsNotAcceptableException

Before really creating Object, creates it in DB if possible

Specified by:

createObject in interface AccessorObjectServiceInterface

Throws:

CcsNotAcceptableException - if already in creation step

CcsOperationException

CcsAlreadyExistException

CcsNotExistException

createObjectFinalize

public AccessorObject createObjectFinalize(AccessorObject accessorObject,
 String hash,
 long len,
 String clientId,
 boolean external)
                                    throws CcsOperationException

Once Object really created in Driver Storage, finalize the Object in DB and Replicator if needed

Specified by:

createObjectFinalize in interface AccessorObjectServiceInterface

Throws:

CcsOperationException

deleteObject

public void deleteObject(String bucketName,
 String objectName,
 String clientId,
 boolean external)
                  throws CcsDeletedException,
CcsNotExistException,
CcsOperationException

Delete object in DB and through Replicator if needed

Specified by:

deleteObject in interface AccessorObjectServiceInterface

Throws:

CcsDeletedException

CcsNotExistException

CcsOperationException

inError

public void inError(String bucketName,
 String objectName)

Called only when QuarkusStreamHandler is in Error and Object in status UPLOAD or UNKNOWN