#pragma once /* * Copyright (C) 2024 Brett Terpstra * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program. If not, see . */ #ifndef BLT_FS_BOUNDED_WRITER_H #define BLT_FS_BOUNDED_WRITER_H #include #include #include #include #include #include namespace blt::fs { inline auto basic_naming_function = [](const size_t invocation, std::string prefix) { prefix += '-'; prefix += std::to_string(invocation); prefix += ".txt"; return prefix; }; using naming_function_t = std::function; class fwriter_t : public writer_t { public: explicit fwriter_t(const std::string& name, std::string mode = "ab"): m_mode(std::move(mode)) { fwriter_t::newfile(name); } // create a writer without creating a new file. Writing without calling newfile is UB explicit fwriter_t(std::string mode = "ab"): m_mode(std::move(mode)) {} i64 write(const char* buffer, size_t bytes) override; virtual void newfile(const std::string& new_name); void flush() override; protected: std::string m_mode; FILE* m_file = nullptr; }; // ReSharper disable once CppClassCanBeFinal class buffered_writer : public fwriter_t { public: explicit buffered_writer(const std::string& name, size_t buffer_size = 1024 * 128); explicit buffered_writer(size_t buffer_size = 1024 * 128); i64 write(const char* buffer, size_t bytes) override; void flush() override; void newfile(const std::string& new_name) override; protected: size_t m_current_pos = 0; std::vector m_buffer; }; /** * Creates a bounded writer where after a specified number of bytes a new file will be opened and written to instead. */ // ReSharper disable once CppClassCanBeFinal class bounded_writer : public fwriter_t { public: explicit bounded_writer(fwriter_t& writer, std::optional base_name, size_t max_size = 1024 * 1024 * 10, naming_function_t naming_function = basic_naming_function); i64 write(const char* buffer, size_t bytes) override; void newfile(const std::string& new_name) override; void flush() override; private: fwriter_t* m_writer; std::optional m_base_name; size_t m_current_invocation = 0; size_t m_max_size; size_t m_currently_written = 0; // inputs: current invocation, then basename string // returns: name of the file to write to naming_function_t m_naming_function; }; struct time_t { i32 year = 0, month = 0, day = 1, hour = -1; time_t(const i32 year, const i32 month, const i32 day, const i32 hour) : year{year}, month{month}, day{day}, hour{hour} {} time_t(const i32 year, const i32 month, const i32 day) : year{year}, month{month}, day{day} {} time_t() = default; }; // ReSharper disable once CppClassCanBeFinal class rotating_writer : public fwriter_t { public: rotating_writer(fwriter_t& writer, time_t period); i64 write(const char* buffer, size_t bytes) override; void flush() override; void newfile(const std::string& new_name) override; void newfile(); void check_for_time(); static time_t get_current_time(); private: fwriter_t* m_writer; time_t m_period; time_t m_last_time; }; } #endif //BLT_FS_BOUNDED_WRITER_H