@@ -106,9 +106,9 @@ local state = require('opencode.state')
106106--- | "file.watcher.updated"
107107--- | "server.connected"
108108--- | "ide.installed"
109- --- | "server_starting"
110- --- | "server_ready"
111- --- | "server_stopped"
109+ --- | "custom. server_starting"
110+ --- | "custom. server_ready"
111+ --- | "custom. server_stopped"
112112
113113--- @class EventManager
114114--- @field events table<string , function[]> Event listener registry
147147--- @overload fun ( self : EventManager , event_name : " file.watcher.updated" , callback : fun ( data : EventFileWatcherUpdated ): nil )
148148--- @overload fun ( self : EventManager , event_name : " server.connected" , callback : fun ( data : EventServerConnected ): nil )
149149--- @overload fun ( self : EventManager , event_name : " ide.installed" , callback : fun ( data : EventIdeInstalled ): nil )
150- --- @overload fun ( self : EventManager , event_name : " server_starting" , callback : fun ( data : ServerStartingEvent ): nil )
151- --- @overload fun ( self : EventManager , event_name : " server_ready" , callback : fun ( data : ServerReadyEvent ): nil )
152- --- @overload fun ( self : EventManager , event_name : " server_stopped" , callback : fun ( data : ServerStoppedEvent ): nil )
150+ --- @overload fun ( self : EventManager , event_name : " custom. server_starting" , callback : fun ( data : ServerStartingEvent ): nil )
151+ --- @overload fun ( self : EventManager , event_name : " custom. server_ready" , callback : fun ( data : ServerReadyEvent ): nil )
152+ --- @overload fun ( self : EventManager , event_name : " custom. server_stopped" , callback : fun ( data : ServerStoppedEvent ): nil )
153153--- @param event_name EventName The event name to listen for
154154--- @param callback function Callback function to execute when event is triggered
155155function EventManager :subscribe (event_name , callback )
177177--- @overload fun ( self : EventManager , event_name : " file.watcher.updated" , callback : fun ( data : EventFileWatcherUpdated ): nil )
178178--- @overload fun ( self : EventManager , event_name : " server.connected" , callback : fun ( data : EventServerConnected ): nil )
179179--- @overload fun ( self : EventManager , event_name : " ide.installed" , callback : fun ( data : EventIdeInstalled ): nil )
180- --- @overload fun ( self : EventManager , event_name : " server_starting" , callback : fun ( data : ServerStartingEvent ): nil )
181- --- @overload fun ( self : EventManager , event_name : " server_ready" , callback : fun ( data : ServerReadyEvent ): nil )
182- --- @overload fun ( self : EventManager , event_name : " server_stopped" , callback : fun ( data : ServerStoppedEvent ): nil )
180+ --- @overload fun ( self : EventManager , event_name : " custom. server_starting" , callback : fun ( data : ServerStartingEvent ): nil )
181+ --- @overload fun ( self : EventManager , event_name : " custom. server_ready" , callback : fun ( data : ServerReadyEvent ): nil )
182+ --- @overload fun ( self : EventManager , event_name : " custom. server_stopped" , callback : fun ( data : ServerStoppedEvent ): nil )
183183--- @param event_name EventName The event name
184184--- @param callback function The callback function to remove
185185function EventManager :unsubscribe (event_name , callback )
@@ -225,21 +225,21 @@ function EventManager:start()
225225 --- @param prev OpencodeServer | nil
226226 function (key , current , prev )
227227 if current and current :get_spawn_promise () then
228- self :emit (' server_starting' , { server_job = current })
228+ self :emit (' custom. server_starting' , { server_job = current })
229229
230230 current :get_spawn_promise ():and_then (function (server )
231- self :emit (' server_ready' , { server_job = server , url = server .url })
231+ self :emit (' custom. server_ready' , { server_job = server , url = server .url })
232232 vim .defer_fn (function ()
233233 self :_subscribe_to_server_events (server )
234234 end , 200 )
235235 end )
236236
237237 current :get_shutdown_promise ():and_then (function ()
238- self :emit (' server_stopped' , {})
238+ self :emit (' custom. server_stopped' , {})
239239 self :_cleanup_server_subscription ()
240240 end )
241241 elseif prev and not current then
242- self :emit (' server_stopped' , {})
242+ self :emit (' custom. server_stopped' , {})
243243 self :_cleanup_server_subscription ()
244244 end
245245 end
0 commit comments