WorkspaceCommandService.h

Go to the documentation of this file.

 
#pragma once
 
#include <string>
#include <vector>
 
#include "core/domain/catalog/WorkspaceCatalog.h"
#include "core/domain/entities/Transaction.h"
#include "core/domain/values/Alias.h"
#include "core/domain/values/AnalysisType.h"
#include "core/domain/values/BookingDate.h"
#include "core/domain/values/ExportFormat.h"
#include "core/domain/values/FilterSpec.h"
#include "core/ports/workspace/WorkspaceCommands.h"
 
namespace core::application {
 
class WorkspaceSession;
 
struct ActorInput {
    std::string name;
    std::vector<core::domain::Alias> aliases;
    std::vector<std::string> contractIds;
};
 
struct PropertyInput {
    std::string name;
    std::vector<core::domain::Alias> aliases;
    std::vector<std::string> contractIds;
};
 
struct ContractInput {
    std::string name;
    std::string type;
    std::string allocatableMode = "mixed";
    std::vector<std::string> actorIds;
    std::vector<std::string> propertyIds;
    std::vector<core::domain::Alias> aliases;
};
 
struct TransactionInput {
    std::string name;
    core::domain::BookingDate bookingDate;
    std::string valuta;
    double amount = 0.0;
    std::string statementId;
    std::string insertAfterTransactionId;
    core::domain::Transaction::Status status = core::domain::Transaction::Status::Neutral;
    std::string actorId;
    std::string contractId;
    bool allocatable = false;
    std::vector<std::string> propertyIds;
};
 
struct AnalysisInput {
    std::string name;
    core::domain::AnalysisType type;
    core::ports::analysis::AnalysisConfigInput config;
    core::ports::analysis::AnalysisFilterSelection filter;
    core::domain::ExportFormat exportFormat;
    bool includeCalculationAdjustments = true;
    std::vector<core::ports::workspace::TransactionSnapshot> snapshotTransactions;
    std::vector<std::pair<std::string, double>> adjustments;
};
 
class WorkspaceCommandService {
public:
    explicit WorkspaceCommandService(WorkspaceSession& session);
    ~WorkspaceCommandService();
 
    WorkspaceCommandService(const WorkspaceCommandService&) = delete;
    WorkspaceCommandService& operator=(const WorkspaceCommandService&) = delete;
    WorkspaceCommandService(WorkspaceCommandService&&) noexcept;
    WorkspaceCommandService& operator=(WorkspaceCommandService&&) noexcept;

    [[nodiscard]] std::string addActor(const core::ports::workspace::ActorCommand& command);
    void updateActor(const core::ports::workspace::ActorCommand& command);
    void deleteActor(const std::string& id);

    [[nodiscard]] std::string addProperty(const core::ports::workspace::PropertyCommand& command);
    void updateProperty(const core::ports::workspace::PropertyCommand& command);
    void deleteProperty(const std::string& id);

    [[nodiscard]] std::string addContract(const core::ports::workspace::ContractCommand& command);
    void updateContract(const core::ports::workspace::ContractCommand& command);
    void deleteContract(const std::string& id);

    [[nodiscard]] std::string addStatement(const core::ports::workspace::StatementCommand& command);
    [[nodiscard]] std::string addStatementWithTransactions(const core::ports::workspace::StatementWithTransactionsCommand& command);
    void updateStatement(const core::ports::workspace::StatementCommand& command);
    void deleteStatement(const std::string& id);

    [[nodiscard]] std::string addTransaction(const core::ports::workspace::TransactionCommand& command);
    void updateTransaction(const core::ports::workspace::TransactionCommand& command);
    void deleteTransaction(const std::string& id);

    [[nodiscard]] std::string addAnalysis(const core::ports::workspace::AnalysisCommand& command);
    void updateAnalysis(const core::ports::workspace::AnalysisCommand& command);
    void deleteAnalysis(const std::string& id);

    [[nodiscard]] std::string addAnnual(const core::ports::workspace::AnnualCommand& command);
    void updateAnnual(const core::ports::workspace::AnnualCommand& command);
    void deleteAnnual(const std::string& id);

    [[nodiscard]] core::ports::workspace::ValidationResult validate(const core::ports::workspace::ActorCommand& command) const;
    [[nodiscard]] core::ports::workspace::ValidationResult validate(const core::ports::workspace::PropertyCommand& command) const;
    [[nodiscard]] core::ports::workspace::ValidationResult validate(const core::ports::workspace::ContractCommand& command) const;
    [[nodiscard]] core::ports::workspace::ValidationResult validate(const core::ports::workspace::StatementCommand& command) const;
    [[nodiscard]] core::ports::workspace::ValidationResult validate(const core::ports::workspace::TransactionCommand& command) const;
    [[nodiscard]] core::ports::workspace::ValidationResult validate(const core::ports::workspace::StatementWithTransactionsCommand& command) const;
    [[nodiscard]] core::ports::workspace::ValidationResult validate(const core::ports::workspace::AnalysisCommand& command) const;
    [[nodiscard]] core::ports::workspace::ValidationResult validate(const core::ports::workspace::AnnualCommand& command) const;
 
private:
    static std::string commitCreated(WorkspaceCommandService& service, std::string id);
    static void commitIfChanged(WorkspaceCommandService& service, bool changed);
 
    core::domain::catalog::WorkspaceCatalog& mutableCatalogState() noexcept;
    const core::domain::catalog::WorkspaceCatalog& catalogState() const noexcept;
    void commit();
    void notifyCatalogChanged();
 
    WorkspaceSession* session_ = nullptr;
};
 
} // namespace core::application