command.cpp

Go to the documentation of this file.

/*
  Command  -  Key abstraction for steam/edit operations and UNDO management

   Copyright (C)
     2009,            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.

* *****************************************************************/


#include "lib/error.hpp"
#include "lib/symbol.hpp"
#include "lib/format-string.hpp"
#include "steam/control/command.hpp"
#include "steam/control/command-def.hpp"
#include "steam/control/command-impl.hpp"
#include "steam/control/command-registry.hpp"
#include "steam/control/command-impl-clone-builder.hpp"
#include "steam/control/handling-pattern.hpp"
#include "lib/util.hpp"

#include <utility>
#include <sstream>
#include <string>

using std::ostringstream;
using std::string;
using std::move;
using util::_Fmt;


namespace lumiera {
namespace error {
  LUMIERA_ERROR_DEFINE (INVALID_COMMAND,   "Unknown or insufficiently defined command");
  LUMIERA_ERROR_DEFINE (DUPLICATE_COMMAND, "Attempt to redefine an already existing command definition");
  LUMIERA_ERROR_DEFINE (INVALID_ARGUMENTS, "Arguments provided for binding doesn't match stored command function parameters");
  LUMIERA_ERROR_DEFINE (UNBOUND_ARGUMENTS, "Command mutation functor not yet usable, because arguments aren't bound");
  LUMIERA_ERROR_DEFINE (MISSING_MEMENTO,   "Undo functor not yet usable, because no undo state has been captured");
}}

namespace steam {
namespace control {
  namespace error = lumiera::error;
  
  
  namespace { // some common error checks...
    
    void
    ___check_notBottom (const Command *handle, lib::Literal operation_descr)
    {
      REQUIRE (handle);
      if (!handle->isValid())
        throw error::Invalid (operation_descr+" an undefined command"
                             , LERR_(INVALID_COMMAND));
    }
    
    void
    ___check_isBound (const Command *handle)
    {
      REQUIRE (handle);
      if (!handle->canExec())
        throw error::State ("Lifecycle error: command arguments not bound"
                           , LERR_(UNBOUND_ARGUMENTS));
    }
    
    void
    ___check_canUndo (const Command *handle)
    {
      REQUIRE (handle);
      if (!handle->canUndo())
        throw error::State ("Lifecycle error: command has not yet captured UNDO information"
                           , LERR_(UNBOUND_ARGUMENTS));
    }
    
  }
  
  
  
  
  lib::Depend<CommandRegistry> CommandRegistry::instance;
  
  
  Command::~Command() { }
  CommandImpl::~CommandImpl() { }
  
  
  
  
  Command
  Command::get (Symbol cmdID)
  {
    Command cmd = CommandRegistry::instance().queryIndex (cmdID);
    if (!cmd)
      throw error::Invalid(_Fmt("Command \"%s\" not found") % cmdID
                          , LERR_(INVALID_COMMAND));
    
    ENSURE (cmdID == CommandRegistry::instance().findDefinition(cmd));
    return cmd;
  }
  
  
  Command
  Command::maybeGetNewInstance (Symbol cmdID)
  {
    Command cmd = CommandRegistry::instance().queryIndex (cmdID);
    return cmd? cmd.newInstance()
              : Command{};
  }
  
  
  Command
  Command::fetchDef (Symbol cmdID)
  {
    return CommandRegistry::instance().queryIndex (cmdID);
  }
  
  
  void
  Command::activate (shared_ptr<CommandImpl> && implFrame, Symbol cmdID)
  {
    REQUIRE (implFrame);
    
    if (this->isValid())
      duplicate_detected (cmdID);
    
    _Handle::activate (move (implFrame));
    if (cmdID)
      {
        CommandRegistry::instance().track (cmdID, *this);
        impl().cmdID = cmdID;
      }
    
    TRACE (command, "%s defined OK", cStr(*this));
  }
  
  
  Command
  Command::storeDef (Symbol newCmdID)  const
  {
    CommandRegistry& registry = CommandRegistry::instance();
    
    ___check_notBottom (this,"Cloning");
    if (registry.queryIndex (newCmdID))
      duplicate_detected (newCmdID);
    
    Command cloneDefinition;
    cloneDefinition.activate (move (registry.createCloneImpl(this->impl())), newCmdID);
    ENSURE (cloneDefinition);
    return cloneDefinition;
  }
  
  
  Command
  Command::newInstance ()  const
  {
    ___check_notBottom (this,"Cloning");
    CommandRegistry& registry = CommandRegistry::instance();
    shared_ptr<CommandImpl> cloneImpl = registry.createCloneImpl(this->impl());
    
    Command clone;
    clone.activate (move (cloneImpl));
    ENSURE (clone);
    return clone;
  }
  
  
  shared_ptr<CommandImpl>
  CommandRegistry::createCloneImpl (CommandImpl const& refObject)
  {
    CommandImplCloneBuilder cloneBuilder(allocator_);
    refObject.prepareClone(cloneBuilder);
    return allocator_.create<CommandImpl> (refObject, cloneBuilder.clonedUndoMutation()
                                                    , cloneBuilder.clonedClosuere());
  }
  
  
  
  void
  Command::duplicate_detected (Symbol newCmdID)  const
  {
    throw error::Logic (_Fmt("Unable to store %s as new command. "
                             "ID \"%s\" is already in use")
                            % *this
                            % newCmdID
                       , LERR_(DUPLICATE_COMMAND));
  }
  
  
  bool
  Command::remove (Symbol cmdID)
  {
    return CommandRegistry::instance().remove (cmdID);
  }
  
  
  void
  Command::setArguments (Arguments& args)
  {
    ___check_notBottom (this, "Binding arguments of");
    _Handle::impl().setArguments(args);
  }
  
  
  void
  Command::setArguments (lib::diff::Rec const& paramData)
  {
    ___check_notBottom (this, "Binding arguments of");
    _Handle::impl().setArguments(paramData);
  }
  
  
  Command&
  Command::unbind()
  {
    ___check_notBottom (this, "Un-binding arguments of");
    _Handle::impl().discardArguments();
    return *this;
  }
  
  
  size_t
  Command::definition_count()
  {
    return CommandRegistry::instance().index_size();
  }
  
  
  
  size_t
  Command::instance_count()
  {
    return CommandRegistry::instance().instance_count();
  }
  
  
  
  namespace {
    inline bool
    was_activated (Command const& com)
    {
      return com.isValid();
    }
    
    inline Command
    registered_for (Symbol id)
    {
      return CommandRegistry::instance().queryIndex (id);
    }
  }
  
  
  CommandDef::~CommandDef()
  {
    if (!was_activated (prototype_))
      CommandRegistry::instance().remove (this->id_);
  }
  
  
  bool
  CommandDef::isValid()  const
  {
    return (was_activated (prototype_))
        && (prototype_ == registered_for (this->id_))
         ;
  }
  
  
  
  bool
  Command::canExec()  const
  {
    return isValid()
        && impl().canExec();
  }
  
  
  bool
  Command::canUndo()  const
  {
    return isValid()
        && impl().canUndo();
  }
  
  
  Symbol
  Command::getID()  const noexcept
  {
    return isValid()? impl().cmdID
                    : Symbol::FAILURE;
  }
  
  
  bool
  Command::isAnonymous()  const
  {
    return not CommandRegistry::instance().findDefinition (*this);
  }
  
  
  
  
  Command::operator string() const
  {
    ostringstream repr;
    repr << "Command(\""<<getID()<<"\") ";
    if (!isValid())
      repr << "NIL";
    else
      if (canUndo())
        repr << "{undo}";
      else
        if (canExec())
          repr << "{exec}";
        else
            repr << "{def}";
    
    return repr.str();
  }
  
  
  
  
  ExecResult
  Command::exec (HandlingPattern const& execPattern)
  {
    ___check_notBottom (this,"Invoking");
    ___check_isBound   (this);
    
    string cmdName{*this};
    CommandImpl& thisCommand (_Handle::impl());
    return execPattern.exec (thisCommand, cmdName);
  }
  
  
  ExecResult
  Command::undo (HandlingPattern const& execPattern)
  {
    ___check_notBottom (this,"UNDOing");
    ___check_canUndo   (this);
    
    string cmdName{*this};
    CommandImpl& thisCommand (_Handle::impl());
    return execPattern.undo (thisCommand, cmdName);
  }
  
  
  ExecResult
  Command::exec (HandlingPattern::ID pattID)
  {
    return exec (HandlingPattern::get(pattID));
  }
  
  
  ExecResult
  Command::undo (HandlingPattern::ID pattID)
  {
    return undo (HandlingPattern::get(pattID));
  }
  
  
  ExecResult
  Command::execSync ()
  {
    return exec (HandlingPattern::get(HandlingPattern::DUMMY));       
  }
  
  
  HandlingPattern::ID
  Command::getDefaultHandlingPattern()  const
  {
    ___check_notBottom (this,"Accessing");
    return impl().getDefaultHandlingPattern();
  }
  
  
  HandlingPattern::ID
  Command::setHandlingPattern (HandlingPattern::ID pattID)
  {
    ___check_notBottom (this, "Configuring");
    return impl().setHandlingPattern(pattID);
  }
  
  
  
  
  
}} // namespace steam::control