Update Mongo driver to v6.9.0

server/package.json

@@ -126,7 +126,7 @@
     "metascraper-description": "^5.22.5",
     "metascraper-image": "^5.22.5",
     "metascraper-title": "^5.22.5",
-    "mongodb": "^3.5.9",
+    "mongodb": "^6.9.0",
     "mongodb-core": "^3.2.7",
     "ms": "^2.1.2",
     "node-fetch": "^2.6.1",
@@ -201,7 +201,6 @@
     "@types/luxon": "^1.22.0",
     "@types/marked": "^0.7.3",
     "@types/mini-css-extract-plugin": "^1.4.3",
-    "@types/mongodb": "3.1.22",
     "@types/ms": "^0.7.31",
     "@types/node": "^12.12.34",
     "@types/node-fetch": "^2.5.5",
@@ -363,11 +362,6 @@
       "Newer versions has problems with using nunjucks.",
       "Update when the following issue is resolved:",
       "https://github.com/tj/consolidate.js/issues/244"
-    ],
-    "@types/[email protected]": [
-      "Newer versions has problems with optional fields when querying with null",
-      "Update when the following issue is resolved:",
-      "https://github.com/DefinitelyTyped/DefinitelyTyped/issues/47686"
     ]
   },
   "graphql-schema-linter": {

server/src/core/server/app/middleware/csp.ts

@@ -6,6 +6,7 @@ import { AppOptions } from "coral-server/app";
 import { getOrigin, prefixSchemeIfRequired } from "coral-server/app/url";
 import { Config } from "coral-server/config";
 import { MongoContext } from "coral-server/data/context";
+import { SiteNotFoundError } from "coral-server/errors";
 import {
   retrieveSite,
   retrieveSiteByOrigin,
@@ -50,6 +51,10 @@ async function retrieveSiteFromQuery(
       return null;
     }
 
+    if (!story.siteID) {
+      throw new SiteNotFoundError(null, storyID);
+    }
+
     // If the site can't be found based on it's allowed origins and the story
     // URL (which is a allowed list), then we know it isn't allowed.
     return retrieveSite(mongo, tenant.id, story.siteID);

server/src/core/server/app/middleware/tenant.ts

@@ -1,7 +1,7 @@
 import { v1 as uuid } from "uuid";
 
 import { MongoContext } from "coral-server/data/context";
-import { TenantNotFoundError } from "coral-server/errors";
+import { SiteNotFoundError, TenantNotFoundError } from "coral-server/errors";
 import logger from "coral-server/logger";
 import {
   retrieveSite,
@@ -110,6 +110,10 @@ async function retrieveSiteFromQuery(
       return null;
     }
 
+    if (!story.siteID) {
+      throw new SiteNotFoundError(null, storyID);
+    }
+
     // If the site can't be found based on it's allowed origins and the story
     // URL (which is a allowed list), then we know it isn't allowed.
     return retrieveSite(mongo, tenant.id, story.siteID);

server/src/core/server/data/cache/commentCache.spec.ts

@@ -24,8 +24,8 @@ const createRedis = (): AugmentedRedis => {
 
 const createMongo = async (): Promise<MongoContext> => {
   const uri = "mongodb://127.0.0.1:27017/coral";
-  const live = await createMongoDB(uri);
-  const archive = await createMongoDB(uri);
+  const live = (await createMongoDB(uri)).db;
+  const archive = (await createMongoDB(uri)).db;
 
   const context = new MongoContextImpl(live, archive);
 

server/src/core/server/data/cache/commentCache.ts

@@ -127,7 +127,11 @@ export class CommentCache implements IDataCache {
         : this.mongo.comments();
 
     const comments = await collection
-      .find({ tenantID, storyID, status: { $in: ["APPROVED", "NONE"] } })
+      .find({
+        tenantID,
+        storyID,
+        status: { $in: [GQLCOMMENT_STATUS.APPROVED, GQLCOMMENT_STATUS.NONE] },
+      })
       .toArray();
     if (!comments || comments.length === 0) {
       return [];
@@ -350,20 +354,20 @@ export class CommentCache implements IDataCache {
     tenantID: string,
     storyID: string,
     parentID?: string | null,
-    isArchived?: boolean
+    isArchived?: boolean | null
   ): Promise<Array<Readonly<Comment>>> {
     const filter = parentID
       ? {
           tenantID,
           storyID,
           parentID,
-          status: { $in: ["APPROVED", "NONE"] },
+          status: { $in: [GQLCOMMENT_STATUS.APPROVED, GQLCOMMENT_STATUS.NONE] },
         }
       : {
           tenantID,
           storyID,
           parentID: null,
-          status: { $in: ["APPROVED", "NONE"] },
+          status: { $in: [GQLCOMMENT_STATUS.APPROVED, GQLCOMMENT_STATUS.NONE] },
         };
 
     const collection = isArchived

server/src/core/server/data/context.ts

@@ -142,7 +142,7 @@ export async function createMongoContext(
 ): Promise<MongoContext> {
   // Setup MongoDB.
   const liveURI = config.get("mongodb");
-  const live = await createMongoDB(liveURI);
+  const live = (await createMongoDB(liveURI)).db;
 
   // If we have an archive URI, use it, otherwise, default
   // to using the live database
@@ -154,7 +154,7 @@ export async function createMongoContext(
   ) {
     archive = live;
   } else {
-    archive = await createMongoDB(archiveURI);
+    archive = (await createMongoDB(archiveURI)).db;
   }
 
   return new MongoContextImpl(live, archive);

server/src/core/server/errors/index.ts

@@ -564,6 +564,15 @@ export class StoryNotFoundError extends CoralError {
   }
 }
 
+export class SiteNotFoundError extends CoralError {
+  constructor(siteID?: string | null, storyID?: string | null) {
+    super({
+      code: ERROR_CODES.SITE_NOT_FOUND,
+      context: { pub: { siteID, storyID } },
+    });
+  }
+}
+
 export class CommentNotFoundError extends CoralError {
   constructor(commentID: string) {
     super({
@@ -1037,9 +1046,8 @@ export class UsernameAlreadyExists extends CoralError {
 }
 
 export class UnableToUpdateStoryURL extends CoralError {
-  constructor(cause: MongoError, id: string, oldUrl: string, url: string) {
+  constructor(id: string, oldUrl: string, url: string) {
     super({
-      cause,
       reportable: true,
       code: ERROR_CODES.UNABLE_TO_UPDATE_STORY_URL,
       context: { pvt: { id, oldUrl, url } },