octane-website/src/routes/rehearsals.js

const express = require('express');
const rehearsalsRepo = require('../repositories/rehearsalsRepo');
const calendarRepo = require('../repositories/calendarRepo');
const discord = require('../lib/discord');
const asyncHandler = require('../lib/asyncHandler');
const { computeRehearsalStatus } = require('../lib/rehearsalStatus');

const router = express.Router();

router.get(
  '/',
  asyncHandler(async (req, res) => {
    const [rehearsals, settings] = await Promise.all([rehearsalsRepo.findUpcoming(), calendarRepo.getSlotSettings()]);
    const threshold = settings.rehearsalConfirmThreshold;
    const hostUserId = settings.rehearsalHostUserId;
    res.json(
      rehearsals.map((r) => ({
        id: r.id,
        startsAt: r.starts_at,
        endsAt: r.ends_at,
        location: r.location,
        proposedBy: r.proposed_by,
        proposedByName: r.proposed_by_name,
        votes: r.votes,
        status: computeRehearsalStatus(r.votes, threshold, hostUserId),
        confirmThreshold: threshold,
        hostUserId,
        hostName: settings.rehearsalHostName,
      }))
    );
  })
);

router.post(
  '/',
  asyncHandler(async (req, res) => {
    const { startsAt, endsAt, location } = req.body || {};
    if (!startsAt || !endsAt) {
      return res.status(400).json({ error: 'starts_at_and_ends_at_required' });
    }
    const start = new Date(startsAt);
    const end = new Date(endsAt);
    if (Number.isNaN(start.getTime()) || Number.isNaN(end.getTime())) {
      return res.status(400).json({ error: 'invalid_date' });
    }
    if (end <= start) {
      return res.status(400).json({ error: 'ends_at_must_be_after_starts_at' });
    }
    if (start < new Date()) {
      return res.status(400).json({ error: 'starts_at_must_be_in_the_future' });
    }
    const rehearsal = await rehearsalsRepo.create({
      startsAt: start,
      endsAt: end,
      location: location ? location.trim() : null,
      proposedBy: req.user.id,
    });
    await rehearsalsRepo.upsertVote(rehearsal.id, req.user.id, 'accept');
    discord.notifyAll(
      discord.rehearsalProposedMessage({ userName: req.user.name, startsAt: rehearsal.starts_at, location: rehearsal.location })
    );
    res.status(201).json({
      id: rehearsal.id,
      startsAt: rehearsal.starts_at,
      endsAt: rehearsal.ends_at,
      location: rehearsal.location,
      proposedBy: rehearsal.proposed_by,
    });
  })
);

router.delete(
  '/:id',
  asyncHandler(async (req, res) => {
    const rehearsal = await rehearsalsRepo.findById(req.params.id);
    if (!rehearsal) return res.status(404).json({ error: 'not_found' });
    if (rehearsal.proposed_by !== req.user.id && !req.user.is_admin) {
      return res.status(403).json({ error: 'forbidden' });
    }
    await rehearsalsRepo.remove(req.params.id);
    discord.notifyAll(discord.rehearsalRemovedMessage({ userName: req.user.name, startsAt: rehearsal.starts_at }));
    res.status(204).end();
  })
);

router.post(
  '/:id/vote',
  asyncHandler(async (req, res) => {
    const { vote } = req.body || {};
    if (!['accept', 'reject'].includes(vote)) {
      return res.status(400).json({ error: 'invalid_vote' });
    }
    const rehearsal = await rehearsalsRepo.findById(req.params.id);
    if (!rehearsal) return res.status(404).json({ error: 'not_found' });
    const saved = await rehearsalsRepo.upsertVote(req.params.id, req.user.id, vote);
    discord.notifyAll(discord.rehearsalVoteMessage({ userName: req.user.name, vote, startsAt: rehearsal.starts_at }));
    res.json({
      id: saved.id,
      rehearsalId: saved.rehearsal_id,
      userId: saved.user_id,
      vote: saved.vote,
    });
  })
);

router.delete(
  '/:id/vote',
  asyncHandler(async (req, res) => {
    await rehearsalsRepo.removeVote(req.params.id, req.user.id);
    res.status(204).end();
  })
);

module.exports = router;