9513e91d66
The very deep tree structure didn't really aggree with me, sorry. This makes the core module rather large, but on the other hand that just highlights that it is rather large.
87 lines
4.4 KiB
JavaScript
87 lines
4.4 KiB
JavaScript
var debugEvents = !true;
|
|
|
|
angular.module('syncthing.core')
|
|
.service('Events', ['$http', '$rootScope', '$timeout', function ($http, $rootScope, $timeout) {
|
|
'use strict';
|
|
|
|
var lastID = 0;
|
|
var self = this;
|
|
|
|
function successFn (data) {
|
|
// When Syncthing restarts while the long polling connection is in
|
|
// progress the browser on some platforms returns a 200 (since the
|
|
// headers has been flushed with the return code 200), with no data.
|
|
// This basically means that the connection has been reset, and the call
|
|
// was not actually successful.
|
|
if (!data) {
|
|
errorFn(data);
|
|
return;
|
|
}
|
|
$rootScope.$broadcast(self.ONLINE);
|
|
|
|
if (lastID > 0) { // not emit events from first response
|
|
data.forEach(function (event) {
|
|
if (debugEvents) {
|
|
console.log("event", event.id, event.type, event.data);
|
|
}
|
|
$rootScope.$broadcast(event.type, event);
|
|
});
|
|
}
|
|
|
|
var lastEvent = data.pop();
|
|
if (lastEvent) {
|
|
lastID = lastEvent.id;
|
|
}
|
|
|
|
$timeout(function () {
|
|
$http.get(urlbase + '/events?since=' + lastID)
|
|
.success(successFn)
|
|
.error(errorFn);
|
|
}, 500, false);
|
|
}
|
|
|
|
function errorFn (dummy) {
|
|
$rootScope.$broadcast(self.OFFLINE);
|
|
|
|
$timeout(function () {
|
|
$http.get(urlbase + '/events?limit=1')
|
|
.success(successFn)
|
|
.error(errorFn);
|
|
}, 1000, false);
|
|
}
|
|
|
|
angular.extend(self, {
|
|
// emitted by this
|
|
|
|
ONLINE: 'UIOnline',
|
|
OFFLINE: 'UIOffline',
|
|
|
|
// emitted by syncthing process
|
|
|
|
CONFIG_SAVED: 'ConfigSaved', // Emitted after the config has been saved by the user or by Syncthing itself
|
|
DEVICE_CONNECTED: 'DeviceConnected', // Generated each time a connection to a device has been established
|
|
DEVICE_DISCONNECTED: 'DeviceDisconnected', // Generated each time a connection to a device has been terminated
|
|
DEVICE_DISCOVERED: 'DeviceDiscovered', // Emitted when a new device is discovered using local discovery
|
|
DEVICE_REJECTED: 'DeviceRejected', // Emitted when there is a connection from a device we are not configured to talk to
|
|
DOWNLOAD_PROGRESS: 'DownloadProgress', // Emitted during file downloads for each folder for each file
|
|
FOLDER_COMPLETION: 'FolderCompletion', //Emitted when the local or remote contents for a folder changes
|
|
FOLDER_REJECTED: 'FolderRejected', // Emitted when a device sends index information for a folder we do not have, or have but do not share with the device in question
|
|
FOLDER_SUMMARY: 'FolderSummary', // Emitted when folder contents have changed locally
|
|
ITEM_FINISHED: 'ItemFinished', // Generated when Syncthing ends synchronizing a file to a newer version
|
|
ITEM_STARTED: 'ItemStarted', // Generated when Syncthing begins synchronizing a file to a newer version
|
|
LOCAL_INDEX_UPDATED: 'LocalIndexUpdated', // Generated when the local index information has changed, due to synchronizing one or more items from the cluster or discovering local changes during a scan
|
|
PING: 'Ping', // Generated automatically every 60 seconds
|
|
REMOTE_INDEX_UPDATED: 'RemoteIndexUpdated', // Generated each time new index information is received from a device
|
|
STARTING: 'Starting', // Emitted exactly once, when Syncthing starts, before parsing configuration etc
|
|
STARTUP_COMPLETED: 'StartupCompleted', // Emitted exactly once, when initialization is complete and Syncthing is ready to start exchanging data with other devices
|
|
STATE_CHANGED: 'StateChanged', // Emitted when a folder changes state
|
|
FOLDER_ERRORS: 'FolderErrors', // Emitted when a folder has errors preventing a full sync
|
|
|
|
start: function() {
|
|
$http.get(urlbase + '/events?limit=1')
|
|
.success(successFn)
|
|
.error(errorFn);
|
|
}
|
|
});
|
|
}]);
|