Package de.dlr.proseo.storagemgr.posix

Class PosixStorage

java.lang.Object
de.dlr.proseo.storagemgr.posix.PosixStorage
All Implemented Interfaces:
Storage
public class PosixStorage extends Object implements Storage
An implementation of the Storage interface for a POSIX-based file system, providing functionality to interact with the storage system, that is retrieving information about the storage, performing file operations, and path conversion. This class assumes a no-bucket concept for POSIX storage.
Author:
Denys Chaykovskiy

  • Constructor Details

    • PosixStorage

      public PosixStorage(PosixConfiguration cfg)
      No bucket constructor initializing the storage with a basePath and sourcePath. It creates the necessary directories if they don't exist.
      Parameters:
      cfg - POSIX configuration

  • Method Details

    • getStorageType

      public StorageType getStorageType()
      Gets the storage type.
      Specified by:
      getStorageType in interface Storage
      Returns:
      the storage type

    • getBasePath

      public String getBasePath()
      Gets the base path.
      Specified by:
      getBasePath in interface Storage
      Returns:
      the base path

    • getAbsoluteBasePath

      public String getAbsoluteBasePath()
      Gets the absolute base path (file system prefix + bucket + base path). In this no-bucket POSIX version, it returns the base path.
      Specified by:
      getAbsoluteBasePath in interface Storage
      Returns:
      the absolute base path

    • getSourcePath

      public String getSourcePath()
      Gets the source path.
      Specified by:
      getSourcePath in interface Storage
      Returns:
      the source path

    • setBucket

      public void setBucket(String bucket)
      Sets the bucket.
      Specified by:
      setBucket in interface Storage
      Parameters:
      bucket - the bucket to set

    • getBucket

      public String getBucket()
      Gets the bucket.
      Specified by:
      getBucket in interface Storage
      Returns:
      the current bucket

    • getBuckets

      public List<String> getBuckets()
      Gets the buckets from the storage.
      Specified by:
      getBuckets in interface Storage
      Returns:
      the list of buckets (one bucket)

    • bucketExists

      public boolean bucketExists(String bucketName)
      Checks if the bucket exists. In the one-bucket concept, it compares with the current bucket.
      Specified by:
      bucketExists in interface Storage
      Parameters:
      bucketName - the name of the bucket
      Returns:
      true if the bucket exists

    • deleteBucket

      public void deleteBucket(String bucket) throws IOException
      Deletes the bucket from the storage.
      Specified by:
      deleteBucket in interface Storage
      Parameters:
      bucket - the bucket to delete
      Throws:
      IOException - if the bucket cannot be deleted

    • getRelativeFiles

      public List<String> getRelativeFiles(String relativePath)
      Gets files from the storage with the given prefix (folder).
      Specified by:
      getRelativeFiles in interface Storage
      Parameters:
      relativePath - the prefix (folder) for searching in the storage
      Returns:
      the list of files with the given prefix

    • getRelativeFiles

      public List<String> getRelativeFiles()
      Gets all files from the storage.
      Specified by:
      getRelativeFiles in interface Storage
      Returns:
      the list of all files from the storage

    • getAbsoluteFiles

      public List<String> getAbsoluteFiles(String relativePath)
      Gets files (absolute paths) from the storage with the given prefix (folder).
      Specified by:
      getAbsoluteFiles in interface Storage
      Parameters:
      relativePath - the prefix (relative path) for searching in the storage
      Returns:
      the list of files with the given prefix

    • getAbsoluteFiles

      public List<String> getAbsoluteFiles()
      Gets all files (absolute paths) from the storage.
      Specified by:
      getAbsoluteFiles in interface Storage
      Returns:
      the list of all files from the storage

    • getRelativePath

      public String getRelativePath(String absolutePath)
      Gets the relative path from the absolute path using the base path list.
      Specified by:
      getRelativePath in interface Storage
      Parameters:
      absolutePath - the absolute path
      Returns:
      the relative path

    • getRelativePath

      public List<String> getRelativePath(List<String> absolutePaths)
      Gets the relative paths from the absolute paths using the base path list.
      Specified by:
      getRelativePath in interface Storage
      Parameters:
      absolutePaths - the absolute paths
      Returns:
      the relative paths

    • getAbsolutePath

      public String getAbsolutePath(String relativePath)
      Gets the absolute path (POSIX: /<storagePath>/<relativePath>).
      Specified by:
      getAbsolutePath in interface Storage
      Parameters:
      relativePath - the relative path
      Returns:
      the absolute file depending on the storage file system

    • getAbsolutePath

      public List<String> getAbsolutePath(List<String> relativePaths)
      Gets the absolute paths (POSIX: /<storagePath>/<relativePath>).
      Specified by:
      getAbsolutePath in interface Storage
      Parameters:
      relativePaths - the relative paths
      Returns:
      the absolute paths depending on the storage file system

    • getStorageFile

      public StorageFile getStorageFile(String relativePath)
      Gets the storage file.
      Specified by:
      getStorageFile in interface Storage
      Parameters:
      relativePath - the relative path in storage to the file
      Returns:
      the storage file object

    • getStorageFiles

      public List<StorageFile> getStorageFiles()
      Gets the storage files.
      Specified by:
      getStorageFiles in interface Storage
      Returns:
      the list of storage files

    • createStorageFile

      public StorageFile createStorageFile(String relativePath, String content) throws IOException
      Creates a physical storage file.
      Specified by:
      createStorageFile in interface Storage
      Parameters:
      relativePath - the relative path of the file
      content - the content of the file
      Returns:
      the storage file object of the created file
      Throws:
      IOException - if the file cannot be created

    • fileExists

      public boolean fileExists(StorageFile storageFile)
      Checks if the file exists.
      Specified by:
      fileExists in interface Storage
      Parameters:
      storageFile - the storage file to check
      Returns:
      true if the file exists physically

    • isFile

      public boolean isFile(StorageFile storageFileOrDir)
      Checks if the storage file or directory is a file (no slash at the end of the path).
      Specified by:
      isFile in interface Storage
      Parameters:
      storageFileOrDir - the storage file or directory
      Returns:
      true if the storage file is a file

    • isDirectory

      public boolean isDirectory(StorageFile storageFileOrDir)
      Checks if the storage file or directory is a directory.
      Specified by:
      isDirectory in interface Storage
      Parameters:
      storageFileOrDir - the storage file or directory
      Returns:
      true if the storage file is a file

    • getFileSize

      public long getFileSize(StorageFile storageFile)
      Gets the file size.
      Specified by:
      getFileSize in interface Storage
      Parameters:
      storageFile - the storage file
      Returns:
      the file size of the storage file

    • getFileContent

      public String getFileContent(StorageFile storageFile) throws IOException
      Gets the file content.
      Specified by:
      getFileContent in interface Storage
      Parameters:
      storageFile - the storage file
      Returns:
      the file content
      Throws:
      IOException - if an error occurs while getting the file content

    • uploadFile

      public String uploadFile(StorageFile sourceFile, StorageFile targetFileOrDir) throws IOException
      Uploads the file to the storage.
      Specified by:
      uploadFile in interface Storage
      Parameters:
      sourceFile - the source file to upload
      targetFileOrDir - the target file or directory in the storage
      Returns:
      the uploaded storage file
      Throws:
      IOException - if the file cannot be uploaded

    • upload

      public List<String> upload(StorageFile sourceFileOrDir, StorageFile targetFileOrDir) throws IOException
      Uploads the file or directory recursively to the storage.
      Specified by:
      upload in interface Storage
      Parameters:
      sourceFileOrDir - the source file or directory
      targetFileOrDir - the target file or directory in the storage
      Returns:
      the list of uploaded files
      Throws:
      IOException - if the file or directory cannot be uploaded

    • upload

      public List<String> upload(StorageFile sourceFileOrDir) throws IOException
      Uploads the file or directory recursively to the storage.
      Specified by:
      upload in interface Storage
      Parameters:
      sourceFileOrDir - the source file or dir to upload
      Returns:
      the list of uploaded files
      Throws:
      IOException - if the file or directory cannot be uploaded

    • uploadFile

      public String uploadFile(StorageFile sourceFile) throws IOException
      Uploads the file to the storage.
      Specified by:
      uploadFile in interface Storage
      Parameters:
      sourceFile - the source file to upload
      Returns:
      the path of the uploaded file
      Throws:
      IOException - if the file cannot be uploaded

    • uploadSourceFileOrDir

      public List<String> uploadSourceFileOrDir(String relativeSourceFileOrDir) throws IOException
      Uploads the source file or directory recursively to the storage.
      Specified by:
      uploadSourceFileOrDir in interface Storage
      Parameters:
      relativeSourceFileOrDir - the relative path to source file or directory
      Returns:
      the list of uploaded files to the storage
      Throws:
      IOException - if the file or directory cannot be uploaded

    • uploadSourceFile

      public String uploadSourceFile(String relativeSourceFile) throws IOException
      Uploads the source file to the storage.
      Specified by:
      uploadSourceFile in interface Storage
      Parameters:
      relativeSourceFile - the relative path to the source file
      Returns:
      the uploaded source file
      Throws:
      IOException - if the file cannot be uploaded

    • download

      public List<String> download(StorageFile sourceFileOrDir, StorageFile targetFileOrDir) throws IOException
      Downloads the file or directory from the storage.
      Specified by:
      download in interface Storage
      Parameters:
      sourceFileOrDir - the storage source file or directory to download
      targetFileOrDir - the target file or directory
      Returns:
      the list of downloaded files
      Throws:
      IOException - if the file cannot be downloaded

    • downloadFile

      public String downloadFile(StorageFile sourceFile, StorageFile targetFileOrDir) throws IOException
      Downloads the file from the storage.
      Specified by:
      downloadFile in interface Storage
      Parameters:
      sourceFile - the storage source file to download
      targetFileOrDir - the target file or directory
      Returns:
      the downloaded storage file
      Throws:
      IOException - if the file cannot be downloaded

    • delete

      public List<String> delete(StorageFile storageFileOrDir) throws IOException
      Deletes the file or directory recursively from the storage.
      Specified by:
      delete in interface Storage
      Parameters:
      storageFileOrDir - the storage file or directory to delete
      Returns:
      the list of deleted files from the storage
      Throws:
      IOException - if the file or directory cannot be deleted

    • deleteFile

      public String deleteFile(StorageFile storageFile) throws IOException
      Deletes the storage file from the storage.
      Specified by:
      deleteFile in interface Storage
      Parameters:
      storageFile - the storage file to delete
      Returns:
      the deleted storage file
      Throws:
      IOException - if the file cannot be deleted

    • delete

      public List<String> delete(String relativeFileOrDir) throws IOException
      Deletes the file or directory recursively from the storage.
      Specified by:
      delete in interface Storage
      Parameters:
      relativeFileOrDir - the relative path to the storage file or directory to delete
      Returns:
      the list of deleted files from the storage
      Throws:
      IOException - if the file or directory cannot be deleted

    • addFSPrefix

      public String addFSPrefix(String path)
      Adds the file system prefix to the path.
      Specified by:
      addFSPrefix in interface Storage
      Parameters:
      path - the path to extend
      Returns:
      the file system prefix + "|" + path

    • addFSPrefix

      public List<String> addFSPrefix(List<String> paths)
      Adds the file system prefix to the paths.
      Specified by:
      addFSPrefix in interface Storage
      Parameters:
      paths - the paths to extend
      Returns:
      the list of file system prefix + path

    • getInputStream

      public InputStream getInputStream(StorageFile storageFile) throws IOException
      Gets the input stream from the file.
      Specified by:
      getInputStream in interface Storage
      Parameters:
      storageFile - the storage file
      Returns:
      the input stream from the file
      Throws:
      IOException - if an error occurs while getting the input stream