FileSink.h

#pragma once

#include "quill/core/Attributes.h"
#include "quill/core/Common.h"
#include "quill/core/Filesystem.h"
#include "quill/core/QuillError.h"
#include "quill/core/ThreadPrimitives.h"
#include "quill/core/TimeUtilities.h"
#include "quill/sinks/StreamSink.h"

#include <cerrno>
#include <chrono>
#include <cstdint>
#include <cstdio>
#include <cstring>
#include <ctime>
#include <memory>
#include <string>
#include <string_view>
#include <utility>
#include <vector>

#if defined(_WIN32)
  #if !defined(WIN32_LEAN_AND_MEAN)
    #define WIN32_LEAN_AND_MEAN
  #endif

  #if !defined(NOMINMAX)
    // Mingw already defines this, so no need to redefine
    #define NOMINMAX
  #endif

  #include <io.h>
  #include <share.h>
  #include <windows.h>
#else
  #include <fcntl.h>
  #include <unistd.h>
#endif

QUILL_BEGIN_NAMESPACE

#if defined(_WIN32) && defined(_MSC_VER) && !defined(__GNUC__)
  #pragma warning(push)
  #pragma warning(disable : 4996)
#endif

QUILL_BEGIN_EXPORT

enum class FilenameAppendOption : uint8_t
{
  None,
  StartDate,
  StartDateTime,
  StartCustomTimestampFormat
};

class FileSinkConfig
{
public:
  QUILL_ATTRIBUTE_COLD void set_filename_append_option(
    FilenameAppendOption value, std::string_view append_filename_format_pattern = std::string_view{})
  {
    _filename_append_option = value;

    if (_filename_append_option == FilenameAppendOption::StartCustomTimestampFormat)
    {
      if (append_filename_format_pattern.empty())
      {
        QUILL_THROW(
          QuillError{"The 'StartCustomTimestampFormat' option was specified, but no format pattern "
                     "was provided. "
                     "Please set a valid strftime format pattern"});
      }

      _append_filename_format_pattern = append_filename_format_pattern;
    }
    else if (_filename_append_option == FilenameAppendOption::StartDateTime)
    {
      _append_filename_format_pattern = "_%Y%m%d_%H%M%S";
    }
    else if (_filename_append_option == FilenameAppendOption::StartDate)
    {
      _append_filename_format_pattern = "_%Y%m%d";
    }
  }

  QUILL_ATTRIBUTE_COLD void set_timezone(Timezone time_zone) { _time_zone = time_zone; }

  QUILL_ATTRIBUTE_COLD void set_fsync_enabled(bool value) { _fsync_enabled = value; }

  QUILL_ATTRIBUTE_COLD void set_open_mode(char open_mode) { _open_mode = open_mode; }

  QUILL_ATTRIBUTE_COLD void set_open_mode(std::string_view open_mode) { _open_mode = open_mode; }

  QUILL_ATTRIBUTE_COLD void set_write_buffer_size(size_t value)
  {
    _write_buffer_size = (value == 0) ? 0 : ((value < 4096) ? 4096 : value);
  }

  QUILL_ATTRIBUTE_COLD void set_minimum_fsync_interval(std::chrono::milliseconds value)
  {
    _minimum_fsync_interval = value;
  }

  QUILL_ATTRIBUTE_COLD void set_override_pattern_formatter_options(std::optional<PatternFormatterOptions> const& options)
  {
    _override_pattern_formatter_options = options;
  }

  QUILL_NODISCARD bool fsync_enabled() const noexcept { return _fsync_enabled; }
  QUILL_NODISCARD Timezone timezone() const noexcept { return _time_zone; }
  QUILL_NODISCARD FilenameAppendOption filename_append_option() const noexcept
  {
    return _filename_append_option;
  }
  QUILL_NODISCARD std::string const& append_filename_format_pattern() const noexcept
  {
    return _append_filename_format_pattern;
  }
  QUILL_NODISCARD std::string const& open_mode() const noexcept { return _open_mode; }
  QUILL_NODISCARD size_t write_buffer_size() const noexcept { return _write_buffer_size; }
  QUILL_NODISCARD std::chrono::milliseconds minimum_fsync_interval() const noexcept
  {
    return _minimum_fsync_interval;
  }
  QUILL_NODISCARD std::optional<PatternFormatterOptions> const& override_pattern_formatter_options() const noexcept
  {
    return _override_pattern_formatter_options;
  }

private:
  std::string _open_mode{'a'};
  std::string _append_filename_format_pattern;
  size_t _write_buffer_size{64 * 1024}; // Default size 64k
  std::chrono::milliseconds _minimum_fsync_interval{0};
  std::optional<PatternFormatterOptions> _override_pattern_formatter_options;
  Timezone _time_zone{Timezone::LocalTime};
  FilenameAppendOption _filename_append_option{FilenameAppendOption::None};
  bool _fsync_enabled{false};
};

#if defined(_WIN32)
class FileSinkBase : public StreamSink
{
public:
  explicit FileSinkBase(fs::path const& filename, FileSinkConfig const& config, FileEventNotifier file_event_notifier,
                        bool /* do_fopen */, std::chrono::system_clock::time_point start_time)
    : StreamSink(_get_updated_filename_with_appended_datetime(filename, config.filename_append_option(),
                                                              config.append_filename_format_pattern(),
                                                              config.timezone(), start_time),
                 nullptr, config.override_pattern_formatter_options(), std::move(file_event_notifier)),
      _config(config)
  {
    if (!_config.fsync_enabled() && (_config.minimum_fsync_interval().count() != 0))
    {
      QUILL_THROW(
        QuillError{"Cannot set a non-zero minimum fsync interval when fsync is disabled."});
    }
  }

  ~FileSinkBase() override = default;

protected:
  QUILL_NODISCARD static std::string format_datetime_string(uint64_t timestamp_ns, Timezone time_zone,
                                                            std::string const& append_format_pattern)
  {
    auto const time_now = static_cast<time_t>(timestamp_ns / 1000000000);
    tm now_tm;

    if (time_zone == Timezone::GmtTime)
    {
      detail::gmtime_rs(&time_now, &now_tm);
    }
    else
    {
      detail::localtime_rs(&time_now, &now_tm);
    }

    static constexpr size_t buffer_size{128};
    static constexpr size_t max_buffer_size{64 * 1024};
    std::vector<char> buffer(buffer_size);

    while (true)
    {
      size_t const len = std::strftime(buffer.data(), buffer.size(), append_format_pattern.data(), &now_tm);
      if (len != 0)
      {
        return std::string{buffer.data(), len};
      }

      if (buffer.size() >= max_buffer_size)
      {
        QUILL_THROW(
          QuillError{"strftime failed to format filename timestamp. The filename "
                     "timestamp pattern may contain an unsupported format specifier."});
      }

      buffer.resize(buffer.size() * 2);
    }
  }

  QUILL_NODISCARD static std::pair<std::string, std::string> extract_stem_and_extension(fs::path const& filename)
  {
    return std::make_pair((filename.parent_path() / filename.stem()).string(), filename.extension().string());
  }

  QUILL_NODISCARD static fs::path append_datetime_to_filename(fs::path const& filename,
                                                              std::string const& append_filename_format_pattern,
                                                              Timezone time_zone,
                                                              std::chrono::system_clock::time_point timestamp)
  {
    auto const [stem, ext] = extract_stem_and_extension(filename);

    uint64_t const timestamp_ns = static_cast<uint64_t>(
      std::chrono::duration_cast<std::chrono::nanoseconds>(timestamp.time_since_epoch()).count());

    return stem + format_datetime_string(timestamp_ns, time_zone, append_filename_format_pattern) + ext;
  }

private:
  QUILL_NODISCARD static fs::path _get_updated_filename_with_appended_datetime(
    fs::path const& filename, FilenameAppendOption append_to_filename_option,
    std::string const& append_filename_format_pattern, Timezone time_zone,
    std::chrono::system_clock::time_point timestamp)
  {
    if ((append_to_filename_option == FilenameAppendOption::None) || (filename == "/dev/null"))
    {
      return filename;
    }

    if ((append_to_filename_option == FilenameAppendOption::StartCustomTimestampFormat) ||
        (append_to_filename_option == FilenameAppendOption::StartDate) ||
        (append_to_filename_option == FilenameAppendOption::StartDateTime))
    {
      return append_datetime_to_filename(filename, append_filename_format_pattern, time_zone, timestamp);
    }

    QUILL_THROW(QuillError{"Unexpected FilenameAppendOption value"});
  }

protected:
  FileSinkConfig _config;
  std::chrono::steady_clock::time_point _last_fsync_timestamp{};
};

class FileSink : public FileSinkBase
{
public:
  explicit FileSink(fs::path const& filename, FileSinkConfig const& config = FileSinkConfig{},
                    FileEventNotifier file_event_notifier = FileEventNotifier{}, bool do_fopen = true,
                    std::chrono::system_clock::time_point start_time = std::chrono::system_clock::now())
    : FileSinkBase(filename, config, std::move(file_event_notifier), do_fopen, start_time)
  {
    if (do_fopen && !is_null())
    {
      open_file(_filename, _config.open_mode());
    }
  }

  ~FileSink() override { _close_file_noexcept(); }

  QUILL_ATTRIBUTE_HOT void flush_sink() override
  {
    if (!_write_occurred)
    {
      return;
    }

    _flush_native_write_buffer();
    _write_occurred = false;

    if (_config.fsync_enabled())
    {
      fsync_file();
    }

    std::error_code ec;
    if (!fs::exists(_filename, ec))
    {
      close_file();
      open_file(_filename, _config.open_mode());
    }
  }

  QUILL_ATTRIBUTE_HOT void write_log(MacroMetadata const* /* log_metadata */,
                                     uint64_t /* log_timestamp */, std::string_view /* thread_id */,
                                     std::string_view /* thread_name */, std::string const& /* process_id */,
                                     std::string_view /* logger_name */, LogLevel /* log_level */,
                                     std::string_view /* log_level_description */,
                                     std::string_view /* log_level_short_code */,
                                     std::vector<std::pair<std::string, std::string>> const* /* named_args */,
                                     std::string_view /* log_message */, std::string_view log_statement) override
  {
    if (QUILL_UNLIKELY(_native_file_handle == INVALID_HANDLE_VALUE))
    {
      return;
    }

    std::string_view statement = log_statement;
    std::string user_log_statement;

    if (_file_event_notifier.before_write)
    {
      user_log_statement = _file_event_notifier.before_write(log_statement);
      statement = user_log_statement;
    }

    auto const stmt_size = statement.size();

    if (_native_write_pos + stmt_size > _native_write_buffer_cap)
    {
      _flush_native_write_buffer();
    }

    if (QUILL_LIKELY(stmt_size <= _native_write_buffer_cap))
    {
      std::memcpy(_native_write_buffer.get() + _native_write_pos, statement.data(), stmt_size);
      _native_write_pos += stmt_size;
    }
    else
    {
      _write_to_file(statement.data(), stmt_size);
    }

    _file_size += stmt_size;
    _write_occurred = true;
  }

protected:
  void open_file(fs::path const& filename, std::string const& mode)
  {
    if (_file_event_notifier.before_open)
    {
      _file_event_notifier.before_open(filename);
    }

    constexpr int max_retries = 3;
    constexpr int retry_delay_ms = 200;
    HANDLE native_file_handle = INVALID_HANDLE_VALUE;
    DWORD last_error = 0;

    for (int attempt = 0; attempt < max_retries; ++attempt)
    {
      DWORD creation_disposition = OPEN_ALWAYS;
      if (!mode.empty() && mode[0] == 'w')
      {
        creation_disposition = CREATE_ALWAYS;
      }

      native_file_handle = ::CreateFileW(filename.c_str(), GENERIC_WRITE,
                                         FILE_SHARE_READ | FILE_SHARE_WRITE | FILE_SHARE_DELETE,
        nullptr, creation_disposition, FILE_ATTRIBUTE_NORMAL | FILE_FLAG_SEQUENTIAL_SCAN, nullptr);

      if (native_file_handle == INVALID_HANDLE_VALUE)
      {
        last_error = ::GetLastError();
      }
      else
      {
        if (!::SetHandleInformation(native_file_handle, HANDLE_FLAG_INHERIT, 0))
        {
          last_error = ::GetLastError();
          ::CloseHandle(native_file_handle);
          native_file_handle = INVALID_HANDLE_VALUE;
        }
      }

      if (native_file_handle != INVALID_HANDLE_VALUE)
      {
        break;
      }

      if (attempt < max_retries - 1)
      {
        detail::sleep_for_ns(static_cast<uint64_t>(retry_delay_ms) * 1'000'000ull);
      }
    }

    if (native_file_handle == INVALID_HANDLE_VALUE)
    {
      QUILL_THROW(QuillError{std::string{"CreateFileW failed after "} + std::to_string(max_retries) +
                             " attempts, path: " + filename.string() + " mode: " + mode +
                             " GetLastError: " + std::to_string(last_error)});
    }

    _native_write_buffer_cap = _native_write_buffer_capacity();
    _native_write_buffer = std::make_unique<char[]>(_native_write_buffer_cap);
    _native_write_pos = 0;

    if (_file_event_notifier.after_open)
    {
      QUILL_TRY { _file_event_notifier.after_open(filename, native_file_handle); }
  #if !defined(QUILL_NO_EXCEPTIONS)
      QUILL_CATCH(...)
      {
        ::CloseHandle(native_file_handle);
        throw;
      }
  #endif
    }

    _append_mode = !mode.empty() && mode[0] == 'a';
    _native_file_handle = native_file_handle;
  }

  void close_file()
  {
    if (_native_file_handle == INVALID_HANDLE_VALUE)
    {
      return;
    }

    if (_file_event_notifier.before_close)
    {
      QUILL_TRY { _file_event_notifier.before_close(_filename, _native_file_handle); }
  #if !defined(QUILL_NO_EXCEPTIONS)
      QUILL_CATCH_ALL()
      {
        HANDLE native_file_handle = _native_file_handle;
        QUILL_TRY { _flush_native_write_buffer(); }
        QUILL_CATCH_ALL() {}
        _native_file_handle = INVALID_HANDLE_VALUE;
        _append_mode = false;
        _native_write_pos = 0;
        ::CloseHandle(native_file_handle);
        throw;
      }
  #endif
    }

    _flush_native_write_buffer();
    ::CloseHandle(_native_file_handle);
    _native_file_handle = INVALID_HANDLE_VALUE;
    _append_mode = false;
    _native_write_pos = 0;

    if (_file_event_notifier.after_close)
    {
      _file_event_notifier.after_close(_filename);
    }
  }

  void _close_file_noexcept() noexcept
  {
    QUILL_TRY { close_file(); }
  #if !defined(QUILL_NO_EXCEPTIONS)
    QUILL_CATCH_ALL() {}
  #endif
  }

  void fsync_file(bool force_fsync = false)
  {
    if (_native_file_handle == INVALID_HANDLE_VALUE)
    {
      return;
    }

    std::chrono::steady_clock::time_point fsync_timestamp{};

    if (!force_fsync)
    {
      fsync_timestamp = std::chrono::steady_clock::now();
      if ((fsync_timestamp - _last_fsync_timestamp) < _config.minimum_fsync_interval())
      {
        return;
      }
    }

    if (!::FlushFileBuffers(_native_file_handle))
    {
      _write_occurred = true;
      QUILL_THROW(QuillError{std::string{"FlushFileBuffers failed. GetLastError: "} +
                             std::to_string(::GetLastError())});
    }

    if (!force_fsync)
    {
      _last_fsync_timestamp = fsync_timestamp;
    }
  }

  QUILL_NODISCARD bool is_open() const noexcept
  {
    return _native_file_handle != INVALID_HANDLE_VALUE;
  }

  void _write_to_file(char const* data, size_t size)
  {
    while (size != 0)
    {
      DWORD bytes_written = 0;
      constexpr size_t max_dword = static_cast<size_t>(~DWORD{0});
      DWORD const chunk = static_cast<DWORD>(std::min<size_t>(size, max_dword));
      OVERLAPPED overlapped{};
      OVERLAPPED* overlapped_ptr{nullptr};

      if (_append_mode)
      {
        overlapped.Offset = 0xFFFFFFFF;
        overlapped.OffsetHigh = 0xFFFFFFFF;
        overlapped_ptr = &overlapped;
      }

      if (!::WriteFile(_native_file_handle, data, chunk, &bytes_written, overlapped_ptr) ||
          (bytes_written == 0))
      {
        QUILL_THROW(QuillError{std::string{"WriteFile failed. GetLastError: "} +
                               std::to_string(::GetLastError())});
      }

      data += bytes_written;
      size -= bytes_written;
    }
  }

  void _flush_native_write_buffer()
  {
    if ((_native_file_handle == INVALID_HANDLE_VALUE) || (_native_write_pos == 0))
    {
      return;
    }

    _write_to_file(_native_write_buffer.get(), _native_write_pos);
    _native_write_pos = 0;
  }

  QUILL_NODISCARD size_t _native_write_buffer_capacity() const noexcept
  {
    return _config.write_buffer_size() == 0 ? default_write_buffer_size : _config.write_buffer_size();
  }

protected:
  static constexpr size_t default_write_buffer_size{64 * 1024};
  HANDLE _native_file_handle{INVALID_HANDLE_VALUE};
  std::unique_ptr<char[]> _native_write_buffer;
  size_t _native_write_pos{0};
  size_t _native_write_buffer_cap{0};
  bool _append_mode{false};
};
#else
class FileSink : public StreamSink
{
public:
  explicit FileSink(fs::path const& filename, FileSinkConfig const& config = FileSinkConfig{},
                    FileEventNotifier file_event_notifier = FileEventNotifier{}, bool do_fopen = true,
                    std::chrono::system_clock::time_point start_time = std::chrono::system_clock::now())
    : StreamSink(_get_updated_filename_with_appended_datetime(filename, config.filename_append_option(),
                                                              config.append_filename_format_pattern(),
                                                              config.timezone(), start_time),
                 nullptr, config.override_pattern_formatter_options(), std::move(file_event_notifier)),
      _config(config)
  {
    if (!_config.fsync_enabled() && (_config.minimum_fsync_interval().count() != 0))
    {
      QUILL_THROW(
        QuillError{"Cannot set a non-zero minimum fsync interval when fsync is disabled."});
    }

    if (do_fopen)
    {
      open_file(_filename, _config.open_mode());
    }
  }

  ~FileSink() override { _close_file_noexcept(); }

  QUILL_ATTRIBUTE_HOT void flush_sink() override
  {
    if (!_write_occurred || !_file)
    {
      return;
    }

    StreamSink::flush_sink();

    if (_config.fsync_enabled())
    {
      fsync_file();
    }

    std::error_code ec;
    if (!fs::exists(_filename, ec))
    {
      close_file();
      open_file(_filename, _config.open_mode());
    }
  }

private:
  struct OpenedFileGuard
  {
    ~OpenedFileGuard()
    {
      if (file)
      {
        std::fclose(file);
      }
    }

    QUILL_NODISCARD FILE* release() noexcept
    {
      FILE* const released_file = file;
      file = nullptr;
      return released_file;
    }

    FILE* file{nullptr};
  };

protected:
  QUILL_NODISCARD static std::string format_datetime_string(uint64_t timestamp_ns, Timezone time_zone,
                                                            std::string const& append_format_pattern)
  {
    auto const time_now = static_cast<time_t>(timestamp_ns / 1000000000);
    tm now_tm;

    if (time_zone == Timezone::GmtTime)
    {
      detail::gmtime_rs(&time_now, &now_tm);
    }
    else
    {
      detail::localtime_rs(&time_now, &now_tm);
    }

    static constexpr size_t buffer_size{128};
    static constexpr size_t max_buffer_size{64 * 1024};
    std::vector<char> buffer(buffer_size);

    while (true)
    {
      size_t const len = std::strftime(buffer.data(), buffer.size(), append_format_pattern.data(), &now_tm);
      if (len != 0)
      {
        return std::string{buffer.data(), len};
      }

      if (buffer.size() >= max_buffer_size)
      {
        QUILL_THROW(
          QuillError{"strftime failed to format filename timestamp. The filename "
                     "timestamp pattern may contain an unsupported format specifier."});
      }

      buffer.resize(buffer.size() * 2);
    }
  }

  QUILL_NODISCARD static std::pair<std::string, std::string> extract_stem_and_extension(fs::path const& filename)
  {
    return std::make_pair((filename.parent_path() / filename.stem()).string(), filename.extension().string());
  }

  QUILL_NODISCARD static fs::path append_datetime_to_filename(fs::path const& filename,
                                                              std::string const& append_filename_format_pattern,
                                                              Timezone time_zone,
                                                              std::chrono::system_clock::time_point timestamp)
  {
    auto const [stem, ext] = extract_stem_and_extension(filename);

    uint64_t const timestamp_ns = static_cast<uint64_t>(
      std::chrono::duration_cast<std::chrono::nanoseconds>(timestamp.time_since_epoch()).count());

    return stem + format_datetime_string(timestamp_ns, time_zone, append_filename_format_pattern) + ext;
  }

  void open_file(fs::path const& filename, std::string const& mode)
  {
    if (_file_event_notifier.before_open)
    {
      _file_event_notifier.before_open(filename);
    }

    constexpr int max_retries = 3;
    constexpr int retry_delay_ms = 200;
    std::unique_ptr<char[]> write_buffer;
    OpenedFileGuard opened_file_guard;

    for (int attempt = 0; attempt < max_retries; ++attempt)
    {
      int flags = O_CREAT | O_WRONLY | O_CLOEXEC;
      flags |= (!mode.empty() && mode[0] == 'w') ? O_TRUNC : O_APPEND;

      // Retry on EINTR — a signal delivered during open() causes it to fail transiently.
      int fd{-1};
      do
      {
        fd = ::open(filename.string().data(), flags, 0644);
      } while (fd == -1 && errno == EINTR);

      if (fd != -1)
      {
        opened_file_guard.file = ::fdopen(fd, mode.data());
        if (!opened_file_guard.file)
        {
          ::close(fd);
        }
      }

      if (opened_file_guard.file)
      {
        break;
      }

      if (attempt < max_retries - 1)
      {
        detail::sleep_for_ns(static_cast<uint64_t>(retry_delay_ms) * 1'000'000ull);
      }
    }

    if (!opened_file_guard.file)
    {
      QUILL_THROW(QuillError{std::string{"fopen failed after "} + std::to_string(max_retries) +
                             " attempts, path: " + filename.string() + " mode: " + mode +
                             " errno: " + std::to_string(errno) + " error: " + std::strerror(errno)});
    }

    if (_config.write_buffer_size() != 0)
    {
      write_buffer = std::make_unique<char[]>(_config.write_buffer_size());

      if (setvbuf(opened_file_guard.file, write_buffer.get(), _IOFBF, _config.write_buffer_size()) != 0)
      {
        QUILL_THROW(QuillError{std::string{"setvbuf failed error: "} + std::strerror(errno)});
      }
    }

    if (_file_event_notifier.after_open)
    {
      _file_event_notifier.after_open(filename, opened_file_guard.file);
    }

    _file = opened_file_guard.release();
    _write_buffer = std::move(write_buffer);
  }

  void close_file()
  {
    if (!_file)
    {
      return;
    }

    if (_file_event_notifier.before_close)
    {
      QUILL_TRY { _file_event_notifier.before_close(_filename, _file); }
  #if !defined(QUILL_NO_EXCEPTIONS)
      QUILL_CATCH_ALL()
      {
        FILE* file = _file;
        _file = nullptr;
        std::fclose(file);
        throw;
      }
  #endif
    }

    FILE* file = _file;
    _file = nullptr;

    if (std::fclose(file) != 0)
    {
      int const saved_errno = errno;
      QUILL_THROW(QuillError{std::string{"fclose failed errno: "} + std::to_string(saved_errno) +
                             " error: " + std::strerror(saved_errno)});
    }

    if (_file_event_notifier.after_close)
    {
      _file_event_notifier.after_close(_filename);
    }
  }

  void _close_file_noexcept() noexcept
  {
    QUILL_TRY { close_file(); }
  #if !defined(QUILL_NO_EXCEPTIONS)
    QUILL_CATCH_ALL() {}
  #endif
  }

  void fsync_file(bool force_fsync = false)
  {
    if (!_file)
    {
      return;
    }

    std::chrono::steady_clock::time_point fsync_timestamp{};

    if (!force_fsync)
    {
      fsync_timestamp = std::chrono::steady_clock::now();
      if ((fsync_timestamp - _last_fsync_timestamp) < _config.minimum_fsync_interval())
      {
        return;
      }
    }

    // Retry on EINTR — a signal delivered during fsync() causes it to fail transiently.
    int ret{0};
    do
    {
      ret = ::fsync(fileno(_file));
    } while (ret != 0 && errno == EINTR);

    if (QUILL_UNLIKELY(ret != 0))
    {
      int const saved_errno = errno;
      _write_occurred = true;
      QUILL_THROW(QuillError{std::string{"fsync failed errno: "} + std::to_string(saved_errno) +
                             " error: " + std::strerror(saved_errno)});
    }

    if (!force_fsync)
    {
      _last_fsync_timestamp = fsync_timestamp;
    }
  }

  QUILL_NODISCARD bool is_open() const noexcept { return _file != nullptr; }

private:
  QUILL_NODISCARD static fs::path _get_updated_filename_with_appended_datetime(
    fs::path const& filename, FilenameAppendOption append_to_filename_option,
    std::string const& append_filename_format_pattern, Timezone time_zone,
    std::chrono::system_clock::time_point timestamp)
  {
    if ((append_to_filename_option == FilenameAppendOption::None) || (filename == "/dev/null"))
    {
      return filename;
    }

    if ((append_to_filename_option == FilenameAppendOption::StartCustomTimestampFormat) ||
        (append_to_filename_option == FilenameAppendOption::StartDate) ||
        (append_to_filename_option == FilenameAppendOption::StartDateTime))
    {
      return append_datetime_to_filename(filename, append_filename_format_pattern, time_zone, timestamp);
    }

    QUILL_THROW(QuillError{"Unexpected FilenameAppendOption value"});
  }

protected:
  FileSinkConfig _config;
  std::chrono::steady_clock::time_point _last_fsync_timestamp{};
  std::unique_ptr<char[]> _write_buffer;
};
#endif

QUILL_END_EXPORT

#if defined(_WIN32) && defined(_MSC_VER) && !defined(__GNUC__)
  #pragma warning(pop)
#endif

QUILL_END_NAMESPACE