package server

import (
	"github.com/mem9-ai/drive9/pkg/backend"
	"github.com/mem9-ai/drive9/pkg/meta"
)

// Work mask constants for the unified tenant notify outbox. Each bit in
// work_mask selects one work type. The poller dispatches by testing bits:
//
//	SSE bit  → wake local SSE bus (broadcast: all pods with subscribers)
//	Semantic/GC/DeleteReconcile bits → kick unified worker (sharded: shard
//	owner only)
//	Metrics cleanup bit → delete local tenant series (broadcast: every pod)
//
// The persisted allocation lives in pkg/meta. Backend and server aliases plus
// the compile-time assertions below keep both producer paths in sync.
const (
	// WorkSSE (bit 0) wakes the local SSE EventBus so SSE handlers re-read
	// fs_events. Broadcast to all pods (not sharded) — any pod with subscribers
	// for the tenant must wake.
	WorkSSE = meta.TenantNotifyWorkSSE
	// WorkSemantic (bit 1) kicks the unified worker to drain semantic tasks
	// for this tenant. Sharded: only the shard-owner pod processes it.
	WorkSemantic = meta.TenantNotifyWorkSemantic
	// WorkFileGC (bit 2) kicks the unified worker to drain file_gc tasks.
	// Sharded: only the shard-owner pod processes it.
	WorkFileGC = meta.TenantNotifyWorkFileGC
	// WorkMetricsCleanup (bit 3) removes all tenant-scoped metric series and
	// invalidates the tenant API-key resolve cache in the local process. It is
	// server-only because it is emitted by durable tenant lifecycle transitions,
	// not by a tenant DB write path.
	WorkMetricsCleanup = meta.TenantNotifyWorkMetricsCleanup
	// WorkAPIKeyCacheCleanup (bit 4) invalidates locally cached API-key
	// resolutions after a key revocation. It is broadcast to every pod but does
	// not touch tenant metrics for live tenants.
	WorkAPIKeyCacheCleanup = meta.TenantNotifyWorkAPIKeyCacheCleanup
	// WorkDeleteReconcile (bit 5) kicks the unified worker to run the
	// delete-orphan reconciliation sweep directly (outside the piggyback
	// maintenance cadence), with a delayed re-kick when the per-tenant
	// reconcile throttle is active. The recursive delete path emits it
	// unconditionally (even with zero orphans enqueued) because the residual
	// commit-boundary window can strand a broken-chain dentry without any
	// file_gc work. Sharded: only the shard-owner pod runs the sweep.
	WorkDeleteReconcile = meta.TenantNotifyWorkDeleteReconcile
	// WorkStorageTierScan (bit 6) is broadcast to every pod, but its consumer
	// uses Pool.AcquireCached only. A pod without a warm tenant backend skips.
	WorkStorageTierScan = meta.TenantNotifyWorkStorageTierScan
	// WorkEmbeddingConfigCleanup evicts the app-embedding resolver and tenant
	// backend cache on every pod. It is broadcast and never opens a tenant DB.
	WorkEmbeddingConfigCleanup = meta.TenantNotifyWorkEmbeddingConfigCleanup
)

// Compile-time assertions that the server-side work mask constants match the
// backend-side constants. If either set changes without the other, the build
// fails here.
var (
	_ = [1]byte{}[backend.BackendWorkSSE^WorkSSE]
	_ = [1]byte{}[backend.BackendWorkSemantic^WorkSemantic]
	_ = [1]byte{}[backend.BackendWorkFileGC^WorkFileGC]
	_ = [1]byte{}[backend.BackendWorkMetricsCleanup^WorkMetricsCleanup]
	_ = [1]byte{}[backend.BackendWorkAPIKeyCacheCleanup^WorkAPIKeyCacheCleanup]
	_ = [1]byte{}[backend.BackendWorkDeleteReconcile^WorkDeleteReconcile]
	_ = [1]byte{}[backend.BackendWorkStorageTierScan^WorkStorageTierScan]
	_ = [1]byte{}[backend.BackendWorkEmbeddingConfigCleanup^WorkEmbeddingConfigCleanup]
)