@@ -3,6 +3,11 @@ package restarthelper
33import (
44 "bufio"
55 "context"
6+ "io"
7+ "os"
8+ "strings"
9+ "time"
10+
611 "github.com/loft-sh/devspace/cmd"
712 "github.com/loft-sh/devspace/cmd/flags"
813 "github.com/loft-sh/devspace/e2e/framework"
@@ -13,9 +18,6 @@ import (
1318 "github.com/onsi/ginkgo/v2"
1419 "github.com/onsi/gomega"
1520 "github.com/sirupsen/logrus"
16- "os"
17- "strings"
18- "time"
1921)
2022
2123var _ = DevSpaceDescribe ("restarthelper" , func () {
@@ -55,6 +57,10 @@ var _ = DevSpaceDescribe("restarthelper", func() {
5557 reader , writer , err := os .Pipe ()
5658 framework .ExpectNoError (err )
5759
60+ teeReader := io .TeeReader (reader , os .Stdout )
61+ scanner := bufio .NewScanner (teeReader )
62+ scanner .Split (scanner2 .ScanLines )
63+
5864 //output := &bytes.Buffer{}
5965 log := logpkg .NewStreamLogger (writer , writer , logrus .DebugLevel )
6066
@@ -63,6 +69,7 @@ var _ = DevSpaceDescribe("restarthelper", func() {
6369 GlobalFlags : & flags.GlobalFlags {
6470 NoWarn : true ,
6571 Namespace : ns ,
72+ Debug : true ,
6673 },
6774 Pipeline : "dev" ,
6875 SkipPush : true ,
@@ -76,9 +83,6 @@ var _ = DevSpaceDescribe("restarthelper", func() {
7683 done <- err
7784 }()
7885
79- scanner := bufio .NewScanner (reader )
80- scanner .Split (scanner2 .ScanLines )
81-
8286 waitSeen := false
8387 waitCount := 0
8488 waitMax := 3
@@ -105,10 +109,6 @@ var _ = DevSpaceDescribe("restarthelper", func() {
105109 }
106110 }
107111
108- if waitSeen && ! hasWaitingMessage {
109- break
110- }
111-
112112 if waitCount > waitMax {
113113 break
114114 }
@@ -138,6 +138,10 @@ var _ = DevSpaceDescribe("restarthelper", func() {
138138 reader , writer , err := os .Pipe ()
139139 framework .ExpectNoError (err )
140140
141+ teeReader := io .TeeReader (reader , os .Stdout )
142+ scanner := bufio .NewScanner (teeReader )
143+ scanner .Split (scanner2 .ScanLines )
144+
141145 //output := &bytes.Buffer{}
142146 log := logpkg .NewStreamLogger (writer , writer , logrus .DebugLevel )
143147
@@ -146,6 +150,7 @@ var _ = DevSpaceDescribe("restarthelper", func() {
146150 GlobalFlags : & flags.GlobalFlags {
147151 NoWarn : true ,
148152 Namespace : ns ,
153+ Debug : true ,
149154 },
150155 Pipeline : "dev" ,
151156 SkipPush : true ,
@@ -159,14 +164,11 @@ var _ = DevSpaceDescribe("restarthelper", func() {
159164 done <- err
160165 }()
161166
162- scanner := bufio .NewScanner (reader )
163- scanner .Split (scanner2 .ScanLines )
164-
165167 waitSeen := false
166168 waitCount := 0
167169 waitMax := 3
168170 waitingMessage := "(Still waiting...)"
169- startedMessage := "Started with restart helper "
171+ startedMessage := "Started with dev command entrypoint "
170172 startedSeen := false
171173
172174 for scanner .Scan () {
@@ -188,10 +190,6 @@ var _ = DevSpaceDescribe("restarthelper", func() {
188190 }
189191 }
190192
191- if waitSeen && ! hasWaitingMessage {
192- break
193- }
194-
195193 if waitCount > waitMax {
196194 break
197195 }
@@ -221,6 +219,10 @@ var _ = DevSpaceDescribe("restarthelper", func() {
221219 reader , writer , err := os .Pipe ()
222220 framework .ExpectNoError (err )
223221
222+ teeReader := io .TeeReader (reader , os .Stdout )
223+ scanner := bufio .NewScanner (teeReader )
224+ scanner .Split (scanner2 .ScanLines )
225+
224226 //output := &bytes.Buffer{}
225227 log := logpkg .NewStreamLogger (writer , writer , logrus .DebugLevel )
226228
@@ -229,6 +231,7 @@ var _ = DevSpaceDescribe("restarthelper", func() {
229231 GlobalFlags : & flags.GlobalFlags {
230232 NoWarn : true ,
231233 Namespace : ns ,
234+ Debug : true ,
232235 },
233236 Pipeline : "dev" ,
234237 SkipPush : true ,
@@ -242,16 +245,13 @@ var _ = DevSpaceDescribe("restarthelper", func() {
242245 done <- err
243246 }()
244247
245- scanner := bufio .NewScanner (reader )
246- scanner .Split (scanner2 .ScanLines )
247-
248248 waitSeen := false
249249 waitCount := 0
250250 waitMax := 3
251251 waitingMessage := "(Still waiting...)"
252- startedMessage := "Started with restart helper "
252+ startedMessage := "Started with dev command entrypoint "
253253 startedSeen := false
254- legacyStartedMessage := "Started with restart helper"
254+ legacyStartedMessage := "Started with legacy restart helper"
255255 legacyStartedSeen := false
256256
257257 for scanner .Scan () {
@@ -279,10 +279,6 @@ var _ = DevSpaceDescribe("restarthelper", func() {
279279 }
280280 }
281281
282- if waitSeen && ! hasWaitingMessage {
283- break
284- }
285-
286282 if waitCount > waitMax {
287283 break
288284 }
@@ -313,6 +309,10 @@ var _ = DevSpaceDescribe("restarthelper", func() {
313309 reader , writer , err := os .Pipe ()
314310 framework .ExpectNoError (err )
315311
312+ teeReader := io .TeeReader (reader , os .Stdout )
313+ scanner := bufio .NewScanner (teeReader )
314+ scanner .Split (scanner2 .ScanLines )
315+
316316 //output := &bytes.Buffer{}
317317 log := logpkg .NewStreamLogger (writer , writer , logrus .DebugLevel )
318318
@@ -321,6 +321,7 @@ var _ = DevSpaceDescribe("restarthelper", func() {
321321 GlobalFlags : & flags.GlobalFlags {
322322 NoWarn : true ,
323323 Namespace : ns ,
324+ Debug : true ,
324325 },
325326 Pipeline : "dev" ,
326327 SkipPush : true ,
@@ -334,9 +335,6 @@ var _ = DevSpaceDescribe("restarthelper", func() {
334335 done <- err
335336 }()
336337
337- scanner := bufio .NewScanner (reader )
338- scanner .Split (scanner2 .ScanLines )
339-
340338 waitSeen := false
341339 waitCount := 0
342340 waitMax := 3
@@ -363,10 +361,6 @@ var _ = DevSpaceDescribe("restarthelper", func() {
363361 }
364362 }
365363
366- if waitSeen && ! hasWaitingMessage {
367- break
368- }
369-
370364 if waitCount > waitMax {
371365 break
372366 }
0 commit comments