com.haulmont.cuba.core.app.filestorage.amazon

Class AmazonS3FileStorage

java.lang.Object

com.haulmont.cuba.core.app.filestorage.amazon.AmazonS3FileStorage

All Implemented Interfaces:

FileStorageAPI

public class AmazonS3FileStorage
extends java.lang.Object
implements FileStorageAPI

Field Summary

Fields

Modifier and Type	Field and Description
protected AmazonS3Config	amazonS3Config

Fields inherited from interface com.haulmont.cuba.core.app.FileStorageAPI

NAME

Constructor Summary

Constructors

Constructor and Description
AmazonS3FileStorage()

Method Summary

Modifier and Type	Method and Description
protected java.lang.String	createAuthorizationHeader(java.net.URL endpointUrl, java.lang.String method, java.util.Map<java.lang.String,java.lang.String> headers)
boolean	fileExists(FileDescriptor fileDescr) Tests whether the file denoted by this file descriptor exists.
protected java.lang.String	getAccessKey()
protected java.net.URL	getAmazonUrl(FileDescriptor fileDescr)
protected java.lang.String	getBucket()
protected java.lang.String	getFileName(FileDescriptor fileDescriptor)
protected java.lang.String	getInputStreamContent(HttpUtils.HttpResponse httpResponse)
protected java.lang.String	getRegionName()
protected java.lang.String	getS3StorageClass()
protected java.util.Map<java.lang.String,java.lang.String>	getSaveStreamHttpHeaders(FileDescriptor fileDescr, int chunkSize, AWS4SignerForChunkedUpload signer)
protected java.lang.String	getSecretAccessKey()
protected java.lang.String	getStorageDir(java.util.Date createDate) INTERNAL.
byte[]	loadFile(FileDescriptor fileDescr) Load a file contents into byte array.
java.io.InputStream	openStream(FileDescriptor fileDescr) Return an input stream to load a file contents.
void	removeFile(FileDescriptor fileDescr) Remove a file from the file storage.
protected java.lang.String	resolveFileName(FileDescriptor fileDescr)
void	saveFile(FileDescriptor fileDescr, byte[] data) Save a byte array into file storage.
long	saveStream(FileDescriptor fileDescr, java.io.InputStream inputStream) Save an InputStream contents into file storage.

Methods inherited from class java.lang.Object

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

Field Detail

amazonS3Config

@Inject
protected AmazonS3Config amazonS3Config

Constructor Detail

AmazonS3FileStorage

public AmazonS3FileStorage()

Method Detail

saveStream

public long saveStream(FileDescriptor fileDescr,
                       java.io.InputStream inputStream)
                throws FileStorageException

Description copied from interface: FileStorageAPI

Save an InputStream contents into file storage.

Specified by:

saveStream in interface FileStorageAPI

Parameters:

fileDescr - file descriptor

inputStream - input stream, must be closed in the calling code

Returns:

number of bytes saved

Throws:

FileStorageException - if something goes wrong

saveFile

public void saveFile(FileDescriptor fileDescr,
                     byte[] data)
              throws FileStorageException

Description copied from interface: FileStorageAPI

Save a byte array into file storage.

Specified by:

saveFile in interface FileStorageAPI

Parameters:

fileDescr - file descriptor

data - byte array

Throws:

FileStorageException - if something goes wrong

removeFile

public void removeFile(FileDescriptor fileDescr)
                throws FileStorageException

Description copied from interface: FileStorageAPI

Remove a file from the file storage.

Specified by:

removeFile in interface FileStorageAPI

Parameters:

fileDescr - file descriptor

Throws:

FileStorageException - if something goes wrong

openStream

public java.io.InputStream openStream(FileDescriptor fileDescr)
                               throws FileStorageException

Description copied from interface: FileStorageAPI

Return an input stream to load a file contents.

Specified by:

openStream in interface FileStorageAPI

Parameters:

fileDescr - file descriptor

Returns:

input stream, must be closed after use

Throws:

FileStorageException - if something goes wrong

loadFile

public byte[] loadFile(FileDescriptor fileDescr)
                throws FileStorageException

Description copied from interface: FileStorageAPI

Load a file contents into byte array.

Specified by:

loadFile in interface FileStorageAPI

Parameters:

fileDescr - file descriptor

Returns:

file contents

Throws:

FileStorageException - if something goes wrong

fileExists

public boolean fileExists(FileDescriptor fileDescr)

Description copied from interface: FileStorageAPI

Tests whether the file denoted by this file descriptor exists.

Specified by:

fileExists in interface FileStorageAPI

Parameters:

fileDescr - file descriptor

Returns:

true if the file denoted by this file descriptor exists

resolveFileName

protected java.lang.String resolveFileName(FileDescriptor fileDescr)

getStorageDir

protected java.lang.String getStorageDir(java.util.Date createDate)

INTERNAL. Don't use in application code.

getAmazonUrl

protected java.net.URL getAmazonUrl(FileDescriptor fileDescr)

getFileName

protected java.lang.String getFileName(FileDescriptor fileDescriptor)

createAuthorizationHeader

protected java.lang.String createAuthorizationHeader(java.net.URL endpointUrl,
                                                     java.lang.String method,
                                                     java.util.Map<java.lang.String,java.lang.String> headers)

getInputStreamContent

protected java.lang.String getInputStreamContent(HttpUtils.HttpResponse httpResponse)

getSaveStreamHttpHeaders

protected java.util.Map<java.lang.String,java.lang.String> getSaveStreamHttpHeaders(FileDescriptor fileDescr,
                                                                                    int chunkSize,
                                                                                    AWS4SignerForChunkedUpload signer)

getS3StorageClass

protected java.lang.String getS3StorageClass()

getRegionName

protected java.lang.String getRegionName()

getBucket

protected java.lang.String getBucket()

getSecretAccessKey

protected java.lang.String getSecretAccessKey()

getAccessKey

protected java.lang.String getAccessKey()