Merge branch 'develop' into feature/62/upload-users-with-excel

src/pages/api/payments/assigned.ts

@@ -0,0 +1,81 @@
+// Next.js API route support: https://nextjs.org/docs/api-routes/introduction
+import type { NextApiRequest, NextApiResponse } from "next";
+import { app } from "@/firebase";
+import {
+  getFirestore,
+  collection,
+  getDocs,
+  query,
+  where,
+} from "firebase/firestore";
+import { withIronSessionApiRoute } from "iron-session/next";
+import { sessionOptions } from "@/lib/session";
+import { Payment } from "@/interfaces/paypal";
+import { PaymentsStatus } from "@/interfaces/user.payments";
+
+const db = getFirestore(app);
+
+export default withIronSessionApiRoute(handler, sessionOptions);
+
+async function handler(req: NextApiRequest, res: NextApiResponse) {
+  if (req.method === "GET") return await get(req, res);
+
+  res.status(404).json(undefined);
+}
+
+// user can fetch payments assigned to him as an agent
+async function get(req: NextApiRequest, res: NextApiResponse) {
+  if (!req.session.user) {
+    res.status(401).json({ ok: false });
+    return;
+  }
+
+  const codeQuery = query(
+    collection(db, "payments"),
+    // where("agent", "==", "xRMirufz6PPQqxKBgvPTWiWKBD63"),
+    where(req.session.user.type, "==", req.session.user.id)
+    // Based on the logic of query we should be able to do this:
+    // where("isPaid", "==", paid === "paid"),
+    // but for some reason it is ignoring all but the first clause
+    // I opted into only fetching relevant content for the user
+    // and then filter it with JS
+  );
+
+  const snapshot = await getDocs(codeQuery);
+  if (snapshot.empty) {
+    res.status(200).json({
+      pending: [],
+      done: [],
+    });
+    return;
+  }
+
+  const docs = snapshot.docs.map((doc) => ({
+    id: doc.id,
+    ...doc.data(),
+  })) as Payment[];
+
+  const paidStatusEntries = docs.reduce(
+    (acc: PaymentsStatus, doc) => {
+      if (doc.isPaid) {
+        return {
+          ...acc,
+          done: [...acc.done, doc.corporate],
+        };
+      }
+
+      return {
+        ...acc,
+        pending: [...acc.pending, doc.corporate],
+      };
+    },
+    {
+      pending: [],
+      done: [],
+    }
+  );
+  res.status(200).json({
+    pending: [...new Set(paidStatusEntries.pending)],
+    done: [...new Set(paidStatusEntries.done)],
+  });
+}