// $Id: Service.hpp,v 1.10 2009/06/20 06:48:15 nishio Exp $

#pragma once
#include <vector>
#include <set>
#include <ISO19111/IO_IdentifiedObject.hpp>
#include <ISO19115.hpp>
#include <RLS/Ability.hpp>
#include <RLS/DataFormat.hpp>
#include <RLS/RoLoArchitecture.hpp>

namespace RoLo
{
  namespace Interface
  {
    enum StreamType {
      PUSH,
      PULL
    };

    class StreamAbility
      : public Ability
    {
    public:
      SetParameter< ::RoLo::DataFormat::DataFormat> dataFormat;
      SetParameter< ::RoLo::Architecture::DataSpecification > dataSpec;
      SetParameter<StreamType> streamType;
      SetParameter<double> frequency;
    };

    class InterfaceBase
      : public ::ISO19111::IO_IdentifiedObject
    {
    public:
      const Ability& getAbility();
      void setParameterValues(const ::std::set<ParameterValueBase>& paramVals);
      const ::std::set<ParameterValueBase>& getParameterValues();
    protected:
      Ability* ability;
    };

    class Stream
      : public InterfaceBase
    {
    public:
      void disconnect();
      bool isConnected();
      const Stream& getConnectedStream();
      const class Service& getService();
    };

    class OutStream
      : public Stream
    {
    public:
      const ::RoLo::Architecture::Data& getData();
      void activate();
      void deactivate();
      bool isActivated();
    };

    class InStream
      : public Stream
    {
    public:
      void setData(const ::RoLo::Architecture::Data& data);
    };

    class ServiceAbility
      : public Ability
    {
    public:
      Attribute<int> maxOutStreamNum;
      Attribute<double> expectedLatency;
      ::std::set<StreamAbility> inStreamAbilities;
      StreamAbility outStreamAbility;
    };

    class Service
      : public InterfaceBase
    {
    public:
      InStream& connect(const InStream& target, const OutStream* source = NULL);
      OutStream& connect(const InStream* source = NULL);
      void adjust(const ::RoLo::Architecture::Data& data);
      const ::std::vector<const Service*> getChildren();
      
    protected:
      ::std::vector<InStream> inStreams;
      ::std::vector<OutStream> outStreams;
    };

  }
}