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

describe Tengine::Core::Handler do
  valid_attributes1 = {
    :filepath => "path/to/driver.rb",
    :lineno => 100,
  }.freeze

  context "filepathとlinenoは必須" do
    it "正常系" do
      driver1 = Tengine::Core::Handler.new(valid_attributes1)
      driver1.valid?.should == true
    end

    [:filepath, :lineno].each do |key|
      it "#{key}なし" do
        attrs = valid_attributes1.dup
        attrs.delete(key)
        driver1 = Tengine::Core::Handler.new(attrs)
        driver1.valid?.should == false
      end
    end
  end

#   context :process_event do
#     before do
#       @driver = Tengine::Core::Driver.new
#       @handler = Tengine::Core::Handler.new(:driver => @driver)
#     end

#     it "マッチするかどうかと関係なくブロックが呼び出されます" do
#       mock_dsl_context = mock(:dsl_context)
#       mock_kernel = mock(:kernel)
#       mock_event = mock(:event)
#       mock_caller = mock(:caller)
#       mock_block = nil
#       mock_caller.instance_eval do
#         mock_block = lambda{}
#       end
#       mock_event.stub(:kernel).and_return(mock_kernel)
#       mock_kernel.stub(:dsl_context).and_return(mock_dsl_context)
#       mock_dsl_context.stub(:__block_for__).and_return(mock_block)
#       # @handler.should_receive(:instance_eval).with(&mock_block)
#       mock_caller.should_receive(:__safety_driver__).and_yield
#       mock_caller.should_receive(:__safety_event__).and_yield
#       mock_caller.should_receive(:instance_eval)
#       @handler.process_event(mock_event, &mock_block)
#     end
#   end

  describe :match? do
    context "without session" do
      # it "by source_name"
      # it "by sender_name"
      # it "by occurred_at"
    end

    context "with session" do
      context "foo & bar" do
        before do
          Tengine::Core::Driver.delete_all
          Tengine::Core::Session.delete_all
          @driver1 = Tengine::Core::Driver.new(:name => "driver1", :version => "123")
          @handler = @driver1.handlers.new(:event_type_names => [:foo, :bar],
            :filepath => "path/to/driver.rb",
            :lineno => 11,
            :filter => {
              'method' => :and,
              'children' => [
                { 'pattern' => 'foo', 'method' => :find_or_mark_in_session },
                { 'pattern' => 'bar', 'method' => :find_or_mark_in_session },
              ]
            })
          @driver1.save!
          @handler
        end
        subject{ @handler }

        it "最初にfooが受信したらセッションに記録してfalse" do
          event_foo = FactoryGirl.create(:"tengine/core/event", :event_type_name => "foo")
          subject.match?(event_foo).should == false
          @driver1.session.system_properties.should == {'mark_foo' => true}
        end

        it "最初にbarが受信したらセッションに記録してfalse" do
          # 実装がall?などを使って全てのフィルタを評価しない場合は失敗することがあります。
          event_bar = FactoryGirl.create(:"tengine/core/event", :event_type_name => "bar")
          subject.match?(event_bar).should == false
          @driver1.session.system_properties.should == {'mark_bar' => true}
        end

        context "一度fooを受信した場合" do
          before do
            session = @driver1.session
            session.system_properties = {'mark_foo' => true}
            session.save!
          end

          it "再度fooが来るとセッションは変更なくfalse" do
            event_foo = FactoryGirl.create(:"tengine/core/event", :event_type_name => "foo")
            subject.match?(event_foo).should == false
            @driver1.reload
            @driver1.session.system_properties.should == {'mark_foo' => true}
          end

          it "barが来るとセッションを変更してtrue" do
            event_bar = FactoryGirl.create(:"tengine/core/event", :event_type_name => "bar")
            subject.match?(event_bar).should == true
            @driver1.reload
            @driver1.session.system_properties.should == {'mark_foo' => true, 'mark_bar' => true}
          end
        end

        context "一度barを受信した場合" do
          before do
            session = @driver1.session
            session.system_properties = {'mark_bar' => true}
            session.save!
          end

          it "fooが来るとセッションを変更してtrue" do
            event_foo = FactoryGirl.create(:"tengine/core/event", :event_type_name => "foo")
            subject.match?(event_foo).should == true
            @driver1.reload
            @driver1.session.system_properties.should == {'mark_foo' => true, 'mark_bar' => true}
          end
        end


      end

    end

  end


  describe 'filter persistence' do
    before do
      Tengine::Core::Driver.delete_all
      @driver1 = Tengine::Core::Driver.new(:name => "driver1", :version => "123")
    end

    it "デフォルトでは空のHash" do
      @driver1.handlers.new(:event_type_names => [:foo, :bar],
        :filepath => "path/to/driver.rb", :lineno => 8)
      @driver1.save!
      loaded = Tengine::Core::Driver.find(@driver1.id)
      handler1 = loaded.handlers.first
      handler1.filter.should == {}
    end

    it "はネストしたフィルタの情報を保持できる" do
      expected_hash = {
          :method => :or,
          :children => [
            {
              :method => :and,
              :children => [
                { :pattern => 'foo', :method => :find_or_mark_in_session },
                { :pattern => 'bar', :method => :find_or_mark_in_session },
              ]
            },
            { :method => :equal, :pattern => "baz"}
          ]
        }
      @driver1.handlers.new(:event_type_names => [:foo, :bar],
        :filepath => "path/to/driver.rb", :lineno => 8,
        :filter => expected_hash)
      @driver1.save!
      loaded = Tengine::Core::Driver.find(@driver1.id)
      handler1 = loaded.handlers.first
      # mongoの制約でSymbolのキーは文字列に変換される。
      handler1.filter.should == {
          'method' => :or,
          'children' => [
            {
              'method' => :and,
              'children' => [
                { 'pattern' => 'foo', 'method' => :find_or_mark_in_session },
                { 'pattern' => 'bar', 'method' => :find_or_mark_in_session },
              ]
            },
            { 'method' => :equal, 'pattern' => "baz"}
          ]
        }
    end
  end

end