107 lines
4 KiB
JavaScript
107 lines
4 KiB
JavaScript
const lbryApi = require('../helpers/libraries/lbryApi.js');
|
|
const db = require('../models');
|
|
const logger = require('winston');
|
|
const getAllFreePublicClaims = require('../helpers/functions/getAllFreePublicClaims.js');
|
|
const isFreePublicClaim = require('../helpers/functions/isFreePublicClaim.js');
|
|
|
|
function getClaimAndHandleResponse (claimUri, resolve, reject) {
|
|
lbryApi
|
|
.getClaim(claimUri)
|
|
.then(({ file_name, download_path, mime_type }) => {
|
|
resolve({
|
|
fileName: file_name,
|
|
filePath: download_path,
|
|
fileType: mime_type,
|
|
});
|
|
})
|
|
.catch(error => {
|
|
reject(error);
|
|
});
|
|
}
|
|
|
|
module.exports = {
|
|
getClaimByName (claimName) {
|
|
const deferred = new Promise((resolve, reject) => {
|
|
// get all free public claims
|
|
getAllFreePublicClaims(claimName)
|
|
.then(freePublicClaimList => {
|
|
const claimId = freePublicClaimList[0].claim_id;
|
|
const name = freePublicClaimList[0].name;
|
|
const freePublicClaimOutpoint = `${freePublicClaimList[0].txid}:${freePublicClaimList[0].nout}`;
|
|
const freePublicClaimUri = `${name}#${claimId}`;
|
|
// check to see if the file is available locally
|
|
db.File
|
|
.findOne({ where: { name: name, claimId: claimId } })
|
|
.then(claim => {
|
|
// if a matching claim is found locally...
|
|
if (claim) {
|
|
logger.debug(`A mysql record was found for ${claimId}`);
|
|
// if the outpoint's match return it
|
|
if (claim.dataValues.outpoint === freePublicClaimOutpoint) {
|
|
logger.debug(`local outpoint matched for ${claimId}`);
|
|
resolve(claim.dataValues);
|
|
// if the outpoint's don't match, fetch updated claim
|
|
} else {
|
|
logger.debug(`local outpoint did not match for ${claimId}`);
|
|
getClaimAndHandleResponse(freePublicClaimUri, resolve, reject);
|
|
}
|
|
// ... otherwise use daemon to retrieve it
|
|
} else {
|
|
getClaimAndHandleResponse(freePublicClaimUri, resolve, reject);
|
|
}
|
|
})
|
|
.catch(error => {
|
|
reject(error);
|
|
});
|
|
})
|
|
.catch(error => {
|
|
reject(error);
|
|
});
|
|
});
|
|
return deferred;
|
|
},
|
|
getClaimByClaimId (claimName, claimId) {
|
|
const deferred = new Promise((resolve, reject) => {
|
|
const uri = `${claimName}#${claimId}`;
|
|
// resolve the Uri
|
|
lbryApi
|
|
.resolveUri(uri) // note: use 'spread' and make parallel with db.File.findOne()
|
|
.then(result => {
|
|
const resolvedOutpoint = `${result[uri].claim.txid}:${result[uri].claim.nout}`;
|
|
// check locally for the claim
|
|
db.File
|
|
.findOne({ where: { name: claimName, claimId: claimId } })
|
|
.then(claim => {
|
|
// if a found locally...
|
|
if (claim) {
|
|
logger.debug(`A mysql record was found for ${claimId}`);
|
|
// if the outpoint's match return it
|
|
if (claim.dataValues.outpoint === resolvedOutpoint) {
|
|
logger.debug(`local outpoint matched for ${claimId}`);
|
|
resolve(claim.dataValues);
|
|
// if the outpoint's don't match, fetch updated claim
|
|
} else {
|
|
logger.debug(`local outpoint did not match for ${claimId}`);
|
|
getClaimAndHandleResponse(uri, resolve, reject);
|
|
}
|
|
// ... otherwise use daemon to retrieve it
|
|
} else {
|
|
if (isFreePublicClaim(result[uri].claim)) {
|
|
getClaimAndHandleResponse(uri, resolve, reject);
|
|
} else {
|
|
reject('NO_FREE_PUBLIC_CLAIMS');
|
|
}
|
|
}
|
|
})
|
|
.catch(error => {
|
|
reject(error);
|
|
});
|
|
})
|
|
.catch(error => {
|
|
reject(error);
|
|
});
|
|
});
|
|
return deferred;
|
|
},
|
|
};
|