org.nuxeo.drive.service.impl

Class NuxeoDriveManagerImpl

java.lang.Object

org.nuxeo.runtime.model.DefaultComponent

org.nuxeo.drive.service.impl.NuxeoDriveManagerImpl

All Implemented Interfaces:

NuxeoDriveManager, Adaptable, Component, Extensible, TimestampedService

public class NuxeoDriveManagerImpl
extends DefaultComponent
implements NuxeoDriveManager

Manage list of NuxeoDrive synchronization roots and devices for a given nuxeo user.

Field Summary

Fields

Modifier and Type	Field and Description
static String	DOCUMENT_CHANGE_LIMIT_PROPERTY
static String	DRIVE_SUBSCRIPTIONS_PROPERTY
static String	NUXEO_DRIVE_FACET

Constructor Summary

Constructors

Constructor and Description
NuxeoDriveManagerImpl()

Method Summary

Methods

Modifier and Type	Method and Description
FileSystemChangeSummary	getChangeSummary(Principal principal, Map<String,Set<IdRef>> lastSyncRootRefs, long lastSuccessfulSync) Uses the AuditChangeFinder to get the summary of document changes for the given user and last successful synchronization date.
Set<IdRef>	getSynchronizationRootReferences(CoreSession session) Fetch the list of synchronization root refs for a given user and a given session repository.
Map<String,SynchronizationRoots>	getSynchronizationRoots(Principal principal) Fetch all the synchronization root references and paths for a given user.
void	handleFolderDeletion(IdRef deleted) Method to be called by a CoreEvent listener monitoring documents deletions to cleanup references to recently deleted documents and invalidate the caches.
void	invalidateSynchronizationRootsCache(String userName) Invalidate the synchronization roots cache for a given user so as to query the repository next time getSynchronizationRoots is called.
boolean	isSynchronizationRoot(Principal principal, DocumentModel doc) Checks if the given DocumentModel is a synchronization root for the given user.
void	registerSynchronizationRoot(Principal principal, DocumentModel newRootContainer, CoreSession session)
void	setChangeFinder(FileSystemChangeFinder changeFinder) Sets the FileSystemChangeFinder member.
void	unregisterSynchronizationRoot(Principal principal, DocumentModel rootContainer, CoreSession session)

Methods inherited from class org.nuxeo.runtime.model.DefaultComponent

activate, applicationStarted, deactivate, getAdapter, getApplicationStartedOrder, getLastModified, registerContribution, registerExtension, setLastModified, unregisterContribution, unregisterExtension

Methods inherited from class java.lang.Object

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

Field Detail

NUXEO_DRIVE_FACET

public static final String NUXEO_DRIVE_FACET

See Also:

Constant Field Values

DRIVE_SUBSCRIPTIONS_PROPERTY

public static final String DRIVE_SUBSCRIPTIONS_PROPERTY

See Also:

Constant Field Values

DOCUMENT_CHANGE_LIMIT_PROPERTY

public static final String DOCUMENT_CHANGE_LIMIT_PROPERTY

See Also:

Constant Field Values

Constructor Detail

NuxeoDriveManagerImpl

public NuxeoDriveManagerImpl()

Method Detail

invalidateSynchronizationRootsCache

public void invalidateSynchronizationRootsCache(String userName)

Description copied from interface: NuxeoDriveManager

Invalidate the synchronization roots cache for a given user so as to query the repository next time getSynchronizationRoots is called.

Specified by:

invalidateSynchronizationRootsCache in interface NuxeoDriveManager

Parameters:

userName - the principal name of the user to invalidate the cache for.

registerSynchronizationRoot

public void registerSynchronizationRoot(Principal principal,
                               DocumentModel newRootContainer,
                               CoreSession session)
                                 throws ClientException

Specified by:

registerSynchronizationRoot in interface NuxeoDriveManager

Parameters:

principal - the Nuxeo Drive user

newRootContainer - the folderish document to be used as synchronization root: must be bound to an active session

Throws:

ClientException

unregisterSynchronizationRoot

public void unregisterSynchronizationRoot(Principal principal,
                                 DocumentModel rootContainer,
                                 CoreSession session)
                                   throws ClientException

Specified by:

unregisterSynchronizationRoot in interface NuxeoDriveManager

Parameters:

principal - the Nuxeo Drive user

rootContainer - the folderish document that should no longer be used as a synchronization root

Throws:

ClientException

getSynchronizationRootReferences

public Set<IdRef> getSynchronizationRootReferences(CoreSession session)
                                            throws ClientException

Description copied from interface: NuxeoDriveManager

Fetch the list of synchronization root refs for a given user and a given session repository. This list is assumed to be short enough (in the order of 100 folder max) so that no paging API is required. The user is taken from the session.getPrincipal() method.

Specified by:

getSynchronizationRootReferences in interface NuxeoDriveManager

Parameters:

session - active CoreSession instance to the repository hosting the roots.

Returns:

the ordered set of non deleted synchronization root references for that user

Throws:

ClientException

See Also:

#getSynchronizationRootPaths(String, CoreSession)

handleFolderDeletion

public void handleFolderDeletion(IdRef deleted)
                          throws ClientException

Description copied from interface: NuxeoDriveManager

Method to be called by a CoreEvent listener monitoring documents deletions to cleanup references to recently deleted documents and invalidate the caches.

Specified by:

handleFolderDeletion in interface NuxeoDriveManager

Throws:

ClientException

getChangeSummary

public FileSystemChangeSummary getChangeSummary(Principal principal,
                                       Map<String,Set<IdRef>> lastSyncRootRefs,
                                       long lastSuccessfulSync)
                                         throws ClientException

Uses the AuditChangeFinder to get the summary of document changes for the given user and last successful synchronization date.

The DOCUMENT_CHANGE_LIMIT_PROPERTY Framework property is used as a limit of document changes to fetch from the audit logs. Default value is 1000. If lastSuccessfulSync is missing (i.e. set to a negative value), the filesystem change summary is empty but the returned sync date is set to the actual server timestamp so that the client can reuse it as a starting timestamp for a future incremental diff request.

Specified by:

getChangeSummary in interface NuxeoDriveManager

lastSyncRootRefs - the map keyed by repository names of document refs for the synchronization roots that were active during last synchornization

lastSuccessfulSync - the last successful synchronization date of the user's device. This time is expected to be in milliseconds since 1970-01-01 UTC as measured on the Nuxeo server clock, typically set to the value returned DocumentChangeSummary#getSyncDate() of the previous call to NuxeoDriveManager#getDocumentChangeSummary(boolean, String, CoreSession, long) or 0 for catching every event since the repository initialization.

Returns:

the summary of document changes

Throws:

ClientException

getSynchronizationRoots

public Map<String,SynchronizationRoots> getSynchronizationRoots(Principal principal)
                                                         throws ClientException

Description copied from interface: NuxeoDriveManager

Fetch all the synchronization root references and paths for a given user. This list is assumed to be short enough (in the order of 100 folder max) so that no paging API is required.

Specified by:

getSynchronizationRoots in interface NuxeoDriveManager

Parameters:

principal - the user to fetch the roots for

Returns:

the map keyed by repository names all active roots definitions for the current user.

Throws:

ClientException

isSynchronizationRoot

public boolean isSynchronizationRoot(Principal principal,
                            DocumentModel doc)
                              throws ClientException

Description copied from interface: NuxeoDriveManager

Checks if the given DocumentModel is a synchronization root for the given user.

Specified by:

isSynchronizationRoot in interface NuxeoDriveManager

Throws:

ClientException

setChangeFinder

public void setChangeFinder(FileSystemChangeFinder changeFinder)

Description copied from interface: NuxeoDriveManager

Sets the FileSystemChangeFinder member.

TODO: make it overridable with an extension point and remove setter.

Specified by:

setChangeFinder in interface NuxeoDriveManager