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
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
|
//
// hatebuWatchDog.js - hatena bookmark watch dog -
//
// Clear all watchers if started watcher exists.
if (plugins.hatebuWatchDog && plugins.hatebuWatchDog.stopWatching)
plugins.hatebuWatchDog.stopWatching();
plugins.hatebuWatchDog = (function() {
const libly = plugins.libly;
let previousValue = 0;
let tasks = [];
function addTask(target) {
liberator.echo(target.site);
const MINUTE = 60; // sec.
interval = getInterval() || (10 * MINUTE); // default 10 min.
interval = Math.max(interval, MINUTE); // lower limt is 1 min.
// initialize previous value
target.previousValue = 0;
tasks.push(setInterval(watch, 1000 * interval, target));
liberator.dump({target: target, interval: interval});
}
function clearAllTasks() {
tasks.forEach(function(task) {
clearInterval(task);
});
tasks = [];
liberator.dump("watch dog is sleeping...");
}
function watch(target) {
getCurrentValue(
target.site,
function(currentValue) {
let delta = currentValue - target.previousValue;
if (delta || notifyAlways()) {
showHatebuNotification(target, currentValue, delta);
}
target.previousValue = currentValue;
},
function() {
liberator.echoerr("Cannot get current value.");
}
);
}
function getCurrentValue(target, onSuccess, onFailure) {
// build hatebu xml-rpc request
let req = new libly.Request(
'http://b.hatena.ne.jp/xmlrpc',
{
'Content-Type' : 'text/xml'
},{
postBody : <methodCall>
<methodName>bookmark.getTotalCount</methodName>
<params>
<param><value><string>{target}</string></value></param>
</params>
</methodCall>.toXMLString()
}
);
let currentValue;
req.addEventListener("onSuccess", function(data) {
liberator.log("XML-RPC request was succeeded.");
let resXml = new XML(data.responseText.replace(/^<\?xml version[^>]+?>/, ''));
currentValue = window.eval(resXml..int.toString());
onSuccess(currentValue);
});
req.addEventListener("onFailure", function(data) {
onFailure();
});
liberator.log("reauest...");
req.post();
liberator.log("done...");
}
function notifyAlways()
window.eval(liberator.globalVariables.hatebuWatchDogAlways) || false;
function showHatebuNotification(target, currentValue, delta) {
let title = delta > 0 ? "\u304A\u3081\u3067\u3068\u3046\u3054\u3056\u3044\u307E\u3059" // good news
:(delta < 0 ? "\u6B8B\u5FF5\u306A\u304A\u77E5\u3089\u305B" // bad news
: "\u304A\u77E5\u3089\u305B");
let suffix = delta != 0 ? "\u306B\u306A\u308A\u307E\u3057\u305F\u3002"
: "\u3067\u3059\u3002";
let message = "'" + target + "' \u306E\u88AB\u306F\u3066\u30D6\u6570\u306F '" +
currentValue + "' " + suffix + " (" + getSignedNum(delta) + ")";
showAlertNotification(null, title, message);
}
function showAlertNotification(icon, title, message) {
Cc['@mozilla.org/alerts-service;1']
.getService(Ci.nsIAlertsService)
.showAlertNotification(
icon, //'chrome://mozapps/skin/downloads/downloadIcon.png',
title,
message
);
}
function getSignedNum(num) {
if (num > 0) return "+" + num;
if (num < 0) return "-" + Math.abs(num);
return "0";
}
function getInterval()
window.eval(liberator.globalVariables.hatebuWatchDogInterval) || 600; // default : 10 min.
return {
interval getter: function() getInterval(),
addTask : addTask,
stopWatching : clearAllTasks
//previous setter: function(val) previousValue = val,
//previous getter: function() previousValue
};
})();
// Awaking the watch dog.
let (targets, self = plugins.hatebuWatchDog) {
try {
targets = window.eval(liberator.globalVariables.hatebuWatchDogTargets);
} catch(e) {
targets = liberator.globalVariables.hatebuWatchDogTargets;
}
if (targets) {
if (!(targets instanceof Array))
targets = [targets];
targets.forEach(function(target) {
self.addTask({site : target});
});
}
else {
liberator.echoerr("Please set g:hatebeWatchDogTargets before watch().");
}
}
liberator.dump("Watch dog is awaking ...");
|
