ome.services.scripts

Class ScriptRepoHelper

java.lang.Object

ome.tools.spring.OnContextRefreshedEventListener

ome.services.scripts.ScriptRepoHelper

All Implemented Interfaces:

EventListener, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationListener<org.springframework.context.event.ContextRefreshedEvent>

public class ScriptRepoHelper
extends OnContextRefreshedEventListener

Strategy used by the ScriptRepository for registering, loading, and saving files.

Since:

Beta4.2

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.commons.io.filefilter.IOFileFilter	BASE_SCRIPT_FILTER IOFileFilter instance used during iterate() to find the matching scripts in the given directory.
protected org.slf4j.Logger	log
static String	SCRIPT_REPO Id used by all script repositories.

Constructor Summary

Constructors

Constructor and Description
ScriptRepoHelper(Executor ex, String sessionUuid, Roles roles)
ScriptRepoHelper(File dir, Executor ex, Principal p, Roles roles)
ScriptRepoHelper(String uuid, File dir, Executor ex, Principal p, Roles roles)

Method Summary

Methods

Modifier and Type	Method and Description
ome.model.core.OriginalFile	addOrReplace(RepoFile repoFile, Long old)
protected ome.model.core.OriginalFile	addOrReplace(org.hibernate.Session session, ome.util.SqlAction sqlAction, ServiceFactory sf, RepoFile repoFile, Long old)
void	buildQuery(QueryBuilder qb) Adds a single clause of the form "AND (A OR B ...)" where each ScriptFileType A, B, etc. is given a chance to define its own clause.
int	countInDb()
int	countInDb(ome.util.SqlAction sql)
int	countOnDisk() Returns the number of files which match scriptFilter in dir.
boolean	delete(long id)
protected Map.Entry<String,ScriptFileType>	findByMimetype(String mimetype) Search through all ScriptFileType instances and find one with a matching mimetype string.
Long	findInDb(RepoFile file, boolean scriptsOnly)
Long	findInDb(ome.util.SqlAction sql, RepoFile repoFile, boolean scriptsOnly) Looks to see if a path is contained in the repository.
Long	findInDb(String path, boolean scriptsOnly)
static String	getDefaultScriptDir() Directory which will be used as the root of this repository if no directory is passed to a constructor.
String	getLauncher(String mimetype) Find an "omero.launcher..." property string for the given mimetype or return "" if none is found.
String	getProcess(String mimetype) Find an "omero.process..." property string for the given mimetype or return "" if none is found.
String	getScriptDir() Returns the actual root of this repository.
String	getUuid() Uuid of this repository.
void	handleContextRefreshedEvent(org.springframework.context.event.ContextRefreshedEvent event) Loads all ScriptFileType instances from the context, and uses them to initialize all scripts in the repo.
List<Long>	idsInDb()
List<Long>	idsInDb(ome.util.SqlAction sql)
boolean	isInRepo(long id)
boolean	isInRepo(ome.util.SqlAction sql, long id)
Iterator<File>	iterate()
ome.model.core.OriginalFile	load(long id, boolean check)
ome.model.core.OriginalFile	load(long id, org.hibernate.Session s, ome.util.SqlAction sqlAction, boolean check)
List<ome.model.core.OriginalFile>	loadAll(boolean modificationCheck) Walks all files in the repository (via iterate() and adds them if not found in the database.
void	modificationCheck() Checks if
String	read(String path)
long	removeMissingFilesFromDb(ome.util.SqlAction sqlAction, org.hibernate.Session session, List<ome.model.core.OriginalFile> filesOnDisk) Given the current files on disk, #unregister(Long, Session) all files which have been removed from disk.
void	setMimetype(ome.model.core.OriginalFile ofile)
void	simpleDelete(Map<String,String> context, Executor executor, Principal p, long id) Unlike delete(long) this method simply performs the DB delete on the given original file id.
protected void	unregister(Long old, ome.util.SqlAction sqlAction) Unregisters a given file from the script repository by setting its Repo uuid to null.
ome.model.core.OriginalFile	update(RepoFile repoFile, Long id, Map<String,String> context)
RepoFile	write(RepoFile repo, String text)
RepoFile	write(String path, String text)

Methods inherited from class ome.tools.spring.OnContextRefreshedEventListener

onApplicationEvent, setApplicationContext

Methods inherited from class java.lang.Object

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

Field Detail

SCRIPT_REPO

public static final String SCRIPT_REPO

Id used by all script repositories. Having a well defined string allows for various repositories to all provide the same functionality.

See Also:

Constant Field Values

BASE_SCRIPT_FILTER

public static final org.apache.commons.io.filefilter.IOFileFilter BASE_SCRIPT_FILTER

IOFileFilter instance used during iterate() to find the matching scripts in the given directory.

log

protected final org.slf4j.Logger log

Constructor Detail

ScriptRepoHelper

public ScriptRepoHelper(Executor ex,
                String sessionUuid,
                Roles roles)

See Also:

#ScriptRepoHelper(String, File, Executor, Principal)

ScriptRepoHelper

public ScriptRepoHelper(File dir,
                Executor ex,
                Principal p,
                Roles roles)

See Also:

#ScriptRepoHelper(String, File, Executor, Principal)

ScriptRepoHelper

public ScriptRepoHelper(String uuid,
                File dir,
                Executor ex,
                Principal p,
                Roles roles)

Parameters:

uuid - Allows setting a non-default uuid for this script service. Primarily for testing, since services rely on the repository name for finding one another.

dir - The directory used by the repo as its root. Other constructors use getDefaultScriptDir() internally.

ex -

p -

Method Detail

handleContextRefreshedEvent

public void handleContextRefreshedEvent(org.springframework.context.event.ContextRefreshedEvent event)

Loads all ScriptFileType instances from the context, and uses them to initialize all scripts in the repo.

Specified by:

handleContextRefreshedEvent in class OnContextRefreshedEventListener

buildQuery

public void buildQuery(QueryBuilder qb)

Adds a single clause of the form "AND (A OR B ...)" where each ScriptFileType A, B, etc. is given a chance to define its own clause.

setMimetype

public void setMimetype(ome.model.core.OriginalFile ofile)

findByMimetype

protected Map.Entry<String,ScriptFileType> findByMimetype(String mimetype)

Search through all ScriptFileType instances and find one with a matching mimetype string. Otherwise, return null.

getLauncher

public String getLauncher(String mimetype)

Find an "omero.launcher..." property string for the given mimetype or return "" if none is found.

getProcess

public String getProcess(String mimetype)

Find an "omero.process..." property string for the given mimetype or return "" if none is found.

getDefaultScriptDir

public static String getDefaultScriptDir()

Directory which will be used as the root of this repository if no directory is passed to a constructor. Equivalent to "lib/scripts" from the current directory.

getScriptDir

public String getScriptDir()

Returns the actual root of this repository.

See Also:

getDefaultScriptDir()

getUuid

public String getUuid()

Uuid of this repository. In the normal case, this will equal SCRIPT_REPO.

countOnDisk

public int countOnDisk()

Returns the number of files which match scriptFilter in dir. Uses iterate() internally.

countInDb

public int countInDb()

countInDb

public int countInDb(ome.util.SqlAction sql)

idsInDb

public List<Long> idsInDb()

idsInDb

public List<Long> idsInDb(ome.util.SqlAction sql)

isInRepo

public boolean isInRepo(long id)

isInRepo

public boolean isInRepo(ome.util.SqlAction sql,
               long id)

findInDb

public Long findInDb(String path,
            boolean scriptsOnly)

findInDb

public Long findInDb(RepoFile file,
            boolean scriptsOnly)

findInDb

public Long findInDb(ome.util.SqlAction sql,
            RepoFile repoFile,
            boolean scriptsOnly)

Looks to see if a path is contained in the repository.

iterate

public Iterator<File> iterate()

loadAll

public List<ome.model.core.OriginalFile> loadAll(boolean modificationCheck)

Walks all files in the repository (via iterate() and adds them if not found in the database. If modificationCheck is true, then a change in the hash for a file in the repository will cause the old file to be removed from the repository

(uuid == null)

and a new file created in its place.

Parameters:

modificationCheck -

Returns:

addOrReplace

public ome.model.core.OriginalFile addOrReplace(RepoFile repoFile,
                                       Long old)

Parameters:

repoFile -

old -

Returns:

addOrReplace

protected ome.model.core.OriginalFile addOrReplace(org.hibernate.Session session,
                                       ome.util.SqlAction sqlAction,
                                       ServiceFactory sf,
                                       RepoFile repoFile,
                                       Long old)

removeMissingFilesFromDb

public long removeMissingFilesFromDb(ome.util.SqlAction sqlAction,
                            org.hibernate.Session session,
                            List<ome.model.core.OriginalFile> filesOnDisk)

Given the current files on disk, #unregister(Long, Session) all files which have been removed from disk.

unregister

protected void unregister(Long old,
              ome.util.SqlAction sqlAction)

Unregisters a given file from the script repository by setting its Repo uuid to null.

update

public ome.model.core.OriginalFile update(RepoFile repoFile,
                                 Long id,
                                 Map<String,String> context)

read

public String read(String path)
            throws IOException

Throws:

IOException

write

public RepoFile write(String path,
             String text)
               throws IOException

Throws:

IOException

write

public RepoFile write(RepoFile repo,
             String text)
               throws IOException

Throws:

IOException

load

public ome.model.core.OriginalFile load(long id,
                               boolean check)

load

public ome.model.core.OriginalFile load(long id,
                               org.hibernate.Session s,
                               ome.util.SqlAction sqlAction,
                               boolean check)

modificationCheck

public void modificationCheck()

Checks if

delete

public boolean delete(long id)

simpleDelete

public void simpleDelete(Map<String,String> context,
                Executor executor,
                Principal p,
                long id)

Unlike delete(long) this method simply performs the DB delete on the given original file id.

Parameters:

context - Call context which affecets which group the current user is in. Can be null to pass no call context.

executor -

p -

id - Id of the OriginalFile to delete.