v9.5.1

server/src/core/server/app/handlers/api/tenor/index.ts

@@ -69,15 +69,15 @@ export const tenorSearchHandler =
       return;
     }
 
-    const gifsEnabled = tenant.media?.gifs.enabled ?? false;
+    const gifsEnabled = tenant.media?.gifs?.enabled ?? false;
     if (!gifsEnabled) {
       res.status(200).send({
         results: [],
       });
       return;
     }
 
-    const apiKey = tenant.media?.gifs.key ?? null;
+    const apiKey = tenant.media?.gifs?.key ?? null;
     if (!apiKey || apiKey.length === 0) {
       res.status(200).send({
         results: [],
@@ -86,7 +86,7 @@ export const tenorSearchHandler =
     }
 
     const contentFilter = convertGiphyContentRatingToTenorLevel(
-      tenant.media?.gifs.maxRating
+      tenant.media?.gifs?.maxRating
     );
 
     const url = new URL(TENOR_SEARCH_URL);
@@ -133,7 +133,7 @@ export const tenorSearchHandler =
     } catch (e) {
       // Ensure that the API key doesn't get leaked to the logs by accident.
       if (e.message) {
-        e.message = e.message.replace(tenant.media?.gifs.key, "[Sensitive]");
+        e.message = e.message.replace(tenant.media?.gifs?.key, "[Sensitive]");
       }
       throw new WrappedInternalError(e as Error, "tenor search error");
     }

server/src/core/server/config.ts

@@ -186,6 +186,12 @@ const config = convict({
     env: "MONGODB_ARCHIVE_URI",
     sensitive: true,
   },
+  mongodb_max_pool_size: {
+    doc: "Max pool size for the MongoDB driver.",
+    format: Number,
+    default: 50,
+    env: "MONGODB_MAX_POOL_SIZE",
+  },
   redis: {
     doc: "The Redis database to connect to.",
     format: "redis-uri",

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

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

server/src/core/server/models/tenant/helpers.ts

@@ -119,13 +119,13 @@ export function supportsMediaType(
       return !!tenant.media?.youtube.enabled;
     case "giphy":
       return (
-        !!tenant.media?.gifs.enabled &&
+        !!tenant.media?.gifs?.enabled &&
         !!tenant.media.gifs.key &&
         tenant.media.gifs.provider === GQLGIF_MEDIA_SOURCE.GIPHY
       );
     case "tenor":
       return (
-        !!tenant.media?.gifs.enabled &&
+        !!tenant.media?.gifs?.enabled &&
         !!tenant.media.gifs.key &&
         tenant.media.gifs.provider === GQLGIF_MEDIA_SOURCE.TENOR
       );

server/src/core/server/services/comments/media.ts

@@ -77,7 +77,10 @@ async function attachTenorMedia(
       video: data.media_formats.mp4.url,
     };
   } catch (err) {
-    throw new WrappedInternalError(err as Error, "cannot attach Tenor Media");
+    if (!(err instanceof Error)) {
+      throw new Error("cannot attach Tenor Media");
+    }
+    throw new WrappedInternalError(err, "cannot attach Tenor Media");
   }
 }
 

server/src/core/server/services/giphy/giphy.ts

@@ -59,7 +59,7 @@ const GiphyRetrieveResponseSchema = Joi.object().keys({
 
 export function ratingIsAllowed(rating: string, tenant: Tenant) {
   const compareRating = rating.toLowerCase();
-  const maxRating = tenant.media?.gifs.maxRating || "g";
+  const maxRating = tenant.media?.gifs?.maxRating || "g";
 
   const compareIndex = RATINGS_ORDER.indexOf(compareRating);
   const maxIndex = RATINGS_ORDER.indexOf(maxRating);
@@ -98,7 +98,7 @@ export async function searchGiphy(
   offset: string,
   tenant: Tenant
 ): Promise<GiphyGifSearchResponse> {
-  if (!supportsMediaType(tenant, "giphy") || !tenant.media.gifs.key) {
+  if (!supportsMediaType(tenant, "giphy") || !tenant.media?.gifs?.key) {
     throw new InternalError("Giphy was not enabled");
   }
 
@@ -137,12 +137,12 @@ export async function retrieveFromGiphy(
   tenant: Tenant,
   id: string
 ): Promise<GiphyGifRetrieveResponse> {
-  if (!supportsMediaType(tenant, "giphy") || !tenant.media.gifs.key) {
+  if (!supportsMediaType(tenant, "giphy") || !tenant.media?.gifs?.key) {
     throw new InternalError("Giphy was not enabled");
   }
 
   const url = new URL(`${GIPHY_FETCH}/${id}`);
-  url.searchParams.set("api_key", tenant.media.gifs.key);
+  url.searchParams.set("api_key", tenant.media?.gifs?.key);
 
   try {
     const res = await fetch(url.toString());
@@ -158,7 +158,7 @@ export async function retrieveFromGiphy(
   } catch (err) {
     // Ensure that the API key doesn't get leaked to the logs by accident.
     if (err.message) {
-      err.message = err.message.replace(tenant.media.gifs.key, "[Sensitive]");
+      err.message = err.message.replace(tenant.media?.gifs?.key, "[Sensitive]");
     }
 
     // Rethrow the error.

server/src/core/server/services/mongodb/index.ts

@@ -3,14 +3,18 @@ import { Db, MongoClient } from "mongodb";
 import { WrappedInternalError } from "coral-server/errors";
 import logger from "coral-server/logger";
 
-async function createMongoClient(mongoURI: string): Promise<MongoClient> {
+async function createMongoClient(
+  mongoURI: string,
+  maxPoolSize = 50
+): Promise<MongoClient> {
   try {
     return await MongoClient.connect(mongoURI, {
       // believe we don't need this since the new driver only uses
       // the new URL parser. But am leaving this here in case we have
       // issues with URL's and want to investigate into it.
       // useNewUrlParser: true,
       ignoreUndefined: true,
+      maxPoolSize,
     });
   } catch (err) {
     throw new WrappedInternalError(
@@ -45,10 +49,11 @@ interface CreateMongoDbResult {
  * @param config application configuration.
  */
 export async function createMongoDB(
-  mongoURI: string
+  mongoURI: string,
+  maxPoolSize?: number
 ): Promise<CreateMongoDbResult> {
   // Connect and create a client for MongoDB.
-  const client = await createMongoClient(mongoURI);
+  const client = await createMongoClient(mongoURI, maxPoolSize);
 
   logger.info("mongodb has connected");
 

server/src/core/server/services/tenor/tenor.ts

@@ -28,7 +28,7 @@ export async function retrieveFromTenor(
   tenant: Tenant,
   id: string
 ): Promise<FetchPayload> {
-  if (!supportsMediaType(tenant, "tenor") || !tenant.media.gifs.key) {
+  if (!supportsMediaType(tenant, "tenor") || !tenant.media?.gifs?.key) {
     throw new InternalError("Tenor was not enabled");
   }