ome.formats.importer

Class ImportLibrary

java.lang.Object

ome.formats.importer.ImportLibrary

All Implemented Interfaces:

IObservable

public class ImportLibrary
extends Object
implements IObservable

support class for the proper usage of OMEROMetadataStoreClient and FormatReader instances. This library was factored out of ImportHandler to support ImportFixture

Since:

3.0-M3

Author:

Josh Moore, josh.moore at gmx.de

See Also:

FormatReader, OMEROMetadataStoreClient, ImportFixture, IObservable, IObserver

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ImportLibrary.ImportCallback

Constructor Summary

Constructors

Constructor and Description
ImportLibrary(OMEROMetadataStoreClient client, OMEROWrapper reader) The default implementation of FileTransfer performs a no-op and therefore need not have FileTransfer#afterTransfer(int, File[]) as with the ImportLibrary(OMEROMetadataStoreClient, OMEROWrapper, FileTransfer) constructor.
ImportLibrary(OMEROMetadataStoreClient client, OMEROWrapper reader, FileTransfer transfer) The library will not close the client instance.
ImportLibrary(OMEROMetadataStoreClient client, OMEROWrapper reader, FileTransfer transfer, int minutesToWait)
ImportLibrary(OMEROMetadataStoreClient client, OMEROWrapper reader, FileTransfer transfer, List<FileExclusion> exclusions, int minutesToWait)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	addObserver(IObserver object) Add observer for notification
void	clear()
ImportLibrary.ImportCallback	createCallback(omero.grid.ImportProcessPrx proc, omero.cmd.HandlePrx handle, ImportContainer container)
omero.grid.ImportProcessPrx	createImport(ImportContainer container) Provide initial configuration to the server in order to create the ImportProcessPrx which will manage state server-side.
List<String>	deleteFilesFromRepository(ImportContainer container) Delete files from the managed repository.
boolean	deleteObserver(IObserver object) Delete observer
boolean	importCandidates(ImportConfig config, ImportCandidates candidates) Primary user method for importing a number
List<omero.model.Pixels>	importImage(ImportContainer container, int index, int numDone, int total) Perform an image import uploading files if necessary.
omero.model.OriginalFile	loadOriginalFile(omero.api.RawFileStorePrx uploader) Use RawFileStorePrx.getFileId() in order to load the OriginalFile that the service argument is acting on.
omero.grid.ManagedRepositoryPrx	lookupManagedRepository() Retrieves the first managed repository from the list of current active repositories.
void	notifyObservers(ImportEvent event) Notify observers of event
String	uploadFile(omero.grid.ImportProcessPrx proc, String[] srcFiles, int index, ChecksumProviderFactory cpf, TimeEstimator estimator, byte[] buf)
String	uploadFile(omero.grid.ImportProcessPrx proc, String[] srcFiles, int index, TimeEstimator estimator)
List<String>	uploadFilesToRepository(String[] srcFiles, omero.grid.ImportProcessPrx proc) Upload files to the managed repository.

Methods inherited from class java.lang.Object

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

Constructor Detail

ImportLibrary

public ImportLibrary(OMEROMetadataStoreClient client,
             OMEROWrapper reader)

The default implementation of FileTransfer performs a no-op and therefore need not have FileTransfer#afterTransfer(int, File[]) as with the ImportLibrary(OMEROMetadataStoreClient, OMEROWrapper, FileTransfer) constructor.

Parameters:

client -

reader -

ImportLibrary

public ImportLibrary(OMEROMetadataStoreClient client,
             OMEROWrapper reader,
             FileTransfer transfer)

The library will not close the client instance. The reader will be closed between calls to import. Note: the responsibility of closing FileTransfer#afterTransfer(int, File[]) falls to invokers of this method.

Parameters:

store - not null

reader - not null

ImportLibrary

public ImportLibrary(OMEROMetadataStoreClient client,
             OMEROWrapper reader,
             FileTransfer transfer,
             int minutesToWait)

ImportLibrary

public ImportLibrary(OMEROMetadataStoreClient client,
             OMEROWrapper reader,
             FileTransfer transfer,
             List<FileExclusion> exclusions,
             int minutesToWait)

Method Detail

addObserver

public boolean addObserver(IObserver object)

Description copied from interface: IObservable

Add observer for notification

Specified by:

addObserver in interface IObservable

Parameters:

object - - observer object

Returns:

true if added

deleteObserver

public boolean deleteObserver(IObserver object)

Description copied from interface: IObservable

Delete observer

Specified by:

deleteObserver in interface IObservable

Parameters:

object - - observer to delete

Returns:

true if deleted

notifyObservers

public void notifyObservers(ImportEvent event)

Description copied from interface: IObservable

Notify observers of event

Specified by:

notifyObservers in interface IObservable

Parameters:

event - - event that happened

importCandidates

public boolean importCandidates(ImportConfig config,
                       ImportCandidates candidates)

Primary user method for importing a number

Parameters:

config - The configuration information.

candidates - Hosts information about the files to import.

deleteFilesFromRepository

public List<String> deleteFilesFromRepository(ImportContainer container)
                                       throws omero.ServerError

Delete files from the managed repository.

Parameters:

container - The current import container containing usedFiles to be deleted.

Returns:

List of files that could not be deleted.

Throws:

omero.ServerError

createImport

public omero.grid.ImportProcessPrx createImport(ImportContainer container)
                                         throws omero.ServerError,
                                                IOException

Provide initial configuration to the server in order to create the ImportProcessPrx which will manage state server-side.

Throws:

IOException - if the used files' absolute path could not be found

omero.ServerError

uploadFilesToRepository

public List<String> uploadFilesToRepository(String[] srcFiles,
                                   omero.grid.ImportProcessPrx proc)

Upload files to the managed repository. This is done by first passing in the possibly absolute local file paths. A common selection of those are chosen and passed back to the client. As each file is written to the server, a message digest is kept updated of the bytes that are being written. These are then returned to the caller so they can be checked against the values found on the server.

Parameters:

container - The current import container we're to handle.

Returns:

A list of the client-side (i.e. local) hashes for each file.

uploadFile

public String uploadFile(omero.grid.ImportProcessPrx proc,
                String[] srcFiles,
                int index,
                TimeEstimator estimator)
                  throws omero.ServerError,
                         IOException

Throws:

omero.ServerError

IOException

uploadFile

public String uploadFile(omero.grid.ImportProcessPrx proc,
                String[] srcFiles,
                int index,
                ChecksumProviderFactory cpf,
                TimeEstimator estimator,
                byte[] buf)
                  throws omero.ServerError,
                         IOException

Throws:

omero.ServerError

IOException

importImage

public List<omero.model.Pixels> importImage(ImportContainer container,
                                   int index,
                                   int numDone,
                                   int total)
                                     throws loci.formats.FormatException,
                                            IOException,
                                            Throwable

Perform an image import uploading files if necessary.

Parameters:

container - The import container which houses all the configuration values and target for the import.

index - Index of the import in a set. 0 is safe if this is a singular import.

numDone - Number of imports completed in a set. 0 is safe if this is a singular import.

total - Total number of imports in a set. 1 is safe if this is a singular import.

Returns:

List of Pixels that have been imported.

Throws:

loci.formats.FormatException - If there is a Bio-Formats image file format error during import.

IOException - If there is an I/O error.

omero.ServerError - If there is an error communicating with the OMERO server we're importing into.

Throwable

Since:

OMERO Beta 4.2.1.

createCallback

public ImportLibrary.ImportCallback createCallback(omero.grid.ImportProcessPrx proc,
                                          omero.cmd.HandlePrx handle,
                                          ImportContainer container)
                                            throws omero.ServerError

Throws:

omero.ServerError

lookupManagedRepository

public omero.grid.ManagedRepositoryPrx lookupManagedRepository()

Retrieves the first managed repository from the list of current active repositories.

Returns:

Active proxy for the legacy repository.

clear

public void clear()

loadOriginalFile

public omero.model.OriginalFile loadOriginalFile(omero.api.RawFileStorePrx uploader)
                                          throws omero.ServerError

Use RawFileStorePrx.getFileId() in order to load the OriginalFile that the service argument is acting on.

Parameters:

uploader - not null

Returns:

Throws:

omero.ServerError