Skip to content

Commit bb1b271

Browse files
Andrew-Lees11GitHub Enterprise
authored andcommitted
Move log file and output directory creation to after verification (#92)
1 parent e1f4a3a commit bb1b271

File tree

2 files changed

+24
-33
lines changed

2 files changed

+24
-33
lines changed

cmd/mustgather/main.go

Lines changed: 2 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -121,36 +121,19 @@ func setDefaultFlags(flags *utils.MustGatherFlags) error {
121121
flags.KubeconfigPath = filepath.Join(homeDir, ".kube/config")
122122
}
123123

124-
timestamp := utils.GetCurrentTimestamp(utils.TimestampFormat)
125124
if flags.OutputDir == "" {
126125
currentWorkingDir, err := os.Getwd()
127126
if err != nil {
128127
return fmt.Errorf("error getting user's current working directory: %v", err)
129128
}
130-
131-
flags.OutputDir = filepath.Join(currentWorkingDir, fmt.Sprintf("Must_Gather_%v", timestamp))
132-
// If OutputDir doesnot exist create the directory
133-
directoryExist := utils.CheckIfDirectoryExist(flags.OutputDir)
134-
if !directoryExist {
135-
if err := utils.CreateDirectory(flags.OutputDir, 0775); err != nil {
136-
return err
137-
}
138-
}
139-
return nil
129+
flags.OutputDir = currentWorkingDir
140130
}
141131

142132
// create a directory inside the output directory, because we don't want to zip the entire outputDir, as it may contain other files apart from must-gather details
133+
timestamp := utils.GetCurrentTimestamp(utils.TimestampFormat)
143134
outputDir := filepath.Join(flags.OutputDir, fmt.Sprintf("Must_Gather_%v", timestamp))
144135
flags.OutputDir = outputDir
145136

146-
// If OutputDir doesnot exist create the directory
147-
directoryExist := utils.CheckIfDirectoryExist(flags.OutputDir)
148-
if !directoryExist {
149-
if err := utils.CreateDirectory(flags.OutputDir, 0775); err != nil {
150-
return err
151-
}
152-
}
153-
154137
return nil
155138

156139
}

internal/mustgather/main.go

Lines changed: 22 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -31,20 +31,6 @@ import (
3131

3232
func MustGather(cfg *rest.Config, flags utils.MustGatherFlags) error {
3333

34-
// initialize logger
35-
logFile, err := utils.InitializeLogFile(flags.OutputDir, utils.MustGatherLogFileName)
36-
if err != nil {
37-
return err
38-
}
39-
defer func(f *os.File) {
40-
if err := f.Close(); err != nil {
41-
fmt.Printf("error closing logFile %v", err)
42-
}
43-
}(logFile)
44-
45-
handler := slog.NewTextHandler(logFile, nil)
46-
logger := slog.New(handler)
47-
4834
// build the required clients
4935
coreClient, err := kubeclient.BuildKubernetesClientFromConfig(cfg)
5036
if err != nil {
@@ -83,6 +69,28 @@ func MustGather(cfg *rest.Config, flags utils.MustGatherFlags) error {
8369
qmPod = pod
8470
}
8571

72+
// If OutputDir doesnot exist create the directory
73+
directoryExist := utils.CheckIfDirectoryExist(flags.OutputDir)
74+
if !directoryExist {
75+
if err := utils.CreateDirectory(flags.OutputDir, 0775); err != nil {
76+
return err
77+
}
78+
}
79+
80+
// initialize logger
81+
logFile, err := utils.InitializeLogFile(flags.OutputDir, utils.MustGatherLogFileName)
82+
if err != nil {
83+
return err
84+
}
85+
defer func(f *os.File) {
86+
if err := f.Close(); err != nil {
87+
fmt.Printf("error closing logFile %v", err)
88+
}
89+
}(logFile)
90+
91+
handler := slog.NewTextHandler(logFile, nil)
92+
logger := slog.New(handler)
93+
8694
logger.Info("---- Starting Must-Gather tool ----")
8795

8896
mustGatherToolStartTime := time.Now()

0 commit comments

Comments
 (0)