ArchiveParser.h

/*
 * Copyright (C) 2026 Yury Bobylev <bobilev_yury@mail.ru>
 *
 * 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, version 3.
 *
 * 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 ARCHIVEPARSER_H
#define ARCHIVEPARSER_H
 
#include <BaseID.h>
#include <LibArchive.h>
#include <MLBookProc.h>
#include <UDBElement.h>
#include <archive_entry.h>
#include <atomic>
#include <condition_variable>
#include <filesystem>
#include <memory>
#include <mutex>

class ArchiveParser : public LibArchive
{
public:
  ArchiveParser(
      const std::shared_ptr<MLBookProc> &mlbp,
      const std::shared_ptr<std::vector<std::tuple<unsigned, bool>>> &thread_v,
      const std::shared_ptr<std::mutex> &thread_v_mtx,
      const std::shared_ptr<std::condition_variable> &thread_v_var);
 
  virtual ~ArchiveParser();

  std::vector<UDBElement>
  parseArchive(const std::filesystem::path &file_path);

  void
  stopAll();
 
private:
  void
  parseEntry(std::shared_ptr<archive> a, std::shared_ptr<archive_entry> e);
 
  enum FileType
  {
    FB2,
    EPUB,
    PDF,
    DJVU,
    ODT,
    TXT,
    DOC,
    RTF,
    DOCX,
    MOBI
  };
 
  UDBElement
  bufferParse(const std::string &buf, const std::string &arch_file_path,
              std::shared_ptr<archive_entry> e, const FileType &ft);
 
  void
  fbdProcessing();
 
  std::vector<UDBElement> fbd;
  std::vector<UDBElement> result;
  std::vector<std::string> unsupported;
 
  std::atomic<bool> cancel;
 
  std::shared_ptr<ArchiveParser> arch_proc;
 
  std::shared_ptr<std::vector<std::tuple<unsigned, bool>>> thread_v;
  std::shared_ptr<std::mutex> thread_v_mtx;
  std::shared_ptr<std::condition_variable> thread_v_var;
 
  int thr_num = 0;
  std::mutex thr_num_mtx;
  std::condition_variable thr_num_var;
 
  BaseID bid;
};
 
#endif // ARCHIVEPARSER_H