Commit.cpp

Go to the documentation of this file.

#include "Commit.h"
 
#include <SimoxUtility/algorithm/apply.hpp>
 
#include <ArmarXCore/core/exceptions/local/ExpressionException.h>
 
#include <RobotAPI/libraries/aron/core/data/variant/container/Dict.h>
 
namespace armarx::armem
{
 
    std::ostream&
    operator<<(std::ostream& os, const EntityUpdate& rhs)
    {
        return os << "Entity update: "
                  << "\n- success:    \t" << rhs.entityID << "\n- timestamp:  \t"
                  << toDateTimeMilliSeconds(rhs.referencedTime) << "\n- #instances: \t"
                  << rhs.instancesData.size() << "\n";
    }
 
    std::ostream&
    operator<<(std::ostream& os, const EntityUpdateResult& rhs)
    {
        return os << "Entity update result: "
                  << "\n- success:       \t" << (rhs.success ? "true" : "false")
                  << "\n- snapshotID:    \t" << rhs.snapshotID << "\n- time arrived:  \t"
                  << toDateTimeMilliSeconds(rhs.arrivedTime) << "\n- error message: \t"
                  << rhs.errorMessage << "\n";
    }
 
    std::ostream&
    operator<<(std::ostream& os, const Commit& rhs)
    {
        os << "Commit with " << rhs.updates.size() << " entity update";
        if (rhs.updates.size() > 1)
        {
            os << "s";
        }
        os << ": \n";
        for (size_t i = 0; i < rhs.updates.size(); ++i)
        {
            os << "[" << i << "] " << rhs.updates[i];
        }
        return os;
    }
 
    std::ostream&
    operator<<(std::ostream& os, const CommitResult& rhs)
    {
        os << "Commit results of " << rhs.results.size() << " entity update";
        if (rhs.results.size() > 1)
        {
            os << "s";
        }
        os << ": \n";
        for (size_t i = 0; i < rhs.results.size(); ++i)
        {
            os << "[" << i << "] " << rhs.results[i];
        }
        return os;
    }
 
    bool
    CommitResult::allSuccess() const
    {
        return std::find_if(results.begin(),
                            results.end(),
                            [](const EntityUpdateResult& r)
                            { return !r.success; }) == results.end();
    }
 
    std::vector<std::string>
    CommitResult::allErrorMessages() const
    {
        return simox::alg::apply(results,
                                 [](const EntityUpdateResult& res) { return res.errorMessage; });
    }
 
    EntityUpdate&
    Commit::add()
    {
        return updates.emplace_back();
    }
 
    EntityUpdate&
    Commit::add(const EntityUpdate& update)
    {
        return updates.emplace_back(update);
    }
 
    void
    Commit::add(const std::vector<EntityUpdate>& updates)
    {
        for (const auto& update : updates)
        {
            add(update);
        }
    }
 
    void
    Commit::append(const Commit& c)
    {
        add(c.updates);
    }
 
} // namespace armarx::armem