| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127 |
- // Copyright (C) 2014 Jakob Borg and Contributors (see the CONTRIBUTORS file).
- // All rights reserved. Use of this source code is governed by an MIT-style
- // license that can be found in the LICENSE file.
- /*jslint browser: true, continue: true, plusplus: true */
- /*global $: false, angular: false */
- 'use strict';
- var syncthing = angular.module('syncthing', ['pascalprecht.translate']);
- var urlbase = 'rest';
- syncthing.config(function ($httpProvider, $translateProvider) {
- $httpProvider.defaults.xsrfHeaderName = 'X-CSRF-Token';
- $httpProvider.defaults.xsrfCookieName = 'CSRF-Token';
- $translateProvider.useStaticFilesLoader({
- prefix: 'lang/lang-',
- suffix: '.json'
- });
- });
- syncthing.controller('EventCtrl', function ($scope, $http) {
- $scope.lastEvent = null;
- var lastID = 0;
- var successFn = function (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 sucessful.
- if (!data) {
- errorFn(data);
- return;
- }
- $scope.$emit('UIOnline');
- if (lastID > 0) {
- data.forEach(function (event) {
- console.log("event", event.id, event.type, event.data);
- $scope.$emit(event.type, event);
- });
- };
- $scope.lastEvent = data[data.length - 1];
- lastID = $scope.lastEvent.id;
- setTimeout(function () {
- $http.get(urlbase + '/events?since=' + lastID)
- .success(successFn)
- .error(errorFn);
- }, 500);
- };
- var errorFn = function (data) {
- $scope.$emit('UIOffline');
- setTimeout(function () {
- $http.get(urlbase + '/events?limit=1')
- .success(successFn)
- .error(errorFn);
- }, 1000);
- };
- $http.get(urlbase + '/events?limit=1')
- .success(successFn)
- .error(errorFn);
- });
- syncthing.controller('SyncthingCtrl', function ($scope, $http, $translate, $location) {
- var prevDate = 0;
- var getOK = true;
- var navigatingAway = false;
- var online = false;
- var restarting = false;
- $scope.completion = {};
- $scope.config = {};
- $scope.configInSync = true;
- $scope.connections = {};
- $scope.errors = [];
- $scope.model = {};
- $scope.myID = '';
- $scope.nodes = [];
- $scope.protocolChanged = false;
- $scope.reportData = {};
- $scope.reportPreview = false;
- $scope.repos = {};
- $scope.seenError = '';
- $scope.upgradeInfo = {};
- $scope.stats = {};
- $http.get(urlbase+"/lang").success(function (langs) {
- // Find the first language in the list provided by the user's browser
- // that is a prefix of a language we have available. That is, "en"
- // sent by the browser will match "en" or "en-US", while "zh-TW" will
- // match only "zh-TW" and not "zh-CN".
- var lang, matching;
- for (var i = 0; i < langs.length; i++) {
- lang = langs[i];
- if (lang.length < 2) {
- continue;
- }
- matching = validLangs.filter(function (possibleLang) {
- // The langs returned by the /rest/langs call will be in lower
- // case. We compare to the lowercase version of the language
- // code we have as well.
- possibleLang = possibleLang.toLowerCase()
- if (possibleLang.length > lang.length) {
- return possibleLang.indexOf(lang) == 0;
- } else {
- return lang.indexOf(possibleLang) == 0;
- }
- });
- if (matching.length >= 1) {
- $translate.use(matching[0]);
- return;
- }
- }
- // Fallback if nothing matched
- $translate.use("en");
- })
- $(window).bind('beforeunload', function() {
- navigatingAway = true;
- });
- $scope.$on("$locationChangeSuccess", function () {
- var lang = $location.search().lang;
- if (lang) {
- $translate.use(lang);
- }
- });
- $scope.needActions = {
- 'rm': 'Del',
- 'rmdir': 'Del (dir)',
- 'sync': 'Sync',
- 'touch': 'Update',
- }
- $scope.needIcons = {
- 'rm': 'remove',
- 'rmdir': 'remove',
- 'sync': 'download',
- 'touch': 'asterisk',
- }
- $scope.$on('UIOnline', function (event, arg) {
- if (online && !restarting) {
- return;
- }
- console.log('UIOnline');
- $scope.init();
- online = true;
- restarting = false;
- $('#networkError').modal('hide');
- $('#restarting').modal('hide');
- $('#shutdown').modal('hide');
- });
- $scope.$on('UIOffline', function (event, arg) {
- if (navigatingAway || !online) {
- return;
- }
- console.log('UIOffline');
- online = false;
- if (!restarting) {
- $('#networkError').modal();
- }
- });
- $scope.$on('StateChanged', function (event, arg) {
- var data = arg.data;
- if ($scope.model[data.repo]) {
- $scope.model[data.repo].state = data.to;
- }
- });
- $scope.$on('LocalIndexUpdated', function (event, arg) {
- var data = arg.data;
- refreshRepo(data.repo);
- // Update completion status for all nodes that we share this repo with.
- $scope.repos[data.repo].Nodes.forEach(function (nodeCfg) {
- refreshCompletion(nodeCfg.NodeID, data.repo);
- });
- });
- $scope.$on('RemoteIndexUpdated', function (event, arg) {
- var data = arg.data;
- refreshRepo(data.repo);
- refreshCompletion(data.node, data.repo);
- });
- $scope.$on('NodeDisconnected', function (event, arg) {
- delete $scope.connections[arg.data.id];
- refreshNodeStats();
- });
- $scope.$on('NodeConnected', function (event, arg) {
- if (!$scope.connections[arg.data.id]) {
- $scope.connections[arg.data.id] = {
- inbps: 0,
- outbps: 0,
- InBytesTotal: 0,
- OutBytesTotal: 0,
- Address: arg.data.addr,
- };
- $scope.completion[arg.data.id] = {
- _total: 100,
- };
- }
- });
- $scope.$on('ConfigLoaded', function (event) {
- if ($scope.config.Options.URAccepted == 0) {
- // If usage reporting has been neither accepted nor declined,
- // we want to ask the user to make a choice. But we don't want
- // to bug them during initial setup, so we set a cookie with
- // the time of the first visit. When that cookie is present
- // and the time is more than four hours ago, we ask the
- // question.
- var firstVisit = document.cookie.replace(/(?:(?:^|.*;\s*)firstVisit\s*\=\s*([^;]*).*$)|^.*$/, "$1");
- if (!firstVisit) {
- document.cookie = "firstVisit=" + Date.now() + ";max-age=" + 30*24*3600;
- } else {
- if (+firstVisit < Date.now() - 4*3600*1000){
- $('#ur').modal();
- }
- }
- }
- })
- $scope.$on('ConfigSaved', function (event, arg) {
- updateLocalConfig(arg.data);
- $http.get(urlbase + '/config/sync').success(function (data) {
- $scope.configInSync = data.configInSync;
- });
- });
- var debouncedFuncs = {};
- function refreshRepo(repo) {
- var key = "refreshRepo" + repo;
- if (!debouncedFuncs[key]) {
- debouncedFuncs[key] = debounce(function () {
- $http.get(urlbase + '/model?repo=' + encodeURIComponent(repo)).success(function (data) {
- $scope.model[repo] = data;
- console.log("refreshRepo", repo, data);
- });
- }, 1000, true);
- }
- debouncedFuncs[key]();
- }
- function updateLocalConfig(config) {
- var hasConfig = !isEmptyObject($scope.config);
- $scope.config = config;
- $scope.config.Options.ListenStr = $scope.config.Options.ListenAddress.join(', ');
- $scope.nodes = $scope.config.Nodes;
- $scope.nodes.forEach(function (nodeCfg) {
- $scope.completion[nodeCfg.NodeID] = {
- _total: 100,
- };
- });
- $scope.nodes.sort(nodeCompare);
- $scope.repos = repoMap($scope.config.Repositories);
- Object.keys($scope.repos).forEach(function (repo) {
- refreshRepo(repo);
- $scope.repos[repo].Nodes.forEach(function (nodeCfg) {
- refreshCompletion(nodeCfg.NodeID, repo);
- });
- });
- if (!hasConfig) {
- $scope.$emit('ConfigLoaded');
- }
- }
- function refreshSystem() {
- $http.get(urlbase + '/system').success(function (data) {
- $scope.myID = data.myID;
- $scope.system = data;
- console.log("refreshSystem", data);
- });
- }
- function refreshCompletion(node, repo) {
- if (node === $scope.myID) {
- return
- }
- var key = "refreshCompletion" + node + repo;
- if (!debouncedFuncs[key]) {
- debouncedFuncs[key] = debounce(function () {
- $http.get(urlbase + '/completion?node=' + node + '&repo=' + encodeURIComponent(repo)).success(function (data) {
- if (!$scope.completion[node]) {
- $scope.completion[node] = {};
- }
- $scope.completion[node][repo] = data.completion;
- var tot = 0, cnt = 0;
- for (var cmp in $scope.completion[node]) {
- if (cmp === "_total") {
- continue;
- }
- tot += $scope.completion[node][cmp];
- cnt += 1;
- }
- $scope.completion[node]._total = tot / cnt;
- console.log("refreshCompletion", node, repo, $scope.completion[node]);
- });
- }, 1000, true);
- }
- debouncedFuncs[key]();
- }
- function refreshConnectionStats() {
- $http.get(urlbase + '/connections').success(function (data) {
- var now = Date.now(),
- td = (now - prevDate) / 1000,
- id;
- prevDate = now;
- 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.connections = data;
- console.log("refreshConnections", data);
- });
- }
- function refreshErrors() {
- $http.get(urlbase + '/errors').success(function (data) {
- $scope.errors = data;
- console.log("refreshErrors", data);
- });
- }
- function refreshConfig() {
- $http.get(urlbase + '/config').success(function (data) {
- updateLocalConfig(data);
- console.log("refreshConfig", data);
- });
- $http.get(urlbase + '/config/sync').success(function (data) {
- $scope.configInSync = data.configInSync;
- });
- }
- var refreshNodeStats = debounce(function () {
- $http.get(urlbase+"/stats/node").success(function (data) {
- $scope.stats = data;
- console.log("refreshNodeStats", data);
- });
- }, 500);
- $scope.init = function() {
- refreshSystem();
- refreshConfig();
- refreshConnectionStats();
- refreshNodeStats();
- $http.get(urlbase + '/version').success(function (data) {
- $scope.version = data;
- });
- $http.get(urlbase + '/report').success(function (data) {
- $scope.reportData = data;
- });
- $http.get(urlbase + '/upgrade').success(function (data) {
- $scope.upgradeInfo = data;
- }).error(function () {
- $scope.upgradeInfo = {};
- });
- };
- $scope.refresh = function () {
- refreshSystem();
- refreshConnectionStats();
- refreshErrors();
- };
- $scope.repoStatus = function (repo) {
- if (typeof $scope.model[repo] === 'undefined') {
- return 'unknown';
- }
- if ($scope.model[repo].invalid !== '') {
- return 'stopped';
- }
- return '' + $scope.model[repo].state;
- };
- $scope.repoClass = function (repo) {
- if (typeof $scope.model[repo] === 'undefined') {
- return 'info';
- }
- if ($scope.model[repo].invalid !== '') {
- return 'danger';
- }
- var state = '' + $scope.model[repo].state;
- if (state == 'idle') {
- return 'success';
- }
- if (state == 'syncing') {
- return 'primary';
- }
- if (state == 'scanning') {
- return 'primary';
- }
- return '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.floor(pct);
- };
- $scope.nodeIcon = function (nodeCfg) {
- if ($scope.connections[nodeCfg.NodeID]) {
- if ($scope.completion[nodeCfg.NodeID] && $scope.completion[nodeCfg.NodeID]._total === 100) {
- return 'ok';
- } else {
- return 'refresh';
- }
- }
- return 'minus';
- };
- $scope.nodeClass = function (nodeCfg) {
- if ($scope.connections[nodeCfg.NodeID]) {
- if ($scope.completion[nodeCfg.NodeID] && $scope.completion[nodeCfg.NodeID]._total === 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.findNode = function (nodeID) {
- var matches = $scope.nodes.filter(function (n) { return n.NodeID == nodeID; });
- if (matches.length != 1) {
- return undefined;
- }
- return matches[0];
- };
- $scope.nodeName = function (nodeCfg) {
- if (typeof nodeCfg === 'undefined') {
- return "";
- }
- if (nodeCfg.Name) {
- return nodeCfg.Name;
- }
- return nodeCfg.NodeID.substr(0, 6);
- };
- $scope.thisNodeName = function () {
- var node = $scope.thisNode();
- if (typeof node === 'undefined') {
- return "(unknown node)";
- }
- if (node.Name) {
- return node.Name;
- }
- return node.NodeID.substr(0, 6);
- };
- $scope.editSettings = function () {
- // Make a working copy
- $scope.tmpOptions = angular.copy($scope.config.Options);
- $scope.tmpOptions.UREnabled = ($scope.tmpOptions.URAccepted > 0);
- $scope.tmpOptions.NodeName = $scope.thisNode().Name;
- $scope.tmpGUI = angular.copy($scope.config.GUI);
- $('#settings').modal();
- };
- $scope.saveConfig = function() {
- var cfg = JSON.stringify($scope.config);
- var opts = {headers: {'Content-Type': 'application/json'}};
- $http.post(urlbase + '/config', cfg, opts).success(function () {
- $http.get(urlbase + '/config/sync').success(function (data) {
- $scope.configInSync = data.configInSync;
- });
- });
- };
- $scope.saveSettings = function () {
- // Make sure something changed
- var changed = !angular.equals($scope.config.Options, $scope.tmpOptions) ||
- !angular.equals($scope.config.GUI, $scope.tmpGUI);
- if (changed) {
- // Check if usage reporting has been enabled or disabled
- if ($scope.tmpOptions.UREnabled && $scope.tmpOptions.URAccepted <= 0) {
- $scope.tmpOptions.URAccepted = 1000;
- } else if (!$scope.tmpOptions.UREnabled && $scope.tmpOptions.URAccepted > 0){
- $scope.tmpOptions.URAccepted = -1;
- }
- // Check if protocol will need to be changed on restart
- if($scope.config.GUI.UseTLS !== $scope.tmpGUI.UseTLS){
- $scope.protocolChanged = true;
- }
- // Apply new settings locally
- $scope.thisNode().Name = $scope.tmpOptions.NodeName;
- $scope.config.Options = angular.copy($scope.tmpOptions);
- $scope.config.GUI = angular.copy($scope.tmpGUI);
- $scope.config.Options.ListenAddress = $scope.config.Options.ListenStr.split(',').map(function (x) { return x.trim(); });
- $scope.saveConfig();
- }
- $('#settings').modal("hide");
- };
- $scope.restart = function () {
- restarting = true;
- $('#restarting').modal();
- $http.post(urlbase + '/restart');
- $scope.configInSync = true;
- // Switch webpage protocol if needed
- if($scope.protocolChanged){
- var protocol = 'http';
- if($scope.config.GUI.UseTLS){
- protocol = 'https';
- }
- setTimeout(function(){
- window.location.protocol = protocol;
- }, 1000);
- $scope.protocolChanged = false;
- }
- };
- $scope.upgrade = function () {
- restarting = true;
- $('#upgrading').modal();
- $http.post(urlbase + '/upgrade').success(function () {
- $('#restarting').modal();
- $('#upgrading').modal('hide');
- }).error(function () {
- $('#upgrading').modal('hide');
- });
- };
- $scope.shutdown = function () {
- restarting = true;
- $http.post(urlbase + '/shutdown').success(function () {
- $('#shutdown').modal();
- });
- $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(', ');
- $scope.nodeEditor.$setPristine();
- $('#editNode').modal();
- };
- $scope.idNode = function () {
- $('#idqr').modal('show');
- };
- $scope.addNode = function () {
- $scope.currentNode = {AddressesStr: 'dynamic', Compression: true};
- $scope.editingExisting = false;
- $scope.editingSelf = false;
- $scope.nodeEditor.$setPristine();
- $('#editNode').modal();
- };
- $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 id in $scope.repos) {
- $scope.repos[id].Nodes = $scope.repos[id].Nodes.filter(function (n) {
- return n.NodeID !== $scope.currentNode.NodeID;
- });
- }
- $scope.saveConfig();
- };
- $scope.saveNode = function () {
- var nodeCfg, done, i;
- $('#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;
- $scope.saveConfig();
- };
- $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.allNodes = function () {
- var nodes = $scope.otherNodes();
- nodes.push($scope.thisNode());
- return nodes;
- };
- $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(urlbase + '/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.repoList = function () {
- return repoList($scope.repos);
- };
- $scope.editRepo = function (nodeCfg) {
- $scope.currentRepo = angular.copy(nodeCfg);
- $scope.currentRepo.selectedNodes = {};
- $scope.currentRepo.Nodes.forEach(function (n) {
- $scope.currentRepo.selectedNodes[n.NodeID] = true;
- });
- if ($scope.currentRepo.Versioning && $scope.currentRepo.Versioning.Type === "simple") {
- $scope.currentRepo.simpleFileVersioning = true;
- $scope.currentRepo.FileVersioningSelector = "simple";
- $scope.currentRepo.simpleKeep = +$scope.currentRepo.Versioning.Params.keep;
- } else if ($scope.currentRepo.Versioning && $scope.currentRepo.Versioning.Type === "staggered") {
- $scope.currentRepo.staggeredFileVersioning = true;
- $scope.currentRepo.FileVersioningSelector = "staggered";
- $scope.currentRepo.staggeredMaxAge = Math.floor(+$scope.currentRepo.Versioning.Params.maxAge / 86400);
- $scope.currentRepo.staggeredCleanInterval = +$scope.currentRepo.Versioning.Params.cleanInterval;
- $scope.currentRepo.staggeredVersionsPath = $scope.currentRepo.Versioning.Params.versionsPath;
- } else {
- $scope.currentRepo.FileVersioningSelector = "none";
- }
- $scope.currentRepo.simpleKeep = $scope.currentRepo.simpleKeep || 5;
- $scope.currentRepo.staggeredCleanInterval = $scope.currentRepo.staggeredCleanInterval || 3600;
- $scope.currentRepo.staggeredVersionsPath = $scope.currentRepo.staggeredVersionsPath || "";
- // staggeredMaxAge can validly be zero, which we should not replace
- // with the default value of 365. So only set the default if it's
- // actually undefined.
- if (typeof $scope.currentRepo.staggeredMaxAge === 'undefined') {
- $scope.currentRepo.staggeredMaxAge = 365;
- }
- $scope.editingExisting = true;
- $scope.repoEditor.$setPristine();
- $('#editRepo').modal();
- };
- $scope.addRepo = function () {
- $scope.currentRepo = {selectedNodes: {}};
- $scope.currentRepo.RescanIntervalS = 60;
- $scope.currentRepo.FileVersioningSelector = "none";
- $scope.currentRepo.simpleKeep = 5;
- $scope.currentRepo.staggeredMaxAge = 365;
- $scope.currentRepo.staggeredCleanInterval = 3600;
- $scope.currentRepo.staggeredVersionsPath = "";
- $scope.editingExisting = false;
- $scope.repoEditor.$setPristine();
- $('#editRepo').modal();
- };
- $scope.saveRepo = function () {
- var repoCfg, done, i;
- $('#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;
- if (repoCfg.FileVersioningSelector === "simple") {
- repoCfg.Versioning = {
- 'Type': 'simple',
- 'Params': {
- 'keep': '' + repoCfg.simpleKeep,
- }
- };
- delete repoCfg.simpleFileVersioning;
- delete repoCfg.simpleKeep;
- } else if (repoCfg.FileVersioningSelector === "staggered") {
- repoCfg.Versioning = {
- 'Type': 'staggered',
- 'Params': {
- 'maxAge': '' + (repoCfg.staggeredMaxAge * 86400),
- 'cleanInterval': '' + repoCfg.staggeredCleanInterval,
- 'versionsPath': '' + repoCfg.staggeredVersionsPath,
- }
- };
- delete repoCfg.staggeredFileVersioning;
- delete repoCfg.staggeredMaxAge;
- delete repoCfg.staggeredCleanInterval;
- delete repoCfg.staggeredVersionsPath;
- } else {
- delete repoCfg.Versioning;
- }
- $scope.repos[repoCfg.ID] = repoCfg;
- $scope.config.Repositories = repoList($scope.repos);
- $scope.saveConfig();
- };
- $scope.sharesRepo = function(repoCfg) {
- var names = [];
- repoCfg.Nodes.forEach(function (node) {
- names.push($scope.nodeName($scope.findNode(node.NodeID)));
- });
- names.sort();
- return names.join(", ");
- };
- $scope.deleteRepo = function () {
- $('#editRepo').modal('hide');
- if (!$scope.editingExisting) {
- return;
- }
- delete $scope.repos[$scope.currentRepo.ID];
- $scope.config.Repositories = repoList($scope.repos);
- $scope.saveConfig();
- };
- $scope.setAPIKey = function (cfg) {
- cfg.APIKey = randomString(30, 32);
- };
- $scope.acceptUR = function () {
- $scope.config.Options.URAccepted = 1000; // Larger than the largest existing report version
- $scope.saveConfig();
- $('#ur').modal('hide');
- };
- $scope.declineUR = function () {
- $scope.config.Options.URAccepted = -1;
- $scope.saveConfig();
- $('#ur').modal('hide');
- };
- $scope.showNeed = function (repo) {
- $scope.neededLoaded = false;
- $('#needed').modal();
- $http.get(urlbase + "/need?repo=" + encodeURIComponent(repo)).success(function (data) {
- $scope.needed = data;
- $scope.neededLoaded = true;
- });
- };
- $scope.needAction = function (file) {
- var fDelete = 4096;
- var fDirectory = 16384;
- if ((file.Flags & (fDelete+fDirectory)) === fDelete+fDirectory) {
- return 'rmdir';
- } else if ((file.Flags & fDelete) === fDelete) {
- return 'rm';
- } else if ((file.Flags & fDirectory) === fDirectory) {
- return 'touch';
- } else {
- return 'sync';
- }
- };
- $scope.override = function (repo) {
- $http.post(urlbase + "/model/override?repo=" + encodeURIComponent(repo));
- };
- $scope.about = function () {
- $('#about').modal('show');
- };
- $scope.showReportPreview = function () {
- $scope.reportPreview = true;
- };
- $scope.rescanRepo = function (repo) {
- $http.post(urlbase + "/scan?repo=" + encodeURIComponent(repo));
- };
- $scope.init();
- setInterval($scope.refresh, 10000);
- });
- 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;
- }
- function repoCompare(a, b) {
- if (a.ID < b.ID) {
- return -1;
- }
- return a.ID > b.ID;
- }
- function repoMap(l) {
- var m = {};
- l.forEach(function (r) {
- m[r.ID] = r;
- });
- return m;
- }
- function repoList(m) {
- var l = [];
- for (var id in m) {
- l.push(m[id]);
- }
- l.sort(repoCompare);
- return l;
- }
- 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;
- }
- function randomString(len, bits)
- {
- bits = bits || 36;
- var outStr = "", newStr;
- while (outStr.length < len)
- {
- newStr = Math.random().toString(bits).slice(2);
- outStr += newStr.slice(0, Math.min(newStr.length, (len - outStr.length)));
- }
- return outStr.toLowerCase();
- }
- function isEmptyObject(obj) {
- var name;
- for (name in obj) {
- return false;
- }
- return true;
- }
- function debounce(func, wait) {
- var timeout, args, context, timestamp, result, again;
- var later = function() {
- var last = Date.now() - timestamp;
- if (last < wait) {
- timeout = setTimeout(later, wait - last);
- } else {
- timeout = null;
- if (again) {
- again = false;
- result = func.apply(context, args);
- context = args = null;
- }
- }
- };
- return function() {
- context = this;
- args = arguments;
- timestamp = Date.now();
- var callNow = !timeout;
- if (!timeout) {
- timeout = setTimeout(later, wait);
- result = func.apply(context, args);
- context = args = null;
- } else {
- again = true;
- }
- return result;
- };
- }
- 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('alwaysNumber', function () {
- return function (input) {
- if (input === undefined) {
- return 0;
- }
- return input;
- };
- });
- syncthing.filter('basename', function () {
- return function (input) {
- if (input === undefined)
- return "";
- var parts = input.split(/[\/\\]/);
- if (!parts || parts.length < 1) {
- return input;
- }
- return parts[parts.length-1];
- };
- });
- syncthing.directive('uniqueRepo', function() {
- return {
- require: 'ngModel',
- link: function(scope, elm, attrs, ctrl) {
- ctrl.$parsers.unshift(function(viewValue) {
- if (scope.editingExisting) {
- // we shouldn't validate
- ctrl.$setValidity('uniqueRepo', true);
- } else if (scope.repos[viewValue]) {
- // the repo exists already
- ctrl.$setValidity('uniqueRepo', false);
- } else {
- // the repo is unique
- ctrl.$setValidity('uniqueRepo', true);
- }
- return viewValue;
- });
- }
- };
- });
- syncthing.directive('validNodeid', function($http) {
- return {
- require: 'ngModel',
- link: function(scope, elm, attrs, ctrl) {
- ctrl.$parsers.unshift(function(viewValue) {
- if (scope.editingExisting) {
- // we shouldn't validate
- ctrl.$setValidity('validNodeid', true);
- } else {
- $http.get(urlbase + '/nodeid?id='+viewValue).success(function (resp) {
- if (resp.error) {
- ctrl.$setValidity('validNodeid', false);
- } else {
- ctrl.$setValidity('validNodeid', true);
- }
- });
- }
- return viewValue;
- });
- }
- };
- });
- syncthing.directive('modal', function () {
- return {
- restrict: 'E',
- templateUrl: 'modal.html',
- replace: true,
- transclude: true,
- scope: {
- title: '@',
- status: '@',
- icon: '@',
- close: '@',
- large: '@',
- },
- }
- });
|