com.flowable.engage.engine.impl.persistence.entity

Class ConversationStatusEntityManagerImpl

java.lang.Object

org.flowable.common.engine.impl.persistence.entity.AbstractEntityManager<EntityImpl,DM>

org.flowable.common.engine.impl.persistence.entity.AbstractEngineEntityManager<EngageEngineConfiguration,ConversationStatusEntity,ConversationStatusDataManager>

com.flowable.engage.engine.impl.persistence.entity.ConversationStatusEntityManagerImpl

All Implemented Interfaces:

ConversationStatusEntityManager, EntityManager<ConversationStatusEntity>

public class ConversationStatusEntityManagerImpl
extends AbstractEngineEntityManager<EngageEngineConfiguration,ConversationStatusEntity,ConversationStatusDataManager>
implements ConversationStatusEntityManager

Author:

Filip Hrisafov

Field Summary

Fields inherited from class org.flowable.common.engine.impl.persistence.entity.AbstractEngineEntityManager

engineConfiguration

Fields inherited from class org.flowable.common.engine.impl.persistence.entity.AbstractEntityManager

dataManager, engineType

Constructor Summary

Constructors

Constructor and Description
ConversationStatusEntityManagerImpl(EngageEngineConfiguration configuration, ConversationStatusDataManager conversationStatusDataManager)

Method Summary

Modifier and Type	Method and Description
long	countByCriteria(ConversationStatusQuery query)
ConversationStatusQuery	createConversationStatusQuery()
List<ConversationStatusEntity>	createStatusEntriesForNewConversation(ConversationEntity conversationEntity)
List<ConversationStatusEntity>	createStatusEntryForConversationParticipant(ConversationEntity conversationEntity, String userId)
void	deleteByConversationId(String conversationId)
protected List<String>	extractParticipantUserIds(List<IdentityLinkEntity> identityLinks)
List<ConversationStatusEntity>	findByConversation(String conversationId)
List<ConversationStatus>	findByCriteria(ConversationStatusQuery query)
List<ConversationStatusEntity>	findByUserAndConversation(String userId, String conversationId)
ConversationStatusEntity	findByUserAndConversationAndFilter(String userId, String conversationId, String filterId)
protected List<ConversationFilterResponse>	findUserConversationFilters(ConversationEntity conversationEntity, String userId)
int	increaseUnreadMessageCountsForConversation(ConversationEntity conversationEntity, MessageEntity messageEntity)
int	markConversationAsRead(String userId, String conversationId)
int	markMessageReceived(String userId, MessageEntity messageEntity)
int	resetConversationStatusesToEverythingRead(String conversationId)
long	unreadCountByUserAndConversationAndNoFilter(String userId, String conversationId)
Map<String,Long>	unreadCountByUserAndFilters(String userId, List<String> filterIds)
long	unreadCountByUserAndNoFilter(String userId)
Map<String,Long>	unreadCountPerConversationByUserAndNoFilterAndOnlyUnread(String userId)
Map<String,Long>	unreadCountsByUserAndFilterAndConversations(String userId, String filterId, Collection<String> conversationIds)

Methods inherited from class org.flowable.common.engine.impl.persistence.entity.AbstractEngineEntityManager

getClock, getCommandExecutor, getEngineConfiguration, getEventDispatcher

Methods inherited from class org.flowable.common.engine.impl.persistence.entity.AbstractEntityManager

create, createEntityEvent, delete, delete, delete, findById, fireEntityDeletedEvent, fireEntityInsertedEvent, fireEntityUpdatedEvent, getDataManager, insert, insert, setDataManager, update, update

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.flowable.common.engine.impl.persistence.entity.EntityManager

create, delete, delete, delete, findById, insert, insert, update, update

Constructor Detail

ConversationStatusEntityManagerImpl

public ConversationStatusEntityManagerImpl(EngageEngineConfiguration configuration,
                                           ConversationStatusDataManager conversationStatusDataManager)

Method Detail

createStatusEntriesForNewConversation

public List<ConversationStatusEntity> createStatusEntriesForNewConversation(ConversationEntity conversationEntity)

Specified by:

createStatusEntriesForNewConversation in interface ConversationStatusEntityManager

extractParticipantUserIds

protected List<String> extractParticipantUserIds(List<IdentityLinkEntity> identityLinks)

createStatusEntryForConversationParticipant

public List<ConversationStatusEntity> createStatusEntryForConversationParticipant(ConversationEntity conversationEntity,
                                                                                  String userId)

Specified by:

createStatusEntryForConversationParticipant in interface ConversationStatusEntityManager

findUserConversationFilters

protected List<ConversationFilterResponse> findUserConversationFilters(ConversationEntity conversationEntity,
                                                                       String userId)

findByConversation

public List<ConversationStatusEntity> findByConversation(String conversationId)

Specified by:

findByConversation in interface ConversationStatusEntityManager

findByUserAndConversationAndFilter

public ConversationStatusEntity findByUserAndConversationAndFilter(String userId,
                                                                   String conversationId,
                                                                   String filterId)

Specified by:

findByUserAndConversationAndFilter in interface ConversationStatusEntityManager

findByUserAndConversation

public List<ConversationStatusEntity> findByUserAndConversation(String userId,
                                                                String conversationId)

Specified by:

findByUserAndConversation in interface ConversationStatusEntityManager

unreadCountByUserAndConversationAndNoFilter

public long unreadCountByUserAndConversationAndNoFilter(String userId,
                                                        String conversationId)

Specified by:

unreadCountByUserAndConversationAndNoFilter in interface ConversationStatusEntityManager

unreadCountByUserAndNoFilter

public long unreadCountByUserAndNoFilter(String userId)

Specified by:

unreadCountByUserAndNoFilter in interface ConversationStatusEntityManager

unreadCountsByUserAndFilterAndConversations

public Map<String,Long> unreadCountsByUserAndFilterAndConversations(String userId,
                                                                    String filterId,
                                                                    Collection<String> conversationIds)

Specified by:

unreadCountsByUserAndFilterAndConversations in interface ConversationStatusEntityManager

unreadCountByUserAndFilters

public Map<String,Long> unreadCountByUserAndFilters(String userId,
                                                    List<String> filterIds)

Specified by:

unreadCountByUserAndFilters in interface ConversationStatusEntityManager

unreadCountPerConversationByUserAndNoFilterAndOnlyUnread

public Map<String,Long> unreadCountPerConversationByUserAndNoFilterAndOnlyUnread(String userId)

Specified by:

unreadCountPerConversationByUserAndNoFilterAndOnlyUnread in interface ConversationStatusEntityManager

markConversationAsRead

public int markConversationAsRead(String userId,
                                  String conversationId)

Specified by:

markConversationAsRead in interface ConversationStatusEntityManager

resetConversationStatusesToEverythingRead

public int resetConversationStatusesToEverythingRead(String conversationId)

Specified by:

resetConversationStatusesToEverythingRead in interface ConversationStatusEntityManager

markMessageReceived

public int markMessageReceived(String userId,
                               MessageEntity messageEntity)

Specified by:

markMessageReceived in interface ConversationStatusEntityManager

increaseUnreadMessageCountsForConversation

public int increaseUnreadMessageCountsForConversation(ConversationEntity conversationEntity,
                                                      MessageEntity messageEntity)

Specified by:

increaseUnreadMessageCountsForConversation in interface ConversationStatusEntityManager

deleteByConversationId

public void deleteByConversationId(String conversationId)

Specified by:

deleteByConversationId in interface ConversationStatusEntityManager

createConversationStatusQuery

public ConversationStatusQuery createConversationStatusQuery()

Specified by:

createConversationStatusQuery in interface ConversationStatusEntityManager

findByCriteria

public List<ConversationStatus> findByCriteria(ConversationStatusQuery query)

Specified by:

findByCriteria in interface ConversationStatusEntityManager

countByCriteria

public long countByCriteria(ConversationStatusQuery query)

Specified by:

countByCriteria in interface ConversationStatusEntityManager