//go:build linux || darwin

package kk_system

import (
	"gitee.com/cruvie/kk_go_kit/kk_stage"
	"log/slog"
	"net"
	"os/exec"
	"strconv"
	"strings"
)

// TerminatePort terminate the process which is using the port.
// port: :8080
func TerminatePort(port string) {
	listener, err := net.Listen("tcp", port)
	if err == nil {
		err := listener.Close()
		if err != nil {
			slog.Error("listener close", kk_stage.NewLog(nil).Error(err).Args()...)
		}
		slog.Info("ok", port, "is not in use")
		return
	}

	// 获取占用端口的进程ID
	cmd := exec.Command("lsof", "-i", port)
	output, err := cmd.Output()
	if err != nil {
		slog.Error("failed to execute command", kk_stage.NewLog(nil).Error(err).Args()...)
		return
	}

	lines := strings.Split(string(output), "\n")

	for _, line := range lines {
		if strings.Contains(line, "LISTEN") {
			fields := strings.Fields(line)
			if len(fields) >= 2 {
				pid, err := strconv.Atoi(fields[1])
				if err == nil {
					// 终止进程
					killCmd := exec.Command("kill", "-9", strconv.Itoa(pid))
					err = killCmd.Run()
					if err != nil {
						slog.Error("failed to terminate process", kk_stage.NewLog(nil).Error(err).Args()...)
						return
					}
				}
			}
		}
	}
}