-
Notifications
You must be signed in to change notification settings - Fork 0
/
subscribe.js
63 lines (58 loc) · 1.61 KB
/
subscribe.js
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
53
54
55
56
57
58
59
60
61
62
63
const Nomad = require('nomad-stream')
const nomad = new Nomad()
console.log(nomad);
nomad.subscribe(['QmRAxkJ7165rcWpGVnrKaB2JavpdbN3AR9eT5UbsRwaf5V', 'QmPMHfhr3p7fR17SNBmB5vuoVGoLWggVLj8tnYDgBCiUbU'], function(message) {
console.log('received new message');
console.log(message.message);
}, function(err){console.log(err)});
nomad.prepareToPublish().catch(function(err){
console.log(err);
}).then(function(n) {
console.log(n);
const nomadInstance = n;
nomadInstance.publishRoot('root hi pie');
var counter = 0;
setInterval(function(){
console.log('publishing');
nomadInstance.publish(`hi pie ${counter}`);
counter++;
}, 10000);
});
// let idx = 0
//
// const createMessage = () => {
// return `Message: ${idx++}`
// }
//
// let instance = null
// nomad.prepareToPublish()
// .then((n) => {
// instance = n
// console.log('DEMO: CONNECTED!!!!')
// return instance.publishRoot('ROOT MESSAGE')
// })
// .catch(() => {
// log.err('Error publishing root message')
// })
// .then(() => {
// console.log('READY')
// console.log('DEMO: ROOT PUBLISHED!!!!')
// setInterval(() => {
// const msg = createMessage();
// console.log('sending message', msg);
// instance.publish(msg)
// }, 60000)
// return nomad.publish(createMessage())
// })
// .catch((err) => {
// log.err('err')
// console.log('DEMO: CONNECT ERROR!!!!', e)
// console.log(e)
// return nomad.publish('Hey there, Gavin!')
// })
// .then(() => {
// console.log('DEMO: PUBLLISHED!!!!', d)
// })
// .catch(() => {
// console.log('DEMO: PUBLISH ERROR!!!!', e)
// })