IImportRunner.h

Go to the documentation of this file.

 
#pragma once
 
#include "core/ports/usecases/import/ImportRequest.h"
#include "core/ports/usecases/import/ImportResult.h"
#include "core/ports/workspace/WorkspaceSnapshot.h"
 
#include <cstdint>
#include <functional>
#include <string>
#include <vector>
 
namespace core::ports::importing {
 
enum class StatementImportState {
  Pending,
  Running,
  Paused,
  Finished,
  Failed,
  Canceled,
};
 
struct StatementImportEvent {
  std::string importId;
  StatementImportState state = StatementImportState::Pending;
  double progress = 0.0;
  std::string message;
};
 
struct StatementImportHandle {
  std::string importId;
  std::uint64_t subscriptionId = 0;
};
 
using StatementImportEventCallback =
    std::function<void(const StatementImportEvent &)>;
 
class IImportRunner {
public:
  virtual ~IImportRunner() = default;

  [[nodiscard]] virtual StatementImportHandle
  startStatementImport(const ImportRequest &request,
                       StatementImportEventCallback callback) = 0;

  virtual void unsubscribe(const StatementImportHandle &handle) = 0;

  virtual void cancel(const StatementImportHandle &handle) = 0;

  virtual void pause(const StatementImportHandle &handle) = 0;

  virtual void resume(const StatementImportHandle &handle) = 0;

  [[nodiscard]] virtual ImportResult
  importResult(const StatementImportHandle &handle) = 0;

  [[nodiscard]] virtual core::ports::importing::draft::DraftDerivedState
  buildDraftDerivedState(
      const core::ports::workspace::WorkspaceSnapshot &state,
      const core::ports::importing::draft::DraftLinkSelection &selection) const = 0;

  virtual bool updateTransactionDraft(
      core::ports::importing::draft::TransactionDraft &draft,
      const core::ports::workspace::WorkspaceSnapshot &state,
      const core::ports::importing::draft::TransactionDraftEdit &edit)
      const = 0;

  virtual core::ports::importing::draft::StatementDraftEditResult
  updateStatementDraft(
      core::ports::importing::draft::StatementDraft &draft,
      const core::ports::importing::draft::StatementDraftEdit &edit)
      const = 0;

  [[nodiscard]] virtual core::ports::importing::draft::StatementDraft
  buildStatementDraft(
      const std::string &sourceFile,
      const core::ports::workspace::StatementSnapshot &statement,
      const core::ports::workspace::WorkspaceSnapshot &state,
      const std::vector<core::ports::importing::draft::TransactionDraft>
          &transactions,
      const std::string &draftId) const = 0;

  [[nodiscard]] virtual core::ports::importing::draft::StatementDraft
  restoreStatementDraft(
      const core::ports::workspace::StatementDraftSnapshot &draft) const = 0;

  [[nodiscard]] virtual core::ports::workspace::StatementDraftSnapshot
  buildStatementDraftSnapshot(
      const core::ports::importing::draft::StatementDraft &draft,
      const core::ports::workspace::WorkspaceSnapshot &state) const = 0;

  [[nodiscard]] virtual core::ports::workspace::WorkspaceSnapshot
  mergeWorkspaceState(
      core::ports::workspace::WorkspaceSnapshot primary,
      const core::ports::workspace::WorkspaceSnapshot &secondary) const = 0;
 
};
 
} // namespace core::ports::importing