fix(supabase): stop server clients leaking a 30s refresh ticker per request (#1612)

* fix(supabase): stop server clients leaking a 30s refresh ticker per request

`autoRefreshToken` defaults to true in supabase-js, and off-browser
@supabase/auth-js starts the refresh ticker unconditionally:

    // in non-browser environments the refresh token ticker runs always
    this.startAutoRefresh()

That is a setInterval firing every 30 s. It calls unref(), so the process
still exits, tests pass, and Vercel never notices because the process is
torn down long before the tickers accumulate. But unref() does not make a
timer collectable: it stays registered in the event loop and remains a GC
root for its callback, which closes over the GoTrueClient, the
SupabaseClient, and the whole request scope around it.

A long-running self-hosted instance therefore leaks one timer plus one
entire request graph (socket, IncomingMessage, ServerResponse, headers,
route context: ~100 kB) per client constructed. One died of "JavaScript
heap out of memory" after 42 h, the last 24 of them completely idle. The
heap snapshot showed 445 retained request graphs and ~1050 Timeouts in
the 30 000 ms bucket, retained via `autoRefreshTicker`, and the rate
matched the traffic exactly: the Docker healthcheck polls /api/health
every 30 s and the webhook dispatch cron runs every minute, so
3 clients/min x 148 min = 444.

- new lib/supabase/service-client.ts: createServiceRoleClient() applies
  SERVER_AUTH_OPTIONS, spread LAST so a caller passing its own auth block
  cannot re-enable the ticker
- 22 call sites migrated; only booking-templates/sync/cron had ever
  passed the options itself
- guard 9 in no-new-antipatterns.mjs fails CI on any new value import of
  supabase-js's createClient outside the wrapper; type-only imports are
  fine. Verified to fail on a deliberate regression and pass once fixed
- browser clients untouched: a signed-in tab genuinely needs the refresh,
  and lib/supabase/client.ts is built on createBrowserClient anyway

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>

* fix(checks): catch namespace imports in the leaky-supabase-client guard

The guard only matched named imports, so

    import * as sb from '@supabase/supabase-js'
    sb.createClient(url, key)

reached createClient through member access without ever naming it, and
passed. Verified against the real script before and after: the shape is
flagged now, and `import type * as sb` still passes.

Namespace value imports are treated as leaky outright rather than tracking
member access, which keeps the check a regex over source text with no new
dependency.

Review also suggested excluding *.test.tsx alongside *.test.ts. Skipped: the
repo has no .test.tsx files, and all four sibling checks in this file use
`.test.ts`. Diverging in one of them would read as an accident; if such files
appear, all four should change together.

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>

---------

Co-authored-by: Claude Opus 5 <noreply@anthropic.com>
This commit is contained in:
bjornbergenheim
2026-08-17 14:30:17 +02:00
committed by GitHub
co-authored by Claude Opus 5
parent 4921d1da5e
commit 43a71aec3c
27 changed files with 285 additions and 51 deletions
+2 -2
View File
@@ -1,4 +1,4 @@
import { createClient } from '@supabase/supabase-js'
import { createServiceRoleClient } from '@/lib/supabase/service-client'
import { NextResponse } from 'next/server'
import { generateCalendarFeed } from '@/lib/calendar/ics-generator'
import { createLogger } from '@/lib/logger'
@@ -59,7 +59,7 @@ export async function GET(
return new NextResponse('Server configuration error', { status: 500 })
}
const supabase = createClient(supabaseUrl, supabaseServiceKey)
const supabase = createServiceRoleClient(supabaseUrl, supabaseServiceKey)
// Fetch feed settings by token
const { data: feed, error: feedError } = await supabase
+2 -2
View File
@@ -1,4 +1,4 @@
import { createClient } from '@supabase/supabase-js'
import { createServiceRoleClient } from '@/lib/supabase/service-client'
import { NextResponse } from 'next/server'
import { updateDeadlineStatuses } from '@/lib/deadlines/status-engine'
import { withCronContext } from '@/lib/api/with-cron-context'
@@ -19,7 +19,7 @@ export const GET = withCronContext('cron.deadlines_status', async (_request, ctx
})
}
const supabase = createClient(supabaseUrl, supabaseServiceKey)
const supabase = createServiceRoleClient(supabaseUrl, supabaseServiceKey)
const result = await updateDeadlineStatuses(supabase)
+2 -2
View File
@@ -1,4 +1,4 @@
import { createClient } from '@supabase/supabase-js'
import { createServiceRoleClient } from '@/lib/supabase/service-client'
import { NextResponse } from 'next/server'
import { withCronContext } from '@/lib/api/with-cron-context'
import { downloadDocumentObject } from '@/lib/core/documents/document-service'
@@ -33,7 +33,7 @@ export const GET = withCronContext('cron.documents_verify', async (_request, ctx
})
}
const supabase = createClient(supabaseUrl, supabaseServiceKey)
const supabase = createServiceRoleClient(supabaseUrl, supabaseServiceKey)
const { data: documents, error: fetchError } = await supabase
.from('document_attachments')
@@ -1,4 +1,4 @@
import { createClient } from '@supabase/supabase-js'
import { createServiceRoleClient } from '@/lib/supabase/service-client'
import { NextResponse } from 'next/server'
import { withCronContext } from '@/lib/api/with-cron-context'
import { errorResponse, errorResponseFromCode } from '@/lib/errors/get-structured-error'
@@ -50,7 +50,7 @@ export const GET = withCronContext('cron.cloud_backup_auto_sync', async (_reques
})
}
const supabase = createClient(supabaseUrl, supabaseServiceKey)
const supabase = createServiceRoleClient(supabaseUrl, supabaseServiceKey)
const now = new Date()
const origin = process.env.NEXT_PUBLIC_APP_URL || 'http://localhost:3000'
@@ -1,4 +1,5 @@
import { createClient, type SupabaseClient } from '@supabase/supabase-js'
import { type SupabaseClient } from '@supabase/supabase-js'
import { createServiceRoleClient } from '@/lib/supabase/service-client'
import { NextResponse } from 'next/server'
import { syncAccountTransactions } from '@/extensions/general/enable-banking/lib/sync'
import {
@@ -52,7 +53,7 @@ export const GET = withCronContext('cron.bank_sync', async (_request, ctx) => {
})
}
const supabase = createClient(supabaseUrl, supabaseServiceKey)
const supabase = createServiceRoleClient(supabaseUrl, supabaseServiceKey)
// Clean up stale pending connections (older than 1 hour)
const oneHourAgo = new Date(Date.now() - 60 * 60 * 1000).toISOString()
@@ -1,4 +1,4 @@
import { createClient } from '@supabase/supabase-js'
import { createServiceRoleClient } from '@/lib/supabase/service-client'
import { NextResponse } from 'next/server'
import { loadExtensions } from '@/lib/extensions/loader'
import { extensionRegistry } from '@/lib/extensions/registry'
@@ -46,7 +46,7 @@ export const GET = withCronContext('cron.push_notifications', async (_request, c
})
}
const supabase = createClient(supabaseUrl, supabaseServiceKey)
const supabase = createServiceRoleClient(supabaseUrl, supabaseServiceKey)
try {
const [taxResult, invoiceResult, underlagResult] = await Promise.all([
@@ -1,4 +1,4 @@
import { createClient } from '@supabase/supabase-js'
import { createServiceRoleClient } from '@/lib/supabase/service-client'
import { NextResponse } from 'next/server'
import { withCronContext } from '@/lib/api/with-cron-context'
import { errorResponse, errorResponseFromCode } from '@/lib/errors/get-structured-error'
@@ -51,7 +51,7 @@ export const GET = withCronContext('cron.shopify_order_sync', async (_request, c
return NextResponse.json({ message: 'Shopify not configured', processed: 0 })
}
const supabase = createClient(supabaseUrl, supabaseServiceKey)
const supabase = createServiceRoleClient(supabaseUrl, supabaseServiceKey)
const { data: connections, error: connError } = await supabase
.from('shopify_connections')
@@ -1,4 +1,4 @@
import { createClient } from '@supabase/supabase-js'
import { createServiceRoleClient } from '@/lib/supabase/service-client'
import { NextResponse } from 'next/server'
import { ensureInitialized } from '@/lib/init'
import { createLogger } from '@/lib/logger'
@@ -68,7 +68,7 @@ export async function GET(request: Request) {
)
}
const supabase = createClient(supabaseUrl, supabaseServiceKey)
const supabase = createServiceRoleClient(supabaseUrl, supabaseServiceKey)
const { data: pending, error: pendingError } = await supabase
.from('agi_declarations')
@@ -1,4 +1,4 @@
import { createClient } from '@supabase/supabase-js'
import { createServiceRoleClient } from '@/lib/supabase/service-client'
import { NextResponse } from 'next/server'
import { ensureInitialized } from '@/lib/init'
import { verifyCronSecret } from '@/lib/auth/cron'
@@ -66,7 +66,7 @@ export async function GET(request: Request) {
return NextResponse.json({ error: 'Missing Supabase configuration' }, { status: 500 })
}
const supabase = createClient(supabaseUrl, supabaseServiceKey)
const supabase = createServiceRoleClient(supabaseUrl, supabaseServiceKey)
// User-token entries. The token row is keyed by user_id but carries
// company_id (multi-tenant refactor). Rows flagged needs_reconsent are
@@ -1,4 +1,4 @@
import { createClient } from '@supabase/supabase-js'
import { createServiceRoleClient } from '@/lib/supabase/service-client'
import { NextResponse } from 'next/server'
import { ensureInitialized } from '@/lib/init'
import { verifyCronSecret } from '@/lib/auth/cron'
@@ -48,7 +48,7 @@ export async function GET(request: Request) {
return NextResponse.json({ error: 'Missing Supabase configuration' }, { status: 500 })
}
const supabase = createClient(supabaseUrl, supabaseServiceKey)
const supabase = createServiceRoleClient(supabaseUrl, supabaseServiceKey)
// AGI submission state uses the distinct `agi_submission_` prefix, so the
// `submission_` filter below cannot match AGI rows.
+2 -2
View File
@@ -1,4 +1,4 @@
import { createClient } from '@supabase/supabase-js'
import { createServiceRoleClient } from '@/lib/supabase/service-client'
import { NextResponse } from 'next/server'
import { ensureInitialized } from '@/lib/init'
import { withCronContext } from '@/lib/api/with-cron-context'
@@ -38,7 +38,7 @@ export const GET = withCronContext('cron.stripe_sync', async (_request, ctx) =>
return NextResponse.json({ message: 'Stripe Connect not configured', processed: 0 })
}
const supabase = createClient(supabaseUrl, supabaseServiceKey)
const supabase = createServiceRoleClient(supabaseUrl, supabaseServiceKey)
const { data: connections, error: connError } = await supabase
.from('stripe_connections')
@@ -1,4 +1,4 @@
import { createClient } from '@supabase/supabase-js'
import { createServiceRoleClient } from '@/lib/supabase/service-client'
import { NextResponse } from 'next/server'
import { withCronContext } from '@/lib/api/with-cron-context'
import { errorResponse, errorResponseFromCode } from '@/lib/errors/get-structured-error'
@@ -36,7 +36,7 @@ export const GET = withCronContext('cron.stripe_transaction_sync', async (_reque
return NextResponse.json({ message: 'Stripe Connect not configured', processed: 0 })
}
const supabase = createClient(supabaseUrl, supabaseServiceKey)
const supabase = createServiceRoleClient(supabaseUrl, supabaseServiceKey)
const { data: connections, error: connError } = await supabase
.from('stripe_connections')
@@ -1,4 +1,4 @@
import { createClient } from '@supabase/supabase-js'
import { createServiceRoleClient } from '@/lib/supabase/service-client'
import { NextResponse } from 'next/server'
import { withCronContext } from '@/lib/api/with-cron-context'
import { errorResponse, errorResponseFromCode } from '@/lib/errors/get-structured-error'
@@ -51,7 +51,7 @@ export const GET = withCronContext('cron.woocommerce_order_sync', async (_reques
return NextResponse.json({ message: 'WooCommerce not configured', processed: 0 })
}
const supabase = createClient(supabaseUrl, supabaseServiceKey)
const supabase = createServiceRoleClient(supabaseUrl, supabaseServiceKey)
const { data: connections, error: connError } = await supabase
.from('woocommerce_connections')
+2 -2
View File
@@ -1,4 +1,4 @@
import { createClient } from '@supabase/supabase-js'
import { createServiceRoleClient } from '@/lib/supabase/service-client'
import { NextResponse } from 'next/server'
import { createLogger } from '@/lib/logger'
@@ -79,7 +79,7 @@ async function runHealthCheck(): Promise<CheckResult> {
}
try {
const supabase = createClient(supabaseUrl, supabaseServiceKey)
const supabase = createServiceRoleClient(supabaseUrl, supabaseServiceKey)
const { error } = await supabase
.from('fiscal_periods')
.select('id', { count: 'exact', head: true })
+2 -2
View File
@@ -1,4 +1,4 @@
import { createClient } from '@supabase/supabase-js'
import { createServiceRoleClient } from '@/lib/supabase/service-client'
import { NextResponse } from 'next/server'
import { withCronContext } from '@/lib/api/with-cron-context'
import { errorResponse, errorResponseFromCode } from '@/lib/errors/get-structured-error'
@@ -35,7 +35,7 @@ export const GET = withCronContext('cron.sandbox_cleanup', async (_request, ctx)
})
}
const supabase = createClient(supabaseUrl, supabaseServiceKey)
const supabase = createServiceRoleClient(supabaseUrl, supabaseServiceKey)
const started = Date.now()
const totals = { cleaned: 0, failed: 0, orphans_removed: 0, batches: 0 }
@@ -1,4 +1,4 @@
import { createClient } from '@supabase/supabase-js'
import { createServiceRoleClient } from '@/lib/supabase/service-client'
import { NextResponse } from 'next/server'
import { withCronContext } from '@/lib/api/with-cron-context'
import { errorResponseFromCode } from '@/lib/errors/get-structured-error'
@@ -39,9 +39,7 @@ export const GET = withCronContext('cron.booking_templates_sync', async (_reques
})
}
const supabase = createClient(supabaseUrl, supabaseServiceKey, {
auth: { persistSession: false, autoRefreshToken: false },
})
const supabase = createServiceRoleClient(supabaseUrl, supabaseServiceKey)
const result = await syncSystemPacks(supabase)
+2 -2
View File
@@ -1,4 +1,4 @@
import { createClient } from '@supabase/supabase-js'
import { createServiceRoleClient } from '@/lib/supabase/service-client'
import { NextResponse } from 'next/server'
import {
backfillMissingTaxDeadlines,
@@ -21,7 +21,7 @@ export const GET = withCronContext('cron.tax_deadlines', async (_request, ctx) =
})
}
const supabase = createClient(supabaseUrl, supabaseServiceKey)
const supabase = createServiceRoleClient(supabaseUrl, supabaseServiceKey)
const now = new Date()
const isAnnualRun = now.getUTCMonth() === 0 && now.getUTCDate() === 2