mirror of
https://github.com/nabbar/golib.git
synced 2025-12-24 11:51:02 +08:00
- FIX: potential CWE-400 with bufio.ReadBytes & bufio.ReadSlices, with no limited read buffer - ADD: test to check overflow buffer with discard or error - REFACTOR: all buffering package, parsing process - UPDATE: doc, examples, test following changes - OPTIMIZE: rework code to optimize process - REWORK: benchmark to check benefice of optimization - FIX: wording error Package IOUtils/Multi: - REWORK: re-design all package to allow sequential/parallel mode - UPDATE: package with adaptive mode to allow switch automaticly between sequential and parallel mode following measurment of sample - OPTIMIZE: code to maximize bandwith and reduce time of write - UPDATE: documentation, test and comments - REWORK: testing organization and benchmark aggregation Package HttpServer: - FIX: bug with dial addr rewrite for healtcheck & testing PortUse Package Logger/HookFile: - FIX: bug with race condition on aggregator counter file Other: - Bump dependencies - FIX: format / import file
152 lines
5.0 KiB
Go
152 lines
5.0 KiB
Go
/*
|
|
* MIT License
|
|
*
|
|
* Copyright (c) 2025 Nicolas JUHEL
|
|
*
|
|
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
|
* of this software and associated documentation files (the "Software"), to deal
|
|
* in the Software without restriction, including without limitation the rights
|
|
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
|
* copies of the Software, and to permit persons to whom the Software is
|
|
* furnished to do so, subject to the following conditions:
|
|
*
|
|
* The above copyright notice and this permission notice shall be included in all
|
|
* copies or substantial portions of the Software.
|
|
*
|
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
|
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
|
|
* SOFTWARE.
|
|
*
|
|
*
|
|
*/
|
|
|
|
package ioutils
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"os"
|
|
"path/filepath"
|
|
)
|
|
|
|
// PathCheckCreate ensures a file or directory exists at the given path with the correct permissions.
|
|
//
|
|
// This function performs the following operations:
|
|
// - Checks if the path exists
|
|
// - Creates the path if it doesn't exist (file or directory based on isFile parameter)
|
|
// - Creates parent directories if needed
|
|
// - Validates that existing paths match the expected type (file vs directory)
|
|
// - Updates permissions if they don't match the specified values
|
|
//
|
|
// Parameters:
|
|
// - isFile: true to ensure path is a file, false for a directory
|
|
// - path: the filesystem path to check/create (should be absolute for predictable behavior)
|
|
// - permFile: permissions to apply to files (e.g., 0644 for rw-r--r--)
|
|
// - permDir: permissions to apply to directories (e.g., 0755 for rwxr-xr-x)
|
|
//
|
|
// Returns:
|
|
// - error: nil on success, or an error if:
|
|
// - The path exists but is the wrong type (file when directory expected, or vice versa)
|
|
// - Parent directory creation fails
|
|
// - Permission updates fail
|
|
// - File/directory creation fails
|
|
// - Path is empty or invalid
|
|
//
|
|
// Behavior:
|
|
// - If path exists as expected type: validates and updates permissions if needed
|
|
// - If path doesn't exist: creates it with specified permissions
|
|
// - If parent directories don't exist: creates them with permDir permissions
|
|
// - If path exists as wrong type: returns an error without modification
|
|
//
|
|
// Implementation Details:
|
|
// - Uses os.OpenRoot for atomic file creation on supported systems
|
|
// - Permission comparison checks full mode, not just permission bits
|
|
// - Recursively creates parent directories as needed
|
|
// - Attempts to set permissions even if initial mode is close
|
|
//
|
|
// Example:
|
|
//
|
|
// // Ensure config directory exists with 0755 permissions
|
|
// err := PathCheckCreate(false, "/etc/app/config", 0644, 0755)
|
|
//
|
|
// // Ensure log file exists with 0644 permissions
|
|
// err := PathCheckCreate(true, "/var/log/app.log", 0644, 0755)
|
|
//
|
|
// Thread Safety:
|
|
//
|
|
// This function is safe to call concurrently for different paths, but
|
|
// concurrent calls for the same path may result in race conditions.
|
|
// Use external synchronization if the same path may be accessed concurrently.
|
|
func PathCheckCreate(isFile bool, path string, permFile os.FileMode, permDir os.FileMode) error {
|
|
// Check if path exists and get its info
|
|
if inf, err := os.Stat(path); err != nil && !errors.Is(err, os.ErrNotExist) {
|
|
// Stat error other than "does not exist"
|
|
return err
|
|
} else if err == nil && inf.IsDir() {
|
|
// Path exists and is a directory
|
|
if isFile {
|
|
return fmt.Errorf("path '%s' already exists but is a directory", path)
|
|
}
|
|
// Update directory permissions if needed
|
|
if inf.Mode() != permDir {
|
|
_ = os.Chmod(path, permDir)
|
|
}
|
|
return nil
|
|
} else if err == nil && !inf.IsDir() {
|
|
// Path exists and is a file
|
|
if !isFile {
|
|
return fmt.Errorf("path '%s' already exists but is not a directory", path)
|
|
}
|
|
// Update file permissions if needed
|
|
if inf.Mode() != permFile {
|
|
_ = os.Chmod(path, permFile)
|
|
}
|
|
return nil
|
|
} else if !isFile {
|
|
// Path doesn't exist and we want a directory
|
|
return os.MkdirAll(path, permDir)
|
|
} else if err = PathCheckCreate(false, filepath.Dir(path), permFile, permDir); err != nil {
|
|
// Path doesn't exist and we want a file - ensure parent directory exists
|
|
return err
|
|
}
|
|
|
|
// Open root directory for atomic file creation
|
|
rt, e := os.OpenRoot(filepath.Dir(path))
|
|
|
|
defer func() {
|
|
if rt != nil {
|
|
_ = rt.Close()
|
|
}
|
|
}()
|
|
|
|
if e != nil {
|
|
return e
|
|
}
|
|
|
|
// Create the file atomically
|
|
hf, e := rt.Create(filepath.Base(path))
|
|
|
|
defer func() {
|
|
if hf != nil {
|
|
_ = hf.Close()
|
|
}
|
|
}()
|
|
|
|
if e != nil {
|
|
return e
|
|
}
|
|
|
|
// Close file handle before setting permissions
|
|
_ = hf.Close()
|
|
hf = nil
|
|
|
|
// Set file permissions
|
|
_ = rt.Chmod(filepath.Base(path), permFile)
|
|
|
|
return nil
|
|
}
|