147 lines
3.8 KiB
C++
147 lines
3.8 KiB
C++
#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 <https://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
#ifndef BLT_FS_BOUNDED_WRITER_H
|
|
#define BLT_FS_BOUNDED_WRITER_H
|
|
|
|
#include <functional>
|
|
#include <optional>
|
|
#include <string>
|
|
#include <utility>
|
|
#include <blt/fs/fwddecl.h>
|
|
#include <blt/std/types.h>
|
|
|
|
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<std::string(size_t, std::string)>;
|
|
|
|
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<char> 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<std::string> 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<std::string> 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
|