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

Fields inherited from interface org.nuxeo.drive.service.NuxeoDriveManager

LOCALLY_EDITED_COLLECTION_NAME

Constructor Summary

Constructors

Constructor and Description
NuxeoDriveManagerImpl()

Method Summary

Methods

Modifier and Type	Method and Description
void	addToLocallyEditedCollection(CoreSession session, DocumentModel doc) Adds the given DocumentModel to the NuxeoDriveManager.LOCALLY_EDITED_COLLECTION_NAME collection.
FileSystemChangeFinder	getChangeFinder() Gets the FileSystemChangeFinder member.
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.
FileSystemChangeSummary	getChangeSummaryIntegerBounds(Principal principal, Map<String,Set<IdRef>> lastSyncRootRefs, long lowerBound) Uses the AuditChangeFinder to get the summary of document changes for the given user and lower bound.
Map<String,Set<String>>	getCollectionSyncRootMemberIds(Principal principal) Fetch all the collection sync root member ids for a given user.
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	invalidateCollectionSyncRootMemberCache() Invalidate the collection sync root member cache for all users so as to query the repository next time NuxeoDriveManager.getCollectionSyncRootMemberIds(Principal) is called.
void	invalidateCollectionSyncRootMemberCache(String userName) Invalidate the collection sync root member cache for a given user so as to query the repository next time NuxeoDriveManager.getCollectionSyncRootMemberIds(Principal) is called.
void	invalidateSynchronizationRootsCache(String userName) Invalidate the synchronization roots cache for a given user so as to query the repository next time NuxeoDriveManager.getSynchronizationRoots(Principal) 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 NuxeoDriveManager.getSynchronizationRoots(Principal) is called.

Specified by:

invalidateSynchronizationRootsCache in interface NuxeoDriveManager

Parameters:

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

invalidateCollectionSyncRootMemberCache

public void invalidateCollectionSyncRootMemberCache(String userName)

Description copied from interface: NuxeoDriveManager

Invalidate the collection sync root member cache for a given user so as to query the repository next time NuxeoDriveManager.getCollectionSyncRootMemberIds(Principal) is called.

Specified by:

invalidateCollectionSyncRootMemberCache in interface NuxeoDriveManager

Parameters:

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

invalidateCollectionSyncRootMemberCache

public void invalidateCollectionSyncRootMemberCache()

Description copied from interface: NuxeoDriveManager

Invalidate the collection sync root member cache for all users so as to query the repository next time NuxeoDriveManager.getCollectionSyncRootMemberIds(Principal) is called.

Specified by:

invalidateCollectionSyncRootMemberCache in interface NuxeoDriveManager

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 by FileSystemChangeSummary.getSyncDate() of the previous call to NuxeoDriveManager.getChangeSummary(Principal, Map, long) or 0 for catching every event since the repository initialization.

Returns:

the summary of document changes

Throws:

ClientException

getChangeSummaryIntegerBounds

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

Uses the AuditChangeFinder to get the summary of document changes for the given user and lower bound.

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 lowerBound is missing (i.e. set to a negative value), the filesystem change summary is empty but the returned upper bound is set to the greater event log id so that the client can reuse it as a starting id for a future incremental diff request.

Specified by:

getChangeSummaryIntegerBounds in interface NuxeoDriveManager

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

lowerBound - the lower bound sent by the user's device. Typically set to the value returned by FileSystemChangeSummary.getUpperBound() of the previous call to NuxeoDriveManager.getChangeSummaryIntegerBounds(Principal, Map, 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

getCollectionSyncRootMemberIds

public Map<String,Set<String>> getCollectionSyncRootMemberIds(Principal principal)
                                                       throws ClientException

Description copied from interface: NuxeoDriveManager

Fetch all the collection sync root member ids for a given user.

Specified by:

getCollectionSyncRootMemberIds in interface NuxeoDriveManager

Parameters:

principal - the user to fetch the ids for

Returns:

the map keyed by repository names all collection sync root member ids 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

getChangeFinder

public FileSystemChangeFinder getChangeFinder()

Description copied from interface: NuxeoDriveManager

Gets the FileSystemChangeFinder member.

Specified by:

getChangeFinder in interface NuxeoDriveManager

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

addToLocallyEditedCollection

public void addToLocallyEditedCollection(CoreSession session,
                                DocumentModel doc)
                                  throws ClientException

Description copied from interface: NuxeoDriveManager

Adds the given DocumentModel to the NuxeoDriveManager.LOCALLY_EDITED_COLLECTION_NAME collection.

Specified by:

addToLocallyEditedCollection in interface NuxeoDriveManager

Throws:

ClientException