awards bp for filled requests

Author: tdjsnelling

api/src/controllers/request.js

@@ -1,6 +1,7 @@
 import Request from "../schema/request";
 import Comment from "../schema/comment";
 import Torrent from "../schema/torrent";
+import User from "../schema/user";
 
 export const createRequest = async (req, res, next) => {
   if (req.body.title && req.body.body) {
@@ -153,7 +154,7 @@ export const fetchRequest = async (req, res, next) => {
         $lookup: {
           from: "torrents",
           as: "candidates",
-          let: { torrentIds: "$candidates" },
+          let: { torrentIds: "$candidates.torrent" },
           pipeline: [
             { $match: { $expr: { $in: ["$_id", "$$torrentIds"] } } },
             {
@@ -254,7 +255,7 @@ export const addCandidate = async (req, res, next) => {
 
       if (
         request.candidates
-          .map((c) => c.toString())
+          .map((c) => c.torrent.toString())
           .includes(torrent._id.toString())
       ) {
         res.status(409).send("Torrent has already been suggested");
@@ -263,7 +264,11 @@ export const addCandidate = async (req, res, next) => {
 
       await Request.findOneAndUpdate(
         { _id: req.params.requestId },
-        { $addToSet: { candidates: torrent._id } }
+        {
+          $addToSet: {
+            candidates: { torrent: torrent._id, suggestedBy: req.userId },
+          },
+        }
       );
 
       res.status(200).send({ torrent });
@@ -293,11 +298,11 @@ export const acceptCandidate = async (req, res, next) => {
         infoHash: req.body.infoHash,
       }).lean();
 
-      if (
-        !request.candidates.some(
-          (candidate) => candidate.toString() === torrent._id.toString()
-        )
-      ) {
+      const candidate = request.candidates.find(
+        (c) => c.torrent.toString() === torrent._id.toString()
+      );
+
+      if (!candidate) {
         res
           .status(403)
           .send("Cannot accept a torrent that has not been suggested");
@@ -309,6 +314,20 @@ export const acceptCandidate = async (req, res, next) => {
         { $set: { fulfilledBy: torrent._id } }
       );
 
+      await User.findOneAndUpdate(
+        { _id: candidate.suggestedBy },
+        {
+          $inc: {
+            bonusPoints:
+              process.env.SQ_BP_EARNED_PER_FILLED_REQUEST *
+              (torrent.uploadedBy.toString() ===
+              candidate.suggestedBy.toString()
+                ? 2
+                : 1),
+          },
+        }
+      );
+
       res.status(200).send({ torrent: torrent._id });
     } catch (e) {
       next(e);

api/src/schema/request.js

@@ -6,8 +6,16 @@ const Request = new mongoose.Schema({
   body: String,
   createdBy: mongoose.Schema.ObjectId,
   created: Number,
-  candidates: Array,
-  fulfilledBy: mongoose.Schema.ObjectId,
+  candidates: [
+    {
+      torrent: mongoose.Schema.ObjectId,
+      suggestedBy: mongoose.Schema.ObjectId,
+    },
+  ],
+  fulfilledBy: {
+    torrent: mongoose.Schema.ObjectId,
+    suggestedBy: mongoose.Schema.ObjectId,
+  },
 });
 
 export default mongoose.model("request", Request);

api/src/utils/validateConfig.js

@@ -17,6 +17,7 @@ const configSchema = yup
         SQ_ALLOW_ANONYMOUS_UPLOADS: yup.boolean().required(),
         SQ_MINIMUM_RATIO: yup.number().min(0).required(),
         SQ_BP_EARNED_PER_GB: yup.number().min(0).required(),
+        SQ_BP_EARNED_PER_FILLED_REQUEST: yup.number().min(0).required(),
         SQ_BP_COST_PER_INVITE: yup.number().min(0).required(),
         SQ_BP_COST_PER_GB: yup.number().min(0).required(),
         SQ_SITE_WIDE_FREELEECH: yup.boolean().required(),

config.example.js

@@ -47,6 +47,10 @@ module.exports = {
     // Number of bonus points awarded to a user for each GB they upload. Minimum 0.
     SQ_BP_EARNED_PER_GB: 1,
 
+    // Number of bonus points awarded to a user if they suggest a torrent to fill a request and it gets accepted
+    // They get double if they also the uploader of the accepted torrent
+    SQ_BP_EARNED_PER_FILLED_REQUEST: 1,
+
     // Number of bonus it costs a user to buy 1 invite (set to 0 to disable buying invites).
     SQ_BP_COST_PER_INVITE: 3,