# -*- coding: utf-8 -*-
require 'spec_helper'

describe Tengine::Core::DslLoader do

  describe :__evaluate__ do
    before do
      Tengine::Core::Driver.delete_all
      Tengine::Core::HandlerPath.delete_all
    end

    context "DSLのファイルを指定する場合" do
      context "Driverを有効化して登録(シングルプロセスモード)" do
        before do
          config = Tengine::Core::Config::Core.new({
              :tengined => {
                :load_path => File.expand_path('../../../examples/uc01_execute_processing_for_event.rb', File.dirname(__FILE__))
              }
            })
          @kernel = Tengine::Core::Kernel.new(config)
        end

        it "イベントハンドラ定義を評価して、ドライバとハンドラを登録する" do
          @kernel.evaluate
          # $LOAD_PATH.include?(@config[:dsl_store_path]).should be_true
          # driver01 = Tengine::Core::Driver.find(:conditions => {:name => "driver01"})
          Tengine::Core::Driver.count.should == 1
          driver01 = Tengine::Core::Driver.first
          driver01.should_not be_nil
          driver01.name.should == "driver01"
          driver01.version.should == "20110902213500"
          driver01.enabled.should == true
          driver01.handlers.count.should == 1
          handler1 = driver01.handlers.first
          handler1.event_type_names.should == %w[event01]
          Tengine::Core::HandlerPath.where(:driver_id => driver01.id).count.should == 1
          Tengine::Core::HandlerPath.default_driver_version = "20110902213500"
          Tengine::Core::HandlerPath.find_handlers("event01").count.should == 1
        end
      end


      context "Driverを無効化して登録(マルチプロセスモード)" do
        before do
          config = Tengine::Core::Config::Core.new({
              :tengined => {
                :load_path => File.expand_path('../../../examples/uc01_execute_processing_for_event.rb', File.dirname(__FILE__)),
                :skip_enablement => true
              }
            })
          @kernel = Tengine::Core::Kernel.new(config)
        end

        it "イベントハンドラ定義を評価して、ドライバとハンドラを登録する" do
          @kernel.evaluate
          Tengine::Core::Driver.count.should == 1
          driver01 = Tengine::Core::Driver.first
          driver01.should_not be_nil
          driver01.name.should == "driver01"
          driver01.version.should == "20110902213500"
          driver01.handlers.count.should == 1
          handler1 = driver01.handlers.first
          handler1.event_type_names.should == %w[event01]
          Tengine::Core::HandlerPath.where(:driver_id => driver01.id).count.should == 1
          Tengine::Core::HandlerPath.default_driver_version = "20110902213500"
          Tengine::Core::HandlerPath.find_handlers("event01").count.should == 0
        end
      end
    end

    context "DSLのファイルを指定しない場合" do
      before do
        config = Tengine::Core::Config::Core.new({
            :tengined => {
              :load_path => File.expand_path('../../../examples', File.dirname(__FILE__))
            }
        })
        @kernel = Tengine::Core::Kernel.new(config)
        @loader = @kernel.dsl_context

        @loader.config.should_receive(:dsl_file_paths).and_return([
            "#{config[:tengined][:load_path]}/uc01_execute_processing_for_event.rb",
            "#{config[:tengined][:load_path]}/uc02_fire_another_event.rb",
            "#{config[:tengined][:load_path]}/uc03_2handlers_for_1event.rb",
          ])
      end

      it "イベントハンドラ定義を評価して、ドライバとハンドラを登録する" do
        # driver03にevent03が複数定義されているための警告メッセージ
        # Tengine::Core.stdout_logger.should_receive(:warn).with("driver\"driver03\"には、同一のevent_type_name\"event03\"が複数存在します")

        @kernel.evaluate

        Tengine::Core::Driver.count.should == 3
        drivers = Tengine::Core::Driver.all
        drivers.map(&:name).sort.should == ["driver01", "driver02", "driver03"]
        drivers.each do |driver|
          driver.version.should == "20110902213500"
        end

        driver01 = Tengine::Core::Driver.where(:name => "driver01").first
        handler1 = driver01.handlers.first
        handler1.event_type_names.should == %w[event01]
        Tengine::Core::HandlerPath.where(:driver_id => driver01.id).count.should == 1

        driver02 = Tengine::Core::Driver.where(:name => "driver02").first
        driver02.handlers.count.should == 2
        handler2_1, handler2_2 = driver02.handlers
        handler2_1.event_type_names.should == %w[event02_1]
        handler2_2.event_type_names.should == %w[event02_2]
        Tengine::Core::HandlerPath.where(:driver_id => driver02.id).count.should == 2

        driver03 = Tengine::Core::Driver.where(:name => "driver03").first
        driver03.handlers.count.should == 2
        handler3_1 = driver03.handlers.first
        handler3_1.filepath.should == "uc03_2handlers_for_1event.rb"
        handler3_1.lineno.should == 8
        handler3_1.event_type_names.should == %w[event03]
        handler3_2 = driver03.handlers.last
        handler3_2.filepath.should == "uc03_2handlers_for_1event.rb"
        handler3_2.lineno.should == 12
        handler3_2.event_type_names.should == %w[event03]
        Tengine::Core::HandlerPath.where(:driver_id => driver03.id).count.should == 2
      end
    end
  end

  describe "フィルタの登録" do
    before do
      Tengine::Core::Driver.delete_all
      Tengine::Core::HandlerPath.delete_all
    end

    context "Driverを有効化して登録(シングルプロセスモード)" do
      before do
        config = Tengine::Core::Config::Core.new({
            :tengined => {
              :load_path => File.expand_path('../../../examples/uc08_if_both_a_and_b_occurs.rb', File.dirname(__FILE__))
            }
          })
        @kernel = Tengine::Core::Kernel.new(config)
      end

      it "イベントハンドラ定義を評価して、ドライバとハンドラを登録する" do
        @kernel.evaluate
        Tengine::Core::Driver.count.should == 1
        driver = Tengine::Core::Driver.first
        driver.should_not be_nil
        driver.name.should == "driver08"
        driver.version.should == "20110902213500"
        driver.handlers.count.should == 1
        handler1 = driver.handlers.first
        handler1.event_type_names.should == %w[event08_a event_08_b]
        handler1.filter.should == {
          'method' => :and,
          'children' => [
            { 'pattern' => :event08_a , 'method' => :find_or_mark_in_session },
            { 'pattern' => :event_08_b, 'method' => :find_or_mark_in_session },
          ]
        }
        Tengine::Core::HandlerPath.where(:driver_id => driver.id).count.should == 2
        Tengine::Core::HandlerPath.default_driver_version = "20110902213500"
        handler_a = Tengine::Core::HandlerPath.find_handlers("event08_a").first
        handler_b = Tengine::Core::HandlerPath.find_handlers("event_08_b").last
        handler_a.id.should == handler1.id
        handler_b.id.should == handler1.id
      end
    end

  end

end