quetre/controllers/apiController.js

/* eslint-disable no-unused-vars */
////////////////////////////////////////////////////////
//                     IMPORTS
////////////////////////////////////////////////////////
import getAxiosInstance from '../utils/getAxiosInstance.js';
import catchAsyncErrors from '../utils/catchAsyncErrors.js';
import getAnswers from '../fetchers/getAnswers.js';
import getTopic from '../fetchers/getTopic.js';
import getProfile from '../fetchers/getProfile.js';
import getSearch from '../fetchers/getSearch.js';

////////////////////////////////////////////////////////
//                     EXPORTS
////////////////////////////////////////////////////////
export const about = (req, res, next) => {
  res.status(200).json({
    status: 'success',
    message: `make a request. 
    available endpoints are: '/slug', '/unanswered/slug', '/topic/slug', '/profile/slug', '/search?q=query', /?q=query.`,
  });
};

export const answers = catchAsyncErrors(async (req, res, next) => {
	const { slug } = req.params;
	const { lang } = req.query;

  const data = await getAnswers(slug, lang);
  res.status(200).json({ status: 'success', data });
});

export const topic = catchAsyncErrors(async (req, res, next) => {
	const { slug } = req.params;
	const { lang } = req.query;

  const data = await getTopic(slug, lang);
  res.status(200).json({ status: 'success', data });
});

export const profile = catchAsyncErrors(async (req, res, next) => {
  const data = await getProfile(req.params.name);
  res.status(200).json({ status: 'success', data });
});

export const search = catchAsyncErrors(async (req, res, next) => {
  const searchText = req.urlObj.searchParams.get('q')?.trim(); // no search to perform if there isn't any query

  let searchData = null;
  if (searchText) searchData = await getSearch(req.urlObj.search);

  res.status(200).json({ status: 'success', data: searchData });
});

export const unimplemented = (req, res, next) => {
  res.status(501).json({
    status: 'fail',
    message: "This route isn't yet implemented. Check back sometime later!",
  });
};

export const image = catchAsyncErrors(async (req, res, next) => {
  const { domain, path } = req.params;
  if (!domain.endsWith('quoracdn.net')) {
    return res.status(403).json({
      status: 'fail',
      message: 'Invalid domain',
    });
  }
  // changing defaults for this particular endpoint
  const axiosInstance = getAxiosInstance();
  axiosInstance.defaults.baseURL = `https://${domain}/`;

  const imageRes = await axiosInstance.get(path, { responseType: 'stream' });

  res.set('Content-Type', imageRes.headers['content-type']);
  return imageRes.data.pipe(res);
});