archive.hpp

Go to the documentation of this file.

// SPDX-FileCopyrightText: 2025 CERN
// SPDX-License-Identifier: GPL-3.0-or-later
 
#ifndef ARCHIVE_HPP_
#define ARCHIVE_HPP_
 
#include "adaptyst/socket.hpp"
#include <filesystem>
#include <istream>
#include <archive.h>
#include <archive_entry.h>
#include <nlohmann/json.hpp>
#include <unordered_set>
 
namespace adaptyst {
  namespace fs = std::filesystem;

  class Archive {
  private:
    struct archive *arch;
    struct archive_entry *arch_entry;
    unsigned int buf_size;
    std::unique_ptr<Connection> conn;
 
  public:
    Archive(fs::path path, unsigned int buf_size = 1024);

    Archive(std::unique_ptr<Connection> &conn, bool padding = true,
            unsigned int buf_size = 1024);

    void add_file(std::string filename, fs::path path);

    void add_file_stream(std::string filename, std::istream &stream,
                         unsigned int size);

    void close();
 
    ~Archive();
 
    class Exception : public std::exception {
    private:
      const char *message;
 
    public:
      Exception(struct archive *arch) {
        this->message = archive_error_string(arch);
      }
 
      Exception() {
        this->message = typeid(*this).name();
      }
 
      const char *what() const noexcept override {
        return this->message;
      }
    };
 
    class InitException : public Exception { using Exception::Exception; };
    class FileExistsException : public Exception { using Exception::Exception; };
    class FileOpenException : public Exception { using Exception::Exception; };
    class FileIOException : public Exception { using Exception::Exception; };
    class CloseException : public Exception { using Exception::Exception; };
    class AlreadyClosedException : public Exception { using Exception::Exception; };
    class FileDoesNotExistException : public Exception { using Exception::Exception; };
    class NotRegularFileException : public Exception { using Exception::Exception; };
  };
};
 
#endif