2023-07-22 23:31:56 +02:00
|
|
|
#pragma once
|
|
|
|
|
|
|
|
#include "./file.hpp"
|
|
|
|
|
|
|
|
#include <fstream>
|
2023-08-15 21:49:01 +02:00
|
|
|
#include <limits>
|
2023-07-22 23:31:56 +02:00
|
|
|
|
|
|
|
struct FileRWFile : public FileI {
|
|
|
|
std::fstream _file;
|
|
|
|
|
2023-08-17 22:40:46 +02:00
|
|
|
// dont truncate by default
|
|
|
|
FileRWFile(std::string_view file_path, uint64_t file_size, bool trunc = false)
|
|
|
|
: _file(
|
|
|
|
static_cast<std::string>(file_path),
|
|
|
|
std::ios::in |
|
|
|
|
std::ios::out |
|
|
|
|
(trunc ? std::ios::trunc | std::ios::binary : std::ios::binary) // hacky but type safe
|
|
|
|
) {
|
|
|
|
_file_size = file_size;
|
|
|
|
|
|
|
|
if (!_file.is_open()) {
|
|
|
|
return; // TODO: error
|
|
|
|
}
|
|
|
|
}
|
2023-07-22 23:31:56 +02:00
|
|
|
|
|
|
|
virtual ~FileRWFile(void) {}
|
|
|
|
|
|
|
|
bool isGood(void) override {
|
|
|
|
return _file.is_open() && _file.good();
|
|
|
|
}
|
|
|
|
|
2023-08-22 17:17:41 +02:00
|
|
|
std::vector<uint8_t> read(uint64_t pos, uint64_t size) override {
|
2023-07-22 23:31:56 +02:00
|
|
|
if (pos >= _file_size) {
|
|
|
|
return {};
|
|
|
|
}
|
|
|
|
|
|
|
|
// TODO: error check
|
2023-08-17 22:40:46 +02:00
|
|
|
_file.seekg(pos, std::ios::beg);
|
2023-07-22 23:31:56 +02:00
|
|
|
|
2023-08-15 21:49:01 +02:00
|
|
|
std::vector<uint8_t> chunk(size);
|
|
|
|
const auto nread = _file.read(reinterpret_cast<char*>(chunk.data()), chunk.size()).gcount();
|
|
|
|
if (nread != std::numeric_limits<std::streamsize>::max()) {
|
|
|
|
chunk.resize(nread); // usually a noop
|
|
|
|
} else {
|
|
|
|
chunk.clear();
|
|
|
|
}
|
2023-07-22 23:31:56 +02:00
|
|
|
|
|
|
|
_bytes_read += chunk.size();
|
|
|
|
|
|
|
|
return chunk;
|
|
|
|
}
|
|
|
|
|
|
|
|
bool write(uint64_t pos, const std::vector<uint8_t>& data) override {
|
|
|
|
if (pos >= _file_size) {
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
// if out-of-order, seek
|
|
|
|
if (_file.tellp() != int64_t(pos)) {
|
|
|
|
// TODO: error check
|
2023-08-21 21:24:10 +02:00
|
|
|
if (_file.seekp(pos, std::ios::beg).fail()) {
|
|
|
|
return false;
|
|
|
|
}
|
2023-07-22 23:31:56 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
_file.write(reinterpret_cast<const char*>(data.data()), data.size());
|
|
|
|
|
|
|
|
return _file.good();
|
|
|
|
}
|
|
|
|
};
|
|
|
|
|