nexus.hpp

Go to the documentation of this file.

/*
  NEXUS.hpp  -  UI-Bus central hub and routing table

   Copyright (C)
     2015,            Hermann Vosseler <Ichthyostega@web.de>

  **Lumiera** is free software; you can redistribute it and/or modify it
  under the terms of the GNU General Public License as published by the
  Free Software Foundation; either version 2 of the License, or (at your
  option) any later version. See the file COPYING for further details.

*/


#ifndef STAGE_CTRL_NEXUS_H
#define STAGE_CTRL_NEXUS_H


#include "lib/error.hpp"
#include "lib/nocopy.hpp"
#include "lib/idi/genfunc.hpp"
#include "lib/diff/mutation-message.hpp"
#include "lib/diff/tree-diff-application.hpp"
#include "stage/ctrl/bus-term.hpp"
#include "stage/model/tangible.hpp"
#include "lib/idi/entry-id.hpp"

#include <unordered_map>


namespace stage {
namespace ctrl{
  
  
  
  class Nexus
    : public BusTerm
    , util::NonCopyable
    {
      typedef std::unordered_map<EntryID, Tangible*, EntryID::UseEmbeddedHash> RoutingTable;
      
      RoutingTable routingTable_;
      
      
    protected:
      virtual bool
      mark (ID subject, GenNode const& mark)  override
        {
          auto entry = routingTable_.find (subject);
          if (entry == routingTable_.end())
            return false;
          else
            {
              entry->second->mark (mark);
              return true;
            }
        }
      
      virtual size_t
      markAll (GenNode const& mark)  override
        {
          for (auto& entry : routingTable_)
            this->mark (entry.first, mark);
          return routingTable_.size();
        }
      
      
      virtual bool
      change (ID subject, MutationMessage&& diff)  override
        {
          auto entry = routingTable_.find (subject);
          if (entry == routingTable_.end())
            return false;
          else
            {
              Tangible& target = *entry->second;
              lib::diff::DiffApplicator<Tangible> applicator{target};
              applicator.consume (move(diff));
              return true;
            }
        }
      
      
      virtual BusTerm&
      routeAdd (ID identity, Tangible& newNode)  override
        {
          routingTable_[identity] = &newNode;
          return *this;
        }
      
      
      virtual void
      routeDetach (ID node)  noexcept override
        {
          routingTable_.erase (node);
        }
      
      
      virtual operator string()  const
        {
          return lib::idi::instanceTypeID(this);
        }
      
      
    public:
      size_t
      size()  const
        {
          return routingTable_.size();
        }
      
      explicit
      Nexus (BusTerm& uplink_to_CoreService, ID identity =lib::idi::EntryID<Nexus>())
        : BusTerm(identity, uplink_to_CoreService)
      { }
      
     ~Nexus()
        {
          if (0 < size())
            ERROR (stage, "Some UI components are still connected to the backbone.");
        }
    };
  
  
  
}} // namespace stage::ctrl
#endif /*STAGE_CTRL_NEXUS_H*/