mirrors/signal-desktop
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages 2 Wiki Activity Actions

Wire up background message migration

Browse source
This commit is contained in:
Daniel Gasienica 2018-03-21 19:48:27 -04:00
parent 4651cbc2eb
commit 5c9f18e1ae
2 changed files with 24 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

26
js/background.js
View file

@ -76,10 +76,26 @@
storage.fetch(); storage.fetch();
const idleListener = new IdleDetector();
idleListener.on('idle', (event) => { /* eslint-enable */
console.log('Detected user idle:', event); /* jshint ignore:start */
const idleDetector = new IdleDetector();
idleDetector.on('idle', async () => {
const results = await MessageMigration.processNext({
BackboneMessage: Whisper.Message,
BackboneMessageCollection: Whisper.MessageCollection,
count: 3,
upgradeMessageSchema,
wrapDeferred,
}); });
console.log('Message schema upgrade:', results);
if (!results.hasMore) {
idleDetector.stop();
}
});
/* jshint ignore:end */
/* eslint-disable */
// We need this 'first' check because we don't want to start the app up any other time // We need this 'first' check because we don't want to start the app up any other time
// than the first time. And storage.fetch() will cause onready() to fire. // than the first time. And storage.fetch() will cause onready() to fire.
@ -91,11 +107,11 @@
first = false; first = false;
ConversationController.load().then(start, start); ConversationController.load().then(start, start);
idleListener.start(); idleDetector.start();
}); });
Whisper.events.on('shutdown', function() { Whisper.events.on('shutdown', function() {
idleListener.stop(); idleDetector.stop();
if (messageReceiver) { if (messageReceiver) {
messageReceiver.close().then(function() { messageReceiver.close().then(function() {

6
preload.js
View file

@ -122,12 +122,12 @@
const upgradeMessageSchema = message => const upgradeMessageSchema = message =>
Message.upgradeSchema(message, upgradeSchemaContext); Message.upgradeSchema(message, upgradeSchemaContext);
window.Signal = window.Signal || {};
const { IdleDetector} = require('./js/modules/idle_detector'); const { IdleDetector} = require('./js/modules/idle_detector');
window.Signal.IdleDetector = IdleDetector;
window.Signal = window.Signal || {};
window.Signal.IdleDetector = IdleDetector;
window.Signal.Logs = require('./js/modules/logs'); window.Signal.Logs = require('./js/modules/logs');
window.Signal.MessageMigration = require('./js/modules/messages_migration');
window.Signal.OS = require('./js/modules/os'); window.Signal.OS = require('./js/modules/os');
window.Signal.Backup = require('./js/modules/backup'); window.Signal.Backup = require('./js/modules/backup');
window.Signal.Crypto = require('./js/modules/crypto'); window.Signal.Crypto = require('./js/modules/crypto');