wekan/server/publications/boards.js

// This is the publication used to display the board list. We publish all the
// non-archived boards:
// 1. that the user is a member of
// 2. the user has starred
import { ReactiveCache } from '/imports/reactiveCache';
import Users from "../../models/users";
import Org from "../../models/org";
import Team from "../../models/team";
import Attachments from '../../models/attachments';

Meteor.publishRelations('boards', function() {
  const userId = this.userId;
  // Ensure that the user is connected. If it is not, we need to return an empty
  // array to tell the client to remove the previously published docs.
  if (!Match.test(userId, String) || !userId) {
    return [];
  }

  // Defensive programming to verify that starredBoards has the expected
  // format -- since the field is in the `profile` a user can modify it.
  // const { starredBoards = [] } = (ReactiveCache.getUser(userId) || {}).profile || {};
  // check(starredBoards, [String]);

  // let currUser = ReactiveCache.getUser(userId);
  // let orgIdsUserBelongs = currUser!== 'undefined' && currUser.teams !== 'undefined' ? currUser.orgIdsUserBelongs() : '';
  // let teamIdsUserBelongs = currUser!== 'undefined' && currUser.teams !== 'undefined' ? currUser.teamIdsUserBelongs() : '';
  // let orgsIds = [];
  // let teamsIds = [];
  // if(orgIdsUserBelongs && orgIdsUserBelongs != ''){
  //   orgsIds = orgIdsUserBelongs.split(',');
  // }
  // if(teamIdsUserBelongs && teamIdsUserBelongs != ''){
  //   teamsIds = teamIdsUserBelongs.split(',');
  // }
  this.cursor(ReactiveCache.getBoards(
    {
      archived: false,
      _id: { $in: Boards.userBoardIds(userId, false) },
      // $or: [
      //   {
      //     // _id: { $in: starredBoards },  // Commented out, to get a list of all public boards
      //     permission: 'public',
      //   },
      //   { members: { $elemMatch: { userId, isActive: true } } },
      //   {'orgs.orgId': {$in : orgsIds}},
      //   {'teams.teamId': {$in : teamsIds}},
      // ],
    },
    {
      sort: { sort: 1 /* boards default sorting */ },
    },
    true,
  ),
    function(boardId, board) {
      this.cursor(
        ReactiveCache.getLists(
          { boardId, archived: false },
          { fields:
            {
              _id: 1,
              title: 1,
              boardId: 1,
              archived: 1,
              sort: 1
            }
          },
          true,
        )
      );
      this.cursor(
        ReactiveCache.getCards(
          { boardId, archived: false },
          { fields: {
            _id: 1,
            boardId: 1,
            listId: 1,
            archived: 1,
            sort: 1
          }},
          true,
        )
      );
    }
  );
  const ret = this.ready();
  return ret;
});

Meteor.publish('boardsReport', function() {
  const userId = this.userId;
  // Ensure that the user is connected. If it is not, we need to return an empty
  // array to tell the client to remove the previously published docs.
  if (!Match.test(userId, String) || !userId) return [];

  const boards = ReactiveCache.getBoards(
    {
      _id: { $in: Boards.userBoardIds(userId, null) },
    },
    {
      fields: {
        _id: 1,
        boardId: 1,
        archived: 1,
        slug: 1,
        title: 1,
        description: 1,
        color: 1,
        backgroundImageURL: 1,
        members: 1,
        orgs: 1,
        teams: 1,
        permission: 1,
        type: 1,
        sort: 1,
      },
      sort: { sort: 1 /* boards default sorting */ },
    },
    true,
  );

  const userIds = [];
  const orgIds = [];
  const teamIds = [];
  boards.forEach(board => {
    if (board.members) {
      board.members.forEach(member => {
        userIds.push(member.userId);
      });
    }
    if (board.orgs) {
      board.orgs.forEach(org => {
        orgIds.push(org.orgId);
      });
    }
    if (board.teams) {
      board.teams.forEach(team => {
        teamIds.push(team.teamId);
      });
    }
  })

  const ret = [
    boards,
    ReactiveCache.getUsers({ _id: { $in: userIds } }, { fields: Users.safeFields }, true),
    ReactiveCache.getTeams({ _id: { $in: teamIds } }, {}, true),
    ReactiveCache.getOrgs({ _id: { $in: orgIds } }, {}, true),
  ]
  return ret;
});

Meteor.publish('archivedBoards', function() {
  const userId = this.userId;
  if (!Match.test(userId, String)) return [];

  const ret = ReactiveCache.getBoards(
    {
      _id: { $in: Boards.userBoardIds(userId, true)},
      archived: true,
      members: {
         $elemMatch: {
           userId,
           isAdmin: true,
         },
       },
    },
    {
      fields: {
        _id: 1,
        archived: 1,
        slug: 1,
        title: 1,
        createdAt: 1,
        modifiedAt: 1,
        archivedAt: 1,
      },
      sort: { archivedAt: -1, modifiedAt: -1 },
    },
    true,
  );
  return ret;
});

// If isArchived = false, this will only return board elements which are not archived.
// If isArchived = true, this will only return board elements which are archived.
Meteor.publishRelations('board', function(boardId, isArchived) {
  this.unblock();
  check(boardId, String);
  check(isArchived, Boolean);
  const thisUserId = this.userId;
  const $or = [{ permission: 'public' }];
  let currUser =  (!Match.test(thisUserId, String) || !thisUserId) ? 'undefined' : ReactiveCache.getUser(thisUserId);
  let orgIdsUserBelongs = currUser!== 'undefined' && currUser.teams !== 'undefined' ? currUser.orgIdsUserBelongs() : '';
  let teamIdsUserBelongs = currUser!== 'undefined' && currUser.teams !== 'undefined' ? currUser.teamIdsUserBelongs() : '';
  let orgsIds = [];
  let teamsIds = [];
  if(orgIdsUserBelongs && orgIdsUserBelongs != ''){
    orgsIds = orgIdsUserBelongs.split(',');
  }
  if(teamIdsUserBelongs && teamIdsUserBelongs != ''){
    teamsIds = teamIdsUserBelongs.split(',');
  }

  if (thisUserId) {
    $or.push({members: { $elemMatch: { userId: thisUserId, isActive: true } }});
    $or.push({'orgs.orgId': {$in : orgsIds}});
    $or.push({'teams.teamId': {$in : teamsIds}});
  }

  this.cursor(
    ReactiveCache.getBoards(
      {
        _id: boardId,
        archived: false,
        // If the board is not public the user has to be a member of it to see
        // it.
        $or,
        // Sort required to ensure oplog usage
      },
      { limit: 1, sort: { sort: 1 /* boards default sorting */ } },
      true,
    ),
    function(boardId, board) {
      this.cursor(ReactiveCache.getLists({ boardId, archived: isArchived }, {}, true));
      this.cursor(ReactiveCache.getSwimlanes({ boardId, archived: isArchived }, {}, true));
      this.cursor(ReactiveCache.getIntegrations({ boardId }, {}, true));
      this.cursor(ReactiveCache.getCardCommentReactions({ boardId }, {}, true));
      this.cursor(
        ReactiveCache.getCustomFields(
          { boardIds: { $in: [boardId] } },
          { sort: { name: 1 } },
          true,
        ),
      );

      // Cards and cards comments
      // XXX Originally we were publishing the card documents as a child of the
      // list publication defined above using the following selector `{ listId:
      // list._id }`. But it was causing a race condition in publish-composite,
      // that I documented here:
      //
      //   https://github.com/englue/meteor-publish-composite/issues/29
      //
      // cottz:publish had a similar problem:
      //
      //   https://github.com/Goluis/cottz-publish/issues/4
      //
      // The current state of relational publishing in meteor is a bit sad,
      // there are a lot of various packages, with various APIs, some of them
      // are unmaintained. Fortunately this is something that will be fixed by
      // meteor-core at some point:
      //
      //   https://trello.com/c/BGvIwkEa/48-easy-joins-in-subscriptions
      //
      // And in the meantime our code below works pretty well -- it's not even a
      // hack!

      // Gather queries and send in bulk
      const cardComments = this.join(CardComments);
      cardComments.selector = _ids => ({ cardId: _ids });
      const cardCommentsLinkedBoard = this.join(CardComments);
      cardCommentsLinkedBoard.selector = _ids => ({ boardId: _ids });
      const cardCommentReactions = this.join(CardCommentReactions);
      cardCommentReactions.selector = _ids => ({ cardId: _ids });
      const attachments = this.join(Attachments.collection);
      attachments.selector = _ids => ({ 'meta.cardId': _ids });
      const checklists = this.join(Checklists);
      checklists.selector = _ids => ({ cardId: _ids });
      const checklistItems = this.join(ChecklistItems);
      checklistItems.selector = _ids => ({ cardId: _ids });
      const parentCards = this.join(Cards);
      parentCards.selector = _ids => ({ parentId: _ids });
      const boards = this.join(Boards);
      const subCards = this.join(Cards);
      subCards.selector = _ids => ({ _id: _ids, archived: isArchived });
      const linkedBoardCards = this.join(Cards);
      linkedBoardCards.selector = _ids => ({ boardId: _ids });

      this.cursor(
        ReactiveCache.getCards({
            boardId: { $in: [boardId, board.subtasksDefaultBoardId] },
            archived: isArchived,
          },
          {},
          true,
        ),
        function(cardId, card) {
          if (card.type === 'cardType-linkedCard') {
            const impCardId = card.linkedId;
            subCards.push(impCardId); // GitHub issue #2688 and #2693
            cardComments.push(impCardId);
            attachments.push(impCardId);
            checklists.push(impCardId);
            checklistItems.push(impCardId);
          } else if (card.type === 'cardType-linkedBoard') {
            boards.push(card.linkedId);
            linkedBoardCards.push(card.linkedId);
            cardCommentsLinkedBoard.push(card.linkedId);
          }
          cardComments.push(cardId);
          attachments.push(cardId);
          checklists.push(cardId);
          checklistItems.push(cardId);
          parentCards.push(cardId);
          cardCommentReactions.push(cardId);
        },
      );

      // Send bulk queries for all found ids
      subCards.send();
      cardComments.send();
      cardCommentReactions.send();
      attachments.send();
      checklists.send();
      checklistItems.send();
      boards.send();
      parentCards.send();
      linkedBoardCards.send();
      cardCommentsLinkedBoard.send();

      if (board.members) {
        // Board members. This publication also includes former board members that
        // aren't members anymore but may have some activities attached to them in
        // the history.
        const memberIds = _.pluck(board.members, 'userId');

        // We omit the current user because the client should already have that data,
        // and sending it triggers a subtle bug:
        // https://github.com/wefork/wekan/issues/15
        this.cursor(
          ReactiveCache.getUsers(
            {
              _id: { $in: _.without(memberIds, thisUserId) },
            },
            {
              fields: {
                username: 1,
                'profile.fullname': 1,
                'profile.avatarUrl': 1,
                'profile.initials': 1,
              },
            },
            true,
          ),
        );

        //this.cursor(presences.find({ userId: { $in: memberIds } }));
      }
    },
  );

  const ret = this.ready();
  return ret;
});

Meteor.methods({
  copyBoard(boardId, properties) {
    check(boardId, String);
    check(properties, Object);

    let ret = null;
    const board = ReactiveCache.getBoard(boardId);
    if (board) {
      for (const key in properties) {
        board[key] = properties[key];
      }
      ret = board.copy();
    }
    return ret;
  },
});