76 lines
3.1 KiB
JavaScript
76 lines
3.1 KiB
JavaScript
const logger = require('winston');
|
|
const db = require('../models');
|
|
const lbryApi = require('../helpers/lbryApi.js');
|
|
const publishHelpers = require('../helpers/publishHelpers.js');
|
|
|
|
module.exports = {
|
|
publish (publishParams, fileName, fileType) {
|
|
return new Promise((resolve, reject) => {
|
|
let publishResults = {};
|
|
// 1. publish the file
|
|
return lbryApi.publishClaim(publishParams)
|
|
// 2. upsert File record (update is in case the claim has been published before by this daemon)
|
|
.then(tx => {
|
|
logger.info(`Successfully published ${fileName}`, tx);
|
|
publishResults = tx;
|
|
return db.Channel.findOne({where: {channelName: publishParams.channel_name}}); // note: should this be db.User ??
|
|
})
|
|
.then(channel => {
|
|
let certificateId;
|
|
if (channel) {
|
|
certificateId = channel.channelClaimId;
|
|
logger.debug('successfully found channel in Channel table');
|
|
} else {
|
|
certificateId = null;
|
|
logger.debug('channel for publish not found in Channel table');
|
|
};
|
|
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,
|
|
};
|
|
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,
|
|
certificateId,
|
|
amount : publishParams.bid,
|
|
};
|
|
const upsertCriteria = {
|
|
name : publishParams.name,
|
|
claimId: publishResults.claim_id,
|
|
};
|
|
// create 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('caught a publishController.publish error');
|
|
publishHelpers.deleteTemporaryFile(publishParams.file_path); // delete the local file
|
|
reject(error);
|
|
});
|
|
});
|
|
},
|
|
};
|