ReverbServiceProvider

No description

Determine whether this provider should be registered and booted.

Hypervel-specific extension (not in Laravel). Override on a subclass to gate registration on runtime config / env / feature flags. When this returns false the provider is instantiated but neither register() nor boot() is called, its bindings/singletons properties are not processed, and it is not tracked in the application's provider list.

Register any application services.

Register a booting callback to be run before the "boot" method is called.

Register a booted callback to be run after the "boot" method is called.

Call the registered booting callbacks.

Call the registered booted callbacks.

Merge the given configuration with the existing configuration.

Top-level keys use shallow merge (app values override package defaults). Keys declared in mergeableOptions() get an additional one-level-deeper merge so the app can add entries to collection arrays (stores, connections, guards, etc.) without losing the package's default entries.

Get configuration arrays whose entries should be merged by name.

Override this in a package service provider to list nested configuration arrays whose entries are named. Application entries replace package entries with the same name, while package entries not defined by the application remain. Nested arrays not listed here are replaced completely.

Replace the given configuration with the existing configuration recursively.

Load the given routes file if routes are not already cached.

Register a view file namespace.

Register the given view components with a custom prefix.

Register a translation file namespace.

Register a JSON translation file path.

Register database migration paths.

Setup an after resolving listener, or fire immediately if already resolved.

Register migration paths to be published by the publish command.

Register paths to be published by the publish command.

Ensure the publish array for the service provider is initialized.

Add a publish group / tag to the service provider.

Get the paths to publish.

Get the paths for the provider or group (or both).

Returns null when no filter is specified, allowing caller to fall back to all paths. Returns empty array when a filter is specified but not found.

Get the paths for the provider and group.

Get the service providers available for publishing.

Get the migration paths available for publishing.

Get the groups available for publishing.

Add a provider to the bootstrap provider configuration file.

Remove a provider from the bootstrap provider file.

Register commands that should run on "optimize".

Register commands that should run on "reload".

Get a short descriptive key for the current service provider.

Register the package's custom Artisan commands.

Register AOP aspects.

Reads $classes and $priority from each aspect class's default property values via reflection (without instantiating the aspect). Must be called during register(), before boot().

Register class map overrides.

Applies entries to the Composer autoloader immediately. Fails hard if any target class is already loaded. Must be called during register(), before the target class is autoloaded.

Replace the bootstrap provider file without exposing partial contents.

Get the default providers for a Hypervel application.

Flush all static state.

Register the Reverb WebSocket server in the server configuration.

Appends a WebSocket server entry to server.servers so Swoole binds the Reverb port alongside the main HTTP server. This is an intentional register-time config mutation: it must run before ServerStartCommand reads server.servers and before workers or coroutines exist. Do not move this into boot/runtime code; config is process-global in Swoole workers.

Resolve Swoole settings for the Reverb server.

Register the isolated Reverb router singleton.

Routes are registered later in boot() so config overrides (e.g. path prefix) are applied before route registration.

Register all Reverb routes on the isolated router.

Bootstrap any application services.

Register periodic tasks for connection cleanup and table monitoring.

Register the pipe message listener for intra-node broadcast fan-out.

Register the graceful shutdown handler for worker exit.

Runs during onWorkerExit while the event loop is still active, so coroutine-dependent operations (Redis pub/sub for scaling, webhook dispatch) still work. This fires before WORKER_EXIT is resumed, meaning periodic timers and the Redis subscriber are still running — the drain does not conflict with them.

Drain all active WebSocket connections on this worker.

Atomically takes each connection from the registry, runs Reverb cleanup (channel unsubscribe, slot release, presence events), then closes the transport with a 1001 Going Away close code.

Disconnect the Redis pub/sub subscriber if scaling is enabled.

Flush any buffered webhook events to the queue.

Reduces recovery delay from 60s to immediate by scheduling flush jobs before the worker dies.

Check Swoole Table capacity and log a warning if nearing the limit.

Check a Swoole Table's capacity and log a warning if above 80%.

Recover stale webhook batch processing keys from crashed flush jobs.

Iterates all apps with batching enabled and checks for orphaned processing hashes. If recovered, schedules an immediate flush.