Class ConversationStatusEntityManagerImpl

java.lang.Object

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

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

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

All Implemented Interfaces:

ConversationStatusEntityManager, org.flowable.common.engine.impl.persistence.entity.EntityManager<ConversationStatusEntity>

public class ConversationStatusEntityManagerImpl
extends org.flowable.common.engine.impl.persistence.entity.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	Description
ConversationStatusEntityManagerImpl(EngageEngineConfiguration configuration, ConversationStatusDataManager conversationStatusDataManager)

Method Summary

Modifier and Type	Method	Description
long	countByCriteria(ConversationStatusQuery query)
protected ConversationStatusEntity	createConversationStatusEntity(String conversationId, String userId, String filterId)
ConversationStatusQuery	createConversationStatusQuery()
List<ConversationStatusEntity>	createStatusEntriesForMutedConversation(ConversationEntity conversationEntity, String userId)
List<ConversationStatusEntity>	createStatusEntriesForNewConversation(ConversationEntity conversationEntity)
List<ConversationStatusEntity>	createStatusEntriesForStarredConversation(ConversationEntity conversationEntity, String userId)
List<ConversationStatusEntity>	createStatusEntryForConversationParticipant(ConversationEntity conversationEntity, String userId)
void	deleteByConversationId(String conversationId)
void	deleteStatusEntriesForMutedFilters(ConversationEntity conversationEntity, String userId)
void	deleteStatusEntriesForStarredFilters(ConversationEntity conversationEntity, String userId)
protected Collection<String>	extractParticipantUserIds(List<org.flowable.identitylink.service.impl.persistence.entity.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 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 Details

ConversationStatusEntityManagerImpl

public ConversationStatusEntityManagerImpl(EngageEngineConfiguration configuration,
 ConversationStatusDataManager conversationStatusDataManager)

Method Details

createStatusEntriesForNewConversation

public List<ConversationStatusEntity> createStatusEntriesForNewConversation(ConversationEntity conversationEntity)

Specified by:

createStatusEntriesForNewConversation in interface ConversationStatusEntityManager

extractParticipantUserIds

protected Collection<String> extractParticipantUserIds(List<org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity> identityLinks)

createStatusEntryForConversationParticipant

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

Specified by:

createStatusEntryForConversationParticipant in interface ConversationStatusEntityManager

createConversationStatusEntity

protected ConversationStatusEntity createConversationStatusEntity(String conversationId,
 String userId,
 String filterId)

createStatusEntriesForMutedConversation

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

Specified by:

createStatusEntriesForMutedConversation in interface ConversationStatusEntityManager

createStatusEntriesForStarredConversation

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

Specified by:

createStatusEntriesForStarredConversation 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

deleteStatusEntriesForStarredFilters

public void deleteStatusEntriesForStarredFilters(ConversationEntity conversationEntity,
 String userId)

Specified by:

deleteStatusEntriesForStarredFilters in interface ConversationStatusEntityManager

deleteStatusEntriesForMutedFilters

public void deleteStatusEntriesForMutedFilters(ConversationEntity conversationEntity,
 String userId)

Specified by:

deleteStatusEntriesForMutedFilters 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