Collection.h

#include <kDBRobotics/Forward.h>
 
#include <QExplicitlySharedDataPointer>
 
#include <knowCore/Uri.h>
 
#include <kDB/Repository/RDF/FocusNodeCollection.h>
 
class TestAgents;
 
template<>
struct kDB::Repository::RDF::FocusNodeCollectionTrait<kDBRobotics::Agents::Collection>
{
  using ValueType = kDBRobotics::Agents::Agent;
};
 
namespace kDBRobotics::Agents
{
 
  class Collection : public kDB::Repository::RDF::FocusNodeCollectionWrapper<Collection>
  {
    friend class ::TestAgents;
  public:
    using ValueType = Agent;
  protected:
    Collection(const kDB::Repository::RDF::FocusNodeCollectionWrapper<Collection>& _rhs);
  public:
    Collection();
    Collection(const Collection& _rhs);
    Collection& operator=(const Collection& _rhs);
    ~Collection();
  public:
    static knowCore::Uri collectionType();
    static knowCore::Uri allFocusNodesView();
    static knowCore::Uri primaryType();
    static knowCore::UriList containedTypes();
    static cres_qresult<knowCore::UriList>
      defaultDatatypes(const QList<QPair<knowCore::Uri, knowCore::ConstrainedValue>>& _constraints);
  public:
    static Collection allAgents(const kDB::Repository::Connection& _connection);
  public:
    cres_qresult<Agent> agent(const knowCore::Uri& _agentUri) const;
    cres_qresult<Stream> stream(const knowCore::Uri& _streamUri) const;
    cres_qresult<bool> hasAgent(const knowCore::Uri& _agentUri) const;
    cres_qresult<bool> hasStream(const knowCore::Uri& _streamUri) const;
    cres_qresult<QList<Stream>> streamsOf(const knowCore::Uri& _resource) const;
    using OperatorOptions = kDB::Repository::RDF::FocusNodeCollection::OperatorOptions;
    cres_qresult<QList<Agent>>
      agents(const QList<QPair<knowCore::Uri, knowCore::ConstrainedValue>>& _constraints,
             const OperatorOptions& _operatorOptions = OperatorOptions()) const;
    template<typename... _TArgs_>
    cres_qresult<QList<Agent>> agents(const knowCore::Uri& _uri,
                                      const knowCore::ConstrainedValue& _constraint,
                                      const _TArgs_&...) const;
    cres_qresult<Agent>
      createAgent(const knowCore::Uri& _typeUri, const QString& _name, const QString& _frame_name,
                  const knowCore::Uri& _agentUri = knowCore::Uri::createUnique({"agent"}));
    cres_qresult<Stream> createStream(const knowCore::Uri& _contentTypeUri,
                                      const QString& _identifier, const knowCore::Uri& _dataTypeUri,
                                      const knowCore::Uri& _streamUri
                                      = knowCore::Uri::createUnique({"stream"}));
  };
} // namespace kDBRobotics::Agents