aboutsummaryrefslogtreecommitdiffstats
path: root/ui/imports/api/scheduled-scans/server/publications.js
blob: 9359c20dce660bc14ca8ec66b1b72ba9fc962d6f (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
import { Meteor } from 'meteor/meteor';
import * as R from 'ramda';
import { Counts } from 'meteor/tmeasday:publish-counts';

import { ScheduledScans,
  subsScheduledScansPageAmountSorted,
  subsScheduledScansPageAmountSortedCounter,
  subsScheduledScansId,
} from '../scheduled-scans.js';

Meteor.publish(subsScheduledScansPageAmountSorted, function (
  page, amountPerPage, sortField, sortDirection) {

  console.log(`server subscribtion: ${subsScheduledScansPageAmountSorted}`);
  console.log('page: ', page);
  console.log('amount: ', amountPerPage);
  console.log('sortField: ', sortField, R.isNil(sortField));
  console.log('sortDirection: ', sortDirection);

  let skip = (page - 1) * amountPerPage;

  let query = {};
  console.log('-query: ', query);
  let sortParams = {};

  sortParams = R.ifElse(R.isNil, R.always(sortParams), 
      R.assoc(R.__, sortDirection, sortParams))(sortField);

  console.log('sort params:', sortParams);

  let qParams = {
    limit: amountPerPage,
    skip: skip,
    sort: sortParams,
  };

  Counts.publish(this, subsScheduledScansPageAmountSortedCounter, ScheduledScans.find(query), {
    noReady: true
  });

  return ScheduledScans.find(query, qParams); 
});

Meteor.publish(subsScheduledScansId, function (_id) {
  console.log(`server subscribtion: ${subsScheduledScansId}`);
  console.log('-id: ', _id);

  //let that = this;

  let query = { _id: _id };
  return ScheduledScans.find(query); 
});