feat: add GHCR build workflow and custom schema support

.github/workflows/deploy-docker.yml

@@ -0,0 +1,52 @@
+name: Build and Push Crove Cal Docker Image
+
+on:
+  push:
+    branches:
+      - dev
+      - main
+  workflow_dispatch:
+
+permissions:
+  contents: read
+  packages: write
+
+jobs:
+  build-and-push:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout repository
+        uses: actions/checkout@v4
+
+      - name: Set up Docker Buildx
+        uses: docker/setup-buildx-action@v3
+
+      - name: Log in to GitHub Container Registry
+        uses: docker/login-action@v3
+        with:
+          registry: ghcr.io
+          username: ${{ github.actor }}
+          password: ${{ secrets.GITHUB_TOKEN }}
+
+      - name: Downcase repository owner for image name
+        id: image-name
+        run: |
+          IMAGE_NAME="ghcr.io/${{ github.repository }}"
+          echo "image_name=${IMAGE_NAME,,}" >> $GITHUB_OUTPUT
+
+      - name: Build and push Docker image
+        uses: docker/build-push-action@v6
+        with:
+          context: .
+          file: ./Dockerfile
+          push: true
+          tags: |
+            ${{ steps.image-name.outputs.image_name }}:latest
+            ${{ steps.image-name.outputs.image_name }}:${{ github.sha }}
+          cache-from: type=gha
+          cache-to: type=gha,mode=max
+          build-args: |
+            NEXT_PUBLIC_WEBAPP_URL=http://localhost:3000
+            NEXT_PUBLIC_API_V2_URL=http://localhost:5555/api/v2
+            NEXT_PUBLIC_LICENSE_CONSENT=agree
+            CALCOM_TELEMETRY_DISABLED=1

apps/api/v2/src/modules/prisma/prisma-read.service.ts

@@ -6,6 +6,17 @@ import { Pool } from "pg";
 
 const DB_MAX_POOL_CONNECTION = 10;
 
+function getSchemaFromUrl(url: string | undefined): string | undefined {
+  if (!url) return undefined;
+  try {
+    const parsed = new URL(url.replace(/^postgresql:\/\//, "http://").replace(/^postgres:\/\//, "http://"));
+    return parsed.searchParams.get("schema") || undefined;
+  } catch {
+    const match = url.match(/[?&]schema=([^&]+)/);
+    return match ? match[1] : undefined;
+  }
+}
+
 @Injectable()
 export class PrismaReadService implements OnModuleInit, OnModuleDestroy {
   private logger = new Logger("PrismaReadService");
@@ -39,6 +50,9 @@ export class PrismaReadService implements OnModuleInit, OnModuleDestroy {
     const isE2E = options.e2e ?? false;
     const usePool = options.usePool ?? true;
 
+    const schema = getSchemaFromUrl(dbUrl);
+    const adapterOptions = schema ? { schema } : undefined;
+
     if (usePool) {
       let maxReadConnections = options.maxReadConnections ?? DB_MAX_POOL_CONNECTION;
       if (isE2E) {
@@ -51,10 +65,10 @@ export class PrismaReadService implements OnModuleInit, OnModuleDestroy {
         idleTimeoutMillis: 300000,
       });
 
-      const adapter = new PrismaPg(this.pool);
+      const adapter = new PrismaPg(this.pool, adapterOptions);
       this.prisma = new PrismaClient({ adapter });
     } else {
-      const adapter = new PrismaPg({ connectionString: dbUrl });
+      const adapter = new PrismaPg({ connectionString: dbUrl }, adapterOptions);
       this.prisma = new PrismaClient({
         adapter,
       });

apps/api/v2/src/modules/prisma/prisma-write.service.ts

@@ -14,6 +14,17 @@ export interface PrismaServiceOptions {
   type: "main" | "worker";
 }
 
+function getSchemaFromUrl(url: string | undefined): string | undefined {
+  if (!url) return undefined;
+  try {
+    const parsed = new URL(url.replace(/^postgresql:\/\//, "http://").replace(/^postgres:\/\//, "http://"));
+    return parsed.searchParams.get("schema") || undefined;
+  } catch {
+    const match = url.match(/[?&]schema=([^&]+)/);
+    return match ? match[1] : undefined;
+  }
+}
+
 @Injectable()
 export class PrismaWriteService implements OnModuleInit, OnModuleDestroy {
   private logger = new Logger("PrismaWriteService");
@@ -45,6 +56,9 @@ export class PrismaWriteService implements OnModuleInit, OnModuleDestroy {
     const isE2E = options.e2e ?? false;
     const usePool = options.usePool ?? true;
 
+    const schema = getSchemaFromUrl(dbUrl);
+    const adapterOptions = schema ? { schema } : undefined;
+
     if (usePool) {
       let maxWriteConnections = options.maxWriteConnections ?? DB_MAX_POOL_CONNECTION;
       if (isE2E) {
@@ -57,10 +71,10 @@ export class PrismaWriteService implements OnModuleInit, OnModuleDestroy {
         idleTimeoutMillis: 300000,
       });
 
-      const adapter = new PrismaPg(this.pool);
+      const adapter = new PrismaPg(this.pool, adapterOptions);
       this.prisma = new PrismaClient({ adapter });
     } else {
-      const adapter = new PrismaPg({ connectionString: dbUrl });
+      const adapter = new PrismaPg({ connectionString: dbUrl }, adapterOptions);
       this.prisma = new PrismaClient({
         adapter,
       });

packages/prisma/index.ts

@@ -7,7 +7,21 @@ import { excludeLockedUsersExtension } from "./extensions/exclude-locked-users";
 import { excludePendingPaymentsExtension } from "./extensions/exclude-pending-payment-teams";
 import { PrismaClient, type Prisma } from "./generated/prisma/client";
 
+function getSchemaFromUrl(url: string | undefined): string | undefined {
+  if (!url) return undefined;
+  try {
+    const parsed = new URL(url.replace(/^postgresql:\/\//, "http://").replace(/^postgres:\/\//, "http://"));
+    return parsed.searchParams.get("schema") || undefined;
+  } catch {
+    const match = url.match(/[?&]schema=([^&]+)/);
+    return match ? match[1] : undefined;
+  }
+}
+
 const connectionString = process.env.DATABASE_URL || "";
+const schema = getSchemaFromUrl(connectionString);
+const adapterOptions = schema ? { schema } : undefined;
+
 const pool =
   process.env.USE_POOL === "true" || process.env.USE_POOL === "1"
     ? new Pool({
@@ -17,7 +31,7 @@ const pool =
       })
     : undefined;
 
-const adapter = pool ? new PrismaPg(pool) : new PrismaPg({ connectionString });
+const adapter = pool ? new PrismaPg(pool, adapterOptions) : new PrismaPg({ connectionString }, adapterOptions);
 const prismaOptions: Prisma.PrismaClientOptions = {
   adapter,
 };
@@ -52,7 +66,11 @@ export const customPrisma = (options?: Prisma.PrismaClientOptions) => {
 
   if (options?.datasources?.db?.url) {
     const customConnectionString = options.datasources.db.url;
-    const customAdapter = new PrismaPg({ connectionString: customConnectionString });
+    const customSchema = getSchemaFromUrl(customConnectionString);
+    const customAdapter = new PrismaPg(
+      { connectionString: customConnectionString },
+      customSchema ? { schema: customSchema } : undefined
+    );
 
     const { datasources: _datasources, ...restOptions } = options;
     finalOptions = {

packages/prisma/migrations/20230418002117_booking_time_status/migration.sql

@@ -2,7 +2,7 @@
 
 -- DROP VIEW public."BookingsTimeStatus";
 
-CREATE OR REPLACE VIEW public."BookingTimeStatus"
+CREATE OR REPLACE VIEW "BookingTimeStatus"
  AS
  SELECT "Booking".id,
     "Booking".uid,

packages/prisma/migrations/20230719214513_update_booking_time_status_fields_event_parent_id/migration.sql

@@ -2,7 +2,7 @@
 
 -- DROP VIEW public."BookingsTimeStatus";
 
-CREATE OR REPLACE VIEW public."BookingTimeStatus"
+CREATE OR REPLACE VIEW "BookingTimeStatus"
  AS
  SELECT "Booking".id,
     "Booking".uid,

packages/prisma/migrations/20230921002822_fix_booking_time_status/migration.sql

@@ -2,7 +2,7 @@
 
 -- DROP VIEW public."BookingsTimeStatus";
 
-CREATE OR REPLACE VIEW public."BookingTimeStatus"
+CREATE OR REPLACE VIEW "BookingTimeStatus"
  AS
  SELECT "Booking".id,
     "Booking".uid,

packages/prisma/migrations/20231001101010_add_user_email_to_booking_time_status/migration.sql

@@ -2,7 +2,7 @@
 
 -- DROP VIEW public."BookingTimeStatus";
 
-CREATE OR REPLACE VIEW public."BookingTimeStatus"
+CREATE OR REPLACE VIEW "BookingTimeStatus"
  AS
  SELECT "Booking".id,
     "Booking".uid,

packages/prisma/migrations/20240419114622_add_ratings_to_insights/migration.sql

@@ -1,4 +1,4 @@
-CREATE OR REPLACE VIEW public."BookingTimeStatus"
+CREATE OR REPLACE VIEW "BookingTimeStatus"
 AS
 SELECT 
     "Booking".id,

packages/prisma/migrations/20240909162522_union_insights_data/migration.sql

@@ -1,4 +1,4 @@
-CREATE OR REPLACE VIEW public."BookingTimeStatus"
+CREATE OR REPLACE VIEW "BookingTimeStatus"
 AS
 SELECT
     "Booking".id,

packages/prisma/migrations/20250505135207_create_booking_time_status_denormalized/migration.sql

@@ -1,11 +1,11 @@
-CREATE OR REPLACE VIEW public."BookingTimeStatusDenormalized" AS
+CREATE OR REPLACE VIEW "BookingTimeStatusDenormalized" AS
 SELECT 
     *,
     CASE
         WHEN "rescheduled" IS TRUE THEN 'rescheduled'
-        WHEN "status" = 'cancelled'::public."BookingStatus" AND "rescheduled" IS NULL THEN 'cancelled'
+        WHEN "status" = 'cancelled'::"BookingStatus" AND "rescheduled" IS NULL THEN 'cancelled'
         WHEN "endTime" < now() THEN 'completed'
         WHEN "endTime" > now() THEN 'uncompleted'
         ELSE NULL
     END as "timeStatus"
-FROM public."BookingDenormalized";
+FROM "BookingDenormalized";

packages/prisma/migrations/20250925122623_add_default_now_eventtype_table_created_at/migration.sql

@@ -1,2 +1,2 @@
 -- AlterTable
-ALTER TABLE "public"."EventType" ALTER COLUMN "createdAt" SET DEFAULT CURRENT_TIMESTAMP;
+ALTER TABLE "EventType" ALTER COLUMN "createdAt" SET DEFAULT CURRENT_TIMESTAMP;

packages/prisma/migrations/20251023133244_add_user_uuid_column/migration.sql

@@ -5,10 +5,10 @@
 
 */
 -- AlterTable
-ALTER TABLE "public"."users" ADD COLUMN     "uuid" UUID;
+ALTER TABLE "users" ADD COLUMN     "uuid" UUID;
 
 -- CreateIndex
-CREATE UNIQUE INDEX "users_uuid_key" ON "public"."users"("uuid");
+CREATE UNIQUE INDEX "users_uuid_key" ON "users"("uuid");
 
 -- Backfill UUIDs in batches to avoid table locking on large datasets
 -- Uses FOR UPDATE SKIP LOCKED to prevent blocking other transactions
@@ -22,15 +22,15 @@ BEGIN
   LOOP
     WITH batch AS (
       SELECT id
-      FROM "public"."users"
+      FROM "users"
       WHERE uuid IS NULL
       LIMIT batch_size
       FOR UPDATE SKIP LOCKED
     )
-    UPDATE "public"."users"
+    UPDATE "users"
     SET uuid = gen_random_uuid()
     FROM batch
-    WHERE "public"."users".id = batch.id;
+    WHERE "users".id = batch.id;
 
     GET DIAGNOSTICS rows_updated = ROW_COUNT;
     total_updated := total_updated + rows_updated;

packages/prisma/migrations/20251024025759_add_webhook_version/migration.sql

@@ -1,2 +1,2 @@
 -- AlterTable
-ALTER TABLE "public"."Webhook" ADD COLUMN     "version" TEXT NOT NULL DEFAULT '2021-10-20';
+ALTER TABLE "Webhook" ADD COLUMN     "version" TEXT NOT NULL DEFAULT '2021-10-20';

packages/prisma/migrations/20251027102656_add_video_call_guest/migration.sql

@@ -1,8 +1,8 @@
 -- AlterTable
-ALTER TABLE "public"."CalVideoSettings" ADD COLUMN     "requireEmailForGuests" BOOLEAN NOT NULL DEFAULT false;
+ALTER TABLE "CalVideoSettings" ADD COLUMN     "requireEmailForGuests" BOOLEAN NOT NULL DEFAULT false;
 
 -- CreateTable
-CREATE TABLE "public"."VideoCallGuest" (
+CREATE TABLE "VideoCallGuest" (
     "id" TEXT NOT NULL,
     "bookingUid" TEXT NOT NULL,
     "email" TEXT NOT NULL,
@@ -15,10 +15,10 @@ CREATE TABLE "public"."VideoCallGuest" (
 );
 
 -- CreateIndex
-CREATE INDEX "VideoCallGuest_bookingUid_idx" ON "public"."VideoCallGuest"("bookingUid");
+CREATE INDEX "VideoCallGuest_bookingUid_idx" ON "VideoCallGuest"("bookingUid");
 
 -- CreateIndex
-CREATE INDEX "VideoCallGuest_email_idx" ON "public"."VideoCallGuest"("email");
+CREATE INDEX "VideoCallGuest_email_idx" ON "VideoCallGuest"("email");
 
 -- CreateIndex
-CREATE UNIQUE INDEX "VideoCallGuest_bookingUid_email_key" ON "public"."VideoCallGuest"("bookingUid", "email");
+CREATE UNIQUE INDEX "VideoCallGuest_bookingUid_email_key" ON "VideoCallGuest"("bookingUid", "email");

packages/prisma/migrations/20251030081154_add_report_status/migration.sql

@@ -1,5 +1,5 @@
 -- CreateEnum
-CREATE TYPE "public"."BookingReportStatus" AS ENUM ('PENDING', 'DISMISSED', 'BLOCKED');
+CREATE TYPE "BookingReportStatus" AS ENUM ('PENDING', 'DISMISSED', 'BLOCKED');
 
 -- AlterTable
-ALTER TABLE "public"."BookingReport" ADD COLUMN     "status" "public"."BookingReportStatus" NOT NULL DEFAULT 'PENDING';
+ALTER TABLE "BookingReport" ADD COLUMN     "status" "BookingReportStatus" NOT NULL DEFAULT 'PENDING';

packages/prisma/migrations/20251103175338_make_user_uuid_required/migration.sql

@@ -5,4 +5,4 @@
 
 */
 -- AlterTable
-ALTER TABLE "public"."users" ALTER COLUMN "uuid" SET NOT NULL;
+ALTER TABLE "users" ALTER COLUMN "uuid" SET NOT NULL;

packages/prisma/migrations/20251110081648_add_delegation_credential_error_webhook_trigger/migration.sql

@@ -1,2 +1,2 @@
 -- AlterEnum
-ALTER TYPE "public"."WebhookTriggerEvents" ADD VALUE 'DELEGATION_CREDENTIAL_ERROR';
+ALTER TYPE "WebhookTriggerEvents" ADD VALUE 'DELEGATION_CREDENTIAL_ERROR';

packages/prisma/migrations/20251110160435_add_outbound_event_type_id_to_agent/migration.sql

@@ -1,5 +1,5 @@
 -- AlterTable
-ALTER TABLE "public"."Agent" ADD COLUMN     "outboundEventTypeId" INTEGER;
+ALTER TABLE "Agent" ADD COLUMN     "outboundEventTypeId" INTEGER;
 
 -- CreateIndex
-CREATE INDEX "Agent_outboundEventTypeId_idx" ON "public"."Agent"("outboundEventTypeId");
+CREATE INDEX "Agent_outboundEventTypeId_idx" ON "Agent"("outboundEventTypeId");

packages/prisma/migrations/20251112171210_add_org_auto_join_on_signup_to_organization_settings/migration.sql

@@ -1,2 +1,2 @@
 -- AlterTable
-ALTER TABLE "public"."OrganizationSettings" ADD COLUMN     "orgAutoJoinOnSignup" BOOLEAN NOT NULL DEFAULT true;
+ALTER TABLE "OrganizationSettings" ADD COLUMN     "orgAutoJoinOnSignup" BOOLEAN NOT NULL DEFAULT true;