@Test public void isExistingObjectNonExistingObject() throws Exception { doReturn(Optional.empty()) .when(objectReferentialRepository).find(any(), any()); boolean existingObject = tapeLibraryContentAddressableStorage.isExistingObject("containerName", "objectName"); assertThat(existingObject).isFalse(); verify(objectReferentialRepository).find("containerName", "objectName"); Mockito.verifyNoMoreInteractions(basicFileStorage, objectReferentialRepository, archiveReferentialRepository, fileBucketTarCreatorManager, readWriteQueueRepository, tapeCatalogService); }
@Override public boolean isExistingObject(String containerName, String objectName) throws ContentAddressableStorageServerException { LOGGER.debug(String.format("Check existence of object %s in container %s", objectName, containerName)); try { Optional<TapeObjectReferentialEntity> objectReferentialEntity = objectReferentialRepository.find(containerName, objectName); return objectReferentialEntity.isPresent(); } catch (ObjectReferentialException ex) { throw new ContentAddressableStorageServerException( String.format("Could not check existence of object %s in container %s", objectName, containerName), ex); } }
TapeLibraryContentAddressableStorage implements ContentAddressableStorage { @Override public boolean isExistingObject(String containerName, String objectName) throws ContentAddressableStorageServerException { LOGGER.debug(String.format("Check existence of object %s in container %s", objectName, containerName)); try { Optional<TapeObjectReferentialEntity> objectReferentialEntity = objectReferentialRepository.find(containerName, objectName); return objectReferentialEntity.isPresent(); } catch (ObjectReferentialException ex) { throw new ContentAddressableStorageServerException( String.format("Could not check existence of object %s in container %s", objectName, containerName), ex); } } }
TapeLibraryContentAddressableStorage implements ContentAddressableStorage { @Override public boolean isExistingObject(String containerName, String objectName) throws ContentAddressableStorageServerException { LOGGER.debug(String.format("Check existence of object %s in container %s", objectName, containerName)); try { Optional<TapeObjectReferentialEntity> objectReferentialEntity = objectReferentialRepository.find(containerName, objectName); return objectReferentialEntity.isPresent(); } catch (ObjectReferentialException ex) { throw new ContentAddressableStorageServerException( String.format("Could not check existence of object %s in container %s", objectName, containerName), ex); } } TapeLibraryContentAddressableStorage(
        BasicFileStorage basicFileStorage,
        ObjectReferentialRepository objectReferentialRepository,
        ArchiveReferentialRepository archiveReferentialRepository,
        ReadRequestReferentialRepository readRequestReferentialRepository,
        FileBucketTarCreatorManager fileBucketTarCreatorManager,
        QueueRepository readWriteQueue, TapeCatalogService tapeCatalogService,
        String outputTarStorageFolder,
        ArchiveOutputRetentionPolicy archiveOutputRetentionPolicy); }
TapeLibraryContentAddressableStorage implements ContentAddressableStorage { @Override public boolean isExistingObject(String containerName, String objectName) throws ContentAddressableStorageServerException { LOGGER.debug(String.format("Check existence of object %s in container %s", objectName, containerName)); try { Optional<TapeObjectReferentialEntity> objectReferentialEntity = objectReferentialRepository.find(containerName, objectName); return objectReferentialEntity.isPresent(); } catch (ObjectReferentialException ex) { throw new ContentAddressableStorageServerException( String.format("Could not check existence of object %s in container %s", objectName, containerName), ex); } } TapeLibraryContentAddressableStorage(
        BasicFileStorage basicFileStorage,
        ObjectReferentialRepository objectReferentialRepository,
        ArchiveReferentialRepository archiveReferentialRepository,
        ReadRequestReferentialRepository readRequestReferentialRepository,
        FileBucketTarCreatorManager fileBucketTarCreatorManager,
        QueueRepository readWriteQueue, TapeCatalogService tapeCatalogService,
        String outputTarStorageFolder,
        ArchiveOutputRetentionPolicy archiveOutputRetentionPolicy); @Override void createContainer(String containerName); @Override boolean isExistingContainer(String containerName); @Override String putObject(String containerName, String objectName, InputStream stream, DigestType digestType,
        Long size); @Override ObjectContent getObject(String containerName, String objectName); @Override String createReadOrderRequest(String containerName, List<String> objectsIds); @Override void removeReadOrderRequest(String readRequestID); @Override void deleteObject(String containerName, String objectName); @Override boolean isExistingObject(String containerName, String objectName); @Override String getObjectDigest(String containerName, String objectName, DigestType algo, boolean noCache); @Override ContainerInformation getContainerInformation(String containerName); @Override MetadatasObject getObjectMetadata(String containerName, String objectName, boolean noCache); @Override void listContainer(String containerName, ObjectListingListener objectListingListener); @Override void close(); }
TapeLibraryContentAddressableStorage implements ContentAddressableStorage { @Override public boolean isExistingObject(String containerName, String objectName) throws ContentAddressableStorageServerException { LOGGER.debug(String.format("Check existence of object %s in container %s", objectName, containerName)); try { Optional<TapeObjectReferentialEntity> objectReferentialEntity = objectReferentialRepository.find(containerName, objectName); return objectReferentialEntity.isPresent(); } catch (ObjectReferentialException ex) { throw new ContentAddressableStorageServerException( String.format("Could not check existence of object %s in container %s", objectName, containerName), ex); } } TapeLibraryContentAddressableStorage(
        BasicFileStorage basicFileStorage,
        ObjectReferentialRepository objectReferentialRepository,
        ArchiveReferentialRepository archiveReferentialRepository,
        ReadRequestReferentialRepository readRequestReferentialRepository,
        FileBucketTarCreatorManager fileBucketTarCreatorManager,
        QueueRepository readWriteQueue, TapeCatalogService tapeCatalogService,
        String outputTarStorageFolder,
        ArchiveOutputRetentionPolicy archiveOutputRetentionPolicy); @Override void createContainer(String containerName); @Override boolean isExistingContainer(String containerName); @Override String putObject(String containerName, String objectName, InputStream stream, DigestType digestType,
        Long size); @Override ObjectContent getObject(String containerName, String objectName); @Override String createReadOrderRequest(String containerName, List<String> objectsIds); @Override void removeReadOrderRequest(String readRequestID); @Override void deleteObject(String containerName, String objectName); @Override boolean isExistingObject(String containerName, String objectName); @Override String getObjectDigest(String containerName, String objectName, DigestType algo, boolean noCache); @Override ContainerInformation getContainerInformation(String containerName); @Override MetadatasObject getObjectMetadata(String containerName, String objectName, boolean noCache); @Override void listContainer(String containerName, ObjectListingListener objectListingListener); @Override void close();  }