Function TestCLINetworkRoundTripIntegration

internal/cli/cli_integration_test.go:651–915

(t *testing.T)

}

func TestCLINetworkRoundTripIntegration(t *testing.T) {
	t.Parallel()

	h := newIntegrationHarness(t)
	mustExecuteRoot(t, h.deps, "daemon", "start", "-o", "json")
	defer func() {
		_, _, _ = executeRootCommand(t, h.deps, "daemon", "stop", "-o", "json")
		_ = h.runner.waitForExit()
	}()

	newOut, _, err := executeRootCommand(
		t,
		h.deps,
		"session",
		"new",
		"--agent",
		"coder",
		"--name",
		"net-demo",
		"--channel",
		"builders",
		"--cwd",
		h.workspace,
		"-o",
		"json",
	)
	if err != nil {
		t.Fatalf("session new --channel error = %v", err)
	}
	var created SessionRecord
	if err := json.Unmarshal([]byte(newOut), &created); err != nil {
		t.Fatalf("json.Unmarshal(session new --channel) error = %v", err)
	}
	senderOut, _, err := executeRootCommand(
		t,
		h.deps,
		"session",
		"new",
		"--agent",
		"coder",
		"--name",
		"net-sender",
		"--channel",
		"builders",
		"--cwd",
		h.workspace,
		"-o",
		"json",
	)
	if err != nil {
		t.Fatalf("sender session new --channel error = %v", err)
	}
	var sender SessionRecord
	if err := json.Unmarshal([]byte(senderOut), &sender); err != nil {
		t.Fatalf("json.Unmarshal(sender session new --channel) error = %v", err)
	}

	statusOut, _, err := executeRootCommand(t, h.deps, "network", "status", "-o", "json")