Hyperdrive works not only with PostgreSQL databases — including Neon, Google Cloud SQL, AWS RDS, and Timescale, but also PostgreSQL-compatible databases like Materialize (a powerful stream-processing database), CockroachDB (a major distributed database), Google Cloud’s AlloyDB, and AWS Aurora Postgres.

Hyperdrive works not only with PostgreSQL databases — including Neon, Google Cloud SQL, AWS RDS, and Timescale, but also PostgreSQL-compatible databases like Materialize (a powerful stream-processing database), CockroachDB (a major distributed database), Google Cloud’s AlloyDB, and AWS Aurora Postgres.

export const runtime = "edge";

import { NextRequest } from "next/server";
import { getRequestContext } from "@cloudflare/next-on-pages";
import { getPrismaClient }from "@/lib/db";
import checkAuth from "@/utils/checkAuth";

export async function GET(req: NextRequest): Promise<Response> {
  try {
    const prisma = getPrismaClient();
    const { profileId } = await checkAuth(prisma) || {};
    if (!profileId) {
      console.log("User not authenticated.");
      return new Response("User not authenticated.", { status: 401 });
    };

    const id = getRequestContext().env.WEBSOCKET.idFromName(profileId.toString());
    const roomObject = getRequestContext().env.WEBSOCKET.get(id);

    console.log("aaa");
    const response = await roomObject.fetch(`http://service-binding/websocket`, req);
    console.log("bbb");
    console.log(response.status);

    return response
  } catch (error) {
    console.log("Internal server error.");
    console.error(error);
    return new Response("Internal server error.", { status: 500 });
  };
};

export const runtime = "edge";

import { NextRequest } from "next/server";
import { getRequestContext } from "@cloudflare/next-on-pages";
import { getPrismaClient }from "@/lib/db";
import checkAuth from "@/utils/checkAuth";

export async function GET(req: NextRequest): Promise<Response> {
  try {
    const prisma = getPrismaClient();
    const { profileId } = await checkAuth(prisma) || {};
    if (!profileId) {
      console.log("User not authenticated.");
      return new Response("User not authenticated.", { status: 401 });
    };

    const id = getRequestContext().env.WEBSOCKET.idFromName(profileId.toString());
    const roomObject = getRequestContext().env.WEBSOCKET.get(id);

    console.log("aaa");
    const response = await roomObject.fetch(`http://service-binding/websocket`, req);
    console.log("bbb");
    console.log(response.status);

    return response
  } catch (error) {
    console.log("Internal server error.");
    console.error(error);
    return new Response("Internal server error.", { status: 500 });
  };
};

export const runtime = "edge";

import { NextRequest } from "next/server";
import { getRequestContext } from "@cloudflare/next-on-pages";
import { getPrismaClient }from "@/lib/db";
import checkAuth from "@/utils/checkAuth";

export async function GET(req: NextRequest): Promise<Response> {
  try {
    const prisma = getPrismaClient();
    const { profileId } = await checkAuth(prisma) || {};
    if (!profileId) {
      console.log("User not authenticated.");
      return new Response("User not authenticated.", { status: 401 });
    };

    const url = new URL(req.url);
    url.pathname = `/${profileId}/websocket`;
    const request = new Request(url, req.clone());
    
    const workerResponse = await getRequestContext().env.WEBSOCKET.fetch(request);
    
    console.log("Worker response status:", workerResponse.status);
    console.log("Worker response headers:", Object.fromEntries(workerResponse.headers));

    return workerResponse;
  } catch (error) {
    console.log("Internal server error.");
    console.error(error);
    return new Response("Internal server error.", { status: 500 });
  };
};

export const runtime = "edge";

import { NextRequest } from "next/server";
import { getRequestContext } from "@cloudflare/next-on-pages";
import { getPrismaClient }from "@/lib/db";
import checkAuth from "@/utils/checkAuth";

export async function GET(req: NextRequest): Promise<Response> {
  try {
    const prisma = getPrismaClient();
    const { profileId } = await checkAuth(prisma) || {};
    if (!profileId) {
      console.log("User not authenticated.");
      return new Response("User not authenticated.", { status: 401 });
    };

    const url = new URL(req.url);
    url.pathname = `/${profileId}/websocket`;
    const request = new Request(url, req.clone());
    
    const workerResponse = await getRequestContext().env.WEBSOCKET.fetch(request);
    
    console.log("Worker response status:", workerResponse.status);
    console.log("Worker response headers:", Object.fromEntries(workerResponse.headers));

    return workerResponse;
  } catch (error) {
    console.log("Internal server error.");
    console.error(error);
    return new Response("Internal server error.", { status: 500 });
  };
};