info-server/pubsub.js at develop · DigixGlobal/info-server · GitHub

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
const { PubSub } = require('apollo-server');

const { proposalToType } = require('./helpers/utils');

const pubsub = new PubSub();

const broadcast = {
  userUpdated(user) {
    return pubsub.publish(
      'userUpdated',
      { userUpdated: user },
    );
  },
  proposalSubmitted(proposal) {
    const proposalObject = proposalToType(proposal);

    return pubsub.publish(
      'proposalSubmitted',
      { proposalSubmitted: proposalObject },
    );
  },
  proposalUpdated(proposal) {
    const proposalObject = proposalToType(proposal);

    return pubsub.publish(
      'proposalUpdated',
      { proposalUpdated: proposalObject },
    );
  },
  daoUpdated(daoInfo) {
    return pubsub.publish(
      'daoUpdated',
      { daoUpdated: daoInfo },
    );
  },
};

module.exports = {
  pubsub,
  broadcast,
};