mirror of
https://github.com/wekan/wekan.git
synced 2026-02-21 07:24:07 +01:00
71eb01e233
Part 3 of ReactiveCache async migration: - Add await before all ReactiveCache.getX() calls - Make functions containing ReactiveCache calls async - Convert forEach/map/filter loops with async callbacks to for...of - Update model helpers, Meteor methods, JsonRoutes handlers - Update collection hooks (.before/.after insert/update/remove) - Update .allow() callbacks to async Files updated across models/ and server/ directories: - Model files: cards, boards, lists, swimlanes, activities, users, checklists, checklistItems, customFields, attachments, integrations, cardComments, settings files, creators, exporters, and more - Server files: publications, methods, notifications, routes, migrations
52 lines
1.2 KiB
JavaScript
52 lines
1.2 KiB
JavaScript
import Attachments from '/models/attachments';
|
|
import { ObjectID } from 'bson';
|
|
|
|
Meteor.publish('attachmentsList', async function(limit) {
|
|
const userId = this.userId;
|
|
|
|
// Get boards the user has access to
|
|
const userBoards = (await ReactiveCache.getBoards({
|
|
$or: [
|
|
{ permission: 'public' },
|
|
{ members: { $elemMatch: { userId, isActive: true } } }
|
|
]
|
|
})).map(board => board._id);
|
|
|
|
if (userBoards.length === 0) {
|
|
// User has no access to any boards, return empty cursor
|
|
return this.ready();
|
|
}
|
|
|
|
// Get cards from those boards
|
|
const userCards = (await ReactiveCache.getCards({
|
|
boardId: { $in: userBoards },
|
|
archived: false
|
|
})).map(card => card._id);
|
|
|
|
if (userCards.length === 0) {
|
|
// No cards found, return empty cursor
|
|
return this.ready();
|
|
}
|
|
|
|
// Only return attachments for cards the user has access to
|
|
const ret = (await ReactiveCache.getAttachments(
|
|
{ 'meta.cardId': { $in: userCards } },
|
|
{
|
|
fields: {
|
|
_id: 1,
|
|
name: 1,
|
|
size: 1,
|
|
type: 1,
|
|
meta: 1,
|
|
path: 1,
|
|
versions: 1,
|
|
},
|
|
sort: {
|
|
name: 1,
|
|
},
|
|
limit: limit,
|
|
},
|
|
true,
|
|
)).cursor;
|
|
return ret;
|
|
});
|