reorganized file system

server/controllers/publishController.js

@@ -0,0 +1,130 @@
+const logger = require('winston');
+const db = require('../models/index');
+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;
+      });
+  },
+};