forked from pubnub/javascript
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathdata-sync.js
More file actions
111 lines (85 loc) · 3.15 KB
/
Copy pathdata-sync.js
File metadata and controls
111 lines (85 loc) · 3.15 KB
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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
/* ---------------------------------------------------------------------------
Init PubNub and Get your PubNub API Keys:
http://www.pubnub.com/account#api-keys
--------------------------------------------------------------------------- */
var PUBNUB = require("../pubnub.js")
var pubnub = PUBNUB({
write_key : "pub-c-bf446f9e-dd7f-43fe-8736-d6e5dce3fe67",
read_key : "sub-c-d1c2cc5a-1102-11e4-8880-02ee2ddab7fe",
origin : "dara24.devbuild.pubnub.com",
auth_key : 'abcd'
});
var ds1 = pubnub.sync("dp7");
var ds = ds1.get('a.c');
ds.on.ready(function(ref){
console.log('READY');
console.log(JSON.stringify(ref.value(), null, 2));
/*
console.log(JSON.stringify(ref.value('a.a.b.c')));
console.log(JSON.stringify(ref.value('a.b')));
console.log(JSON.stringify(ref.value('a.c')));
*/
});
// Data Events
ds.on.merge(function(ref) {
console.log('UPDATE');
console.log(ref.path);
console.log(JSON.stringify(ref.data.value(), null, 2));
//console.log(JSON.stringify(ref.data.value('a.a.b.c')));
//console.log(JSON.stringify(ref.data.value('a.b')));
//console.log(JSON.stringify(ref.data.value('a.c')));
//console.log(JSON.stringify(ds.get(), null, 2));
})
ds.on.replace(function(ref){
console.log('REPLACE');
//console.log(JSON.stringify(params));
console.log(JSON.stringify(ref.value(), null, 2));
console.log(JSON.stringify(ref.value('a.a.b.c')));
console.log(JSON.stringify(ref.value('a.b')));
console.log(JSON.stringify(ref.value('a.c')));
})
ds.on.remove(function(ref){
console.log('REMOVE');
//console.log(JSON.stringify(params));
console.log(JSON.stringify(ref.value(), null, 2));
console.log(JSON.stringify(ref.value('a.a.b.c')));
console.log(JSON.stringify(ref.value('a.b')));
})
ds.on.error(function(ref){
console.log('ERROR');
console.log(JSON.stringify(ref));
})
// Network Events
ds.on.network.connect(function(params) { console.log(JSON.stringify(params)); })
ds.on.network.disconnect(function(params) { console.log(JSON.stringify(params)); })
ds.on.network.reconnect(function(params) { console.log(JSON.stringify(params)); })
/*
ds1.on.ready(function(){
console.log('READY');
console.log(JSON.stringify(ds1.value(), null, 2));
});
// Data Events
ds1.on.update(function(params) {
console.log('UPDATE 1');
console.log(JSON.stringify(params.value(), null, 2));
//console.log(JSON.stringify(ds.get(), null, 2));
})
ds1.on.set(function(params){
console.log('SET 1');
//console.log(JSON.stringify(params));
console.log(JSON.stringify(params.value(), null, 2));
})
ds1.on.remove(function(params){
console.log('REMOVE 1');
//console.log(JSON.stringify(params));
console.log(JSON.stringify(params.value(), null, 2));
})
ds1.on.error(function(params){
console.log('ERROR 1');
console.log(JSON.stringify(params.value()));
})
// Network Events
ds1.on.network.connect(function(params) { console.log(JSON.stringify(params)); })
ds1.on.network.disconnect(function(params) { console.log(JSON.stringify(params)); })
ds1.on.network.reconnect(function(params) { console.log(JSON.stringify(params)); })
*/