Ruote::Context

# File lib/ruote/context.rb, line 43
def initialize (storage, worker=nil)

  @storage = storage
  @storage.context = self

  @engine = nil
  @worker = worker

  @services = {}

  initialize_services
end

# File lib/ruote/context.rb, line 83
def [] (key)

  SERVICE_PREFIX.match(key) ? @services[key] : get_conf[key]
end

# File lib/ruote/context.rb, line 90
def []= (key, value)

  raise(
    ArgumentError.new('use context#add_service to register services')
  ) if SERVICE_PREFIX.match(key)

  cf = get_conf
  cf[key] = value
  @storage.put(cf)

  value
end

# File lib/ruote/context.rb, line 108
def add_service (key, *args)

  path, klass, opts = args

  key = "s_#{key}" unless SERVICE_PREFIX.match(key)

  service = if klass

    require(path) if path

    aa = [ self ]
    aa << opts if opts

    @services[key] = Ruote.constantize(klass).new(*aa)
  else

    @services[key] = path
  end

  self.class.class_eval %{ def #{key[2..-1]}; @services['#{key}']; end }
    #
    # This 'one-liner' will add an instance method to Context for this
    # service.
    #
    # If the service key is 's_dishwasher', then the service will be
    # available via Context#dishwasher.
    #
    # I.e. dishwasher = engine.context.dishwasher

  service
end

# File lib/ruote/context.rb, line 64
def context

  self
end

# File lib/ruote/context.rb, line 72
def engine_id

  get_conf['engine_id'] || 'engine'
end

# File lib/ruote/context.rb, line 103
def keys

  get_conf.keys
end

# File lib/ruote/context.rb, line 142
def shutdown

  @storage.shutdown if @storage.respond_to?(:shutdown)
  @worker.shutdown if @worker

  @services.values.each { |s| s.shutdown if s.respond_to?(:shutdown) }
end

# File lib/ruote/context.rb, line 167
def default_conf

  { 's_wfidgen' => [
      'ruote/id/mnemo_wfid_generator', 'Ruote::MnemoWfidGenerator' ],
    's_parser' => [
      'ruote/parser', 'Ruote::Parser' ],
    's_treechecker' => [
      'ruote/util/treechecker', 'Ruote::TreeChecker' ],
    's_expmap' => [
       'ruote/exp/expression_map', 'Ruote::ExpressionMap' ],
    's_tracker' => [
      'ruote/evt/tracker', 'Ruote::Tracker' ],
    's_plist' => [
      'ruote/part/participant_list', 'Ruote::ParticipantList' ],
    's_dispatch_pool' => [
      'ruote/part/dispatch_pool', 'Ruote::DispatchPool' ],
    's_logger' => [
      'ruote/log/wait_logger', 'Ruote::WaitLogger' ],
    's_error_handler' => [
      'ruote/error_handler', 'Ruote::ErrorHandler' ] }
end

# File lib/ruote/context.rb, line 152
def get_conf

  @storage.get_configuration('engine') || {}
end

# File lib/ruote/context.rb, line 157
def initialize_services

  default_conf.merge(get_conf).each do |key, value|

    next unless SERVICE_PREFIX.match(key)

    add_service(key, *value)
  end
end