@@ -24,6 +24,8 @@ import (
24
24
"net/http/httptest"
25
25
"os"
26
26
"os/exec"
27
+ "os/user"
28
+ "path/filepath"
27
29
"strconv"
28
30
"strings"
29
31
"testing"
@@ -63,22 +65,6 @@ func TestMain(m *testing.M) {
63
65
os .Exit (m .Run ())
64
66
}
65
67
66
- // func getTestBinaryServer(t *testing.T) *httptest.Server {
67
- // ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
68
- // raw, err := ioutil.ReadFile("getmesh")
69
- // require.NoError(t, err)
70
- // gz := gzip.NewWriter(w)
71
- // defer gz.Close()
72
- // tw := tar.NewWriter(gz)
73
- // defer tw.Close()
74
- // hdr := &tar.Header{Name: "getmesh", Mode: 0600, Size: int64(len(raw))}
75
- // require.NoError(t, tw.WriteHeader(hdr))
76
- // _, err = tw.Write(raw)
77
- // require.NoError(t, err)
78
- // }))
79
- // return ts
80
- // }
81
-
82
68
func Test_E2E (t * testing.T ) {
83
69
t .Run ("getmesh_install" , getmeshInstall )
84
70
t .Run ("list" , list )
@@ -127,40 +113,18 @@ func securityPatchChecker(t *testing.T) {
127
113
}
128
114
129
115
func getmeshInstall (t * testing.T ) {
130
- // TODO: revert after the next release
131
- // ts := getTestBinaryServer(t)
132
- // defer ts.Close()
133
- // env := append(os.Environ(), fmt.Sprintf("GETMESH_TEST_BINRAY_URL=%s", ts.URL))
134
-
135
- // cmd := exec.Command("bash", "site/install.sh")
136
- // cmd.Stdout = os.Stdout
137
- // cmd.Stderr = os.Stderr
138
- // cmd.Env = env
139
- // require.NoError(t, cmd.Run())
140
-
141
- // // check directory
142
- // u, err := user.Current()
143
- // require.NoError(t, err)
144
- // gh := filepath.Join(u.HomeDir, ".getmesh")
145
- // _, err = os.Stat(filepath.Join(gh, "bin/getmesh"))
146
- // require.NoError(t, err)
147
- // _, err = os.Stat(filepath.Join(gh, "istio"))
148
- // require.NoError(t, err)
149
-
150
- // // install again, and check if it does not break anything
151
- // cmd = exec.Command("bash", "site/install.sh")
152
- // cmd.Stdout = os.Stdout
153
- // cmd.Stderr = os.Stderr
154
- // cmd.Env = env
155
- // require.NoError(t, cmd.Run())
156
- // _, err = os.Stat(filepath.Join(gh, "bin/getmesh"))
157
- // require.NoError(t, err)
158
-
159
- cmd := exec .Command ("./getmesh" , "fetch" , "--version" , "1.9.5" ,
160
- "--flavor" , "tetrate" , "--flavor-version" , strconv .Itoa (0 ))
116
+ cmd := exec .Command ("bash" , "site/install.sh" )
161
117
cmd .Stdout = os .Stdout
162
118
cmd .Stderr = os .Stderr
163
119
require .NoError (t , cmd .Run ())
120
+
121
+ // check directory
122
+ u , err := user .Current ()
123
+ require .NoError (t , err )
124
+ _ , err = os .Stat (filepath .Join ("bin/getmesh" ))
125
+ require .NoError (t , err )
126
+ _ , err = os .Stat (filepath .Join (u .HomeDir , ".getmesh" , "istio" ))
127
+ require .NoError (t , err )
164
128
}
165
129
166
130
func enfOfLife (t * testing.T ) {
@@ -526,7 +490,6 @@ func version(t *testing.T) {
526
490
cmd .Stderr = os .Stderr
527
491
require .NoError (t , cmd .Run ())
528
492
actual := buf .String ()
529
- require .Contains (t , actual , "getmesh version: dev" )
530
493
require .Contains (t , actual , "active istioctl" )
531
494
// latest version is available
532
495
require .NotContains (t , actual , "control plane version" )
@@ -539,7 +502,6 @@ func version(t *testing.T) {
539
502
cmd .Stderr = os .Stderr
540
503
require .NoError (t , cmd .Run ())
541
504
actual := buf .String ()
542
- require .Contains (t , actual , "getmesh version: dev" )
543
505
require .Contains (t , actual , "active istioctl" )
544
506
require .Contains (t , actual , "no active Kubernetes clusters found" )
545
507
})
0 commit comments