Refresh token in logs is disabled for Korifi

- Configured with `Config.IsCFOnK8s`

Co-authored-by: Clint Yoshimura <clinty@vmware.com>

command/v7/logs_command.go

@@ -58,20 +58,23 @@ func (cmd LogsCommand) Execute(args []string) error {
 		return cmd.displayRecentLogs()
 	}
 
-	stop := make(chan struct{})
-	stoppedRefreshing := make(chan struct{})
-	stoppedOutputtingRefreshErrors := make(chan struct{})
-	err = cmd.refreshTokenPeriodically(stop, stoppedRefreshing, stoppedOutputtingRefreshErrors)
-	if err != nil {
-		return err
+	if !cmd.Config.IsCFOnK8s() {
+		stop := make(chan struct{})
+		stoppedRefreshing := make(chan struct{})
+		stoppedOutputtingRefreshErrors := make(chan struct{})
+		err = cmd.refreshTokenPeriodically(stop, stoppedRefreshing, stoppedOutputtingRefreshErrors)
+		if err != nil {
+			return err
+		}
+		defer func() {
+			close(stop)
+			<-stoppedRefreshing
+			<-stoppedOutputtingRefreshErrors
+		}()
 	}
 
 	err = cmd.streamLogs()
 
-	close(stop)
-	<-stoppedRefreshing
-	<-stoppedOutputtingRefreshErrors
-
 	return err
 }
 

command/v7/logs_command_test.go

@@ -248,6 +248,16 @@ var _ = Describe("logs command", func() {
 					})
 				})
 
+				When("isCFOnK8s is true", func() {
+					BeforeEach(func() {
+						fakeConfig.IsCFOnK8sReturns(true)
+					})
+
+					It("does not call ScheduleTokenRefresh", func() {
+						Expect(fakeActor.ScheduleTokenRefreshCallCount()).To(Equal(0))
+					})
+				})
+
 				It("displays the error and all warnings", func() {
 					Expect(executeErr).NotTo(HaveOccurred())
 					Expect(testUI.Err).To(Say("steve for all I care"))