移除 SSH 登录事件中的登录方法字段

pkg/agent/service/agent.go

@@ -925,22 +925,10 @@ func (a *Agent) sshLoginEventLoop(ctx context.Context, conn *safeConn, done chan
 		case <-ctx.Done():
 			return
 		case event := <-eventCh:
-			// 转换为 protocol 结构
-			eventData := protocol.SSHLoginEvent{
-				Username:  event.Username,
-				IP:        event.IP,
-				Port:      event.Port,
-				Timestamp: event.Timestamp,
-				Status:    event.Status,
-				Method:    event.Method,
-				TTY:       event.TTY,
-				SessionID: event.SessionID,
-			}
-
 			// 上报到服务端
 			if err := conn.WriteJSON(protocol.OutboundMessage{
 				Type: protocol.MessageTypeSSHLoginEvent,
-				Data: eventData,
+				Data: event,
 			}); err != nil {
 				slog.Warn("发送SSH登录事件失败", "error", err)
 			} else {

pkg/agent/sshmonitor/event.go

@@ -1,13 +0,0 @@
-package sshmonitor
-
-// SSHLoginEvent SSH登录事件（内部结构）
-type SSHLoginEvent struct {
-	Username  string `json:"username"`
-	IP        string `json:"ip"`
-	Port      string `json:"port,omitempty"`
-	Timestamp int64  `json:"timestamp"`
-	Status    string `json:"status"`
-	Method    string `json:"method,omitempty"`
-	TTY       string `json:"tty,omitempty"`
-	SessionID string `json:"sessionId,omitempty"`
-}

pkg/agent/sshmonitor/hook_client.go

@@ -7,6 +7,8 @@ import (
 	"strconv"
 	"strings"
 	"time"
+
+	"github.com/dushixiang/pika/internal/protocol"
 )
 
 // SendEventFromEnv 从 PAM 环境变量构建并发送事件
@@ -19,7 +21,7 @@ func SendEventFromEnv() error {
 }
 
 // BuildEventFromEnv 从 PAM 环境变量构建事件
-func BuildEventFromEnv() SSHLoginEvent {
+func BuildEventFromEnv() protocol.SSHLoginEvent {
 	now := time.Now().UnixMilli()
 
 	username := os.Getenv("PAM_USER")
@@ -48,20 +50,19 @@ func BuildEventFromEnv() SSHLoginEvent {
 		ip = "localhost"
 	}
 
-	return SSHLoginEvent{
+	return protocol.SSHLoginEvent{
 		Username:  username,
 		IP:        ip,
 		Port:      port,
 		Timestamp: now,
 		Status:    "success",
-		Method:    "unknown",
 		TTY:       tty,
 		SessionID: strconv.Itoa(os.Getpid()),
 	}
 }
 
 // SendEvent 发送事件到本地 socket
-func SendEvent(event SSHLoginEvent) error {
+func SendEvent(event protocol.SSHLoginEvent) error {
 	addr := &net.UnixAddr{
 		Name: DefaultSocketPath,
 		Net:  "unixgram",

pkg/agent/sshmonitor/monitor.go

@@ -28,7 +28,7 @@ type Monitor struct {
 	listener    *net.UnixConn
 	ctx         context.Context
 	cancel      context.CancelFunc
-	eventCh     chan SSHLoginEvent
+	eventCh     chan protocol.SSHLoginEvent
 	hookManager *HookManager
 }
 
@@ -37,7 +37,7 @@ func NewMonitor() *Monitor {
 	return &Monitor{
 		enabled:     false,
 		socketPath:  DefaultSocketPath,
-		eventCh:     make(chan SSHLoginEvent, 100),
+		eventCh:     make(chan protocol.SSHLoginEvent, 100),
 		hookManager: NewHookManager(),
 	}
 }
@@ -124,7 +124,7 @@ func (m *Monitor) stopInternal() error {
 }
 
 // GetEvents 获取事件通道
-func (m *Monitor) GetEvents() <-chan SSHLoginEvent {
+func (m *Monitor) GetEvents() <-chan protocol.SSHLoginEvent {
 	return m.eventCh
 }
 
@@ -178,7 +178,7 @@ func (m *Monitor) readLoop() {
 			continue
 		}
 
-		var event SSHLoginEvent
+		var event protocol.SSHLoginEvent
 		if err := json.Unmarshal(buf[:n], &event); err != nil {
 			slog.Warn("解析SSH登录事件失败", "error", err)
 			continue