|
1 | 1 | package cli
|
2 | 2 |
|
3 | 3 | import (
|
| 4 | + "bytes" |
| 5 | + "fmt" |
| 6 | + "net/http" |
| 7 | + "net/http/httptest" |
| 8 | + "net/url" |
4 | 9 | "os"
|
5 | 10 | "runtime"
|
6 | 11 | "testing"
|
7 | 12 |
|
8 | 13 | "github.com/stretchr/testify/require"
|
9 | 14 | "go.uber.org/goleak"
|
| 15 | + |
| 16 | + "github.com/coder/coder/v2/buildinfo" |
| 17 | + "github.com/coder/coder/v2/cli/cliui" |
| 18 | + "github.com/coder/coder/v2/coderd" |
| 19 | + "github.com/coder/coder/v2/coderd/httpapi" |
| 20 | + "github.com/coder/coder/v2/codersdk" |
| 21 | + "github.com/coder/pretty" |
10 | 22 | )
|
11 | 23 |
|
12 | 24 | func Test_formatExamples(t *testing.T) {
|
@@ -84,3 +96,85 @@ func TestMain(m *testing.M) {
|
84 | 96 | goleak.IgnoreTopFunction("github.com/lib/pq.NewDialListener"),
|
85 | 97 | )
|
86 | 98 | }
|
| 99 | + |
| 100 | +func Test_checkVersions(t *testing.T) { |
| 101 | + t.Parallel() |
| 102 | + |
| 103 | + t.Run("CustomUpgradeMessage", func(t *testing.T) { |
| 104 | + t.Parallel() |
| 105 | + |
| 106 | + expectedUpgradeMessage := "My custom upgrade message" |
| 107 | + |
| 108 | + srv := httptest.NewServer(http.HandlerFunc(func(rw http.ResponseWriter, r *http.Request) { |
| 109 | + httpapi.Write(r.Context(), rw, http.StatusOK, codersdk.BuildInfoResponse{ |
| 110 | + ExternalURL: buildinfo.ExternalURL(), |
| 111 | + // Provide a version that will not match |
| 112 | + Version: "v1.0.0", |
| 113 | + AgentAPIVersion: coderd.AgentAPIVersionREST, |
| 114 | + // does not matter what the url is |
| 115 | + DashboardURL: "https://example.com", |
| 116 | + WorkspaceProxy: false, |
| 117 | + UpgradeMessage: expectedUpgradeMessage, |
| 118 | + }) |
| 119 | + })) |
| 120 | + defer srv.Close() |
| 121 | + surl, err := url.Parse(srv.URL) |
| 122 | + require.NoError(t, err) |
| 123 | + |
| 124 | + client := codersdk.New(surl) |
| 125 | + |
| 126 | + r := &RootCmd{} |
| 127 | + |
| 128 | + cmd, err := r.Command(nil) |
| 129 | + require.NoError(t, err) |
| 130 | + |
| 131 | + var buf bytes.Buffer |
| 132 | + inv := cmd.Invoke() |
| 133 | + inv.Stderr = &buf |
| 134 | + |
| 135 | + err = r.checkVersions(inv, client, "v2.0.0") |
| 136 | + require.NoError(t, err) |
| 137 | + |
| 138 | + fmtOutput := fmt.Sprintf("version mismatch: client v2.0.0, server v1.0.0\n%s", expectedUpgradeMessage) |
| 139 | + expectedOutput := fmt.Sprintln(pretty.Sprint(cliui.DefaultStyles.Warn, fmtOutput)) |
| 140 | + require.Equal(t, expectedOutput, buf.String()) |
| 141 | + }) |
| 142 | + |
| 143 | + t.Run("DefaultUpgradeMessage", func(t *testing.T) { |
| 144 | + t.Parallel() |
| 145 | + |
| 146 | + srv := httptest.NewServer(http.HandlerFunc(func(rw http.ResponseWriter, r *http.Request) { |
| 147 | + httpapi.Write(r.Context(), rw, http.StatusOK, codersdk.BuildInfoResponse{ |
| 148 | + ExternalURL: buildinfo.ExternalURL(), |
| 149 | + // Provide a version that will not match |
| 150 | + Version: "v1.0.0", |
| 151 | + AgentAPIVersion: coderd.AgentAPIVersionREST, |
| 152 | + // does not matter what the url is |
| 153 | + DashboardURL: "https://example.com", |
| 154 | + WorkspaceProxy: false, |
| 155 | + UpgradeMessage: "", |
| 156 | + }) |
| 157 | + })) |
| 158 | + defer srv.Close() |
| 159 | + surl, err := url.Parse(srv.URL) |
| 160 | + require.NoError(t, err) |
| 161 | + |
| 162 | + client := codersdk.New(surl) |
| 163 | + |
| 164 | + r := &RootCmd{} |
| 165 | + |
| 166 | + cmd, err := r.Command(nil) |
| 167 | + require.NoError(t, err) |
| 168 | + |
| 169 | + var buf bytes.Buffer |
| 170 | + inv := cmd.Invoke() |
| 171 | + inv.Stderr = &buf |
| 172 | + |
| 173 | + err = r.checkVersions(inv, client, "v2.0.0") |
| 174 | + require.NoError(t, err) |
| 175 | + |
| 176 | + fmtOutput := fmt.Sprintf("version mismatch: client v2.0.0, server v1.0.0\n%s", defaultUpgradeMessage("v1.0.0")) |
| 177 | + expectedOutput := fmt.Sprintln(pretty.Sprint(cliui.DefaultStyles.Warn, fmtOutput)) |
| 178 | + require.Equal(t, expectedOutput, buf.String()) |
| 179 | + }) |
| 180 | +} |
0 commit comments