Method handleLogsStream

internal/nodeagent/dispatch.go:215–237

handleLogsStream 同步阻塞，把 nodeapi.LogsChannel 的每行包成 {"line":"..."} 通过 sender 推回 server，event="log"。 ctx 取消（caller Close 或 server cancel_id）或日志通道关闭时返回 nil； session 会在 Handle 返回后回一条普通 Ok 响应，作为流终态。

(ctx context.Context)

// ctx 取消（caller Close 或 server cancel_id）或日志通道关闭时返回 nil；
// session 会在 Handle 返回后回一条普通 Ok 响应，作为流终态。
func (d *APIDispatcher) handleLogsStream(ctx context.Context) error {
	if d.sender == nil {
		return errors.New("nodeagent: sender not initialized for streaming")
	}
	reqID := ReqIDFromContext(ctx)
	if reqID == "" {
		return errors.New("nodeagent: LogsStream missing reqID in ctx")
	}
	ch := d.api.LogsChannel(ctx)
	for line := range ch {
		body, err := json.Marshal(map[string]string{"line": line})
		if err != nil {
			return fmt.Errorf("marshal log frame: %w", err)
		}
		if err := d.sender.PushEvent(reqID, "log", body, 0); err != nil {
			return err
		}
		if ctx.Err() != nil {
			return nil
		}
	}
	return nil
}

// handleTracerouteStream 同步阻塞，把 nodeapi.TracerouteHops 的每跳推回 server，
// event="traceroute_hop"。错误事件会作为终态错误返回（session 会回一条 Ok=false 响应）。