net.bluemind.backend.mail.replica.service.internal

Class BaseMailboxRecordsService

java.lang.Object

net.bluemind.backend.mail.replica.service.internal.BaseMailboxRecordsService

All Implemented Interfaces:

IChangelogSupport, ICountingSupport, ISortingSupport

Direct Known Subclasses:

DbMailboxRecordsService, ImapMailboxRecordsService

public class BaseMailboxRecordsService
extends java.lang.Object
implements IChangelogSupport, ICountingSupport, ISortingSupport

Field Summary

Fields

Modifier and Type	Field and Description
protected Container	container
protected BmContext	context
protected java.lang.String	mailboxUniqueId
protected java.util.Optional<ReplicasStore.SubtreeLocation>	optRecordsLocation
protected RBACManager	rbac
protected MailboxRecordStore	recordStore
protected ReplicasStore	replicaStore
protected ContainerStoreService<MailboxRecord>	storeService

Constructor Summary

Constructors

Constructor and Description
BaseMailboxRecordsService(Container cont, BmContext context, java.lang.String mailboxUniqueId, MailboxRecordStore recordStore, ContainerStoreService<MailboxRecord> storeService, ReplicasStore store)

Method Summary

Modifier and Type	Method and Description
protected ItemValue<MailboxItem>	adapt(ItemValue<MailboxRecord> rec)
ListResult<java.lang.Long>	allIds(java.lang.String filter, java.lang.Long knownContainerVersion, java.lang.Integer limit, java.lang.Integer offset)
ContainerChangeset<java.lang.String>	changeset(java.lang.Long since)
ContainerChangeset<java.lang.Long>	changesetById(java.lang.Long since)
protected boolean	checkExistOnBackend(long imapUid)
ContainerChangelog	containerChangelog(java.lang.Long since)
Count	count(ItemFlagFilter filter) Count items matching an ItemFlagFilter
Stream	fetchComplete(long imapUid)
protected java.io.InputStream	fetchCompleteOIO(long imapUid)
ContainerChangeset<ItemVersion>	filteredChangesetById(java.lang.Long since, ItemFlagFilter filter)
long	getVersion()
ItemChangelog	itemChangelog(java.lang.String itemUid, java.lang.Long since)
java.util.List<java.lang.Long>	sortedIds(SortDescriptor sorted) Returns all items in a container matching a sort criteria

Methods inherited from class java.lang.Object

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

Field Detail

context

protected final BmContext context

mailboxUniqueId

protected final java.lang.String mailboxUniqueId

storeService

protected final ContainerStoreService<MailboxRecord> storeService

recordStore

protected final MailboxRecordStore recordStore

container

protected final Container container

replicaStore

protected final ReplicasStore replicaStore

optRecordsLocation

protected final java.util.Optional<ReplicasStore.SubtreeLocation> optRecordsLocation

rbac

protected final RBACManager rbac

Constructor Detail

BaseMailboxRecordsService

public BaseMailboxRecordsService(Container cont,
                                 BmContext context,
                                 java.lang.String mailboxUniqueId,
                                 MailboxRecordStore recordStore,
                                 ContainerStoreService<MailboxRecord> storeService,
                                 ReplicasStore store)

Method Detail

adapt

protected ItemValue<MailboxItem> adapt(ItemValue<MailboxRecord> rec)

itemChangelog

public ItemChangelog itemChangelog(java.lang.String itemUid,
                                   java.lang.Long since)

Specified by:

itemChangelog in interface IChangelogSupport

Returns:

if successful, return a ContainerChangelog

containerChangelog

public ContainerChangelog containerChangelog(java.lang.Long since)

Specified by:

containerChangelog in interface IChangelogSupport

Returns:

if successful, return a ContainerChangelog

changeset

public ContainerChangeset<java.lang.String> changeset(java.lang.Long since)

Specified by:

changeset in interface IChangelogSupport

Returns:

if successful, return a ContainerChangeset

changesetById

public ContainerChangeset<java.lang.Long> changesetById(java.lang.Long since)

Specified by:

changesetById in interface IChangelogSupport

Returns:

if successful, return a ContainerChangeset with internal numeric ids

filteredChangesetById

public ContainerChangeset<ItemVersion> filteredChangesetById(java.lang.Long since,
                                                             ItemFlagFilter filter)
                                                      throws ServerFault

Specified by:

filteredChangesetById in interface IChangelogSupport

filter - to exclude some items (eg. deleted items)

Returns:

if successful, return a ContainerChangeset with internal numeric ids matching the given filter

Throws:

ServerFault

getVersion

public long getVersion()

Specified by:

getVersion in interface IChangelogSupport

count

public Count count(ItemFlagFilter filter)

Description copied from interface: ICountingSupport

Count items matching an ItemFlagFilter

Specified by:

count in interface ICountingSupport

Returns:

the count of items matching the filter

sortedIds

public java.util.List<java.lang.Long> sortedIds(SortDescriptor sorted)

Description copied from interface: ISortingSupport

Returns all items in a container matching a sort criteria

Specified by:

sortedIds in interface ISortingSupport

Parameters:

sorted - sorting criteria

Returns:

a list of ItemValue.internalId sorted

allIds

public ListResult<java.lang.Long> allIds(java.lang.String filter,
                                         java.lang.Long knownContainerVersion,
                                         java.lang.Integer limit,
                                         java.lang.Integer offset)

Specified by:

allIds in interface IChangelogSupport

fetchComplete

public Stream fetchComplete(long imapUid)

fetchCompleteOIO

protected java.io.InputStream fetchCompleteOIO(long imapUid)

checkExistOnBackend

protected boolean checkExistOnBackend(long imapUid)