transmission/web/javascript/remote.js

266 lines
7.7 KiB
JavaScript
Raw Normal View History

/*
* Copyright © Dave Perrett, Malcolm Jarvis and Bruno Bierbaumer
* This code is licensed under the GPL version 2.
* For details, see http://www.gnu.org/licenses/old-licenses/gpl-2.0.html
*
* Class TransmissionRemote
*/
function RPC() { }
//Prefs.prototype = { }
// Constants
RPC._Root = '../rpc';
RPC._DaemonVersion = 'version';
RPC._Encryption = 'encryption';
RPC._EncryptionPreferred = 'preferred';
RPC._EncryptionRequired = 'required';
RPC._UpSpeedLimit = 'speed-limit-up';
RPC._DownSpeedLimit = 'speed-limit-down';
RPC._DownloadDir = 'download-dir';
RPC._PeerPort = 'peer-port';
RPC._UpSpeedLimited = 'speed-limit-up-enabled';
RPC._DownSpeedLimited = 'speed-limit-down-enabled';
RPC._TurtleState = 'alt-speed-enabled';
RPC._TurtleUpSpeedLimit = 'alt-speed-up';
RPC._TurtleDownSpeedLimit = 'alt-speed-down';
RPC._TurtleTimeEnabled = 'alt-speed-time-enabled';
RPC._TurtleTimeBegin = 'alt-speed-time-begin';
RPC._TurtleTimeEnd = 'alt-speed-time-end';
RPC._TurtleTimeDay = 'alt-speed-time-day';
RPC._PeerLimitGlobal = 'peer-limit-global';
RPC._PeerLimitPerTorrent = 'peer-limit-per-torrent';
RPC._PexEnabled = 'pex-enabled';
RPC._DhtEnabled = 'dht-enabled';
RPC._LpdEnabled = 'lpd-enabled';
RPC._BlocklistEnabled = 'blocklist-enabled';
RPC._BlocklistURL = 'blocklist-url';
RPC._BlocklistSize = 'blocklist-size';
RPC._UtpEnabled = 'utp-enabled';
RPC._PeerPortRandom = 'peer-port-random-on-start';
RPC._PortForwardingEnabled = 'port-forwarding-enabled';
RPC._StartAddedTorrent = 'start-added-torrents';
RPC._QueueMoveTop = 'queue-move-top';
RPC._QueueMoveBottom = 'queue-move-bottom';
RPC._QueueMoveUp = 'queue-move-up';
RPC._QueueMoveDown = 'queue-move-down';
function TransmissionRemote(controller)
{
this.initialize(controller);
return this;
}
TransmissionRemote.prototype =
{
/*
* Constructor
*/
initialize: function(controller) {
this._controller = controller;
this._error = '';
2009-05-08 15:02:22 +00:00
this._token = '';
},
/*
* Display an error if an ajax request fails, and stop sending requests
2009-05-08 15:02:22 +00:00
* or on a 409, globally set the X-Transmission-Session-Id and resend
*/
2009-05-08 15:02:22 +00:00
ajaxError: function(request, error_string, exception, ajaxObject) {
var token;
2009-05-08 02:43:17 +00:00
remote = this;
2009-05-08 15:02:22 +00:00
// set the Transmission-Session-Id on a 409
if (request.status == 409 && (token = request.getResponseHeader('X-Transmission-Session-Id'))){
2009-05-08 15:02:22 +00:00
remote._token = token;
$.ajax(ajaxObject);
return;
}
2009-05-08 02:43:17 +00:00
remote._error = request.responseText
? request.responseText.trim().replace(/(<([^>]+)>)/ig,"")
: "";
if (!remote._error.length)
2009-05-08 02:43:17 +00:00
remote._error = 'Server not responding';
dialog.confirm('Connection Failed',
'Could not connect to the server. You may need to reload the page to reconnect.',
'Details',
'alert(remote._error);',
null,
'Dismiss');
remote._controller.togglePeriodicSessionRefresh(false);
},
2009-05-08 15:02:22 +00:00
appendSessionId: function(XHR) {
XHR.setRequestHeader('X-Transmission-Session-Id', this._token);
},
sendRequest: function(data, callback, context, async) {
2009-05-08 02:43:17 +00:00
remote = this;
if (typeof async != 'boolean')
2010-06-21 13:14:33 +00:00
async = true;
var ajaxSettings = {
url: RPC._Root,
type: 'POST',
contentType: 'json',
dataType: 'json',
cache: false,
data: JSON.stringify(data),
beforeSend: function(XHR){ remote.appendSessionId(XHR); },
error: function(request, error_string, exception){ remote.ajaxError(request, error_string, exception, ajaxSettings); },
success: callback,
context: context,
async: async
};
$.ajax(ajaxSettings);
},
loadDaemonPrefs: function(callback, context, async) {
var o = { method: 'session-get' };
this.sendRequest(o, callback, context, async);
},
checkPort: function(callback, context, async) {
var o = { method: 'port-test' };
this.sendRequest(o, callback, context, async);
},
loadDaemonStats: function(callback, context, async) {
var o = { method: 'session-stats' };
this.sendRequest(o, callback, context, async);
},
updateTorrents: function(torrentIds, fields, callback, context) {
var o = {
method: 'torrent-get',
'arguments': {
'fields': fields,
}
};
if (torrentIds)
o['arguments'].ids = torrentIds;
this.sendRequest(o, function(response) {
var args = response['arguments'];
callback.call(context,args.torrents,args.removed);
});
},
2010-06-21 13:14:33 +00:00
changeFileCommand: function(command, rows) {
var remote = this;
var torrent_ids = [ rows[0].getTorrent().getId() ];
var files = [];
for (var i=0, row; row=rows[i]; ++i)
files.push(row.getIndex());
var o = {
method: 'torrent-set',
arguments: { ids: torrent_ids }
};
o.arguments[command] = files;
this.sendRequest(o, function() {
remote._controller.refreshTorrents(torrent_ids);
});
},
2010-06-21 13:14:33 +00:00
sendTorrentSetRequests: function(method, torrent_ids, args, callback, context) {
if (!args) args = { };
args['ids'] = torrent_ids;
var o = {
method: method,
arguments: args
};
this.sendRequest(o, callback, context);
},
2010-06-21 13:14:33 +00:00
sendTorrentActionRequests: function(method, torrent_ids, callback, context) {
this.sendTorrentSetRequests(method, torrent_ids, null, callback, context);
},
startTorrents: function(torrent_ids, noqueue, callback, context) {
var name = noqueue ? 'torrent-start-now' : 'torrent-start';
this.sendTorrentActionRequests(name, torrent_ids, callback, context);
},
stopTorrents: function(torrent_ids, callback, context) {
this.sendTorrentActionRequests('torrent-stop', torrent_ids, callback, context);
},
removeTorrents: function(torrent_ids, callback, context) {
this.sendTorrentActionRequests('torrent-remove', torrent_ids, callback, context);
},
removeTorrentsAndData: function(torrents) {
2009-03-18 21:43:11 +00:00
var remote = this;
2009-03-18 00:47:25 +00:00
var o = {
method: 'torrent-remove',
arguments: {
'delete-local-data': true,
ids: [ ]
}
};
if (torrents) {
for (var i=0, len=torrents.length; i<len; ++i) {
o.arguments.ids.push(torrents[i].getId());
}
}
this.sendRequest(o, function() {
2009-05-22 22:45:09 +00:00
remote._controller.refreshTorrents();
});
},
verifyTorrents: function(torrent_ids, callback, context) {
this.sendTorrentActionRequests('torrent-verify', torrent_ids, callback, context);
},
reannounceTorrents: function(torrent_ids, callback) {
this.sendTorrentActionRequests('torrent-reannounce', torrent_ids, callback);
},
addTorrentByUrl: function(url, options) {
2009-03-30 22:35:13 +00:00
var remote = this;
if (url.match(/^[0-9a-f]{40}$/i)) {
url = 'magnet:?xt=urn:btih:'+url;
}
2009-03-30 22:35:13 +00:00
var o = {
method: 'torrent-add',
arguments: {
paused: (options.paused),
filename: url
}
2009-03-30 22:35:13 +00:00
};
this.sendRequest(o, function() {
2009-05-22 22:45:09 +00:00
remote._controller.refreshTorrents();
});
},
savePrefs: function(args) {
var remote = this;
var o = {
method: 'session-set',
arguments: args
};
this.sendRequest(o, function() {
remote._controller.loadDaemonPrefs();
});
},
updateBlocklist: function() {
var remote = this;
var o = {
method: 'blocklist-update'
};
this.sendRequest(o, function() {
remote._controller.loadDaemonPrefs();
});
},
// Added queue calls
moveTorrentsToTop: function(torrent_ids, callback, context) {
this.sendTorrentActionRequests(RPC._QueueMoveTop, torrent_ids, callback, context);
},
moveTorrentsToBottom: function(torrent_ids, callback, context) {
this.sendTorrentActionRequests(RPC._QueueMoveBottom, torrent_ids, callback, context);
},
moveTorrentsUp: function(torrent_ids, callback, context) {
this.sendTorrentActionRequests(RPC._QueueMoveUp, torrent_ids, callback, context);
},
moveTorrentsDown: function(torrent_ids, callback, context) {
this.sendTorrentActionRequests(RPC._QueueMoveDown, torrent_ids, callback, context);
}
};