Method Shutdown

utils/service_utils/service_manager.go:223–292

()

}

func (sm *ServiceManager) Shutdown() {
	log.Println("Stopping all services...")

	sigChan := make(chan os.Signal, 1)
	signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM)

	var forceKillOnce sync.Once

	forceKill := make(chan struct{})

	var wg sync.WaitGroup

	for name := range sm.Services {
		wg.Add(1)
		go func(serviceName string) {
			defer wg.Done()

			if err := sm.StopService(serviceName); err != nil {
				if !strings.Contains(err.Error(), "not working") {
					log.Printf("%s error while stopping: %v", serviceName, err)
				}
			}

			sm.Mu.RLock()
			service, exists := sm.Services[serviceName]
			sm.Mu.RUnlock()

			if exists && service.CMD != nil && service.CMD.Process != nil {
				if err := service.CMD.Process.Signal(syscall.Signal(0)); err == nil {
					log.Printf("Service still working, forcing to stop: %s", serviceName)
					KillProcess(service.PID)
				}
			}
		}(name)
	}

	go func() {
		select {
		case <-sigChan:
			log.Println("Force shutdown requested by user (CTRL+C again)")
			forceKillOnce.Do(func() {
				close(forceKill)
			})
		case <-forceKill:
			return
		}
	}()

	done := make(chan struct{})
	go func() {
		wg.Wait()
		close(done)
	}()

	select {
	case <-done:
		log.Println("All services were stopped successfully!")
	case <-time.After(30 * time.Second):