define([ '/common/rpc.js', ], function (Rpc) { var create = function (network, proxy, cb) { if (!network) { window.setTimeout(function () { cb('INVALID_NETWORK'); }); return; } if (!proxy) { window.setTimeout(function () { cb('INVALID_PROXY'); }); return; } var edPrivate = proxy.edPrivate; var edPublic = proxy.edPublic; if (!(edPrivate && edPublic)) { window.setTimeout(function () { cb('INVALID_KEYS'); }); return; } Rpc.create(network, edPrivate, edPublic, function (e, rpc) { if (e) { return void cb(e); } var exp = {}; // expose the supplied publicKey as an identifier exp.publicKey = edPublic; // expose the RPC module's raw 'send' command exp.send = rpc.send; // you can ask the server to pin a particular channel for you exp.pin = function (channels, cb) { if (!Array.isArray(channels)) { window.setTimeout(function () { cb('[TypeError] pin expects an array'); }); return; } rpc.send('PIN', channels, cb); }; // you can also ask to unpin a particular channel exp.unpin = function (channels, cb) { if (!Array.isArray(channels)) { window.setTimeout(function () { cb('[TypeError] pin expects an array'); }); return; } rpc.send('UNPIN', channels, cb); }; // ask the server what it thinks your hash is exp.getServerHash = function (cb) { rpc.send('GET_HASH', edPublic, function (e, hash) { if (!(hash && hash[0])) { return void cb('NO_HASH_RETURNED'); } cb(e, hash[0]); }); }; // if local and remote hashes don't match, send a reset exp.reset = function (channels, cb) { if (!Array.isArray(channels)) { window.setTimeout(function () { cb('[TypeError] pin expects an array'); }); return; } rpc.send('RESET', channels, function (e, response) { if (e) { return void cb(e); } if (!response.length) { console.log(response); return void cb('INVALID_RESPONSE'); } cb(e, response[0]); }); }; // get the total stored size of a channel's patches (in bytes) exp.getFileSize = function (file, cb) { rpc.send('GET_FILE_SIZE', file, function (e, response) { if (e) { return void cb(e); } if (response && response.length && typeof(response[0]) === 'number') { return void cb(void 0, response[0]); } else { cb('INVALID_RESPONSE'); } }); }; // get the combined size of all channels (in bytes) for all the // channels which the server has pinned for your publicKey exp.getFileListSize = function (cb) { rpc.send('GET_TOTAL_SIZE', undefined, function (e, response) { if (e) { return void cb(e); } if (response && response.length && typeof(response[0]) === 'number') { cb(void 0, response[0]); } else { cb('INVALID_RESPONSE'); } }); }; // Update the limit value for all the users and return the limit for your publicKey exp.updatePinLimits = function (cb) { rpc.send('UPDATE_LIMITS', undefined, function (e, response) { if (e) { return void cb(e); } if (response && response.length && typeof(response[0]) === "number") { cb (void 0, response[0], response[1], response[2]); } else { cb('INVALID_RESPONSE'); } }); }; // Get the storage limit associated with your publicKey exp.getLimit = function (cb) { rpc.send('GET_LIMIT', undefined, function (e, response) { if (e) { return void cb(e); } if (response && response.length && typeof(response[0]) === "number") { cb (void 0, response[0], response[1], response[2]); } else { cb('INVALID_RESPONSE'); } }); }; exp.clearOwnedChannel = function (channel, cb) { if (typeof(channel) !== 'string' || channel.length !== 32) { return void cb('INVALID_ARGUMENTS'); } rpc.send('CLEAR_OWNED_CHANNEL', channel, function (e, response) { if (e) { return cb(e); } if (response && response.length) { cb(void 0, response[0]); } else { cb(); } }); }; exp.uploadComplete = function (cb) { rpc.send('UPLOAD_COMPLETE', null, function (e, res) { if (e) { return void cb(e); } var id = res[0]; if (typeof(id) !== 'string') { return void cb('INVALID_ID'); } cb(void 0, id); }); }; exp.uploadStatus = function (size, cb) { if (typeof(size) !== 'number') { return void window.setTimeout(function () { cb('INVALID_SIZE'); }); } rpc.send('UPLOAD_STATUS', size, function (e, res) { if (e) { return void cb(e); } var pending = res[0]; if (typeof(pending) !== 'boolean') { return void cb('INVALID_RESPONSE'); } cb(void 0, pending); }); }; exp.uploadCancel = function (cb) { rpc.send('UPLOAD_CANCEL', void 0, function (e) { if (e) { return void cb(e); } cb(); }); }; cb(e, exp); }); }; return { create: create }; });