lbry-desktop/ui/js/lbry.js

347 lines
9 KiB
JavaScript
Raw Normal View History

import jsonrpc from "./jsonrpc.js";
import lbryuri from "./lbryuri.js";
function getLocal(key, fallback = undefined) {
const itemRaw = localStorage.getItem(key);
return itemRaw === null ? fallback : JSON.parse(itemRaw);
}
function setLocal(key, value) {
localStorage.setItem(key, JSON.stringify(value));
}
const { remote, ipcRenderer } = require("electron");
const menu = remote.require("./menu/main-menu");
let lbry = {
isConnected: false,
2017-08-15 23:04:09 +02:00
daemonConnectionString: "http://localhost:5279",
pendingPublishTimeout: 20 * 60 * 1000,
};
2017-06-15 02:21:31 +02:00
function apiCall(method, params, resolve, reject) {
return jsonrpc.call(
lbry.daemonConnectionString,
method,
params,
resolve,
reject,
reject
);
}
/**
* Records a publish attempt in local storage. Returns a dictionary with all the data needed to
* needed to make a dummy claim or file info object.
*/
2017-06-29 00:08:16 +02:00
let pendingId = 0;
2017-06-06 06:21:55 +02:00
function savePendingPublish({ name, channel_name }) {
let uri;
if (channel_name) {
uri = lbryuri.build({ name: channel_name, path: name }, false);
} else {
uri = lbryuri.build({ name: name }, false);
}
2017-06-29 00:08:16 +02:00
++pendingId;
const pendingPublishes = getLocal("pendingPublishes") || [];
const newPendingPublish = {
name,
channel_name,
2017-06-29 00:08:16 +02:00
claim_id: "pending-" + pendingId,
txid: "pending-" + pendingId,
nout: 0,
2017-06-29 00:08:16 +02:00
outpoint: "pending-" + pendingId + ":0",
time: Date.now(),
};
setLocal("pendingPublishes", [...pendingPublishes, newPendingPublish]);
return newPendingPublish;
}
/**
* If there is a pending publish with the given name or outpoint, remove it.
* A channel name may also be provided along with name.
*/
2017-06-06 06:21:55 +02:00
function removePendingPublishIfNeeded({ name, channel_name, outpoint }) {
function pubMatches(pub) {
return (
pub.outpoint === outpoint ||
(pub.name === name &&
(!channel_name || pub.channel_name === channel_name))
);
}
setLocal(
"pendingPublishes",
lbry.getPendingPublishes().filter(pub => !pubMatches(pub))
);
}
/**
* Gets the current list of pending publish attempts. Filters out any that have timed out and
* removes them from the list.
*/
lbry.getPendingPublishes = function() {
const pendingPublishes = getLocal("pendingPublishes") || [];
const newPendingPublishes = pendingPublishes.filter(
pub => Date.now() - pub.time <= lbry.pendingPublishTimeout
);
setLocal("pendingPublishes", newPendingPublishes);
return newPendingPublishes;
2017-06-06 06:21:55 +02:00
};
/**
* Gets a pending publish attempt by its name or (fake) outpoint. A channel name can also be
* provided along withe the name. If no pending publish is found, returns null.
*/
2017-06-06 06:21:55 +02:00
function getPendingPublish({ name, channel_name, outpoint }) {
const pendingPublishes = lbry.getPendingPublishes();
return (
pendingPublishes.find(
pub =>
pub.outpoint === outpoint ||
(pub.name === name &&
(!channel_name || pub.channel_name === channel_name))
) || null
);
}
2017-06-06 06:21:55 +02:00
function pendingPublishToDummyClaim({
channel_name,
name,
outpoint,
claim_id,
txid,
nout,
2017-06-06 06:21:55 +02:00
}) {
return { name, outpoint, claim_id, txid, nout, channel_name };
}
2017-06-06 06:21:55 +02:00
function pendingPublishToDummyFileInfo({ name, outpoint, claim_id }) {
return { name, outpoint, claim_id, metadata: null };
}
2016-03-14 23:05:24 +01:00
//core
2017-04-09 17:06:23 +02:00
lbry._connectPromise = null;
lbry.connect = function() {
if (lbry._connectPromise === null) {
lbry._connectPromise = new Promise((resolve, reject) => {
let tryNum = 0;
function checkDaemonStartedFailed() {
if (tryNum <= 200) {
// Move # of tries into constant or config option
setTimeout(() => {
tryNum++;
checkDaemonStarted();
}, tryNum < 50 ? 400 : 1000);
} else {
reject(new Error("Unable to connect to LBRY"));
}
}
// Check every half second to see if the daemon is accepting connections
function checkDaemonStarted() {
2017-06-15 02:21:31 +02:00
lbry.status().then(resolve).catch(checkDaemonStartedFailed);
}
checkDaemonStarted();
});
}
return lbry._connectPromise;
2017-06-06 06:21:55 +02:00
};
2016-03-14 23:05:24 +01:00
/**
* Publishes a file. The optional fileListedCallback is called when the file becomes available in
* lbry.file_list() during the publish process.
*
* This currently includes a work-around to cache the file in local storage so that the pending
* publish can appear in the UI immediately.
*/
2017-06-15 02:21:31 +02:00
lbry.publishDeprecated = function(
params,
fileListedCallback,
publishedCallback,
errorCallback
2017-06-06 06:21:55 +02:00
) {
2017-06-15 02:21:31 +02:00
lbry.publish(params).then(
result => {
if (returnPendingTimeout) clearTimeout(returnPendingTimeout);
publishedCallback(result);
},
err => {
if (returnPendingTimeout) clearTimeout(returnPendingTimeout);
errorCallback(err);
}
);
// Give a short grace period in case publish() returns right away or (more likely) gives an error
const returnPendingTimeout = setTimeout(
() => {
if (publishedCallback) {
savePendingPublish({
name: params.name,
channel_name: params.channel_name,
});
publishedCallback(true);
}
if (fileListedCallback) {
const { name, channel_name } = params;
savePendingPublish({
name: params.name,
channel_name: params.channel_name,
});
fileListedCallback(true);
}
},
2000,
{ once: true }
);
2017-06-06 06:21:55 +02:00
};
2017-06-06 06:21:55 +02:00
lbry.imagePath = function(file) {
return "img/" + file;
2017-06-06 06:21:55 +02:00
};
lbry.getMediaType = function(contentType, fileName) {
if (contentType) {
return /^[^/]+/.exec(contentType)[0];
} else if (fileName) {
var dotIndex = fileName.lastIndexOf(".");
if (dotIndex == -1) {
return "unknown";
}
var ext = fileName.substr(dotIndex + 1);
2017-06-30 22:33:49 +02:00
if (/^mp4|m4v|webm|flv|f4v|ogv$/i.test(ext)) {
return "video";
} else if (/^mp3|m4a|aac|wav|flac|ogg|opus$/i.test(ext)) {
return "audio";
} else if (
/^html|htm|xml|pdf|odf|doc|docx|md|markdown|txt|epub|org$/i.test(ext)
) {
return "document";
} else {
return "unknown";
}
} else {
return "unknown";
}
2017-06-06 06:21:55 +02:00
};
2016-05-16 10:16:40 +02:00
2017-05-25 20:29:28 +02:00
lbry.getAppVersionInfo = function() {
return new Promise((resolve, reject) => {
ipcRenderer.once("version-info-received", (event, versionInfo) => {
resolve(versionInfo);
});
ipcRenderer.send("version-info-requested");
});
2017-06-06 06:21:55 +02:00
};
2017-04-27 08:52:14 +02:00
/**
* Wrappers for API methods to simulate missing or future behavior. Unlike the old-style stubs,
* these are designed to be transparent wrappers around the corresponding API methods.
*/
/**
* Returns results from the file_list API method, plus dummy entries for pending publishes.
* (If a real publish with the same name is found, the pending publish will be ignored and removed.)
*/
2017-06-06 06:21:55 +02:00
lbry.file_list = function(params = {}) {
return new Promise((resolve, reject) => {
const { name, channel_name, outpoint } = params;
/**
* If we're searching by outpoint, check first to see if there's a matching pending publish.
* Pending publishes use their own faux outpoints that are always unique, so we don't need
* to check if there's a real file.
*/
if (outpoint) {
const pendingPublish = getPendingPublish({ outpoint });
if (pendingPublish) {
resolve([pendingPublishToDummyFileInfo(pendingPublish)]);
return;
}
}
2017-06-20 14:08:52 +02:00
2017-06-15 02:21:31 +02:00
apiCall(
"file_list",
params,
fileInfos => {
removePendingPublishIfNeeded({ name, channel_name, outpoint });
2017-07-30 21:20:36 +02:00
//if a naked file_list call, append the pending file infos
if (!name && !channel_name && !outpoint) {
const dummyFileInfos = lbry
.getPendingPublishes()
.map(pendingPublishToDummyFileInfo);
resolve([...fileInfos, ...dummyFileInfos]);
} else {
resolve(fileInfos);
}
},
reject
);
});
2017-06-06 06:21:55 +02:00
};
2017-06-06 06:21:55 +02:00
lbry.claim_list_mine = function(params = {}) {
return new Promise((resolve, reject) => {
2017-06-15 02:21:31 +02:00
apiCall(
"claim_list_mine",
params,
claims => {
for (let { name, channel_name, txid, nout } of claims) {
removePendingPublishIfNeeded({
name,
channel_name,
outpoint: txid + ":" + nout,
});
}
const dummyClaims = lbry
.getPendingPublishes()
.map(pendingPublishToDummyClaim);
resolve([...claims, ...dummyClaims]);
},
reject
);
});
2017-06-06 06:21:55 +02:00
};
2017-06-06 06:21:55 +02:00
lbry.resolve = function(params = {}) {
return new Promise((resolve, reject) => {
apiCall(
"resolve",
params,
function(data) {
if ("uri" in params) {
// If only a single URI was requested, don't nest the results in an object
resolve(data && data[params.uri] ? data[params.uri] : {});
} else {
resolve(data || {});
}
},
reject
);
});
2017-06-06 06:21:55 +02:00
};
2017-04-13 20:52:26 +02:00
lbry = new Proxy(lbry, {
get: function(target, name) {
if (name in target) {
return target[name];
}
return function(params = {}) {
return new Promise((resolve, reject) => {
2017-06-15 02:21:31 +02:00
apiCall(name, params, resolve, reject);
});
};
},
});
export default lbry;