kill lbry.call

This commit is contained in:
Jeremy Kauffman 2017-06-14 20:21:31 -04:00
parent a6b8ae2ce4
commit 4b095c3ea6
5 changed files with 31 additions and 85 deletions

View file

@ -22,7 +22,7 @@ export function doFetchTransactions() {
type: types.FETCH_TRANSACTIONS_STARTED, type: types.FETCH_TRANSACTIONS_STARTED,
}); });
lbry.call("transaction_list", {}, results => { lbry.transaction_list().then(results => {
dispatch({ dispatch({
type: types.FETCH_TRANSACTIONS_COMPLETED, type: types.FETCH_TRANSACTIONS_COMPLETED,
data: { data: {
@ -55,7 +55,7 @@ export function doCheckAddressIsMine(address) {
type: types.CHECK_ADDRESS_IS_MINE_STARTED, type: types.CHECK_ADDRESS_IS_MINE_STARTED,
}); });
lbry.checkAddressIsMine(address, isMine => { lbry.wallet_is_address_mine({ address }).then(isMine => {
if (!isMine) dispatch(doGetNewAddress()); if (!isMine) dispatch(doGetNewAddress());
dispatch({ dispatch({
@ -103,12 +103,12 @@ export function doSendDraftTransaction() {
dispatch(doOpenModal("transactionFailed")); dispatch(doOpenModal("transactionFailed"));
}; };
lbry.sendToAddress( lbry
draftTx.amount, .send_amount_to_address({
draftTx.address, amount: draftTx.amount,
successCallback, address: draftTx.address,
errorCallback })
); .then(successCallback, errorCallback);
}; };
} }

View file

@ -22,6 +22,17 @@ let lbry = {
}, },
}; };
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 * 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. * needed to make a dummy claim or file info object.
@ -110,23 +121,6 @@ function pendingPublishToDummyFileInfo({ name, outpoint, claim_id }) {
return { name, outpoint, claim_id, metadata: null }; return { name, outpoint, claim_id, metadata: null };
} }
lbry.call = function(
method,
params,
callback,
errorCallback,
connectFailedCallback
) {
return jsonrpc.call(
lbry.daemonConnectionString,
method,
params,
callback,
errorCallback,
connectFailedCallback
);
};
//core //core
lbry._connectPromise = null; lbry._connectPromise = null;
lbry.connect = function() { lbry.connect = function() {
@ -148,13 +142,7 @@ lbry.connect = function() {
// Check every half second to see if the daemon is accepting connections // Check every half second to see if the daemon is accepting connections
function checkDaemonStarted() { function checkDaemonStarted() {
lbry.call( lbry.status().then(resolve).catch(checkDaemonStartedFailed);
"status",
{},
resolve,
checkDaemonStartedFailed,
checkDaemonStartedFailed
);
} }
checkDaemonStarted(); checkDaemonStarted();
@ -164,19 +152,6 @@ lbry.connect = function() {
return lbry._connectPromise; return lbry._connectPromise;
}; };
lbry.checkAddressIsMine = function(address, callback) {
lbry.call("wallet_is_address_mine", { address: address }, callback);
};
lbry.sendToAddress = function(amount, address, callback, errorCallback) {
lbry.call(
"send_amount_to_address",
{ amount: amount, address: address },
callback,
errorCallback
);
};
/** /**
* Takes a LBRY URI; will first try and calculate a total cost using * Takes a LBRY URI; will first try and calculate a total cost using
* Lighthouse. If Lighthouse can't be reached, it just retrives the * Lighthouse. If Lighthouse can't be reached, it just retrives the
@ -238,15 +213,13 @@ lbry.getCostInfo = function(uri) {
* This currently includes a work-around to cache the file in local storage so that the pending * This currently includes a work-around to cache the file in local storage so that the pending
* publish can appear in the UI immediately. * publish can appear in the UI immediately.
*/ */
lbry.publish = function( lbry.publishDeprecated = function(
params, params,
fileListedCallback, fileListedCallback,
publishedCallback, publishedCallback,
errorCallback errorCallback
) { ) {
lbry.call( lbry.publish(params).then(
"publish",
params,
result => { result => {
if (returnedPending) { if (returnedPending) {
return; return;
@ -320,20 +293,6 @@ lbry.setClientSetting = function(setting, value) {
return localStorage.setItem("setting_" + setting, JSON.stringify(value)); return localStorage.setItem("setting_" + setting, JSON.stringify(value));
}; };
lbry.getSessionInfo = function(callback) {
lbry.call("status", { session_status: true }, callback);
};
lbry.reportBug = function(message, callback) {
lbry.call(
"report_bug",
{
message: message,
},
callback
);
};
//utilities //utilities
lbry.formatCredits = function(amount, precision) { lbry.formatCredits = function(amount, precision) {
return amount.toFixed(precision || 1).replace(/\.?0+$/, ""); return amount.toFixed(precision || 1).replace(/\.?0+$/, "");
@ -374,10 +333,6 @@ lbry.getMediaType = function(contentType, fileName) {
} }
}; };
lbry.stop = function(callback) {
lbry.call("stop", {}, callback);
};
lbry._subscribeIdCount = 0; lbry._subscribeIdCount = 0;
lbry._balanceSubscribeCallbacks = {}; lbry._balanceSubscribeCallbacks = {};
lbry._balanceSubscribeInterval = 5000; lbry._balanceSubscribeInterval = 5000;
@ -463,7 +418,7 @@ lbry.file_list = function(params = {}) {
} }
} }
lbry.call( apiCall(
"file_list", "file_list",
params, params,
fileInfos => { fileInfos => {
@ -474,7 +429,6 @@ lbry.file_list = function(params = {}) {
.map(pendingPublishToDummyFileInfo); .map(pendingPublishToDummyFileInfo);
resolve([...fileInfos, ...dummyFileInfos]); resolve([...fileInfos, ...dummyFileInfos]);
}, },
reject,
reject reject
); );
}); });
@ -482,7 +436,7 @@ lbry.file_list = function(params = {}) {
lbry.claim_list_mine = function(params = {}) { lbry.claim_list_mine = function(params = {}) {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
lbry.call( apiCall(
"claim_list_mine", "claim_list_mine",
params, params,
claims => { claims => {
@ -499,7 +453,6 @@ lbry.claim_list_mine = function(params = {}) {
.map(pendingPublishToDummyClaim); .map(pendingPublishToDummyClaim);
resolve([...claims, ...dummyClaims]); resolve([...claims, ...dummyClaims]);
}, },
reject,
reject reject
); );
}); });
@ -516,10 +469,10 @@ lbry.resolve = function(params = {}) {
if (params.uri && lbry._claimCache[params.uri] !== undefined) { if (params.uri && lbry._claimCache[params.uri] !== undefined) {
resolve(lbry._claimCache[params.uri]); resolve(lbry._claimCache[params.uri]);
} else { } else {
lbry._resolveXhrs[params.uri] = lbry.call( lbry._resolveXhrs[params.uri] = apiCall(
"resolve", "resolve",
params, params,
function(data) { data => {
if (data !== undefined) { if (data !== undefined) {
lbry._claimCache[params.uri] = data; lbry._claimCache[params.uri] = data;
} }
@ -547,14 +500,7 @@ lbry = new Proxy(lbry, {
return function(params = {}) { return function(params = {}) {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
jsonrpc.call( apiCall(name, params, resolve, reject);
lbry.daemonConnectionString,
name,
params,
resolve,
reject,
reject
);
}); });
}; };
}, },

View file

@ -26,12 +26,12 @@ class HelpPage extends React.PureComponent {
upgradeAvailable: upgradeAvailable, upgradeAvailable: upgradeAvailable,
}); });
}); });
lbry.call("version", {}, info => { lbry.version().then(info => {
this.setState({ this.setState({
versionInfo: info, versionInfo: info,
}); });
}); });
lbry.getSessionInfo(info => { lbry.status({ session_status: true }).then(info => {
this.setState({ this.setState({
lbryId: info.lbry_id, lbryId: info.lbry_id,
}); });

View file

@ -134,7 +134,7 @@ class PublishPage extends React.PureComponent {
publishArgs.file_path = this.refs.file.getValue(); publishArgs.file_path = this.refs.file.getValue();
} }
lbry.publish( lbry.publishDeprecated(
publishArgs, publishArgs,
message => { message => {
this.handlePublishStarted(); this.handlePublishStarted();

View file

@ -19,7 +19,7 @@ class ReportPage extends React.PureComponent {
this.setState({ this.setState({
submitting: true, submitting: true,
}); });
lbry.reportBug(this._messageArea.value, () => { lbry.report_bug({ message: this._messageArea.value }).then(() => {
this.setState({ this.setState({
submitting: false, submitting: false,
modal: "submitted", modal: "submitted",