f815f6b3e5
* Wip
* update name so it references changing the reaction on a post
* handleAddEmoji -> handleAddCustomEmoji
* add remove reaction logic
* sanitizeReactions
* use skipSync to return early if not deleting any records that are
not in the server db
* return the filtered delete results and have the handler destroy the
records
* fix lint
* use forEach instead of map.
* PR feedback
* PR feedback
* Update app/actions/websocket/reactions.ts
* remove console.log
Co-authored-by: Elias Nahum <nahumhbl@gmail.com>
57 lines
2.2 KiB
TypeScript
57 lines
2.2 KiB
TypeScript
// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
|
|
// See LICENSE.txt for license information.
|
|
import {Q} from '@nozbe/watermelondb';
|
|
|
|
import {MM_TABLES} from '@constants/database';
|
|
|
|
import type {RecordPair, SanitizeReactionsArgs} from '@typings/database/database';
|
|
import type ReactionModel from '@typings/database/models/servers/reaction';
|
|
|
|
const {REACTION} = MM_TABLES.SERVER;
|
|
|
|
/**
|
|
* sanitizeReactions: Treats reactions happening on a Post. For example, a user can add/remove an emoji. Hence, this function
|
|
* tell us which reactions to create/delete in the Reaction table and which custom-emoji to create in our database.
|
|
* For more information, please have a look at https://community.mattermost.com/core/pl/rq9e8jnonpyrmnyxpuzyc4d6ko
|
|
* @param {SanitizeReactionsArgs} sanitizeReactions
|
|
* @param {Database} sanitizeReactions.database
|
|
* @param {string} sanitizeReactions.post_id
|
|
* @param {RawReaction[]} sanitizeReactions.rawReactions
|
|
* @returns {Promise<{createReactions: RawReaction[], deleteReactions: Reaction[]}>}
|
|
*/
|
|
export const sanitizeReactions = async ({database, post_id, rawReactions, skipSync}: SanitizeReactionsArgs) => {
|
|
const reactions = (await database.collections.
|
|
get(REACTION).
|
|
query(Q.where('post_id', post_id)).
|
|
fetch()) as ReactionModel[];
|
|
|
|
// similarObjects: Contains objects that are in both the RawReaction array and in the Reaction table
|
|
const similarObjects: ReactionModel[] = [];
|
|
|
|
const createReactions: RecordPair[] = [];
|
|
|
|
for (let i = 0; i < rawReactions.length; i++) {
|
|
const raw = rawReactions[i];
|
|
|
|
// If the reaction is not present let's add it to the db
|
|
const exists = reactions.find((r) => (
|
|
r.userId === raw.user_id &&
|
|
r.emojiName === raw.emoji_name));
|
|
|
|
if (exists) {
|
|
similarObjects.push(exists);
|
|
} else {
|
|
createReactions.push({raw});
|
|
}
|
|
}
|
|
|
|
if (skipSync) {
|
|
return {createReactions, deleteReactions: []};
|
|
}
|
|
|
|
// finding out elements to delete using array subtract
|
|
const deleteReactions = reactions.
|
|
filter((reaction) => !similarObjects.includes(reaction));
|
|
|
|
return {createReactions, deleteReactions};
|
|
};
|