receptor/src/actions/selection.js

import { filter_subscribe, filter_unsubscribe } from './filter_subscribe';
import { unsubscribe } from './subscribe';
import { push_path } from './routing';

export const UNION = 'UNION';
export const SUBTRACT = 'SUBTRACT';
export const EXCLUSIVE = 'EXCLUSIVE';

export default function selectTorrent(ids, action, navigate=true) {
  return (dispatch, getState) => {
    const previous = new Set(getState().selection);
    dispatch({ type: action, ids });

    const state = getState();
    const next = new Set(state.selection);
    const filter_subscriptions = state.filter_subscribe;
    const subscriptions = state.subscribe;
    const { peers, files, trackers } = state;

    const added = next.difference(previous);
    const removed = previous.difference(next);

    added.forEach(t => {
      const criteria = [
        { field: "torrent_id", op: "==", value: t }
      ];
      dispatch(filter_subscribe("peer", criteria));
      dispatch(filter_subscribe("file", criteria));
      dispatch(filter_subscribe("tracker", criteria));
    });

    removed.forEach(t => {
      /* Remove filter subscriptions */
      const serials = filter_subscriptions
        .filter(sub => sub.criteria[0] && sub.criteria[0].value === t)
        .map(sub => sub.serial);
      serials.forEach(serial => dispatch(filter_unsubscribe(serial)));
      /* Remove resource subscriptions */
      const _ids = [
        ...Object.values(files)
          .filter(file => file.torrent_id === t)
          .map(file => file.id),
        ...Object.values(peers)
          .filter(peer => peer.torrent_id === t)
          .map(peer => peer.id),
        ...Object.values(trackers)
          .filter(tracker => tracker.torrent_id === t)
          .map(tracker => tracker.id)
      ];
      if (_ids.length > 0) {
        dispatch(unsubscribe(..._ids));
      }
    });

    if (navigate) {
      const url_torrents = state.selection.slice(0, 3);
      if (url_torrents.length > 0) {
        dispatch(push_path(`/torrents/${url_torrents}`));
      } else {
        dispatch(push_path("/"));
      }
    }
  };
}