131 lines
4.6 KiB
JavaScript
131 lines
4.6 KiB
JavaScript
const logger = require('winston');
|
|
const db = require('../models');
|
|
const lbryApi = require('../helpers/lbryApi.js');
|
|
const publishHelpers = require('../helpers/publishHelpers.js');
|
|
const { publishing: { primaryClaimAddress, additionalClaimAddresses } } = require('../../config/siteConfig.js');
|
|
const Sequelize = require('sequelize');
|
|
const Op = Sequelize.Op;
|
|
|
|
module.exports = {
|
|
publish (publishParams, fileName, fileType) {
|
|
return new Promise((resolve, reject) => {
|
|
let publishResults, certificateId, channelName;
|
|
// publish the file
|
|
return lbryApi.publishClaim(publishParams)
|
|
.then(tx => {
|
|
logger.info(`Successfully published ${publishParams.name} ${fileName}`, tx);
|
|
publishResults = tx;
|
|
// get the channel information
|
|
if (publishParams.channel_name) {
|
|
logger.debug(`this claim was published in channel: ${publishParams.channel_name}`);
|
|
return db.Channel.findOne({where: {channelName: publishParams.channel_name}});
|
|
} else {
|
|
logger.debug('this claim was not published in a channel');
|
|
return null;
|
|
}
|
|
})
|
|
.then(channel => {
|
|
// set channel information
|
|
certificateId = null;
|
|
channelName = null;
|
|
if (channel) {
|
|
certificateId = channel.channelClaimId;
|
|
channelName = channel.channelName;
|
|
}
|
|
logger.debug(`certificateId: ${certificateId}`);
|
|
})
|
|
.then(() => {
|
|
// create the File record
|
|
const fileRecord = {
|
|
name : publishParams.name,
|
|
claimId : publishResults.claim_id,
|
|
title : publishParams.metadata.title,
|
|
description: publishParams.metadata.description,
|
|
address : publishParams.claim_address,
|
|
outpoint : `${publishResults.txid}:${publishResults.nout}`,
|
|
height : 0,
|
|
fileName,
|
|
filePath : publishParams.file_path,
|
|
fileType,
|
|
nsfw : publishParams.metadata.nsfw,
|
|
};
|
|
// create the Claim record
|
|
const claimRecord = {
|
|
name : publishParams.name,
|
|
claimId : publishResults.claim_id,
|
|
title : publishParams.metadata.title,
|
|
description: publishParams.metadata.description,
|
|
address : publishParams.claim_address,
|
|
thumbnail : publishParams.metadata.thumbnail,
|
|
outpoint : `${publishResults.txid}:${publishResults.nout}`,
|
|
height : 0,
|
|
contentType: fileType,
|
|
nsfw : publishParams.metadata.nsfw,
|
|
amount : publishParams.bid,
|
|
certificateId,
|
|
channelName,
|
|
};
|
|
// upsert criteria
|
|
const upsertCriteria = {
|
|
name : publishParams.name,
|
|
claimId: publishResults.claim_id,
|
|
};
|
|
// upsert the records
|
|
return Promise.all([db.upsert(db.File, fileRecord, upsertCriteria, 'File'), db.upsert(db.Claim, claimRecord, upsertCriteria, 'Claim')]);
|
|
})
|
|
.then(([file, claim]) => {
|
|
logger.debug('File and Claim records successfully created');
|
|
return Promise.all([file.setClaim(claim), claim.setFile(file)]);
|
|
})
|
|
.then(() => {
|
|
logger.debug('File and Claim records successfully associated');
|
|
resolve(publishResults); // resolve the promise with the result from lbryApi.publishClaim;
|
|
})
|
|
.catch(error => {
|
|
logger.error('PUBLISH ERROR', error);
|
|
publishHelpers.deleteTemporaryFile(publishParams.file_path); // delete the local file
|
|
reject(error);
|
|
});
|
|
});
|
|
},
|
|
claimNameIsAvailable (name) {
|
|
const claimAddresses = additionalClaimAddresses || [];
|
|
claimAddresses.push(primaryClaimAddress);
|
|
// find any records where the name is used
|
|
return db.Claim
|
|
.findAll({
|
|
attributes: ['address'],
|
|
where : {
|
|
name,
|
|
address: {
|
|
[Op.or]: claimAddresses,
|
|
},
|
|
},
|
|
})
|
|
.then(result => {
|
|
if (result.length >= 1) {
|
|
throw new Error('That claim is already in use');
|
|
};
|
|
return name;
|
|
})
|
|
.catch(error => {
|
|
throw error;
|
|
});
|
|
},
|
|
checkChannelAvailability (name) {
|
|
return db.Channel
|
|
.findAll({
|
|
where: { channelName: name },
|
|
})
|
|
.then(result => {
|
|
if (result.length >= 1) {
|
|
throw new Error('That channel has already been claimed');
|
|
}
|
|
return name;
|
|
})
|
|
.catch(error => {
|
|
throw error;
|
|
});
|
|
},
|
|
};
|