Class MessagesDAO

Hierarchy (View Summary)

BaseDAO
- MessagesDAO

Implements

IMessagesDAO

Constructors

constructor

new MessagesDAO(dbClient: IDbClient): MessagesDAO
Parameters
- dbClient: IDbClient
Returns MessagesDAO
Overrides BaseDAO.constructor
- Defined in src/dao/db/MessagesDAO.ts:7

Properties

`Protected` `Readonly`db

Methods

checkIfMessageExists

checkIfMessageExists(message_id: number): Promise<boolean>
Parameters
- message_id: number
Returns Promise<boolean>
Implementation of IMessagesDAO.checkIfMessageExists
- Defined in src/dao/db/MessagesDAO.ts:31

countChatMessages

countChatMessages(stream_id: number): Promise<number>
Parameters
- stream_id: number
Returns Promise<number>
Implementation of IMessagesDAO.countChatMessages
- Defined in src/dao/db/MessagesDAO.ts:61

countMessageEdits

countMessageEdits(message_id: number): Promise<number>
Parameters
- message_id: number
Returns Promise<number>
Implementation of IMessagesDAO.countMessageEdits
- Defined in src/dao/db/MessagesDAO.ts:80

createChatMessage

createChatMessage(
    stream_id: number,
    user_id: number,
    content: string,
): Promise<Message | null>
Parameters
- stream_id: number
- user_id: number
- content: string
Returns Promise<Message | null>
Implementation of IMessagesDAO.createChatMessage
- Defined in src/dao/db/MessagesDAO.ts:11

deleteChatMessage

deleteChatMessage(message_id: number): Promise<boolean>
Parameters
- message_id: number
Returns Promise<boolean>
Implementation of IMessagesDAO.deleteChatMessage
- Defined in src/dao/db/MessagesDAO.ts:45

editChatMessage

editChatMessage(message_id: number, newContent: string): Promise<boolean>
Parameters
- message_id: number
- newContent: string
Returns Promise<boolean>
Implementation of IMessagesDAO.editChatMessage
- Defined in src/dao/db/MessagesDAO.ts:36

`Protected`executeQuery

executeQuery<T>(query: string, params?: any[]): Promise<T | null>
Type Parameters
- T
Parameters
- query: string
- Optionalparams: any[]
Returns Promise<T | null>
Inherited from BaseDAO.executeQuery
- Defined in src/dao/db/BaseDao.ts:83

`Protected`executeQueryMultiple

executeQueryMultiple<T>(query: string, params?: any[]): Promise<T[]>
Type Parameters
- T
Parameters
- query: string
- Optionalparams: any[]
Returns Promise<T[]>
Inherited from BaseDAO.executeQueryMultiple
- Defined in src/dao/db/BaseDao.ts:97

getAllMessagesPaginated

getAllMessagesPaginated(
    stream_id: number,
    limit?: number,
    offset?: number,
): Promise<Message[]>
Parameters
- stream_id: number
- Optionallimit: number
- Optionaloffset: number
Returns Promise<Message[]>
Implementation of IMessagesDAO.getAllMessagesPaginated
- Defined in src/dao/db/MessagesDAO.ts:134

getChatMessages

getChatMessages(
    stream_id: number,
    limit?: number,
    offset?: number,
): Promise<Message[]>
Parameters
- stream_id: number
- Optionallimit: number
- Optionaloffset: number
Returns Promise<Message[]>
Implementation of IMessagesDAO.getChatMessages
- Defined in src/dao/db/MessagesDAO.ts:21

getDeletedMessages

getDeletedMessages(stream_id: number): Promise<Message[]>
Parameters
- stream_id: number
Returns Promise<Message[]>
Implementation of IMessagesDAO.getDeletedMessages
- Defined in src/dao/db/MessagesDAO.ts:85

getDeletedMessagesPaginated

getDeletedMessagesPaginated(
    stream_id: number,
    limit?: number,
    offset?: number,
): Promise<Message[]>
Parameters
- stream_id: number
- Optionallimit: number
- Optionaloffset: number
Returns Promise<Message[]>
Implementation of IMessagesDAO.getDeletedMessagesPaginated
- Defined in src/dao/db/MessagesDAO.ts:103

getLastMessage

getLastMessage(stream_id: number): Promise<Message | null>
Parameters
- stream_id: number
Returns Promise<Message | null>
Implementation of IMessagesDAO.getLastMessage
- Defined in src/dao/db/MessagesDAO.ts:66

getMessageEditHistory

getMessageEditHistory(message_id: number): Promise<OldMessageRecord[]>
Parameters
- message_id: number
Returns Promise<OldMessageRecord[]>
Implementation of IMessagesDAO.getMessageEditHistory
- Defined in src/dao/db/MessagesDAO.ts:50

getMessageEditHistoryPaginated

getMessageEditHistoryPaginated(
    message_id: number,
    limit?: number,
    offset?: number,
): Promise<OldMessageRecord[]>
Parameters
- message_id: number
- Optionallimit: number
- Optionaloffset: number
Returns Promise<OldMessageRecord[]>
Implementation of IMessagesDAO.getMessageEditHistoryPaginated
- Defined in src/dao/db/MessagesDAO.ts:113

getUserMessagesPaginated

getUserMessagesPaginated(
    stream_id: number,
    user_id: number,
    limit?: number,
    offset?: number,
): Promise<Message[]>
Parameters
- stream_id: number
- user_id: number
- Optionallimit: number
- Optionaloffset: number
Returns Promise<Message[]>
Implementation of IMessagesDAO.getUserMessagesPaginated
- Defined in src/dao/db/MessagesDAO.ts:123

hardDeleteChatMessage

hardDeleteChatMessage(message_id: number): Promise<boolean>
Parameters
- message_id: number
Returns Promise<boolean>
Implementation of IMessagesDAO.hardDeleteChatMessage
- Defined in src/dao/db/MessagesDAO.ts:97

isUserMessageAuthor

isUserMessageAuthor(message_id: number, user_id: number): Promise<boolean>
Parameters
- message_id: number
- user_id: number
Returns Promise<boolean>
Implementation of IMessagesDAO.isUserMessageAuthor
- Defined in src/dao/db/MessagesDAO.ts:71

`Protected`mapCacheError

mapCacheError(error: any): DaoError
Parameters
- error: any
Returns DaoError
Inherited from BaseDAO.mapCacheError
- Defined in src/dao/db/BaseDao.ts:47

`Protected`mapError

mapError(error: any): DaoError
Parameters
- error: any
Returns DaoError
Inherited from BaseDAO.mapError
- Defined in src/dao/db/BaseDao.ts:60

`Protected`mapPostgresError

mapPostgresError(error: any): DaoError
Parameters
- error: any
Returns DaoError
Inherited from BaseDAO.mapPostgresError
- Defined in src/dao/db/BaseDao.ts:16

`Protected`scalar

scalar<T = any>(query: string, params?: any[]): Promise<T>
Type Parameters
- T = any
Parameters
- query: string
- Optionalparams: any[]
Returns Promise<T>
Inherited from BaseDAO.scalar
- Defined in src/dao/db/BaseDao.ts:109

undeleteAllChatMessages

undeleteAllChatMessages(stream_id: number): Promise<number>
Parameters
- stream_id: number
Returns Promise<number>
Implementation of IMessagesDAO.undeleteAllChatMessages
- Defined in src/dao/db/MessagesDAO.ts:91

undeleteChatMessage

undeleteChatMessage(message_id: number): Promise<boolean>
Parameters
- message_id: number
Returns Promise<boolean>
Implementation of IMessagesDAO.undeleteChatMessage
- Defined in src/dao/db/MessagesDAO.ts:56