mirror of
https://github.com/octoleo/syncthing.git
synced 2024-11-09 23:00:58 +00:00
530 lines
15 KiB
JavaScript
530 lines
15 KiB
JavaScript
/*jslint browser: true, continue: true, plusplus: true */
|
|
/*global $: false, angular: false */
|
|
|
|
'use strict';
|
|
|
|
var syncthing = angular.module('syncthing', []);
|
|
|
|
syncthing.controller('SyncthingCtrl', function ($scope, $http) {
|
|
var prevDate = 0;
|
|
var getOK = true;
|
|
var restarting = false;
|
|
|
|
$scope.connections = {};
|
|
$scope.config = {};
|
|
$scope.myID = '';
|
|
$scope.nodes = [];
|
|
$scope.configInSync = true;
|
|
$scope.errors = [];
|
|
$scope.seenError = '';
|
|
$scope.model = {};
|
|
$scope.repos = [];
|
|
|
|
// Strings before bools look better
|
|
$scope.settings = [
|
|
{id: 'ListenStr', descr: 'Sync Protocol Listen Addresses', type: 'text', restart: true},
|
|
{id: 'MaxSendKbps', descr: 'Outgoing Rate Limit (KBps)', type: 'number', restart: true},
|
|
{id: 'RescanIntervalS', descr: 'Rescan Interval (s)', type: 'number', restart: true},
|
|
{id: 'ReconnectIntervalS', descr: 'Reconnect Interval (s)', type: 'number', restart: true},
|
|
{id: 'ParallelRequests', descr: 'Max Outstanding Requests', type: 'number', restart: true},
|
|
{id: 'MaxChangeKbps', descr: 'Max File Change Rate (KBps)', type: 'number', restart: true},
|
|
|
|
{id: 'GlobalAnnEnabled', descr: 'Global Announce', type: 'bool', restart: true},
|
|
{id: 'LocalAnnEnabled', descr: 'Local Announce', type: 'bool', restart: true},
|
|
{id: 'StartBrowser', descr: 'Start Browser', type: 'bool'},
|
|
{id: 'UPnPEnabled', descr: 'Enable UPnP', type: 'bool'},
|
|
];
|
|
|
|
$scope.guiSettings = [
|
|
{id: 'Address', descr: 'GUI Listen Addresses', type: 'text', restart: true},
|
|
{id: 'User', descr: 'GUI Authentication User', type: 'text', restart: true},
|
|
{id: 'Password', descr: 'GUI Authentication Password', type: 'password', restart: true},
|
|
];
|
|
|
|
function getSucceeded() {
|
|
if (!getOK) {
|
|
$('#networkError').modal('hide');
|
|
getOK = true;
|
|
}
|
|
if (restarting) {
|
|
$('#restarting').modal('hide');
|
|
restarting = false;
|
|
}
|
|
}
|
|
|
|
function getFailed() {
|
|
if (restarting) {
|
|
return;
|
|
}
|
|
if (getOK) {
|
|
$('#networkError').modal({backdrop: 'static', keyboard: false});
|
|
getOK = false;
|
|
}
|
|
}
|
|
|
|
function nodeCompare(a, b) {
|
|
if (typeof a.Name !== 'undefined' && typeof b.Name !== 'undefined') {
|
|
if (a.Name < b.Name)
|
|
return -1;
|
|
return a.Name > b.Name;
|
|
}
|
|
if (a.NodeID < b.NodeID) {
|
|
return -1;
|
|
}
|
|
return a.NodeID > b.NodeID;
|
|
}
|
|
|
|
$scope.refresh = function () {
|
|
$http.get('/rest/system').success(function (data) {
|
|
getSucceeded();
|
|
$scope.system = data;
|
|
}).error(function () {
|
|
getFailed();
|
|
});
|
|
$scope.repos.forEach(function (repo) {
|
|
$http.get('/rest/model?repo=' + encodeURIComponent(repo.ID)).success(function (data) {
|
|
$scope.model[repo.ID] = data;
|
|
});
|
|
});
|
|
$http.get('/rest/connections').success(function (data) {
|
|
var now = Date.now(),
|
|
td = (now - prevDate) / 1000,
|
|
id;
|
|
|
|
prevDate = now;
|
|
$scope.inbps = 0;
|
|
$scope.outbps = 0;
|
|
|
|
for (id in data) {
|
|
if (!data.hasOwnProperty(id)) {
|
|
continue;
|
|
}
|
|
try {
|
|
data[id].inbps = Math.max(0, 8 * (data[id].InBytesTotal - $scope.connections[id].InBytesTotal) / td);
|
|
data[id].outbps = Math.max(0, 8 * (data[id].OutBytesTotal - $scope.connections[id].OutBytesTotal) / td);
|
|
} catch (e) {
|
|
data[id].inbps = 0;
|
|
data[id].outbps = 0;
|
|
}
|
|
$scope.inbps += data[id].inbps;
|
|
$scope.outbps += data[id].outbps;
|
|
}
|
|
$scope.connections = data;
|
|
});
|
|
$http.get('/rest/errors').success(function (data) {
|
|
$scope.errors = data;
|
|
});
|
|
};
|
|
|
|
$scope.repoStatus = function (repo) {
|
|
if (typeof $scope.model[repo] === 'undefined') {
|
|
return 'Unknown';
|
|
}
|
|
|
|
var state = '' + $scope.model[repo].state;
|
|
state = state[0].toUpperCase() + state.substr(1);
|
|
|
|
if (state == "Syncing" || state == "Idle") {
|
|
state += " (" + $scope.syncPercentage(repo) + "%)";
|
|
}
|
|
|
|
return state;
|
|
}
|
|
|
|
$scope.repoClass = function (repo) {
|
|
if (typeof $scope.model[repo] === 'undefined') {
|
|
return 'text-info';
|
|
}
|
|
|
|
var state = '' + $scope.model[repo].state;
|
|
if (state == 'idle') {
|
|
return 'text-success';
|
|
}
|
|
if (state == 'syncing') {
|
|
return 'text-primary';
|
|
}
|
|
return 'text-info';
|
|
}
|
|
|
|
$scope.syncPercentage = function (repo) {
|
|
if (typeof $scope.model[repo] === 'undefined') {
|
|
return 100;
|
|
}
|
|
if ($scope.model[repo].globalBytes === 0) {
|
|
return 100;
|
|
}
|
|
|
|
var pct = 100 * $scope.model[repo].inSyncBytes / $scope.model[repo].globalBytes;
|
|
return Math.ceil(pct);
|
|
};
|
|
|
|
$scope.nodeStatus = function (nodeCfg) {
|
|
var conn = $scope.connections[nodeCfg.NodeID];
|
|
if (conn) {
|
|
if (conn.Completion === 100) {
|
|
return 'In Sync';
|
|
} else {
|
|
return 'Syncing (' + conn.Completion + '%)';
|
|
}
|
|
}
|
|
|
|
return 'Disconnected';
|
|
};
|
|
|
|
$scope.nodeIcon = function (nodeCfg) {
|
|
var conn = $scope.connections[nodeCfg.NodeID];
|
|
if (conn) {
|
|
if (conn.Completion === 100) {
|
|
return 'ok';
|
|
} else {
|
|
return 'refresh';
|
|
}
|
|
}
|
|
|
|
return 'minus';
|
|
};
|
|
|
|
$scope.nodeClass = function (nodeCfg) {
|
|
var conn = $scope.connections[nodeCfg.NodeID];
|
|
if (conn) {
|
|
if (conn.Completion === 100) {
|
|
return 'success';
|
|
} else {
|
|
return 'primary';
|
|
}
|
|
}
|
|
|
|
return 'info';
|
|
};
|
|
|
|
$scope.nodeAddr = function (nodeCfg) {
|
|
var conn = $scope.connections[nodeCfg.NodeID];
|
|
if (conn) {
|
|
return conn.Address;
|
|
}
|
|
return '?';
|
|
};
|
|
|
|
$scope.nodeCompletion = function (nodeCfg) {
|
|
var conn = $scope.connections[nodeCfg.NodeID];
|
|
if (conn) {
|
|
return conn.Completion + '%';
|
|
}
|
|
return '';
|
|
};
|
|
|
|
$scope.nodeVer = function (nodeCfg) {
|
|
if (nodeCfg.NodeID === $scope.myID) {
|
|
return $scope.version;
|
|
}
|
|
var conn = $scope.connections[nodeCfg.NodeID];
|
|
if (conn) {
|
|
return conn.ClientVersion;
|
|
}
|
|
return '?';
|
|
};
|
|
|
|
$scope.nodeName = function (nodeCfg) {
|
|
if (nodeCfg.Name) {
|
|
return nodeCfg.Name;
|
|
}
|
|
return nodeCfg.NodeID.substr(0, 6);
|
|
};
|
|
|
|
$scope.editSettings = function () {
|
|
$('#settings').modal({backdrop: 'static', keyboard: true});
|
|
}
|
|
|
|
$scope.saveSettings = function () {
|
|
$scope.configInSync = false;
|
|
$scope.config.Options.ListenAddress = $scope.config.Options.ListenStr.split(',').map(function (x) { return x.trim(); });
|
|
$http.post('/rest/config', JSON.stringify($scope.config), {headers: {'Content-Type': 'application/json'}});
|
|
$('#settings').modal("hide");
|
|
};
|
|
|
|
$scope.restart = function () {
|
|
restarting = true;
|
|
$('#restarting').modal('show');
|
|
$http.post('/rest/restart');
|
|
$scope.configInSync = true;
|
|
};
|
|
|
|
$scope.editNode = function (nodeCfg) {
|
|
$scope.currentNode = $.extend({}, nodeCfg);
|
|
$scope.editingExisting = true;
|
|
$scope.editingSelf = (nodeCfg.NodeID == $scope.myID);
|
|
$scope.currentNode.AddressesStr = nodeCfg.Addresses.join(', ');
|
|
$('#editNode').modal({backdrop: 'static', keyboard: true});
|
|
};
|
|
|
|
$scope.addNode = function () {
|
|
$scope.currentNode = {AddressesStr: 'dynamic'};
|
|
$scope.editingExisting = false;
|
|
$scope.editingSelf = false;
|
|
$('#editNode').modal({backdrop: 'static', keyboard: true});
|
|
};
|
|
|
|
$scope.deleteNode = function () {
|
|
$('#editNode').modal('hide');
|
|
if (!$scope.editingExisting) {
|
|
return;
|
|
}
|
|
|
|
$scope.nodes = $scope.nodes.filter(function (n) {
|
|
return n.NodeID !== $scope.currentNode.NodeID;
|
|
});
|
|
$scope.config.Nodes = $scope.nodes;
|
|
|
|
for (var i = 0; i < $scope.repos.length; i++) {
|
|
$scope.repos[i].Nodes = $scope.repos[i].Nodes.filter(function (n) {
|
|
return n.NodeID !== $scope.currentNode.NodeID;
|
|
});
|
|
}
|
|
|
|
$scope.configInSync = false;
|
|
$http.post('/rest/config', JSON.stringify($scope.config), {headers: {'Content-Type': 'application/json'}});
|
|
};
|
|
|
|
$scope.saveNode = function () {
|
|
var nodeCfg, done, i;
|
|
|
|
$scope.configInSync = false;
|
|
$('#editNode').modal('hide');
|
|
nodeCfg = $scope.currentNode;
|
|
nodeCfg.Addresses = nodeCfg.AddressesStr.split(',').map(function (x) { return x.trim(); });
|
|
|
|
done = false;
|
|
for (i = 0; i < $scope.nodes.length; i++) {
|
|
if ($scope.nodes[i].NodeID === nodeCfg.NodeID) {
|
|
$scope.nodes[i] = nodeCfg;
|
|
done = true;
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (!done) {
|
|
$scope.nodes.push(nodeCfg);
|
|
}
|
|
|
|
$scope.nodes.sort(nodeCompare);
|
|
$scope.config.Nodes = $scope.nodes;
|
|
|
|
$http.post('/rest/config', JSON.stringify($scope.config), {headers: {'Content-Type': 'application/json'}});
|
|
};
|
|
|
|
$scope.otherNodes = function () {
|
|
return $scope.nodes.filter(function (n){
|
|
return n.NodeID !== $scope.myID;
|
|
});
|
|
};
|
|
|
|
$scope.thisNode = function () {
|
|
var i, n;
|
|
|
|
for (i = 0; i < $scope.nodes.length; i++) {
|
|
n = $scope.nodes[i];
|
|
if (n.NodeID === $scope.myID) {
|
|
return [n];
|
|
}
|
|
}
|
|
};
|
|
|
|
$scope.errorList = function () {
|
|
return $scope.errors.filter(function (e) {
|
|
return e.Time > $scope.seenError;
|
|
});
|
|
};
|
|
|
|
$scope.clearErrors = function () {
|
|
$scope.seenError = $scope.errors[$scope.errors.length - 1].Time;
|
|
$http.post('/rest/error/clear');
|
|
};
|
|
|
|
$scope.friendlyNodes = function (str) {
|
|
for (var i = 0; i < $scope.nodes.length; i++) {
|
|
var cfg = $scope.nodes[i];
|
|
str = str.replace(cfg.NodeID, $scope.nodeName(cfg));
|
|
}
|
|
return str;
|
|
};
|
|
|
|
$scope.editRepo = function (nodeCfg) {
|
|
$scope.currentRepo = $.extend({selectedNodes: {}}, nodeCfg);
|
|
$scope.currentRepo.Nodes.forEach(function (n) {
|
|
$scope.currentRepo.selectedNodes[n.NodeID] = true;
|
|
});
|
|
$scope.editingExisting = true;
|
|
$('#editRepo').modal({backdrop: 'static', keyboard: true});
|
|
};
|
|
|
|
$scope.addRepo = function () {
|
|
$scope.currentRepo = {selectedNodes: {}};
|
|
$scope.editingExisting = false;
|
|
$('#editRepo').modal({backdrop: 'static', keyboard: true});
|
|
};
|
|
|
|
$scope.saveRepo = function () {
|
|
var repoCfg, done, i;
|
|
|
|
$scope.configInSync = false;
|
|
$('#editRepo').modal('hide');
|
|
repoCfg = $scope.currentRepo;
|
|
repoCfg.Nodes = [];
|
|
repoCfg.selectedNodes[$scope.myID] = true;
|
|
for (var nodeID in repoCfg.selectedNodes) {
|
|
if (repoCfg.selectedNodes[nodeID] === true) {
|
|
repoCfg.Nodes.push({NodeID: nodeID});
|
|
}
|
|
}
|
|
delete repoCfg.selectedNodes;
|
|
|
|
done = false;
|
|
for (i = 0; i < $scope.repos.length; i++) {
|
|
if ($scope.repos[i].ID === repoCfg.ID) {
|
|
$scope.repos[i] = repoCfg;
|
|
done = true;
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (!done) {
|
|
$scope.repos.push(repoCfg);
|
|
}
|
|
|
|
$scope.config.Repositories = $scope.repos;
|
|
|
|
$http.post('/rest/config', JSON.stringify($scope.config), {headers: {'Content-Type': 'application/json'}});
|
|
};
|
|
|
|
$scope.deleteRepo = function () {
|
|
$('#editRepo').modal('hide');
|
|
if (!$scope.editingExisting) {
|
|
return;
|
|
}
|
|
|
|
$scope.repos = $scope.repos.filter(function (r) {
|
|
return r.ID !== $scope.currentRepo.ID;
|
|
});
|
|
|
|
$scope.config.Repositories = $scope.repos;
|
|
|
|
$scope.configInSync = false;
|
|
$http.post('/rest/config', JSON.stringify($scope.config), {headers: {'Content-Type': 'application/json'}});
|
|
};
|
|
|
|
$http.get('/rest/version').success(function (data) {
|
|
$scope.version = data;
|
|
});
|
|
|
|
$http.get('/rest/system').success(function (data) {
|
|
$scope.system = data;
|
|
$scope.myID = data.myID;
|
|
});
|
|
|
|
$http.get('/rest/config').success(function (data) {
|
|
$scope.config = data;
|
|
$scope.config.Options.ListenStr = $scope.config.Options.ListenAddress.join(', ');
|
|
|
|
var nodes = $scope.config.Nodes;
|
|
nodes.sort(nodeCompare);
|
|
$scope.nodes = nodes;
|
|
|
|
$scope.repos = $scope.config.Repositories;
|
|
|
|
$scope.refresh();
|
|
});
|
|
|
|
$http.get('/rest/config/sync').success(function (data) {
|
|
$scope.configInSync = data.configInSync;
|
|
});
|
|
|
|
setInterval($scope.refresh, 10000);
|
|
});
|
|
|
|
function decimals(val, num) {
|
|
var digits, decs;
|
|
|
|
if (val === 0) {
|
|
return 0;
|
|
}
|
|
|
|
digits = Math.floor(Math.log(Math.abs(val)) / Math.log(10));
|
|
decs = Math.max(0, num - digits);
|
|
return decs;
|
|
}
|
|
|
|
syncthing.filter('natural', function () {
|
|
return function (input, valid) {
|
|
return input.toFixed(decimals(input, valid));
|
|
};
|
|
});
|
|
|
|
syncthing.filter('binary', function () {
|
|
return function (input) {
|
|
if (input === undefined) {
|
|
return '0 ';
|
|
}
|
|
if (input > 1024 * 1024 * 1024) {
|
|
input /= 1024 * 1024 * 1024;
|
|
return input.toFixed(decimals(input, 2)) + ' Gi';
|
|
}
|
|
if (input > 1024 * 1024) {
|
|
input /= 1024 * 1024;
|
|
return input.toFixed(decimals(input, 2)) + ' Mi';
|
|
}
|
|
if (input > 1024) {
|
|
input /= 1024;
|
|
return input.toFixed(decimals(input, 2)) + ' Ki';
|
|
}
|
|
return Math.round(input) + ' ';
|
|
};
|
|
});
|
|
|
|
syncthing.filter('metric', function () {
|
|
return function (input) {
|
|
if (input === undefined) {
|
|
return '0 ';
|
|
}
|
|
if (input > 1000 * 1000 * 1000) {
|
|
input /= 1000 * 1000 * 1000;
|
|
return input.toFixed(decimals(input, 2)) + ' G';
|
|
}
|
|
if (input > 1000 * 1000) {
|
|
input /= 1000 * 1000;
|
|
return input.toFixed(decimals(input, 2)) + ' M';
|
|
}
|
|
if (input > 1000) {
|
|
input /= 1000;
|
|
return input.toFixed(decimals(input, 2)) + ' k';
|
|
}
|
|
return Math.round(input) + ' ';
|
|
};
|
|
});
|
|
|
|
syncthing.filter('short', function () {
|
|
return function (input) {
|
|
return input.substr(0, 6);
|
|
};
|
|
});
|
|
|
|
syncthing.filter('alwaysNumber', function () {
|
|
return function (input) {
|
|
if (input === undefined) {
|
|
return 0;
|
|
}
|
|
return input;
|
|
};
|
|
});
|
|
|
|
syncthing.directive('optionEditor', function () {
|
|
return {
|
|
restrict: 'C',
|
|
replace: true,
|
|
transclude: true,
|
|
scope: {
|
|
setting: '=setting',
|
|
},
|
|
template: '<input type="text" ng-model="config.Options[setting.id]"></input>',
|
|
};
|
|
});
|