accepting of candidates on request

Author: tdjsnelling

api/src/controllers/request.js

@@ -1,5 +1,6 @@
 import Request from '../schema/request'
 import Comment from '../schema/comment'
+import Torrent from '../schema/torrent'
 
 export const createRequest = async (req, res) => {
   if (req.body.title && req.body.body) {
@@ -148,13 +149,38 @@ export const fetchRequest = async (req, res) => {
           ],
         },
       },
+      {
+        $lookup: {
+          from: 'torrents',
+          as: 'candidates',
+          let: { torrentIds: '$candidates' },
+          pipeline: [
+            { $match: { $expr: { $in: ['$_id', '$$torrentIds'] } } },
+            {
+              $project: {
+                infoHash: 1,
+                name: 1,
+                type: 1,
+                created: 1,
+              },
+            },
+            {
+              $unwind: {
+                path: '$candidates',
+                preserveNullAndEmptyArrays: true,
+              },
+            },
+          ],
+        },
+      },
     ])
     if (!request) {
       res.status(404).send('Request could not be found')
       return
     }
     res.send(request)
   } catch (e) {
+    console.error(e)
     res.status(500).send(e.message)
   }
 }
@@ -206,3 +232,84 @@ export const addComment = async (req, res) => {
     res.status(400).send('Request must include comment')
   }
 }
+
+export const addCandidate = async (req, res) => {
+  if (req.body.infoHash) {
+    try {
+      const request = await Request.findOne({
+        _id: req.params.requestId,
+      }).lean()
+
+      const torrent = await Torrent.findOne(
+        {
+          infoHash: req.body.infoHash,
+        },
+        { infoHash: 1, name: 1, type: 1, created: 1 }
+      ).lean()
+
+      if (!torrent) {
+        res.status(404).send('Torrent does not exist')
+        return
+      }
+
+      if (request.candidates.includes(torrent._id)) {
+        res.status(409).send('Torrent has already been suggested')
+        return
+      }
+
+      await Request.findOneAndUpdate(
+        { _id: req.params.requestId },
+        { $addToSet: { candidates: torrent._id } }
+      )
+
+      res.status(200).send({ torrent })
+    } catch (err) {
+      res.status(500).send(err.message)
+    }
+  } else {
+    res.status(400).send('Request must include infoHash')
+  }
+}
+
+export const acceptCandidate = async (req, res) => {
+  if (req.body.infoHash) {
+    try {
+      const request = await Request.findOne({
+        _id: req.params.requestId,
+      }).lean()
+
+      if (req.userId.toString() !== request.createdBy.toString()) {
+        res
+          .status(401)
+          .send('You do not have permission to accept that suggestion')
+        return
+      }
+
+      const torrent = await Torrent.findOne({
+        infoHash: req.body.infoHash,
+      }).lean()
+
+      if (
+        !request.candidates.some(
+          (candidate) => candidate.toString() === torrent._id.toString()
+        )
+      ) {
+        res
+          .status(403)
+          .send('Cannot accept a torrent that has not been suggested')
+        return
+      }
+
+      await Request.findOneAndUpdate(
+        { _id: req.params.requestId },
+        { $set: { fulfilledBy: torrent._id } }
+      )
+
+      res.status(200).send({ torrent: torrent._id })
+    } catch (e) {
+      res.status(500).send(e.message)
+    }
+  } else {
+    res.status(400).send('Request must include infoHash')
+  }
+}

api/src/index.js

@@ -61,6 +61,8 @@ import {
   fetchRequest,
   deleteRequest,
   addComment as addCommentRequest,
+  addCandidate,
+  acceptCandidate,
 } from './controllers/request'
 import validateConfig from './utils/validateConfig'
 import createAdminUser from './setup/createAdminUser'
@@ -202,6 +204,8 @@ app.get('/requests/page/:page', getRequests)
 app.get('/requests/:index', fetchRequest)
 app.delete('/requests/:index', deleteRequest)
 app.post('/requests/comment/:requestId', addCommentRequest)
+app.post('/requests/suggest/:requestId', addCandidate)
+app.post('/requests/accept/:requestId', acceptCandidate)
 
 const port = process.env.SQ_PORT || 3001
 app.listen(port, () => {

client/components/Button.js

@@ -4,7 +4,7 @@ import css from '@styled-system/css'
 import { darken, lighten, getLuminance } from 'polished'
 
 const StyledButton = styled.button(
-  ({ theme }) =>
+  ({ theme, small }) =>
     css({
       appearance: 'none',
       bg: 'primary',
@@ -15,7 +15,7 @@ const StyledButton = styled.button(
       fontFamily: 'body',
       fontSize: 2,
       px: 4,
-      py: 3,
+      py: !small ? 3 : 2,
       cursor: 'pointer',
       whiteSpace: 'nowrap',
       '&:hover': {

client/components/List.js

@@ -85,13 +85,17 @@ const List = ({ data = [], columns = [], ...rest }) => {
                   ]}
                   gridGap={[2, 4]}
                   alignItems="center"
-                  p={4}
+                  minHeight="50px"
+                  px={4}
                 >
                   {columns.map((col, j) => (
                     <Box
                       key={`list-row-${i}-col-${j}`}
+                      width="100%"
+                      display="flex"
+                      alignItems="center"
                       textAlign={col.rightAlign ? ['left', 'right'] : 'left'}
-                      _css={{ whiteSpace: 'nowrap' }}
+                      _css={{ whiteSpace: 'nowrap', '> *': { width: '100%' } }}
                     >
                       {col.cell({
                         value: col.accessor ? getIn(row, col.accessor) : null,