Method dispatchResult

backend/daemon.go:198–368

(ctx context.Context, client *wsClient, req RPCRequest)

		return err
	}
	actualPort := listener.Addr().(*net.TCPAddr).Port
	server := &DaemonServer{
		opts:    opts,
		token:   token,
		clients: map[*wsClient]struct{}{},
		upgrader: websocket.Upgrader{CheckOrigin: func(r *http.Request) bool {
			return r.Host == r.URL.Host || strings.HasPrefix(r.RemoteAddr, "127.0.0.1:") || strings.HasPrefix(r.RemoteAddr, "[::1]:")
		}},
	}
	server.manager = NewSessionManager(opts.Config, server.broadcast)
	server.teamManager = luminateam.NewManager(opts.Config, func(parentSessionID, eventType string, payload any) {
		server.broadcast(PushEvent{
			Type:      "event",
			SessionID: parentSessionID,
			Seq:       time.Now().UnixNano(),
			Event: map[string]any{
				"type":    eventType,
				"payload": payload,
			},
		})
	}, nil)
	mux := http.NewServeMux()
	mux.HandleFunc("/v1/ws", server.handleWS)
	mux.HandleFunc("/v1/a2a/ws", server.handleA2AWS)
	mux.HandleFunc("/healthz", func(w http.ResponseWriter, _ *http.Request) {
		_, _ = w.Write([]byte("ok"))
	})
	server.httpSrv = &http.Server{Handler: mux}
	endpoint := EndpointInfo{
		PID:       os.Getpid(),
		Host:      opts.Host,
		Port:      actualPort,
		AuthToken: token,
		StartedAt: nowRFC3339(),
		URL:       fmt.Sprintf("ws://%s:%d/v1/ws", opts.Host, actualPort),
	}
	if err := writeEndpoint(opts.EndpointPath, endpoint); err != nil {
		_ = listener.Close()
		return err
	}
	server.startManagedServices()
	defer server.shutdownManagedResources()
	go func() {
		<-ctx.Done()
		_ = server.httpSrv.Shutdown(context.Background())
	}()
	go server.startIdleHeartbeat(ctx)
	fmt.Fprintf(os.Stderr, "lumina-backend daemon listening on %s:%d\n", opts.Host, actualPort)
	err = server.httpSrv.Serve(listener)
	if err == http.ErrServerClosed {
		return nil
	}
	return err
}

func (s *DaemonServer) startManagedServices() {
	if path := s.searxNGScriptPath(); path != "" {
		if output, err := runManagedScript(path, "start", s.opts.Config); err != nil {