Package org.saidone.service.content

Class S3ContentService

java.lang.Object
org.saidone.component.BaseComponent
org.saidone.service.content.S3ContentService
All Implemented Interfaces:
ContentService, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware
@Service @ConfigurationProperties(prefix="application.service.vault.storage") @ConditionalOnExpression("\'${application.service.vault.storage.impl:}\' == \'s3\'") public class S3ContentService extends BaseComponent implements ContentService
ContentService implementation that stores node binaries in Amazon S3.

During archival the content stream is written to a temporary file so the checksum can be computed before uploading. The resulting hash and other metadata are persisted as S3 user metadata. Retrieval operations return NodeContentStream and NodeContentInfo descriptors built from HeadObject and GetObject responses.

This service is enabled when application.service.vault.storage.impl is set to s3.

  • Constructor Details

    • S3ContentService

      public S3ContentService()

  • Method Details

    • archiveNodeContent

      public void archiveNodeContent(org.alfresco.core.model.Node node, InputStream inputStream)
      Saves the content stream of the given node to S3.

      The method computes the checksum while copying the payload to a temporary file, then uploads that file with Alfresco metadata (UUID, file name, MIME type, checksum algorithm and checksum value).

      Specified by:
      archiveNodeContent in interface ContentService
      Parameters:
      node - node whose content is being archived
      inputStream - input stream providing the node content

    • getNodeContent

      public NodeContentStream getNodeContent(String nodeId)
      Retrieves the content of a node from S3.
      Specified by:
      getNodeContent in interface ContentService
      Parameters:
      nodeId - identifier of the node
      Returns:
      descriptor containing file name, content type and the data stream
      Throws:
      NodeNotFoundOnVaultException - if the object is not found

    • getNodeContentInfo

      public NodeContentInfo getNodeContentInfo(String nodeId)
      Retrieves only the metadata of a node's content stored in S3 without streaming the actual binary.
      Specified by:
      getNodeContentInfo in interface ContentService
      Parameters:
      nodeId - identifier of the node
      Returns:
      a populated NodeContentInfo
      Throws:
      NodeNotFoundOnVaultException - if the object does not exist in S3

    • deleteNodeContent

      public void deleteNodeContent(String nodeId)
      Removes the stored object associated with the given node id.
      Specified by:
      deleteNodeContent in interface ContentService
      Parameters:
      nodeId - identifier of the node

    • computeHash

      public String computeHash(String nodeId, String algorithm)
      Computes the checksum of a stored object using the supplied algorithm.
      Specified by:
      computeHash in interface ContentService
      Parameters:
      nodeId - identifier of the node
      algorithm - name of the hash algorithm
      Returns:
      hexadecimal encoded hash string
      Throws:
      VaultException - if the object cannot be read from the vault

    • stop

      @PreDestroy public void stop()
      Description copied from class: BaseComponent
      Called just before the bean is destroyed. Logs a shutdown message indicating that the component is stopping.
      Overrides:
      stop in class BaseComponent