fix(data-drains): dispatcher must short-circuit enterprise check on self-hosted

isOrganizationOnEnterprisePlan returns false on deployments without billing
infrastructure, so the dispatcher would silently skip every drain on
self-hosted even with DATA_DRAINS_ENABLED=true. Mirror the access.ts pattern:
when isBillingEnabled is false, treat all orgs as eligible — the cron route's
DATA_DRAINS_ENABLED gate already controls global on/off.

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

Author: waleedlatif1

apps/sim/lib/data-drains/dispatcher.test.ts

@@ -19,6 +19,7 @@ vi.mock('@/lib/billing/core/subscription', () => ({
   isOrganizationOnEnterprisePlan: mockIsEnterprise,
 }))
 vi.mock('@/lib/core/async-jobs', () => ({ getJobQueue: mockGetJobQueue }))
+vi.mock('@/lib/core/config/feature-flags', () => ({ isBillingEnabled: true }))
 
 import { dispatchDueDrains, reapOrphanedRuns } from '@/lib/data-drains/dispatcher'
 

apps/sim/lib/data-drains/dispatcher.ts

@@ -4,6 +4,7 @@ import { createLogger } from '@sim/logger'
 import { and, eq, isNull, lt, or } from 'drizzle-orm'
 import { isOrganizationOnEnterprisePlan } from '@/lib/billing/core/subscription'
 import { getJobQueue } from '@/lib/core/async-jobs'
+import { isBillingEnabled } from '@/lib/core/config/feature-flags'
 
 const logger = createLogger('DataDrainsDispatcher')
 
@@ -83,8 +84,13 @@ export async function dispatchDueDrains(now: Date = new Date()): Promise<{
   }
 
   // Cache enterprise checks per-org since we may have several drains per org.
+  // Self-hosted (no billing) deployments have no subscription infrastructure,
+  // so the enterprise predicate would return false for every org and silently
+  // skip every drain — short-circuit to allow when billing is disabled, and
+  // let the cron route's `DATA_DRAINS_ENABLED` gate own the global on/off.
   const enterpriseCache = new Map<string, boolean>()
   const isEnterprise = async (orgId: string): Promise<boolean> => {
+    if (!isBillingEnabled) return true
     const cached = enterpriseCache.get(orgId)
     if (cached !== undefined) return cached
     const result = await isOrganizationOnEnterprisePlan(orgId)