SourceGroupWithOnDemandProperties.h

Go to the documentation of this file.

#ifndef _SEFRAMEWORK_SOURCE_SOURCEGROUP_H
#define _SEFRAMEWORK_SOURCE_SOURCEGROUP_H

#include <set>
#include <iterator>
#include <type_traits>

#include "SEFramework/Source/SourceInterface.h"
#include "SEFramework/Source/SourceGroupInterface.h"
#include "SEFramework/Task/TaskProvider.h"
#include "SEFramework/Property/PropertyHolder.h"

namespace SourceXtractor {

class SourceGroupWithOnDemandProperties : public SourceGroupInterface {

public:

  explicit SourceGroupWithOnDemandProperties(std::shared_ptr<TaskProvider> task_provider);

  virtual ~SourceGroupWithOnDemandProperties() = default;

  iterator begin() override;

  iterator end() override;

  const_iterator cbegin() const override;

  const_iterator cend() const override;

  const_iterator begin() const override;

  const_iterator end() const override;

  void addSource(std::unique_ptr<SourceInterface> source) override;

  iterator removeSource(iterator pos) override;

  void merge(SourceGroupInterface&& other) override;

  unsigned int size() const override;

  using SourceInterface::getProperty;
  using SourceInterface::setProperty;

protected:

  const Property& getProperty(const PropertyId& property_id) const override;

  void setProperty(std::unique_ptr<Property> property, const PropertyId& property_id) override;

private:

  class EntangledSource;
  std::list<SourceWrapper> m_sources;
  PropertyHolder m_property_holder;
  std::shared_ptr<TaskProvider> m_task_provider;

  void clearGroupProperties();

}; /* End of SourceGroup class */



class SourceGroupWithOnDemandProperties::EntangledSource : public SourceInterface {

public:

  EntangledSource(std::shared_ptr<SourceInterface> source, SourceGroupWithOnDemandProperties& group);

  virtual ~EntangledSource() = default;

  const Property& getProperty(const PropertyId& property_id) const override;

  void setProperty(std::unique_ptr<Property> property, const PropertyId& property_id) override;

  bool operator<(const EntangledSource& other) const;

private:

  PropertyHolder m_property_holder;
  std::shared_ptr<SourceInterface> m_source;
  SourceGroupWithOnDemandProperties& m_group;

  friend void SourceGroupWithOnDemandProperties::clearGroupProperties();
  friend void SourceGroupWithOnDemandProperties::merge(SourceGroupInterface&&);

};

} /* namespace SourceXtractor */

#endif