|
|
@ -115,6 +115,7 @@ module.exports = {
|
|
|
|
getAllPrivateConversations,
|
|
|
|
getAllPrivateConversations,
|
|
|
|
getAllGroupsInvolvingId,
|
|
|
|
getAllGroupsInvolvingId,
|
|
|
|
removeAllConversations,
|
|
|
|
removeAllConversations,
|
|
|
|
|
|
|
|
removeAllPrivateConversations,
|
|
|
|
|
|
|
|
|
|
|
|
searchConversations,
|
|
|
|
searchConversations,
|
|
|
|
searchMessages,
|
|
|
|
searchMessages,
|
|
|
@ -2657,6 +2658,10 @@ async function removeAllConversations() {
|
|
|
|
await removeAllFromTable(CONVERSATIONS_TABLE);
|
|
|
|
await removeAllFromTable(CONVERSATIONS_TABLE);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
async function removeAllPrivateConversations() {
|
|
|
|
|
|
|
|
await db.run(`DELETE FROM ${CONVERSATIONS_TABLE} WHERE type = 'private'`);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
async function getMessagesNeedingUpgrade(limit, { maxVersion }) {
|
|
|
|
async function getMessagesNeedingUpgrade(limit, { maxVersion }) {
|
|
|
|
const rows = await db.all(
|
|
|
|
const rows = await db.all(
|
|
|
|
`SELECT json FROM messages
|
|
|
|
`SELECT json FROM messages
|
|
|
|