Function TestCall_Success

internal/nodehub/hub_test.go:189–220

---- 测试：Call 成功 ----

(t *testing.T)

// ---- 测试：Call 成功 ----

func TestCall_Success(t *testing.T) {
	hub := New(Options{PeerExtractor: mdPeerExtractor})
	env := newTestEnv(t, hub)

	cc := env.dial(t)
	mock := startNodeMock(t, cc, "node-1")
	waitOnline(t, hub, "node-1")

	type req struct{ Foo string }
	type resp struct{ Echo string }

	mock.handle("hello", func(reqID string, body []byte) (bool, []byte, string) {
		var r req
		_ = json.Unmarshal(body, &r)
		out, _ := json.Marshal(resp{Echo: "hi-" + r.Foo})
		return true, out, ""
	})

	ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
	defer cancel()
	raw, err := hub.Call(ctx, "node-1", "hello", req{Foo: "abc"})
	if err != nil {
		t.Fatalf("Call: %v", err)
	}
	var got resp
	if err := json.Unmarshal(raw, &got); err != nil {
		t.Fatalf("unmarshal: %v", err)
	}
	if got.Echo != "hi-abc" {
		t.Fatalf("unexpected echo: %q", got.Echo)
	}
}

// ---- 测试：Call 错误响应 ----