backend

type Backend interface {
	// Watch subscribes a connection to variable changes.
	// For LuaBackend: manages tally, registers with tracker if new.
	// For ProxiedBackend: relays to external backend.
	Watch(varID int64, connectionID string) WatchResult

	// Unwatch removes a connection's subscription to variable changes.
	// For LuaBackend: decrements tally, unregisters from tracker if zero.
	// For ProxiedBackend: relays to external backend.
	Unwatch(varID int64, connectionID string) UnwatchResult

	// UnwatchAll removes all watches for a connection (on disconnect).
	// Returns list of variable IDs that were unwatched.
	UnwatchAll(connectionID string) []int64

	// GetWatchers returns all connection IDs watching a variable.
	GetWatchers(varID int64) []string

	// GetWatcherCount returns the current observer count for a variable.
	GetWatcherCount(varID int64) int

	// DetectChanges computes and returns changes for watched variables.
	// Only meaningful for LuaBackend; ProxiedBackend returns nil.
	DetectChanges() []VariableUpdate

	// GetTracker returns the change-tracker instance for this session.
	// Only meaningful for LuaBackend; ProxiedBackend returns nil.
	GetTracker() *changetracker.Tracker

	// SetInactive marks a variable as inactive (updates not relayed).
	SetInactive(varID int64, inactive bool)

	// IsInactive checks if a variable or any ancestor is inactive.
	IsInactive(varID int64) bool

	// GetSessionID returns the session ID associated with this backend.
	GetSessionID() string

	// Shutdown cleans up backend resources.
	Shutdown()
}

type LuaBackend struct {
	// contains filtered or unexported fields
}

type UnwatchResult struct {
	ShouldForward bool // True if tally changed 1->0 for bound variables
	Count         int  // New watch count
}

type VariableUpdate struct {
	VarID      int64
	Value      json.RawMessage
	Properties map[string]string
}

type WatchResult struct {
	ShouldForward bool // True if tally changed 0->1 for bound variables
	Count         int  // New watch count
}