net.bluemind.calendar.service.internal

Class CalendarService

java.lang.Object

net.bluemind.calendar.service.internal.CalendarService

All Implemented Interfaces:

ICalendar, IInternalCalendar, IChangelogSupport, ICountingSupport, ICrudByIdSupport<VEventSeries>, IDataShardSupport, ISortingSupport

public class CalendarService
extends java.lang.Object
implements IInternalCalendar

Field Summary

Fields

Modifier and Type	Field and Description
static int	SYNC_ERRORS_LIMIT When this limit is reached, sync on demand stops.

Constructor Summary

Constructors

Constructor and Description
CalendarService(javax.sql.DataSource pool, org.elasticsearch.client.Client esearchClient, Container container, BmContext context, CalendarAuditor auditor)

Method Summary

Modifier and Type	Method and Description
java.util.List<java.lang.String>	all() Returns all the items uid from the container.
ContainerChangeset<java.lang.String>	changeset(java.lang.Long since)
ContainerChangeset<java.lang.Long>	changesetById(java.lang.Long since)
ContainerChangelog	containerChangelog(java.lang.Long since)
Count	count(ItemFlagFilter filter) Count items matching an ItemFlagFilter
void	create(java.lang.String uid, VEventSeries event, java.lang.Boolean sendNotifications) Creates a VEvent.
Ack	createById(long id, VEventSeries event) Creates a VEventSeries.
void	delete(java.lang.String uid, java.lang.Boolean sendNotifications) Deletes the VEventSeries identified by the given unique identifier.
void	deleteById(long id) Delete the event identified by the given item identifier.
void	emitNotification()
ContainerChangeset<ItemVersion>	filteredChangesetById(java.lang.Long since, ItemFlagFilter filter)
java.util.List<ItemValue<VEventSeries>>	getByIcsUid(java.lang.String uid) Returns all VEventSeries matching the given ICS unique identifier.
ItemValue<VEventSeries>	getComplete(java.lang.String uid) Returns the VEventSeries identified by the given unique identifier.
ItemValue<VEventSeries>	getCompleteById(long id) Retrieve the VEventSeries identified by the given identifier.
long	getVersion()
boolean	isAutoSyncActivated() Check the automatic synchronization is activated for this calendar.
ItemChangelog	itemChangelog(java.lang.String itemUid, java.lang.Long since)
ListResult<ItemValue<VEventSeries>>	list() List all the events of this calendar.
void	multipleDeleteById(java.util.List<java.lang.Long> ids)
java.util.List<ItemValue<VEventSeries>>	multipleGet(java.util.List<java.lang.String> uids) Fetch multiple VEventSeries identified by the given unique identifiers.
java.util.List<ItemValue<VEventSeries>>	multipleGetById(java.util.List<java.lang.Long> ids) Fetch multiple VEventSeries from theirs uniques ids
TaskRef	reset() Remove all events from this calendar.
ListResult<ItemValue<VEventSeries>>	search(VEventQuery query) Search for events matching the given query.
ListResult<ItemValue<VEventSeries>>	searchPendingCounters() Search pending counters of the current user
java.util.List<java.lang.Long>	sortedIds(SortDescriptor sorted) Sort the events item identifiers in function of the given SortDescriptor.
ContainerChangeset<java.lang.String>	sync(java.lang.Long since, VEventChanges changes) Apply the given changes and return the differences since the given time.
void	touch(java.lang.String uid) Touch a VEvent.
void	update(java.lang.String uid, VEventSeries event, java.lang.Boolean sendNotifications) Updates a VEventSeries.
Ack	updateById(long id, VEventSeries event) Update the event identified by the given item identifier.
ContainerUpdatesResult	updates(VEventChanges changes) Applies changes (create, update, delete) to a calendar specified by its containerUid.
ContainerUpdatesResult	updates(VEventChanges changes, boolean notify)
void	xfer(java.lang.String serverUid)

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.bluemind.core.container.api.IChangelogSupport

allIds

Field Detail

SYNC_ERRORS_LIMIT

public static final int SYNC_ERRORS_LIMIT

When this limit is reached, sync on demand stops.

See Also:

Constant Field Values

Constructor Detail

CalendarService

public CalendarService(javax.sql.DataSource pool,
                       org.elasticsearch.client.Client esearchClient,
                       Container container,
                       BmContext context,
                       CalendarAuditor auditor)
                throws ServerFault

Throws:

ServerFault

Method Detail

create

public void create(java.lang.String uid,
                   VEventSeries event,
                   java.lang.Boolean sendNotifications)
            throws ServerFault

Description copied from interface: ICalendar

Creates a VEvent.

Specified by:

create in interface ICalendar

Parameters:

uid - the unique identifier for the new event

event - the VEventSeries to store

sendNotifications - if true then notify this event creation on the events bus

Throws:

ServerFault

createById

public Ack createById(long id,
                      VEventSeries event)
               throws ServerFault

Description copied from interface: ICalendar

Creates a VEventSeries.

Specified by:

createById in interface ICalendar

Specified by:

createById in interface ICrudByIdSupport<VEventSeries>

Parameters:

id - the item identifier of the VEventSeries

event - the VEventSeries to store

Returns:

the acknowledgement object with the new version of the updated item

Throws:

ServerFault

updateById

public Ack updateById(long id,
                      VEventSeries event)

Description copied from interface: ICalendar

Update the event identified by the given item identifier.

Specified by:

updateById in interface ICalendar

Specified by:

updateById in interface ICrudByIdSupport<VEventSeries>

Parameters:

id - the item identifier of the VEventSeries

event - the new value to set

Returns:

the acknowledgement object with the new version of the updated item

update

public void update(java.lang.String uid,
                   VEventSeries event,
                   java.lang.Boolean sendNotifications)
            throws ServerFault

Description copied from interface: ICalendar

Updates a VEventSeries.

Specified by:

update in interface ICalendar

Parameters:

uid - the unique identifier of the event

event - the VEventSeries to update

sendNotifications - if true then notify this event creation on the events bus

Throws:

ServerFault

getComplete

public ItemValue<VEventSeries> getComplete(java.lang.String uid)
                                    throws ServerFault

Description copied from interface: ICalendar

Returns the VEventSeries identified by the given unique identifier.

Specified by:

getComplete in interface ICalendar

Parameters:

uid - the unique identifier of the event

Returns:

a VEventSeries if successful

Throws:

ServerFault

getCompleteById

public ItemValue<VEventSeries> getCompleteById(long id)

Description copied from interface: ICalendar

Retrieve the VEventSeries identified by the given identifier.

Specified by:

getCompleteById in interface ICalendar

Specified by:

getCompleteById in interface ICrudByIdSupport<VEventSeries>

Parameters:

id - the identifier of the event

Returns:

a VEventSeries if successfulSortDescriptor

getByIcsUid

public java.util.List<ItemValue<VEventSeries>> getByIcsUid(java.lang.String uid)
                                                    throws ServerFault

Description copied from interface: ICalendar

Returns all VEventSeries matching the given ICS unique identifier.

Specified by:

getByIcsUid in interface ICalendar

Parameters:

uid - the ICS unique identifier

Returns:

the list of matching VEventSeries

Throws:

ServerFault

multipleGet

public java.util.List<ItemValue<VEventSeries>> multipleGet(java.util.List<java.lang.String> uids)
                                                    throws ServerFault

Description copied from interface: ICalendar

Fetch multiple VEventSeries identified by the given unique identifiers.

Specified by:

multipleGet in interface ICalendar

Parameters:

uids - the list of unique identifiers

Returns:

all matching VEventSeries

Throws:

ServerFault

multipleGetById

public java.util.List<ItemValue<VEventSeries>> multipleGetById(java.util.List<java.lang.Long> ids)
                                                        throws ServerFault

Description copied from interface: ICalendar

Fetch multiple VEventSeries from theirs uniques ids

Specified by:

multipleGetById in interface ICalendar

Parameters:

ids - the list of unique id

Returns:

all matching VEventSeries

Throws:

ServerFault

deleteById

public void deleteById(long id)

Description copied from interface: ICalendar

Delete the event identified by the given item identifier.

Specified by:

deleteById in interface ICalendar

Specified by:

deleteById in interface ICrudByIdSupport<VEventSeries>

delete

public void delete(java.lang.String uid,
                   java.lang.Boolean sendNotifications)
            throws ServerFault

Description copied from interface: ICalendar

Deletes the VEventSeries identified by the given unique identifier.

Specified by:

delete in interface ICalendar

Parameters:

uid - the unique identifier of the event

sendNotifications - if true then notify this event deletion on the events bus

Throws:

ServerFault

touch

public void touch(java.lang.String uid)
           throws ServerFault

Description copied from interface: ICalendar

Touch a VEvent.

Specified by:

touch in interface ICalendar

Parameters:

uid - the unique identifier of the event

Throws:

ServerFault

containerChangelog

public ContainerChangelog containerChangelog(java.lang.Long since)
                                      throws ServerFault

Specified by:

containerChangelog in interface IChangelogSupport

Returns:

if successful, return a ContainerChangelog

Throws:

ServerFault

itemChangelog

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

Specified by:

itemChangelog in interface IChangelogSupport

Returns:

if successful, return a ContainerChangelog

Throws:

ServerFault

updates

public ContainerUpdatesResult updates(VEventChanges changes,
                                      boolean notify)

Specified by:

updates in interface IInternalCalendar

updates

public ContainerUpdatesResult updates(VEventChanges changes)
                               throws ServerFault

Description copied from interface: ICalendar

Applies changes (create, update, delete) to a calendar specified by its containerUid.

Specified by:

updates in interface ICalendar

Parameters:

changes - the changes to apply

Throws:

ServerFault

search

public ListResult<ItemValue<VEventSeries>> search(VEventQuery query)
                                           throws ServerFault

Description copied from interface: ICalendar

Search for events matching the given query.

Specified by:

search in interface ICalendar

Parameters:

query - the VEventQuery to match against

Returns:

the matching VEventSeries

Throws:

ServerFault

changeset

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

Specified by:

changeset in interface IChangelogSupport

Returns:

if successful, return a ContainerChangeset

Throws:

ServerFault

changesetById

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

Specified by:

changesetById in interface IChangelogSupport

Returns:

if successful, return a ContainerChangeset with internal numeric ids

Throws:

ServerFault

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

sync

public ContainerChangeset<java.lang.String> sync(java.lang.Long since,
                                                 VEventChanges changes)
                                          throws ServerFault

Description copied from interface: ICalendar

Apply the given changes and return the differences since the given time. CLIENT_WIN style.

Specified by:

sync in interface ICalendar

Parameters:

since - the time from wich compare changes

changes - the changes to apply

Returns:

the ContainerChangeset of the difSortDescriptorferences

Throws:

ServerFault

list

public ListResult<ItemValue<VEventSeries>> list()
                                         throws ServerFault

Description copied from interface: ICalendar

List all the events of this calendar.

Specified by:

list in interface ICalendar

Returns:

all the VEventSeries

Throws:

ServerFault

all

public java.util.List<java.lang.String> all()
                                     throws ServerFault

Description copied from interface: ICalendar

Returns all the items uid from the container.

Specified by:

all in interface ICalendar

Returns:

all the items uid from the container.

Throws:

ServerFault

reset

public TaskRef reset()
              throws ServerFault

Description copied from interface: ICalendar

Remove all events from this calendar.

Specified by:

reset in interface ICalendar

Returns:

the reference to this asynchronous operation

Throws:

ServerFault

getVersion

public long getVersion()
                throws ServerFault

Specified by:

getVersion in interface IChangelogSupport

Throws:

ServerFault

count

public Count count(ItemFlagFilter filter)
            throws ServerFault

Description copied from interface: ICountingSupport

Count items matching an ItemFlagFilter

Specified by:

count in interface ICountingSupport

Returns:

the count of items matching the filter

Throws:

ServerFault

sortedIds

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

Description copied from interface: ICalendar

Sort the events item identifiers in function of the given SortDescriptor.

Specified by:

sortedIds in interface ICalendar

Specified by:

sortedIds in interface ISortingSupport

Parameters:

sorted - sorting criteria

Returns:

the sorted event items identifiers

Throws:

ServerFault

xfer

public void xfer(java.lang.String serverUid)
          throws ServerFault

Specified by:

xfer in interface IDataShardSupport

Throws:

ServerFault

multipleDeleteById

public void multipleDeleteById(java.util.List<java.lang.Long> ids)
                        throws ServerFault

Specified by:

multipleDeleteById in interface ICrudByIdSupport<VEventSeries>

Throws:

ServerFault

isAutoSyncActivated

public boolean isAutoSyncActivated()
                            throws ServerFault

Description copied from interface: ICalendar

Check the automatic synchronization is activated for this calendar.

Specified by:

isAutoSyncActivated in interface ICalendar

Returns:

true if this calendar is automatically synchronized, false otherwise

Throws:

ServerFault

emitNotification

public void emitNotification()

Specified by:

emitNotification in interface IInternalCalendar

searchPendingCounters

public ListResult<ItemValue<VEventSeries>> searchPendingCounters()

Description copied from interface: ICalendar

Search pending counters of the current user

Specified by:

searchPendingCounters in interface ICalendar

Returns: