2015-12-03 00:58:53 +00:00
|
|
|
"use strict";
|
|
|
|
|
2017-06-08 09:59:12 +00:00
|
|
|
// The ext-* files are imported into the same scopes.
|
|
|
|
/* import-globals-from ext-toolkit.js */
|
|
|
|
|
2016-03-08 19:03:41 +00:00
|
|
|
// WeakMap[Extension -> Map[name -> Alarm]]
|
2017-04-01 02:36:00 +00:00
|
|
|
let alarmsMap = new WeakMap();
|
2015-06-03 22:34:44 +00:00
|
|
|
|
2015-09-07 00:53:09 +00:00
|
|
|
// WeakMap[Extension -> Set[callback]]
|
2017-04-01 02:36:00 +00:00
|
|
|
let alarmCallbacksMap = new WeakMap();
|
2015-06-03 22:34:44 +00:00
|
|
|
|
|
|
|
// Manages an alarm created by the extension (alarms API).
|
2015-12-03 00:58:53 +00:00
|
|
|
function Alarm(extension, name, alarmInfo) {
|
2015-06-03 22:34:44 +00:00
|
|
|
this.extension = extension;
|
|
|
|
this.name = name;
|
|
|
|
this.when = alarmInfo.when;
|
|
|
|
this.delayInMinutes = alarmInfo.delayInMinutes;
|
|
|
|
this.periodInMinutes = alarmInfo.periodInMinutes;
|
|
|
|
this.canceled = false;
|
|
|
|
|
|
|
|
let delay, scheduledTime;
|
|
|
|
if (this.when) {
|
|
|
|
scheduledTime = this.when;
|
|
|
|
delay = this.when - Date.now();
|
|
|
|
} else {
|
2015-10-16 17:24:57 +00:00
|
|
|
if (!this.delayInMinutes) {
|
|
|
|
this.delayInMinutes = this.periodInMinutes;
|
|
|
|
}
|
2015-06-03 22:34:44 +00:00
|
|
|
delay = this.delayInMinutes * 60 * 1000;
|
|
|
|
scheduledTime = Date.now() + delay;
|
|
|
|
}
|
|
|
|
|
|
|
|
this.scheduledTime = scheduledTime;
|
|
|
|
|
|
|
|
let timer = Cc["@mozilla.org/timer;1"].createInstance(Ci.nsITimer);
|
|
|
|
timer.init(this, delay, Ci.nsITimer.TYPE_ONE_SHOT);
|
|
|
|
this.timer = timer;
|
|
|
|
}
|
|
|
|
|
|
|
|
Alarm.prototype = {
|
|
|
|
clear() {
|
|
|
|
this.timer.cancel();
|
2016-03-08 19:03:41 +00:00
|
|
|
alarmsMap.get(this.extension).delete(this.name);
|
2015-06-03 22:34:44 +00:00
|
|
|
this.canceled = true;
|
|
|
|
},
|
|
|
|
|
|
|
|
observe(subject, topic, data) {
|
|
|
|
if (this.canceled) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2016-03-16 15:01:12 +00:00
|
|
|
for (let callback of alarmCallbacksMap.get(this.extension)) {
|
|
|
|
callback(this);
|
|
|
|
}
|
|
|
|
|
2015-06-03 22:34:44 +00:00
|
|
|
if (!this.periodInMinutes) {
|
|
|
|
this.clear();
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
let delay = this.periodInMinutes * 60 * 1000;
|
|
|
|
this.scheduledTime = Date.now() + delay;
|
|
|
|
this.timer.init(this, delay, Ci.nsITimer.TYPE_ONE_SHOT);
|
|
|
|
},
|
|
|
|
|
|
|
|
get data() {
|
|
|
|
return {
|
|
|
|
name: this.name,
|
|
|
|
scheduledTime: this.scheduledTime,
|
|
|
|
periodInMinutes: this.periodInMinutes,
|
|
|
|
};
|
|
|
|
},
|
|
|
|
};
|
|
|
|
|
2017-04-01 02:36:00 +00:00
|
|
|
this.alarms = class extends ExtensionAPI {
|
|
|
|
onShutdown() {
|
|
|
|
let {extension} = this;
|
2015-06-03 22:34:44 +00:00
|
|
|
|
2017-04-01 02:36:00 +00:00
|
|
|
if (alarmsMap.has(extension)) {
|
|
|
|
for (let alarm of alarmsMap.get(extension).values()) {
|
|
|
|
alarm.clear();
|
|
|
|
}
|
|
|
|
alarmsMap.delete(extension);
|
|
|
|
alarmCallbacksMap.delete(extension);
|
2016-07-13 11:12:59 +00:00
|
|
|
}
|
2015-06-03 22:34:44 +00:00
|
|
|
}
|
|
|
|
|
2017-04-01 02:36:00 +00:00
|
|
|
getAPI(context) {
|
|
|
|
let {extension} = context;
|
2015-06-03 22:34:44 +00:00
|
|
|
|
2017-04-01 02:36:00 +00:00
|
|
|
alarmsMap.set(extension, new Map());
|
|
|
|
alarmCallbacksMap.set(extension, new Set());
|
2015-06-03 22:34:44 +00:00
|
|
|
|
2017-04-01 02:36:00 +00:00
|
|
|
return {
|
|
|
|
alarms: {
|
|
|
|
create: function(name, alarmInfo) {
|
|
|
|
name = name || "";
|
|
|
|
let alarms = alarmsMap.get(extension);
|
|
|
|
if (alarms.has(name)) {
|
|
|
|
alarms.get(name).clear();
|
|
|
|
}
|
|
|
|
let alarm = new Alarm(extension, name, alarmInfo);
|
|
|
|
alarms.set(alarm.name, alarm);
|
|
|
|
},
|
|
|
|
|
|
|
|
get: function(name) {
|
|
|
|
name = name || "";
|
|
|
|
let alarms = alarmsMap.get(extension);
|
|
|
|
if (alarms.has(name)) {
|
|
|
|
return Promise.resolve(alarms.get(name).data);
|
|
|
|
}
|
|
|
|
return Promise.resolve();
|
|
|
|
},
|
|
|
|
|
|
|
|
getAll: function() {
|
|
|
|
let result = Array.from(alarmsMap.get(extension).values(), alarm => alarm.data);
|
|
|
|
return Promise.resolve(result);
|
|
|
|
},
|
|
|
|
|
|
|
|
clear: function(name) {
|
|
|
|
name = name || "";
|
|
|
|
let alarms = alarmsMap.get(extension);
|
|
|
|
if (alarms.has(name)) {
|
|
|
|
alarms.get(name).clear();
|
|
|
|
return Promise.resolve(true);
|
|
|
|
}
|
|
|
|
return Promise.resolve(false);
|
|
|
|
},
|
|
|
|
|
|
|
|
clearAll: function() {
|
|
|
|
let cleared = false;
|
|
|
|
for (let alarm of alarmsMap.get(extension).values()) {
|
|
|
|
alarm.clear();
|
|
|
|
cleared = true;
|
|
|
|
}
|
|
|
|
return Promise.resolve(cleared);
|
|
|
|
},
|
|
|
|
|
2017-06-09 20:49:07 +00:00
|
|
|
onAlarm: new EventManager(context, "alarms.onAlarm", fire => {
|
2017-04-01 02:36:00 +00:00
|
|
|
let callback = alarm => {
|
|
|
|
fire.sync(alarm.data);
|
|
|
|
};
|
|
|
|
|
|
|
|
alarmCallbacksMap.get(extension).add(callback);
|
|
|
|
return () => {
|
|
|
|
alarmCallbacksMap.get(extension).delete(callback);
|
|
|
|
};
|
|
|
|
}).api(),
|
2015-06-03 22:34:44 +00:00
|
|
|
},
|
2017-04-01 02:36:00 +00:00
|
|
|
};
|
|
|
|
}
|
|
|
|
};
|