62 lines
2.2 KiB
JavaScript
62 lines
2.2 KiB
JavaScript
const logger = require('winston');
|
|
const db = require('../../../../models');
|
|
const { publishClaim } = require('../../../../lbrynet');
|
|
const { createFileRecordDataAfterPublish } = require('../../../../models/utils/createFileRecordData.js');
|
|
const { createClaimRecordDataAfterPublish } = require('../../../../models/utils/createClaimRecordData.js');
|
|
const deleteFile = require('./deleteFile.js');
|
|
|
|
const publish = async (publishParams, fileName, fileType) => {
|
|
let publishResults;
|
|
let channel;
|
|
let fileRecord;
|
|
let filePath = publishParams.file_path;
|
|
let newFile = Boolean(filePath);
|
|
|
|
try {
|
|
publishResults = await publishClaim(publishParams);
|
|
logger.info(`Successfully published ${publishParams.name} ${fileName}`, publishResults);
|
|
|
|
// get the channel information
|
|
if (publishParams.channel_name) {
|
|
logger.debug(`this claim was published in channel: ${publishParams.channel_name}`);
|
|
channel = await db.Channel.findOne({
|
|
where: {
|
|
channelName: publishParams.channel_name,
|
|
},
|
|
});
|
|
} else {
|
|
channel = null;
|
|
}
|
|
const certificateId = channel ? channel.channelClaimId : null;
|
|
const channelName = channel ? channel.channelName : null;
|
|
|
|
const claimRecord = await createClaimRecordDataAfterPublish(certificateId, channelName, fileName, fileType, publishParams, publishResults);
|
|
const {claimId} = claimRecord;
|
|
const upsertCriteria = {name: publishParams.name, claimId};
|
|
if (newFile) {
|
|
fileRecord = await createFileRecordDataAfterPublish(fileName, fileType, publishParams, publishResults);
|
|
} else {
|
|
fileRecord = await db.File.findOne({where: {claimId}});
|
|
}
|
|
|
|
const [file, claim] = await Promise.all([
|
|
db.upsert(db.File, fileRecord, upsertCriteria, 'File'),
|
|
db.upsert(db.Claim, claimRecord, upsertCriteria, 'Claim'),
|
|
]);
|
|
logger.info('File and Claim records successfully created');
|
|
|
|
await Promise.all([
|
|
file.setClaim(claim),
|
|
claim.setFile(file),
|
|
]);
|
|
logger.info('File and Claim records successfully associated');
|
|
|
|
return claimRecord;
|
|
} catch (err) {
|
|
logger.error('PUBLISH ERROR', err);
|
|
await deleteFile(filePath);
|
|
return err;
|
|
}
|
|
};
|
|
|
|
module.exports = publish;
|