EditingAuthority.h

浏览该文件的文档.

#pragma once
#include "common/Export.h"
 
 
#include "editing/EditingProtocol.h"
#include "editing/EditingTargetOperations.h"
 
#include <memory>
#include <span>
#include <unordered_map>
#include <vector>
 
namespace eve::editing {
 
class IEditAuthority {
public:
    virtual ~IEditAuthority() = default;
 
    virtual Result<AuthorityPlan> preflight(const TransactionSpec&           transaction,
                                                  std::span<const DomainOperation> operations) = 0;
    virtual Result<TransactionReceipt> commit(const AuthorityPlan& plan) = 0;
    virtual Result<TransactionReceipt> compensate(const TransactionReceipt& receipt) = 0;
};
 
class EVENGINE_API_PLATFORM LocalWorldAuthority final : public IEditAuthority {
public:
    explicit LocalWorldAuthority(IDomainOperationTarget* target) : target_(target) {}
 
    Result<AuthorityPlan>      preflight(const TransactionSpec&           transaction,
                                               std::span<const DomainOperation> operations) override;
    Result<TransactionReceipt> commit(const AuthorityPlan& plan) override;
    Result<TransactionReceipt> compensate(const TransactionReceipt& receipt) override;
 
private:
    struct CommittedEntry {
        TransactionReceipt           receipt;
        std::vector<DomainOperation> operations;
    };
 
    static DomainOperation inverseOf(const DomainOperation& operation);
    Result<void>     rollbackApplied(std::span<const DomainOperation> operations, std::size_t count);
 
    IDomainOperationTarget*                                                              target_ = nullptr;
    std::unordered_map<TransactionId, CommittedEntry, StrongIdHash<TransactionId>> committed_;
    std::vector<TransactionId>                                                     commitOrder_;
    std::uint64_t                                                                        receiptSequence_ = 0;
};
 
class EVENGINE_API_PLATFORM ReadOnlyAuthority final : public IEditAuthority {
public:
    Result<AuthorityPlan>      preflight(const TransactionSpec&           transaction,
                                               std::span<const DomainOperation> operations) override;
    Result<TransactionReceipt> commit(const AuthorityPlan& plan) override;
    Result<TransactionReceipt> compensate(const TransactionReceipt& receipt) override;
};
 
}  // namespace eve::editing