diff --git a/apps/dashboard/src/lib/utils/services/org/index.ts b/apps/dashboard/src/lib/utils/services/org/index.ts index 6b549973..18c8b544 100644 --- a/apps/dashboard/src/lib/utils/services/org/index.ts +++ b/apps/dashboard/src/lib/utils/services/org/index.ts @@ -262,8 +262,9 @@ export async function createOrgPlan(params: { planName: string; triggeredBy: number; data: OrganizationPlan['lmz_data']; + supabase: typeof supabase; }) { - return await supabase.from('organization_plan').insert({ + return await params.supabase.from('organization_plan').insert({ activated_at: new Date().toDateString(), org_id: params.orgId, triggered_by: params.triggeredBy, diff --git a/apps/dashboard/src/routes/api/lmz/webhook/+server.js b/apps/dashboard/src/routes/api/lmz/webhook/+server.js index 236b2b7a..17c2ec9f 100644 --- a/apps/dashboard/src/routes/api/lmz/webhook/+server.js +++ b/apps/dashboard/src/routes/api/lmz/webhook/+server.js @@ -3,9 +3,12 @@ import crypto from 'crypto'; import { LEMON_SQUEEZY_WEBHOOK_SECRET } from '$env/static/private'; import { createOrgPlan, cancelOrgPlan } from '$lib/utils/services/org'; import { PLAN } from 'shared/src/plans/constants'; +import { getServerSupabase } from '$lib/utils/functions/supabase.server'; export async function POST({ request }) { try { + const supabase = getServerSupabase(); + // Catch the event type const clonedReq = request.clone(); const eventType = request.headers.get('X-Event-Name'); @@ -37,6 +40,7 @@ export async function POST({ request }) { if (isSuccessful && orgId) { const { data, error } = await createOrgPlan({ + supabase, orgId, triggeredBy: parseInt(triggeredBy), planName: PLAN.EARLY_ADOPTER,