Skip to content

Commit 70a09fb

Browse files
arjunkomatharjunkomath
committed
Fix Supabase server clients
1 parent 7fbb3b5 commit 70a09fb

35 files changed

+240
-178
lines changed

‎apps/web/pages/api/ai/get-streaming-url.ts‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import { IErrorResponse } from "@changes-page/supabase/types/api";
22
import type { NextApiRequest, NextApiResponse } from "next";
33
import { createSignedStreamingUrl } from "../../../utils/manageprompt";
4-
import { getSupabaseServerClient } from "../../../utils/supabase/supabase-admin";
4+
import { getSupabaseServerClientForAPI } from "../../../utils/supabase/supabase-admin";
55

66
const expandConcept = async (
77
req: NextApiRequest,
@@ -10,7 +10,7 @@ const expandConcept = async (
1010
if (req.method === "POST") {
1111
const { workflowId } = req.body;
1212
try {
13-
await getSupabaseServerClient({ req, res });
13+
await getSupabaseServerClientForAPI({ req, res });
1414

1515
const url = await createSignedStreamingUrl(workflowId);
1616

‎apps/web/pages/api/ai/suggest-title.ts‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import { IErrorResponse } from "@changes-page/supabase/types/api";
22
import type { NextApiRequest, NextApiResponse } from "next";
33
import { runWorkflow } from "../../../utils/manageprompt";
4-
import { getSupabaseServerClient } from "../../../utils/supabase/supabase-admin";
4+
import { getSupabaseServerClientForAPI } from "../../../utils/supabase/supabase-admin";
55

66
const suggestTitle = async (
77
req: NextApiRequest,
@@ -11,7 +11,7 @@ const suggestTitle = async (
1111
const { content } = req.body;
1212

1313
try {
14-
await getSupabaseServerClient({ req, res });
14+
await getSupabaseServerClientForAPI({ req, res });
1515

1616
const result = await runWorkflow("wf_e1eb79b1dc017ca189506d799453caae", {
1717
content,

‎apps/web/pages/api/auth/callback.ts‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,13 @@
11
import { NextApiHandler } from "next";
22
import { ROUTES } from "../../../data/routes.data";
3-
import { createServerClientSSR } from "../../../utils/supabase/server";
3+
import { createServerClientForAPI } from "../../../utils/supabase/server";
44

55
const callback: NextApiHandler = async (req, res) => {
66
const code = req.query.code;
77
const redirectedFrom = req.query.redirectedFrom;
88

99
if (typeof code === "string") {
10-
const supabase = createServerClientSSR({ req, res });
10+
const supabase = createServerClientForAPI({ req, res });
1111

1212
try {
1313
const { data, error } = await supabase.auth.exchangeCodeForSession(code);

‎apps/web/pages/api/billing/create-billing-portal.ts‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import { IErrorResponse } from "@changes-page/supabase/types/api";
22
import type { NextApiRequest, NextApiResponse } from "next";
33
import { apiRateLimiter } from "../../../utils/rate-limit";
4-
import { getSupabaseServerClient } from "../../../utils/supabase/supabase-admin";
4+
import { getSupabaseServerClientForAPI } from "../../../utils/supabase/supabase-admin";
55
import { createOrRetrieveCustomer } from "../../../utils/useDatabase";
66
import { getAppBaseURL } from "./../../../utils/helpers";
77
const stripe = require("stripe")(process.env.STRIPE_SECRET_KEY);
@@ -15,7 +15,7 @@ const createBillingSession = async (
1515
const { return_url } = req.body;
1616

1717
try {
18-
const { user } = await getSupabaseServerClient({ req, res });
18+
const { user } = await getSupabaseServerClientForAPI({ req, res });
1919
const customer = await createOrRetrieveCustomer(user.id, user.email);
2020

2121
console.log(

‎apps/web/pages/api/billing/enable-email-notifications.ts‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
1+
import { IErrorResponse } from "@changes-page/supabase/types/api";
12
import type { NextApiRequest, NextApiResponse } from "next";
23
import Stripe from "stripe";
3-
import { IErrorResponse } from "@changes-page/supabase/types/api";
4-
import { getSupabaseServerClient } from "../../../utils/supabase/supabase-admin";
4+
import { getSupabaseServerClientForAPI } from "../../../utils/supabase/supabase-admin";
55
import { getUserById } from "../../../utils/useDatabase";
66

77
const stripe = require("stripe")(process.env.STRIPE_SECRET_KEY);
@@ -12,7 +12,7 @@ const enableEmailNotifications = async (
1212
) => {
1313
if (req.method === "PUT") {
1414
try {
15-
const { user } = await getSupabaseServerClient({ req, res });
15+
const { user } = await getSupabaseServerClientForAPI({ req, res });
1616

1717
const { stripe_subscription_id, stripe_subscription } = await getUserById(
1818
user.id

‎apps/web/pages/api/billing/index.ts‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@ import { IErrorResponse } from "@changes-page/supabase/types/api";
22
import type { NextApiRequest, NextApiResponse } from "next";
33
import Stripe from "stripe";
44
import { IBillingInfo } from "../../../data/user.interface";
5-
import { getSupabaseServerClient } from "../../../utils/supabase/supabase-admin";
5+
import { getSupabaseServerClientForAPI } from "../../../utils/supabase/supabase-admin";
66
import { getUserById } from "../../../utils/useDatabase";
77

88
const stripe = require("stripe")(process.env.STRIPE_SECRET_KEY);
@@ -13,7 +13,7 @@ const getBillingStatus = async (
1313
) => {
1414
if (req.method === "GET") {
1515
try {
16-
const { user } = await getSupabaseServerClient({ req, res });
16+
const { user } = await getSupabaseServerClientForAPI({ req, res });
1717

1818
const {
1919
pro_gifted,

‎apps/web/pages/api/billing/redirect-to-checkout.ts‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import type { NextApiRequest, NextApiResponse } from "next";
22
import { getAppBaseURL } from "../../../utils/helpers";
33
import { apiRateLimiter } from "../../../utils/rate-limit";
4-
import { getSupabaseServerClient } from "../../../utils/supabase/supabase-admin";
4+
import { getSupabaseServerClientForAPI } from "../../../utils/supabase/supabase-admin";
55
import {
66
createOrRetrieveCustomer,
77
getUserById,
@@ -18,7 +18,7 @@ const redirectToCheckout = async (
1818
const { return_url } = req.query;
1919

2020
try {
21-
const { user } = await getSupabaseServerClient({ req, res });
21+
const { user } = await getSupabaseServerClientForAPI({ req, res });
2222

2323
const {
2424
stripe_customer_id,

‎apps/web/pages/api/emails/subscribers/export-csv.ts‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@ import { supabaseAdmin } from "@changes-page/supabase/admin";
22
import { Parser } from "@json2csv/plainjs";
33
import { NextApiRequest, NextApiResponse } from "next";
44
import { apiRateLimiter } from "../../../../utils/rate-limit";
5-
import { getSupabaseServerClient } from "../../../../utils/supabase/supabase-admin";
5+
import { getSupabaseServerClientForAPI } from "../../../../utils/supabase/supabase-admin";
66

77
const getSubscribersExportCsv = async (
88
req: NextApiRequest,
@@ -11,9 +11,9 @@ const getSubscribersExportCsv = async (
1111
if (req.method === "GET") {
1212
try {
1313
await apiRateLimiter(req, res);
14-
const { user } = await getSupabaseServerClient({ req, res });
14+
const { user } = await getSupabaseServerClientForAPI({ req, res });
1515

16-
const { page_id } = req.query;
16+
const page_id = String(req.query.page_id);
1717

1818
await supabaseAdmin
1919
.from("pages")

‎apps/web/pages/api/emails/subscribers/index.ts‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,16 +1,16 @@
11
import { supabaseAdmin } from "@changes-page/supabase/admin";
22
import { NextApiRequest, NextApiResponse } from "next";
3-
import { getSupabaseServerClient } from "../../../../utils/supabase/supabase-admin";
3+
import { getSupabaseServerClientForAPI } from "../../../../utils/supabase/supabase-admin";
44

55
const getEmailSubscribers = async (
66
req: NextApiRequest,
77
res: NextApiResponse
88
) => {
99
if (req.method === "GET") {
1010
try {
11-
const { user } = await getSupabaseServerClient({ req, res });
11+
const { user } = await getSupabaseServerClientForAPI({ req, res });
1212

13-
const { page_id } = req.query;
13+
const page_id = String(req.query.page_id);
1414

1515
await supabaseAdmin
1616
.from("pages")

‎apps/web/pages/api/pages/new.ts‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ import { IPage } from "@changes-page/supabase/types/page";
33
import type { NextApiRequest, NextApiResponse } from "next";
44
import { NewPageSchema } from "../../../data/schema";
55
import { apiRateLimiter } from "../../../utils/rate-limit";
6-
import { getSupabaseServerClient } from "../../../utils/supabase/supabase-admin";
6+
import { getSupabaseServerClientForAPI } from "../../../utils/supabase/supabase-admin";
77
import {
88
createPage,
99
getUserById,
@@ -20,7 +20,7 @@ const createNewPage = async (
2020
const { url_slug, title, description, type } = req.body;
2121

2222
try {
23-
const { user } = await getSupabaseServerClient({ req, res });
23+
const { user } = await getSupabaseServerClientForAPI({ req, res });
2424

2525
const { has_active_subscription } = await getUserById(user.id);
2626
if (!has_active_subscription) {

0 commit comments

Comments
 (0)