org.ametys.plugins.messagingconnector

Class AbstractMessagingConnector

java.lang.Object

org.ametys.runtime.plugin.component.AbstractLogEnabled

org.ametys.plugins.messagingconnector.AbstractMessagingConnector

All Implemented Interfaces:

MessagingConnector, LogEnabled, Initializable, Component, Serviceable

Direct Known Subclasses:

BluemindConnector, ExchangeConnector, ZimbraConnector

public abstract class AbstractMessagingConnector
extends AbstractLogEnabled
implements MessagingConnector, Initializable, Serviceable

Abstract implementation of MessagingConnector with cache.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	AbstractMessagingConnector.EmailCacheKey Internal class for key of events count cache
(package private) class	AbstractMessagingConnector.EventCacheKey Internal class for key of events cache
(package private) class	AbstractMessagingConnector.EventCountCacheKey Internal class for key of events count cache

Nested classes/interfaces inherited from interface org.ametys.plugins.messagingconnector.MessagingConnector

MessagingConnector.AttendeeInformation, MessagingConnector.FreeBusyStatus, MessagingConnector.ResponseType

Field Summary

Fields

Modifier and Type	Field and Description
private Cache<AbstractMessagingConnector.EmailCacheKey,List<EmailMessage>>	_emailsCache
private Cache<UserIdentity,Integer>	_emailsCountCache
private Cache<AbstractMessagingConnector.EventCacheKey,List<CalendarEvent>>	_eventsCache
private Cache<AbstractMessagingConnector.EventCountCacheKey,Integer>	_eventsCountCache
private List<String>	_populationIds
protected UserPopulationDAO	_userPopulationDAO The user population DAO

Fields inherited from interface org.ametys.plugins.messagingconnector.MessagingConnector

ROLE

Constructor Summary

Constructors

Constructor and Description
AbstractMessagingConnector()

Method Summary

Modifier and Type	Method and Description
String	createEvent(String title, String description, String place, boolean isAllDay, Date startDate, Date endDate, EventRecurrenceTypeEnum recurrenceType, Date untilDate, Map<String,Boolean> attendees, UserIdentity organiser) Create an event
void	deleteEvent(String eventId, UserIdentity organiser) Delete an event
List<String>	getAllowedPopulationIds() Get the list of population id allowed to the messaging connector
Map<String,MessagingConnector.AttendeeInformation>	getAttendees(String eventId, UserIdentity organiser) Get the map of attendees for an event
List<CalendarEvent>	getEvents(UserIdentity userIdentity, Date fromDate, Date untilDate, int maxEvents) Get the list of events betweend two dates for a given user
int	getEventsCount(UserIdentity userIdentity, Date fromDate, Date untilDate) Return the number of upcoming events
Map<String,MessagingConnector.FreeBusyStatus>	getFreeBusy(Date startDate, Date endDate, boolean isAllDay, Set<String> attendees, UserIdentity organiser) Get free/busy status for attendees for a time window
int	getUnreadEmailCount(UserIdentity userIdentity) Return the number of unread mails for a given user
List<EmailMessage>	getUnreadEmails(UserIdentity userIdentity, int maxEmails) Return the unread emails for a given user
void	initialize()
protected abstract List<EmailMessage>	internalGetEmails(UserIdentity userIdentity, int maxEmails) Get emails (no caching)
protected abstract int	internalGetEmailsCount(UserIdentity userIdentity) Get emails count (no caching)
protected abstract List<CalendarEvent>	internalGetEvents(UserIdentity userIdentity, Date fromDate, Date untilDate, int maxEvents) Get events between two date (no caching)
protected abstract int	internalGetEventsCount(UserIdentity userIdentity, Date fromDate, Date untilDate) Get events count between two date (no caching)
protected boolean	isAllowed(UserIdentity userIdentity) True if the user is allowed
boolean	isEventExist(String eventId, UserIdentity organiser) True if the event exist in the messaging connector
boolean	isUserExist(UserIdentity userIdentity) True if the user exist
void	service(ServiceManager manager)
void	setAttendees(String eventId, Map<String,Boolean> attendees, UserIdentity organiser) Set attendees for an event
boolean	supportInvitation() Tell if the messaging connector supports event invitation
void	updateEvent(String eventId, String title, String description, String place, boolean isAllDay, Date startDate, Date endDate, EventRecurrenceTypeEnum recurrenceType, Date untilDate, Map<String,Boolean> attendees, UserIdentity organiser) Update an event

Methods inherited from class org.ametys.runtime.plugin.component.AbstractLogEnabled

getLogger, setLogger

Methods inherited from class java.lang.Object

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

Field Detail

_userPopulationDAO

protected UserPopulationDAO _userPopulationDAO

The user population DAO

_eventsCache

private Cache<AbstractMessagingConnector.EventCacheKey,List<CalendarEvent>> _eventsCache

_eventsCountCache

private Cache<AbstractMessagingConnector.EventCountCacheKey,Integer> _eventsCountCache

_emailsCache

private Cache<AbstractMessagingConnector.EmailCacheKey,List<EmailMessage>> _emailsCache

_emailsCountCache

private Cache<UserIdentity,Integer> _emailsCountCache

_populationIds

private List<String> _populationIds

Constructor Detail

AbstractMessagingConnector

public AbstractMessagingConnector()

Method Detail

service

public void service(ServiceManager manager)
             throws ServiceException

Specified by:

service in interface Serviceable

Throws:

ServiceException

initialize

public void initialize()

Specified by:

initialize in interface Initializable

getAllowedPopulationIds

public List<String> getAllowedPopulationIds()

Description copied from interface: MessagingConnector

Get the list of population id allowed to the messaging connector

Specified by:

getAllowedPopulationIds in interface MessagingConnector

Returns:

the list of population id allowed to the messaging connector

isAllowed

protected boolean isAllowed(UserIdentity userIdentity)

True if the user is allowed

Parameters:

userIdentity - the user identity

Returns:

true if the user is allowed

getEvents

public List<CalendarEvent> getEvents(UserIdentity userIdentity,
                                     Date fromDate,
                                     Date untilDate,
                                     int maxEvents)
                              throws MessagingConnectorException

Description copied from interface: MessagingConnector

Get the list of events betweend two dates for a given user

Specified by:

getEvents in interface MessagingConnector

Parameters:

userIdentity - the owner of the events

fromDate - The start date of search

untilDate - The end date of search

maxEvents - the maximum number of events to retrieve

Returns:

the next events

Throws:

MessagingConnectorException - if failed to get events

getEventsCount

public int getEventsCount(UserIdentity userIdentity,
                          Date fromDate,
                          Date untilDate)
                   throws MessagingConnectorException

Description copied from interface: MessagingConnector

Return the number of upcoming events

Specified by:

getEventsCount in interface MessagingConnector

Parameters:

userIdentity - the owner of the events

fromDate - The start date of search

untilDate - The end date of search

Returns:

the number of upcoming events

Throws:

MessagingConnectorException - if failed to get events' count

getUnreadEmails

public List<EmailMessage> getUnreadEmails(UserIdentity userIdentity,
                                          int maxEmails)
                                   throws MessagingConnectorException

Description copied from interface: MessagingConnector

Return the unread emails for a given user

Specified by:

getUnreadEmails in interface MessagingConnector

Parameters:

userIdentity - the recipient of the mails

maxEmails - The max number of emails to return

Returns:

a mail messsages

Throws:

MessagingConnectorException - if failed to get mails

getUnreadEmailCount

public int getUnreadEmailCount(UserIdentity userIdentity)
                        throws MessagingConnectorException

Description copied from interface: MessagingConnector

Return the number of unread mails for a given user

Specified by:

getUnreadEmailCount in interface MessagingConnector

Parameters:

userIdentity - the receiver of the mails

Returns:

the number of unread mails

Throws:

MessagingConnectorException - if failed to get unread mails ' count

internalGetEvents

protected abstract List<CalendarEvent> internalGetEvents(UserIdentity userIdentity,
                                                         Date fromDate,
                                                         Date untilDate,
                                                         int maxEvents)
                                                  throws MessagingConnectorException

Get events between two date (no caching)

Parameters:

userIdentity - The user identity

fromDate - The date to start search

untilDate - The date to end search

maxEvents - The maximum number of events to retrieve

Returns:

The calendar events

Throws:

MessagingConnectorException - if failed to get events from server

internalGetEventsCount

protected abstract int internalGetEventsCount(UserIdentity userIdentity,
                                              Date fromDate,
                                              Date untilDate)
                                       throws MessagingConnectorException

Get events count between two date (no caching)

Parameters:

userIdentity - The user identity

fromDate - The date to start search

untilDate - The date to end search

Returns:

The number of calendar events

Throws:

MessagingConnectorException - if failed to get events from server

internalGetEmails

protected abstract List<EmailMessage> internalGetEmails(UserIdentity userIdentity,
                                                        int maxEmails)
                                                 throws MessagingConnectorException

Get emails (no caching)

Parameters:

userIdentity - The user identity

maxEmails - The maximum number of emails to retrieve

Returns:

The emails

Throws:

MessagingConnectorException - if failed to get events from server

internalGetEmailsCount

protected abstract int internalGetEmailsCount(UserIdentity userIdentity)
                                       throws MessagingConnectorException

Get emails count (no caching)

Parameters:

userIdentity - The user identity

Returns:

The emails count

Throws:

MessagingConnectorException - if failed to get events from server

supportInvitation

public boolean supportInvitation()
                          throws MessagingConnectorException

Description copied from interface: MessagingConnector

Tell if the messaging connector supports event invitation

Specified by:

supportInvitation in interface MessagingConnector

Returns:

true if the messaging connector supports event invitation

Throws:

MessagingConnectorException - if failed to get events from server

isEventExist

public boolean isEventExist(String eventId,
                            UserIdentity organiser)
                     throws MessagingConnectorException

Description copied from interface: MessagingConnector

True if the event exist in the messaging connector

Specified by:

isEventExist in interface MessagingConnector

Parameters:

eventId - the event id

organiser - the organiser

Returns:

true if the event exist

Throws:

MessagingConnectorException - if an error occurred

createEvent

public String createEvent(String title,
                          String description,
                          String place,
                          boolean isAllDay,
                          Date startDate,
                          Date endDate,
                          EventRecurrenceTypeEnum recurrenceType,
                          Date untilDate,
                          Map<String,Boolean> attendees,
                          UserIdentity organiser)
                   throws MessagingConnectorException

Description copied from interface: MessagingConnector

Create an event

Specified by:

createEvent in interface MessagingConnector

Parameters:

title - the event title

description - the event description

place - the event place

isAllDay - if the event is all day

startDate - the event start date

endDate - the event end date

recurrenceType - recurrence type

untilDate - until date of the recurring event

attendees - the map of attendees (email -> optional or requested) to set

organiser - the event organiser

Returns:

the id of the event created

Throws:

MessagingConnectorException - if failed to get events from server

updateEvent

public void updateEvent(String eventId,
                        String title,
                        String description,
                        String place,
                        boolean isAllDay,
                        Date startDate,
                        Date endDate,
                        EventRecurrenceTypeEnum recurrenceType,
                        Date untilDate,
                        Map<String,Boolean> attendees,
                        UserIdentity organiser)
                 throws MessagingConnectorException

Description copied from interface: MessagingConnector

Update an event

Specified by:

updateEvent in interface MessagingConnector

Parameters:

eventId - the event id to delete

title - the event title

description - the event description

place - the event place

isAllDay - if the event is all day

startDate - the event start date

endDate - the event end date

recurrenceType - recurrence type

untilDate - until date of the recurring event

attendees - the map of attendees (email -> optional or requested) to set

organiser - the event organiser

Throws:

MessagingConnectorException - if failed to get events from server

deleteEvent

public void deleteEvent(String eventId,
                        UserIdentity organiser)
                 throws MessagingConnectorException

Description copied from interface: MessagingConnector

Delete an event

Specified by:

deleteEvent in interface MessagingConnector

Parameters:

eventId - the event id to delete

organiser - the event organiser

Throws:

MessagingConnectorException - if failed to get events from server

getAttendees

public Map<String,MessagingConnector.AttendeeInformation> getAttendees(String eventId,
                                                                       UserIdentity organiser)
                                                                throws MessagingConnectorException

Description copied from interface: MessagingConnector

Get the map of attendees for an event

Specified by:

getAttendees in interface MessagingConnector

Parameters:

eventId - the event id

organiser - the event organiser

Returns:

the map of attendees (email -> attendee information)

Throws:

MessagingConnectorException - if failed to get events from server

setAttendees

public void setAttendees(String eventId,
                         Map<String,Boolean> attendees,
                         UserIdentity organiser)
                  throws MessagingConnectorException

Description copied from interface: MessagingConnector

Set attendees for an event

Specified by:

setAttendees in interface MessagingConnector

Parameters:

eventId - the event id

attendees - the map of attendees (email -> optional or requested) to set

organiser - the event organiser

Throws:

MessagingConnectorException - if failed to get events from server

getFreeBusy

public Map<String,MessagingConnector.FreeBusyStatus> getFreeBusy(Date startDate,
                                                                 Date endDate,
                                                                 boolean isAllDay,
                                                                 Set<String> attendees,
                                                                 UserIdentity organiser)
                                                          throws MessagingConnectorException

Description copied from interface: MessagingConnector

Get free/busy status for attendees for a time window

Specified by:

getFreeBusy in interface MessagingConnector

Parameters:

startDate - the start date

endDate - the end date

isAllDay - true if is an allday event

attendees - the list of attendees email

organiser - the event organiser

Returns:

the map of attendees (email -> freeBusy status)

Throws:

MessagingConnectorException - if failed to get events from server

isUserExist

public boolean isUserExist(UserIdentity userIdentity)
                    throws MessagingConnectorException

Description copied from interface: MessagingConnector

True if the user exist

Specified by:

isUserExist in interface MessagingConnector

Parameters:

userIdentity - the user identity

Returns:

true if the user exist

Throws:

MessagingConnectorException - if failed to get events from server