Method handleTracerouteStream

internal/nodeagent/dispatch.go:241–275

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

(ctx context.Context, req nodes.TracerouteRequest)

// handleTracerouteStream 同步阻塞，把 nodeapi.TracerouteHops 的每跳推回 server，
// event="traceroute_hop"。错误事件会作为终态错误返回（session 会回一条 Ok=false 响应）。
func (d *APIDispatcher) handleTracerouteStream(ctx context.Context, req nodes.TracerouteRequest) error {
	if d.sender == nil {
		return errors.New("nodeagent: sender not initialized for streaming")
	}
	reqID := ReqIDFromContext(ctx)
	if reqID == "" {
		return errors.New("nodeagent: TracerouteStream missing reqID in ctx")
	}
	apiReq := nodeapi.TracerouteRequest{
		Host:   req.Host,
		Method: req.Method,
		Port:   req.Port,
	}
	ch := d.api.TracerouteHops(ctx, apiReq)
	for ev := range ch {
		if ev.Err != "" {
			// 把错误事件也作为帧推回（与 HTTP SSE 行为对齐：客户端能看到错误内容），
			// 然后返回一个非 nil error 让 session 回 Ok=false 终态。
			body, _ := json.Marshal(map[string]string{"error": ev.Err})
			_ = d.sender.PushEvent(reqID, "traceroute_hop", body, 0)
			return errors.New(ev.Err)
		}
		body, err := json.Marshal(ev.Hop)
		if err != nil {
			return fmt.Errorf("marshal hop frame: %w", err)
		}
		if err := d.sender.PushEvent(reqID, "traceroute_hop", body, 0); err != nil {
			return err
		}
		if ctx.Err() != nil {
			return nil
		}
	}
	return nil
}

// ── ConfigHasher ─────────────────────────────────────────────────