Initialize logger directory to allow group access (#433)

internal/pkg/agent/cmd/container.go

@@ -806,6 +806,13 @@ func setPaths(statePath, configPath, logsPath string, writePaths bool) error {
 			return fmt.Errorf("preparing LOGS_PATH(%s) failed: %w", logsPath, err)
 		}
 	}
+
+	// ensure that the internal logger directory exists
+	loggerPath := filepath.Join(paths.Home(), logger.DefaultLogDirectory)
+	if err := os.MkdirAll(loggerPath, 0755); err != nil {
+		return fmt.Errorf("preparing internal log path(%s) failed: %w", loggerPath, err)
+	}
+
 	// persist the paths so other commands in the container will use the correct paths
 	if writePaths {
 		if err := writeContainerPaths(originalTop, statePath, configPath, logsPath); err != nil {

pkg/core/logger/logger.go

@@ -29,6 +29,9 @@ const iso8601Format = "2006-01-02T15:04:05.000Z0700"
 // DefaultLogLevel used in agent and its processes.
 const DefaultLogLevel = logp.InfoLevel
 
+// DefaultLogDirectory used in agent and its processes.
+const DefaultLogDirectory = "logs"
+
 // Logger alias ecslog.Logger with Logger.
 type Logger = logp.Logger
 
@@ -114,7 +117,7 @@ func makeInternalFileOutput(cfg *Config) (zapcore.Core, error) {
 	// defaultCfg is used to set the defaults for the file rotation of the internal logging
 	// these settings cannot be changed by a user configuration
 	defaultCfg := logp.DefaultConfig(logp.DefaultEnvironment)
-	filename := filepath.Join(paths.Home(), "logs", cfg.Beat)
+	filename := filepath.Join(paths.Home(), DefaultLogDirectory, cfg.Beat)
 
 	rotator, err := file.NewFileRotator(filename,
 		file.MaxSizeBytes(defaultCfg.Files.MaxSize),