fake-configrules.cpp

Go to the documentation of this file.

/*
  FakeConfigRules  -  dummy implementation of the config rules system

   Copyright (C)
     2008,            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 "steam/mobject/session/query/fake-configrules.hpp"

#include "steam/mobject/session.hpp"
#include "steam/mobject/session/fork.hpp"
#include "steam/asset/procpatt.hpp"
#include "steam/asset/pipe.hpp"
#include "lib/query-util.hpp"
#include "common/query.hpp"

#include "include/logging.h"
#include "lib/symbol.hpp"
#include "lib/util.hpp"

using lib::Literal;
using util::isnil;


namespace steam {
namespace mobject {
namespace session {
  
  namespace query {
    
    using asset::Struct;
    using asset::Pipe;
    using asset::PPipe;
    
    using asset::ProcPatt;
    using asset::PProcPatt;
    
//  using lib::query::extractID;
    using lib::query::extractID;   
    using lib::query::removeTerm;
    
    
    namespace {
      
      typedef std::pair<const QueryKey, any> AnyPair;
      
      template<class TY>
      AnyPair entry (Query<TY> const& query, typename WrapReturn<TY>::Wrapper& obj)
      {
        return AnyPair(query, any(obj)); 
      }
      
      template<class STRU>
      AnyPair entry_Struct(Literal caps)
      {
        typedef typename WrapReturn<STRU>::Wrapper Ptr;
        
        string capabilities (caps);
        Query<STRU> query (capabilities); 
        Ptr obj = Struct::retrieve (query);
        return AnyPair(query, obj);
      }
    }
    
    
    void
    MockTable::fill_mock_table ()
    {
      INFO (config, "creating mock answers for some hard wired config queries...");
      isInit_ = true; // allow re-entrance
      
      typedef const ProcPatt cPP;
      
      
      // for baiscpipetest.cpp ---------
      answer_.insert (entry_Struct<cPP> ("stream(video)"));
      answer_.insert (entry_Struct<cPP> ("stream(teststream)"));
      item<cPP> ("stream(default)")  = item<cPP> ("stream(video)"); // set up a default stream
      
      answer_.insert (entry_Struct<Pipe> ("pipe(master), stream(video)"));
      item<Pipe> ("") = item<Pipe>("pipe(master), stream(video)");//   use as default
      
      answer_.insert (entry_Struct<Pipe> ("pipe(ambiance)"));
    }
    
    
    void
    MockTable::reset()
    {
      answer_.clear();
      isInit_ = false;
      INFO (config, "discarded all config query mock answers.");
    }
    
    
    
    
    
    /* under some circumstances we need to emulate the behaviour *
     * of a real resolution engine in a more detailed manner.    *
     * The code below implements these cases hard wired.         */
    
    bool 
    MockTable::fabricate_matching_new_Pipe (Query<Pipe> const& q, string const& pipeID, string const& streamID)
    {
      typedef WrapReturn<Pipe>::Wrapper Ptr;
      
      Ptr newPipe (Struct::retrieve.newPipe (pipeID, streamID));
      answer_.insert (entry<Pipe> (q, newPipe));
      return true; // indicates that the query will now succeed...
    }
    
    bool 
    MockTable::fabricate_just_new_Pipe (Query<Pipe> const& q )
    {
      typedef WrapReturn<Pipe>::Wrapper Ptr;
      
      Ptr newPipe (Struct::retrieve.made4fake (q));
      answer_.insert (entry<Pipe> (q, newPipe));
      return true;
    }
    
    bool 
    MockTable::fabricate_ProcPatt_on_demand (Query<const ProcPatt> const& q)
    {
      typedef const ProcPatt cPP;
      typedef WrapReturn<cPP>::Wrapper Ptr;
      
      Ptr newPP (Struct::retrieve.made4fake (q));
      answer_.insert (entry<cPP> (q, newPP));
      return true;
    }
    
    bool 
    MockTable::fabricate_Timeline_on_demand (Query<asset::Timeline> const& query)
    {
      typedef asset::Timeline aTL;
      typedef WrapReturn<aTL>::Wrapper Ptr;
      
      string nameID = query.extractID("id");
      if (isnil (nameID))
        nameID = query.extractID("timeline");
      if (isnil (nameID))
        nameID = "prime";
      
      Query<aTL> normalisedQuery =
          query.rebuild()
               .removeTerm("id")
               .removeTerm("timeline")
               .prependConditions("id("+nameID+")");
      
      // try to find an existing one with the desired id
      Ptr newTimeline;
      size_t i=0, cnt=Session::current->timelines.size();
      for ( ; i < cnt; ++i)
        if (nameID == Session::current->timelines[i]->ident.name)
          {
            newTimeline = Session::current->timelines[i];
            break;
          }
      
      if (!newTimeline)
        newTimeline = Struct::retrieve.made4fake (normalisedQuery); // no suitable Timeline found: create and attach new one
      answer_.insert (entry<aTL> (normalisedQuery, newTimeline));  // "learn" the found/created Timeline as new solution
      answer_.insert (entry<aTL> (query, newTimeline));
      return true;
    }
    
    bool 
    MockTable::fabricate_Sequence_on_demand (Query<asset::Sequence> const& query)
    {
      typedef asset::Sequence aSeq;
      typedef WrapReturn<aSeq>::Wrapper Ptr;
      
      string nameID = query.extractID("id");
      if (isnil (nameID))
        nameID = query.extractID("sequence");
      if (isnil (nameID))
        nameID = "first";
      
      Query<aSeq> normalisedQuery =
          query.rebuild()
               .removeTerm("id")
               .removeTerm("sequence")
               .prependConditions("id("+nameID+")");
      
      // try to find an existing sequence with the desired id
      Ptr newSequence;
      size_t i=0, cnt=Session::current->sequences.size();
      for ( ; i < cnt; ++i)
        if (nameID == Session::current->sequences[i]->ident.name)
          {
            newSequence = Session::current->sequences[i];
            break;
          }
      
      if (!newSequence)
        newSequence = Struct::retrieve.made4fake (normalisedQuery);  // no suitable found: create and attach new Sequence
      answer_.insert (entry<aSeq> (normalisedQuery, newSequence));  // "learn" the found/created new solution
      answer_.insert (entry<aSeq> (query, newSequence));
      return true;
    }
    
    
    template<class TY>
    bool 
    MockTable::set_new_mock_solution (Query<TY> const& q, typename WrapReturn<TY>::Wrapper& obj)
    {
      answer_.erase (q);
      answer_.insert (entry<TY> (q, obj));
      return true;
    }
    // generate the necessary specialisations-----------------------------------
    template bool MockTable::set_new_mock_solution (Query<Pipe> const&, PPipe&);
    
    
    
    
    
    MockConfigRules::MockConfigRules () 
    {
      WARN (config, "using a mock implementation of the ConfigQuery interface");
    }
    
    
    MockTable::MockTable ()
      : answer_()
      , isInit_(false)
    { }
    
    
    
    
    any const& 
    MockTable::fetch_from_table_for (QueryKey const& query)
    {
      static const any NOTFOUND;
      if (!isInit_) fill_mock_table();
      
      Tab::iterator i = answer_.find (query);
      if (i == answer_.end())
        return NOTFOUND;
      else
        return i->second;
    }
  
  
  
  } // namespace query
}}} // namespace steam::mobject::session