Getting "Max client connections reached" with only 25/60 connections

import { PrismaClient } from '@prisma/client/app';

declare global {
  // eslint-disable-next-line vars-on-top, no-var
  var localPrisma: PrismaClient;
}

// Export the prisma client
const getPrismaClient = (): PrismaClient => {
  if (process.env.NODE_ENV === 'production') {
    return new PrismaClient({ datasourceUrl: process.env.POSTGRES_PRISMA_URL });
  }

  if (!global.localPrisma) {
    global.localPrisma = new PrismaClient({ datasourceUrl: process.env.POSTGRES_PRISMA_URL });
  }
  return global.localPrisma;
};

const prisma = getPrismaClient();
export default prisma;

import { PrismaClient } from '@prisma/client/app';

declare global {
  // eslint-disable-next-line vars-on-top, no-var
  var localPrisma: PrismaClient;
}

// Export the prisma client
const getPrismaClient = (): PrismaClient => {
  if (process.env.NODE_ENV === 'production') {
    return new PrismaClient({ datasourceUrl: process.env.POSTGRES_PRISMA_URL });
  }

  if (!global.localPrisma) {
    global.localPrisma = new PrismaClient({ datasourceUrl: process.env.POSTGRES_PRISMA_URL });
  }
  return global.localPrisma;
};

const prisma = getPrismaClient();
export default prisma;

import prisma, { ImageFileType } from '@artelo/database';
import { ImageUploadUtils } from '@artelo/process-image';
import { ImageFileConfig } from '@artelo/types';
import { UploadUtils } from '@artelo/utils';
import { GetObjectCommand, PutObjectCommand, S3Client } from '@aws-sdk/client-s3';
import { Handler, SNSEvent } from 'aws-lambda';
import { ReadableStream } from 'stream/web';

const processNewFile: Handler = async (event: SNSEvent) => {
  const { fileKey, ...fileDetails } = JSON.parse(event.Records[0].Sns.Message) as ImageFileConfig;
  const bucketName = process.env.S3_UPLOAD_BUCKET;

  const s3Client = new S3Client();
  const response = await s3Client.send(new GetObjectCommand({ Bucket: bucketName, Key: fileKey }));

  const mimeType = response.ContentType;
  const stream = response.Body.transformToWebStream();
  const image = await ImageUploadUtils.getJpegImage(stream as ReadableStream, mimeType);
  const { height, width } = await ImageUploadUtils.getImageDimensions(image);
  const previews = await ImageUploadUtils.makePreviews(image);

  // Set the previews in S3
  await Promise.all(
    previews.map((preview) =>
      s3Client.send(
        new PutObjectCommand({
          Body: preview.previewBuffer,
          Bucket: bucketName,
          ContentType: 'image/jpeg',
          Key: UploadUtils.getPreviewKey(fileDetails.id, fileDetails.userId, preview.size)
        })
      )
    )
  );

  await prisma.imageFile.create({
    data: {
      ...fileDetails,
      fileType: fileDetails.fileType as ImageFileType,
      height,
      width
    }
  });
};

export default processNewFile;

import prisma, { ImageFileType } from '@artelo/database';
import { ImageUploadUtils } from '@artelo/process-image';
import { ImageFileConfig } from '@artelo/types';
import { UploadUtils } from '@artelo/utils';
import { GetObjectCommand, PutObjectCommand, S3Client } from '@aws-sdk/client-s3';
import { Handler, SNSEvent } from 'aws-lambda';
import { ReadableStream } from 'stream/web';

const processNewFile: Handler = async (event: SNSEvent) => {
  const { fileKey, ...fileDetails } = JSON.parse(event.Records[0].Sns.Message) as ImageFileConfig;
  const bucketName = process.env.S3_UPLOAD_BUCKET;

  const s3Client = new S3Client();
  const response = await s3Client.send(new GetObjectCommand({ Bucket: bucketName, Key: fileKey }));

  const mimeType = response.ContentType;
  const stream = response.Body.transformToWebStream();
  const image = await ImageUploadUtils.getJpegImage(stream as ReadableStream, mimeType);
  const { height, width } = await ImageUploadUtils.getImageDimensions(image);
  const previews = await ImageUploadUtils.makePreviews(image);

  // Set the previews in S3
  await Promise.all(
    previews.map((preview) =>
      s3Client.send(
        new PutObjectCommand({
          Body: preview.previewBuffer,
          Bucket: bucketName,
          ContentType: 'image/jpeg',
          Key: UploadUtils.getPreviewKey(fileDetails.id, fileDetails.userId, preview.size)
        })
      )
    )
  );

  await prisma.imageFile.create({
    data: {
      ...fileDetails,
      fileType: fileDetails.fileType as ImageFileType,
      height,
      width
    }
  });
};

export default processNewFile;

postgres://postgres.<ref>:<password>@aws-0-us-east-1.pooler.supabase.com:6543/postgres

postgres://postgres.<ref>:<password>@aws-0-us-east-1.pooler.supabase.com:6543/postgres

import { PrismaClient } from '@prisma/client'

const prismaClientSingleton = () => {
  return new PrismaClient({
      datasourceUrl:
        'postgres://postgres.P:PASSWORD@aws-0-us-east-1.pooler.supabase.com:6543/postgres?pgbouncer=true&connection_limit=1'
    })
}

declare global {
  var prisma: undefined | ReturnType<typeof prismaClientSingleton>
}

const prisma = globalThis.prisma ?? prismaClientSingleton()

export default prisma

if (process.env.NODE_ENV !== 'production') globalThis.prisma = prisma

import { PrismaClient } from '@prisma/client'

const prismaClientSingleton = () => {
  return new PrismaClient({
      datasourceUrl:
        'postgres://postgres.P:PASSWORD@aws-0-us-east-1.pooler.supabase.com:6543/postgres?pgbouncer=true&connection_limit=1'
    })
}

declare global {
  var prisma: undefined | ReturnType<typeof prismaClientSingleton>
}

const prisma = globalThis.prisma ?? prismaClientSingleton()

export default prisma

if (process.env.NODE_ENV !== 'production') globalThis.prisma = prisma

import { NextApiRequest, NextApiResponse } from "next";

import { createClient } from "@supabase/supabase-js";

const supabase = createClient(
  "https://PROJECT.supabase.co",
  SERVICE_ROLE_KEY
);

export default async (req: NextApiRequest, res: NextApiResponse) => {
  let { data: AppData, error } = await supabase.from("AppData").select("*");
  return res.status(200).send(AppData);
};

import { NextApiRequest, NextApiResponse } from "next";

import { createClient } from "@supabase/supabase-js";

const supabase = createClient(
  "https://PROJECT.supabase.co",
  SERVICE_ROLE_KEY
);

export default async (req: NextApiRequest, res: NextApiResponse) => {
  let { data: AppData, error } = await supabase.from("AppData").select("*");
  return res.status(200).send(AppData);
};

ConnectorError(ConnectorError { user_facing_error: None, kind: QueryError(PostgresError { code: "42P05", message: "prepared statement \"s3\" already exists", severity: "ERROR", detail: None, column: None, hint: None }), transient: false })

ConnectorError(ConnectorError { user_facing_error: None, kind: QueryError(PostgresError { code: "42P05", message: "prepared statement \"s3\" already exists", severity: "ERROR", detail: None, column: None, hint: None }), transient: false })