spee.ch/server/controllers/assets/serveByIdentifierAndClaim/index.js

const logger = require('winston');

const { sendGAServeEvent } = require('../../../utils/googleAnalytics');
const handleShowRender = require('../../../render/build/handleShowRender.js');

const lbryUri = require('../../utils/lbryUri.js');

const determineRequestType = require('../utils/determineRequestType.js');
const getClaimIdAndServeAsset = require('../utils/getClaimIdAndServeAsset.js');
const flipClaimNameAndId = require('../utils/flipClaimNameAndId.js');

const { SHOW } = require('../constants/request_types.js');

/*

  route to serve an asset or the react app via the claim name and an identifier

*/

const serverByIdentifierAndClaim = (req, res) => {
  const { headers, ip, originalUrl, params } = req;

  try {
    let hasFileExtension, claimName, isChannel, channelName, channelClaimId, claimId;

    ({ hasFileExtension } = lbryUri.parseModifier(params.claim));
    if (determineRequestType(hasFileExtension, headers) === SHOW) {
      logger.debug('show request:', { headers, ip, originalUrl, params });
      return handleShowRender(req, res);
    }

    ({ claimName } = lbryUri.parseClaim(params.claim));
    ({ isChannel, channelName, channelClaimId, claimId } = lbryUri.parseIdentifier(params.identifier));

    if (!isChannel) {
      [claimId, claimName] = flipClaimNameAndId(claimId, claimName);
    }

    logger.debug('serve request:', { headers, ip, originalUrl, params });

    getClaimIdAndServeAsset(channelName, channelClaimId, claimName, claimId, originalUrl, ip, res);

    sendGAServeEvent(headers, ip, originalUrl);
  } catch (error) {
    return res.status(400).json({success: false, message: error.message});
  }
};

module.exports = serverByIdentifierAndClaim;