Source: lib/db/writes.js

  1. /** @module lib/db/writes */
  3. import { ObjectId } from "bson";
  4. import {
  5.   getApiKeysCollection,
  6.   getApprovedCompletionsCollection,
  7.   getCompletionsPendingReviewCollection,
  8.   getRejectedCompletionsCollection,
  9. } from "../mongodb";
  11. /**
  12.  * Approves a completion.
  13.  *
  14.  * @param data The completion data to approve.
  15.  */
  16. async function approveCompletion(data) {
  17.   const [collection, approvedCollection] = await Promise.all([
  18.     getCompletionsPendingReviewCollection(),
  19.     getApprovedCompletionsCollection(),
  20.   ]);
  22.   const id = data._id;
  23.   delete data._id;
  25.   const approvedResult = await approvedCollection.insertOne(data);
  26.   await collection.deleteOne({ _id: new ObjectId(id) });
  28.   return approvedResult;
  29. }
  31. /**
  32.  * Rejects a completion.
  33.  *
  34.  * @param data The completion data to reject.
  35.  */
  36. async function rejectCompletion(data) {
  37.   const [collection, rejectedCollection] = await Promise.all([
  38.     getCompletionsPendingReviewCollection(),
  39.     getRejectedCompletionsCollection(),
  40.   ]);
  42.   const id = data._id;
  43.   delete data._id;
  45.   const rejectedResult = await rejectedCollection.insertOne(data);
  46.   await collection.deleteOne({ _id: new ObjectId(id) });
  48.   return rejectedResult;
  49. }
  51. async function approve2Reject(data) {
  52.   const [collection, rejectedCollection] = await Promise.all([
  53.     getApprovedCompletionsCollection(),
  54.     getRejectedCompletionsCollection(),
  55.   ]);
  57.   const id = data._id;
  58.   delete data._id;
  60.   const rejectedResult = await rejectedCollection.insertOne(data);
  61.   await collection.deleteOne({ _id: new ObjectId(id) });
  63.   return rejectedResult;
  64. }
  66. async function reject2Approve(data) {
  67.   const [collection, approvedCollection] = await Promise.all([
  68.     getRejectedCompletionsCollection(),
  69.     getApprovedCompletionsCollection(),
  70.   ]);
  72.   const id = data._id;
  73.   delete data._id;
  74.   const approvedResult = await approvedCollection.insertOne(data);
  75.   await collection.deleteOne({ _id: new ObjectId(id) });
  77.   return approvedResult;
  78. }
  80. /**
  81.  * Starts a review pipeline for a completion.
  82.  *
  83.  * @param data The completion data to review
  84.  * @param {"pending2approve" | "pending2reject" | "approve2reject" | "reject2Approve"} direction Direction of the review
  85.  */
  86. export async function reviewCompletion(data, direction) {
  87.   // TODO: Does approve2pending; reject2pending make sense?
  88.   switch (direction) {
  89.     case "pending2approve":
  90.       return approveCompletion(data);
  91.     case "pending2reject":
  92.       return rejectCompletion(data);
  93.     // TODO: Support these use cases on the front-end, eventually
  94.     case "approve2reject":
  95.       return approve2Reject(data);
  96.     case "reject2approve":
  97.       return reject2Approve(data);
  98.     default:
  99.       throw new Error("Invalid direction");
  100.   }
  101. }
  103. /**
  104.  * Saves a completion to the database for review.
  105.  *
  106.  * @param completionData Completion data to save
  107.  */
  108. export async function saveCompletion(completionData) {
  109.   const collection = await getCompletionsPendingReviewCollection();
  111.   const result = await collection.insertOne(completionData);
  113.   return result;
  114. }
  116. /**
  117.  * Inserts an API key created from the API Management page into the database.
  118.  *
  119.  * @param  data The API key data to save.
  120.  */
  121. export async function saveApiKeys(data) {
  122.   const collection = await getApiKeysCollection();
  124.   const result = await collection.insertOne({
  125.     ...data,
  126.     createdAt: new Date().toISOString(),
  127.   });
  129.   return result;
  130. }