132 lines
3.9 KiB
JavaScript
132 lines
3.9 KiB
JavaScript
const logger = require('winston');
|
|
|
|
const db = require('../../../models');
|
|
const chainquery = require('chainquery').default;
|
|
const isApprovedChannel = require('../../../../utils/isApprovedChannel');
|
|
|
|
const getClaimId = require('../../utils/getClaimId.js');
|
|
const { handleErrorResponse } = require('../../utils/errorHandlers.js');
|
|
|
|
const serveFile = require('./serveFile.js');
|
|
|
|
const NO_CHANNEL = 'NO_CHANNEL';
|
|
const NO_CLAIM = 'NO_CLAIM';
|
|
const BLOCKED_CLAIM = 'BLOCKED_CLAIM';
|
|
const NO_FILE = 'NO_FILE';
|
|
const CONTENT_UNAVAILABLE = 'CONTENT_UNAVAILABLE';
|
|
|
|
const {
|
|
publishing: { serveOnlyApproved, approvedChannels },
|
|
} = require('@config/siteConfig');
|
|
|
|
const getClaimIdAndServeAsset = (
|
|
channelName,
|
|
channelClaimId,
|
|
claimName,
|
|
claimId,
|
|
originalUrl,
|
|
ip,
|
|
res,
|
|
headers
|
|
) => {
|
|
getClaimId(channelName, channelClaimId, claimName, claimId)
|
|
.then(fullClaimId => {
|
|
claimId = fullClaimId;
|
|
return chainquery.claim.queries.resolveClaim(claimName, fullClaimId).catch(() => {});
|
|
})
|
|
.then(claim => {
|
|
if (!claim) {
|
|
logger.debug('Full claim id:', claimId);
|
|
return db.Claim.findOne({
|
|
where: {
|
|
name: claimName,
|
|
claimId,
|
|
},
|
|
});
|
|
}
|
|
|
|
return claim;
|
|
})
|
|
.then(claim => {
|
|
let claimDataValues = claim.dataValues;
|
|
|
|
if (
|
|
serveOnlyApproved &&
|
|
!isApprovedChannel(
|
|
{ longId: claimDataValues.publisher_id || claimDataValues.certificateId },
|
|
approvedChannels
|
|
)
|
|
) {
|
|
throw new Error(CONTENT_UNAVAILABLE);
|
|
}
|
|
|
|
let outpoint =
|
|
claimDataValues.outpoint ||
|
|
`${claimDataValues.transaction_hash_id}:${claimDataValues.vout}`;
|
|
logger.debug('Outpoint:', outpoint);
|
|
return db.Blocked.isNotBlocked(outpoint).then(() => {
|
|
// If content was found, is approved, and not blocked - log a view.
|
|
if (headers && headers['user-agent'] && /LBRY/.test(headers['user-agent']) === false) {
|
|
db.Views.create({
|
|
time: Date.now(),
|
|
isChannel: false,
|
|
claimId: claimDataValues.claim_id || claimDataValues.claimId,
|
|
publisherId: claimDataValues.publisher_id || claimDataValues.certificateId,
|
|
ip,
|
|
});
|
|
}
|
|
});
|
|
})
|
|
.then(() => {
|
|
return db.File.findOne({
|
|
where: {
|
|
claimId,
|
|
name: claimName,
|
|
},
|
|
});
|
|
})
|
|
.then(fileRecord => {
|
|
if (!fileRecord) {
|
|
throw NO_FILE;
|
|
}
|
|
serveFile(fileRecord.dataValues, res, originalUrl);
|
|
})
|
|
.catch(error => {
|
|
if (error === NO_CLAIM) {
|
|
logger.debug('no claim found');
|
|
return res.status(404).json({
|
|
success: false,
|
|
message: 'No matching claim id could be found for that url',
|
|
});
|
|
}
|
|
if (error === NO_CHANNEL) {
|
|
logger.debug('no channel found');
|
|
return res.status(404).json({
|
|
success: false,
|
|
message: 'No matching channel id could be found for that url',
|
|
});
|
|
}
|
|
if (error === CONTENT_UNAVAILABLE) {
|
|
logger.debug('unapproved channel');
|
|
return res.status(400).json({
|
|
success: false,
|
|
message: 'This content is unavailable',
|
|
});
|
|
}
|
|
if (error === BLOCKED_CLAIM) {
|
|
logger.debug('claim was blocked');
|
|
return res.status(451).json({
|
|
success: false,
|
|
message:
|
|
'In response to a complaint we received under the US Digital Millennium Copyright Act, we have blocked access to this content from our applications. For more details, see https://lbry.io/faq/dmca',
|
|
});
|
|
}
|
|
if (error === NO_FILE) {
|
|
logger.debug('no file available');
|
|
return res.status(307).redirect(`/api/claim/get/${claimName}/${claimId}`);
|
|
}
|
|
handleErrorResponse(originalUrl, ip, error, res);
|
|
});
|
|
};
|
|
|
|
module.exports = getClaimIdAndServeAsset;
|