Agents.h

#include "Forward.h"
 
#include <QExplicitlySharedDataPointer>
 
#include <knowCore/Uri.h>
 
class TestAgents;
 
namespace kDBRobotics
{
  class Agents
  {
    friend class ::TestAgents;
  public:
    Agents();
    Agents(const Agents& _rhs);
    Agents operator=(const Agents& _rhs);
    ~Agents();
  public:
    bool operator==(const Agents& _dss) const;
  public:
    static knowCore::ReturnValue<Agents> get(const kDB::Repository::Connection& _connection, const knowCore::Uri& _graph);
    static knowCore::ReturnValue<Agents> create(const kDB::Repository::Connection& _connection, const knowCore::Uri& _graph);
    static knowCore::ReturnValue<Agents> getOrCreate(const kDB::Repository::Connection& _connection, const knowCore::Uri& _graph);
    static Agents allAgents(const kDB::Repository::Connection& _connection);
    static knowCore::ReturnValue<QList<knowCore::Uri>> allAgentsUris(const kDB::Repository::Connection& _connection);
  public:
    bool isValid() const;
    bool isReadOnly() const;
    knowCore::Uri uri() const;
    kDB::Repository::Connection connection() const;
    std::size_t count() const;
    knowCore::ReturnValue<Agent> agent(const knowCore::Uri& _agentUri) const;
    knowCore::ReturnValue<Stream> stream(const knowCore::Uri& _streamUri) const;
    knowCore::ReturnValue<bool> hasAgent(const knowCore::Uri& _agentUri) const;
    knowCore::ReturnValue<bool> hasStream(const knowCore::Uri& _streamUri) const;
    knowCore::ReturnValue<QList<Stream>> streamsOf(const knowCore::Uri& _resource) const;
    QList<Agent> all() const;
    struct OperatorOptions
    {
      OperatorOptions() : intersectsPrecision(0.0) {}
      OperatorOptions(double _intersectsPrecision) : intersectsPrecision(_intersectsPrecision) {}
      double intersectsPrecision;
    };
    knowCore::ReturnValue<QList<Agent>> agents(const QList<QPair<knowCore::Uri, knowCore::ConstrainedValue>>& _constraints, const OperatorOptions& _operatorOptions = OperatorOptions()) const;
    template<typename... _TArgs_>
    knowCore::ReturnValue<QList<Agent>> agents(const knowCore::Uri& _uri, const knowCore::ConstrainedValue& _constraint, const _TArgs_&...) const;
    knowCore::ReturnValue<Agent> createAgent(const knowCore::Uri& _typeUri, const QString& _name, const knowCore::Uri& _agentUri = knowCore::Uri::createUnique({"agent"}));
    knowCore::ReturnValue<Stream> createStream(const knowCore::Uri& _contentTypeUri, const QString& _identifier, const knowCore::Uri& _dataTypeUri, const knowCore::Uri& _streamUri = knowCore::Uri::createUnique({"stream"}));
  private:
    struct Private;
    QExplicitlySharedDataPointer<Private> d;
    Agents(const QExplicitlySharedDataPointer<Private>& _d);
    static void clearCache();
  };
}