826c6683f8
* Adds actions, queries, db models and rest client * Adds Websocket handling for categories * fix merge * small refactor for categories websocket events * fix bad merge * Category delete handled * Handles deletion (prune on store) * Resolves feedback, adds team handling for prune * Minor fixes; param order and return, imports, type naming Co-authored-by: Elias Nahum <nahumhbl@gmail.com>
96 lines
3.2 KiB
TypeScript
96 lines
3.2 KiB
TypeScript
// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
|
|
// See LICENSE.txt for license information.
|
|
|
|
import {deleteCategory, storeCategories} from '@actions/local/category';
|
|
import {fetchCategories} from '@actions/remote/category';
|
|
import DatabaseManager from '@database/manager';
|
|
import {queryCategoriesById} from '@queries/servers/categories';
|
|
|
|
type WebsocketCategoriesMessage = {
|
|
broadcast: {
|
|
team_id: string;
|
|
};
|
|
data: {
|
|
team_id: string;
|
|
category?: string;
|
|
category_id: string;
|
|
updatedCategories?: string;
|
|
order?: string[];
|
|
};
|
|
}
|
|
|
|
const addOrUpdateCategories = async (serverUrl: string, categories: CategoryWithChannels[]) => {
|
|
try {
|
|
storeCategories(serverUrl, categories);
|
|
} catch (e) {
|
|
// eslint-disable-next-line no-console
|
|
console.log('Category WS: addOrUpdateCategories', e, categories);
|
|
}
|
|
};
|
|
|
|
export async function handleCategoryCreatedEvent(serverUrl: string, msg: WebsocketCategoriesMessage) {
|
|
let category;
|
|
try {
|
|
category = JSON.parse(msg.data.category!);
|
|
addOrUpdateCategories(serverUrl, [category]);
|
|
} catch (e) {
|
|
// eslint-disable-next-line no-console
|
|
console.log('Category WS: handleCategoryCreatedEvent', e, msg);
|
|
fetchCategories(serverUrl, msg.broadcast.team_id);
|
|
}
|
|
}
|
|
|
|
export async function handleCategoryUpdatedEvent(serverUrl: string, msg: WebsocketCategoriesMessage) {
|
|
let categories;
|
|
|
|
try {
|
|
categories = JSON.parse(msg.data.updatedCategories!);
|
|
addOrUpdateCategories(serverUrl, categories);
|
|
} catch (e) {
|
|
// eslint-disable-next-line no-console
|
|
console.log('Category WS: handleCategoryUpdatedEvent', e, msg);
|
|
fetchCategories(serverUrl, msg.broadcast.team_id, true);
|
|
}
|
|
}
|
|
|
|
export async function handleCategoryDeletedEvent(serverUrl: string, msg: WebsocketCategoriesMessage) {
|
|
try {
|
|
// Delete the Category
|
|
await deleteCategory(serverUrl, msg.data.category_id);
|
|
|
|
// Fetch the categories again as channels will have moved
|
|
fetchCategories(serverUrl, msg.broadcast.team_id);
|
|
} catch (e) {
|
|
// eslint-disable-next-line no-console
|
|
console.log('Category WS: handleCategoryDeletedEvent', e, msg);
|
|
}
|
|
}
|
|
|
|
export async function handleCategoryOrderUpdatedEvent(serverUrl: string, msg: WebsocketCategoriesMessage) {
|
|
try {
|
|
const operator = DatabaseManager.serverDatabases[serverUrl]?.operator;
|
|
|
|
if (!operator) {
|
|
return;
|
|
}
|
|
|
|
const {database} = operator;
|
|
|
|
// Update category order
|
|
if (msg.data.order?.length) {
|
|
const order = msg.data.order;
|
|
const categories = await queryCategoriesById(database, order);
|
|
categories.forEach((c) => {
|
|
const findOrder = (id: string) => id === c.id;
|
|
c.prepareUpdate(() => {
|
|
c.sortOrder = order.findIndex(findOrder);
|
|
});
|
|
});
|
|
await operator.batchRecords(categories);
|
|
}
|
|
} catch (e) {
|
|
// eslint-disable-next-line no-console
|
|
console.log('Category WS: handleCategoryOrderUpdatedEvent', e, msg);
|
|
fetchCategories(serverUrl, msg.data.team_id);
|
|
}
|
|
}
|