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
    {
      using RoutingTable = std::unordered_map<EntryID, Tangible*, EntryID::UseEmbeddedHash>;
      
      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*/