117 lines
3.7 KiB
JavaScript
117 lines
3.7 KiB
JavaScript
const logger = require('winston');
|
|
const db = require('../models');
|
|
const lbryApi = require('../helpers/libraries/lbryApi.js');
|
|
const publishHelpers = require('../helpers/libraries/publishHelpers.js');
|
|
|
|
function upsert (Model, values, condition) {
|
|
return Model
|
|
.findOne({ where: condition })
|
|
.then(function (obj) {
|
|
if (obj) { // update
|
|
logger.silly(`updating ${values.name}:${values.claimId} in File db`);
|
|
return obj.update(values);
|
|
} else { // insert
|
|
logger.silly(`creating ${values.name}:${values.claimId} in File db`);
|
|
return Model.create(values);
|
|
}
|
|
}).catch(function (error) {
|
|
logger.error('Sequelize findOne error', error);
|
|
});
|
|
}
|
|
|
|
function checkNameAvailability (name) {
|
|
const deferred = new Promise((resolve, reject) => {
|
|
// find any records where the name is used
|
|
db.File
|
|
.findAll({ where: { name } })
|
|
.then(result => {
|
|
if (result.length >= 1) {
|
|
// filter out any results that were not published from a spee.ch wallet address
|
|
lbryApi
|
|
.getWalletList()
|
|
.then((walletList) => {
|
|
const filteredResult = result.filter((claim) => {
|
|
return walletList.includes(claim.address);
|
|
});
|
|
if (filteredResult.length >= 1) {
|
|
resolve(false);
|
|
} else {
|
|
resolve(true);
|
|
}
|
|
})
|
|
.catch((error) => {
|
|
reject(error);
|
|
});
|
|
} else {
|
|
resolve(true);
|
|
}
|
|
})
|
|
.catch(error => {
|
|
reject(error);
|
|
});
|
|
});
|
|
return deferred;
|
|
};
|
|
|
|
module.exports = {
|
|
publish (publishParams, fileName, fileType) {
|
|
const deferred = new Promise((resolve, reject) => {
|
|
// 1. make sure the name is available
|
|
checkNameAvailability(publishParams.name)
|
|
.then(result => {
|
|
if (result === true) {
|
|
// 2. publish the file
|
|
lbryApi
|
|
.publishClaim(publishParams)
|
|
.then(result => {
|
|
logger.info(`Successfully published ${fileName}`, result);
|
|
// 3. update old record or create new one (update is in case the claim has been published before by this daemon)
|
|
upsert(
|
|
db.File,
|
|
{
|
|
name : publishParams.name,
|
|
claimId : result.claim_id,
|
|
address : publishParams.claim_address,
|
|
outpoint: `${result.txid}:${result.nout}`,
|
|
height : 0,
|
|
fileName,
|
|
filePath: publishParams.file_path,
|
|
fileType,
|
|
nsfw : publishParams.metadata.nsfw,
|
|
},
|
|
{
|
|
name : publishParams.name,
|
|
claimId: result.claim_id,
|
|
}
|
|
).then(() => {
|
|
// resolve the promise with the result from lbryApi.publishClaim;
|
|
resolve(result);
|
|
})
|
|
.catch(error => {
|
|
logger.error('Sequelize findOne error', error);
|
|
// reject the promise
|
|
reject(error);
|
|
});
|
|
})
|
|
.catch(error => {
|
|
// delete the local file
|
|
publishHelpers.deleteTemporaryFile(publishParams.file_path);
|
|
// reject the promise
|
|
reject(error);
|
|
});
|
|
} else {
|
|
const err = new Error('That name has already been claimed by spee.ch. Please choose a new claim name.');
|
|
reject(err);
|
|
}
|
|
})
|
|
.catch(error => {
|
|
reject(error);
|
|
});
|
|
});
|
|
return deferred;
|
|
},
|
|
checkNameAvailability (name) {
|
|
return checkNameAvailability(name);
|
|
},
|
|
};
|