import establishedDatabase from "../../database/database.js";

/* eslint-disable consistent-return */
const mustHaveAccountLinkedToPlex = (req, res, next) => {
  const database = establishedDatabase;

  // TODO use mustByAuthenticated middleware
  if (!req.loggedInUser) {
    return res.status(401).send({
      success: false,
      message: "You must have your account linked to a plex account."
    });
  }

  database
    .get(
      `SELECT plex_userid FROM settings WHERE user_name IS ?`,
      req.loggedInUser.username
    )
    .then(row => {
      const plexUserId = row?.plex_userid || null;

      if (plexUserId === null) {
        return res.status(403).send({
          success: false,
          message:
            "No plex account user id found for your user. Please authenticate your plex account at /user/authenticate."
        });
      }

      req.loggedInUser.plexUserId = plexUserId;
      next();
    });
};
/* eslint-enable consistent-return */

export default mustHaveAccountLinkedToPlex;