#!/usr/bin/env rspec

require 'spec_helper'

module MCollective
  module RPC
    describe Stats do
      before(:each) do
        @expected = {:discoverytime => 0,
                     :okcount => 0,
                     :blocktime => 0,
                     :failcount => 0,
                     :noresponsefrom => [],
                     :responses => 0,
                     :totaltime => 0,
                     :discovered => 0,
                     :starttime => 1300031826.0,
                     :requestid => nil,
                     :aggregate_summary => [],
                     :aggregate_failures => [],
                     :discovered_nodes => []}

        @stats = Stats.new
      end

      describe "#initialize" do
        it "should reset stats on creation" do
          Stats.any_instance.stubs(:reset).returns(true).once
          s = Stats.new
        end
      end

      describe "#reset" do
        it "should initialize data correctly" do
          Time.stubs(:now).returns(Time.at(1300031826))
          s = Stats.new

          @expected.keys.each do |k|
            @expected[k].should == s.send(k)
          end
        end
      end

      describe "#to_hash" do
        it "should return correct stats" do
          Time.stubs(:now).returns(Time.at(1300031826))
          s = Stats.new

          s.to_hash.should == @expected
        end
      end

      describe "#[]" do
        it "should return stat values" do
          Time.stubs(:now).returns(Time.at(1300031826))
          s = Stats.new

          @expected.keys.each do |k|
            @expected[k].should == s[k]
          end
        end

        it "should return nil for unknown values" do
          @stats["foo"].should == nil
        end
      end

      describe "#ok" do
        it "should increment stats" do
          @stats.ok
          @stats[:okcount].should == 1
        end
      end

      describe "#fail" do
        it "should increment stats" do
          @stats.fail
          @stats.failcount.should == 1
        end
      end

      describe "#time_discovery" do
        it "should set start time correctly" do
          Time.stubs(:now).returns(Time.at(1300031826))

          @stats.time_discovery(:start)

          @stats.instance_variable_get("@discovery_start").should == 1300031826.0
        end

        it "should record the difference correctly" do
          Time.stubs(:now).returns(Time.at(1300031826))
          @stats.time_discovery(:start)

          Time.stubs(:now).returns(Time.at(1300031827))
          @stats.time_discovery(:end)

          @stats.discoverytime.should == 1.0
        end

        it "should handle unknown actions and set discovery time to 0" do
          Time.stubs(:now).returns(Time.at(1300031826))
          @stats.time_discovery(:start)

          Time.stubs(:now).returns(Time.at(1300031827))
          @stats.time_discovery(:stop)

          @stats.discoverytime.should == 0
        end

      end

      describe "#client_stats=" do
        it "should store stats correctly" do
          data = {}
          keys = [:noresponsefrom, :responses, :starttime, :blocktime, :totaltime, :discoverytime]
          keys.each {|k| data[k] = k}

          @stats.client_stats = data

          keys.each do |k|
            @stats[k].should == data[k]
          end
        end

        it "should not store discovery time if it was already stored" do
          data = {}
          keys = [:noresponsefrom, :responses, :starttime, :blocktime, :totaltime, :discoverytime]
          keys.each {|k| data[k] = k}

          Time.stubs(:now).returns(Time.at(1300031826))
          @stats.time_discovery(:start)

          Time.stubs(:now).returns(Time.at(1300031827))
          @stats.time_discovery(:end)

          dtime = @stats.discoverytime

          @stats.client_stats = data

          @stats.discoverytime.should == dtime
        end
      end

      describe "#time_block_execution" do
        it "should set start time correctly" do
          Time.stubs(:now).returns(Time.at(1300031826))

          @stats.time_block_execution(:start)

          @stats.instance_variable_get("@block_start").should == 1300031826.0
        end

        it "should record the difference correctly" do
          Time.stubs(:now).returns(Time.at(1300031826))
          @stats.time_block_execution(:start)

          Time.stubs(:now).returns(Time.at(1300031827))
          @stats.time_block_execution(:end)

          @stats.blocktime.should == 1
        end

        it "should handle unknown actions and set discovery time to 0" do
          Time.stubs(:now).returns(Time.at(1300031826))
          @stats.time_block_execution(:start)

          Time.stubs(:now).returns(Time.at(1300031827))
          @stats.time_block_execution(:stop)

          @stats.blocktime.should == 0
        end
      end

      describe "#discovered_agents" do
        it "should set discovered_nodes" do
          nodes = ["one", "two"]
          @stats.discovered_agents(nodes)
          @stats.discovered_nodes.should == nodes
        end

        it "should set discovered count" do
          nodes = ["one", "two"]
          @stats.discovered_agents(nodes)
          @stats.discovered.should == 2
        end
      end

      describe "#finish_request" do
        it "should calculate totaltime correctly" do
          Time.stubs(:now).returns(Time.at(1300031824))
          @stats.time_discovery(:start)

          Time.stubs(:now).returns(Time.at(1300031825))
          @stats.time_discovery(:end)

          Time.stubs(:now).returns(Time.at(1300031826))
          @stats.time_block_execution(:start)

          Time.stubs(:now).returns(Time.at(1300031827))
          @stats.time_block_execution(:end)

          @stats.discovered_agents(["one", "two", "three"])
          @stats.node_responded("one")
          @stats.node_responded("two")

          @stats.finish_request

          @stats.totaltime.should == 2
        end

        it "should calculate no responses correctly" do
          Time.stubs(:now).returns(Time.at(1300031824))
          @stats.time_discovery(:start)

          Time.stubs(:now).returns(Time.at(1300031825))
          @stats.time_discovery(:end)

          Time.stubs(:now).returns(Time.at(1300031826))
          @stats.time_block_execution(:start)

          Time.stubs(:now).returns(Time.at(1300031827))
          @stats.time_block_execution(:end)

          @stats.discovered_agents(["one", "two", "three"])
          @stats.node_responded("one")
          @stats.node_responded("two")

          @stats.finish_request

          @stats.noresponsefrom.should == ["three"]
        end

        it "should recover from failure correctly" do
          Time.stubs(:now).returns(Time.at(1300031824))
          @stats.time_discovery(:start)

          Time.stubs(:now).returns(Time.at(1300031825))
          @stats.time_discovery(:end)

          Time.stubs(:now).returns(Time.at(1300031826))
          @stats.time_block_execution(:start)

          Time.stubs(:now).returns(Time.at(1300031827))
          @stats.time_block_execution(:end)

          # cause the .each to raise an exception
          @stats.instance_variable_set("@responsesfrom", nil)
          @stats.finish_request

          @stats.noresponsefrom.should == []
          @stats.totaltime.should == 0
        end
      end

      describe "#node_responded" do
        it "should append to the list of nodes" do
          @stats.node_responded "foo"
          @stats.responsesfrom.should == ["foo"]
        end

        it "should create a new array if adding fails" do
          # cause the << to fail
          @stats.instance_variable_set("@responsesfrom", nil)

          @stats.node_responded "foo"
          @stats.responsesfrom.should == ["foo"]
        end
      end

      describe "#no_response_report" do
        it "should create an empty report if all nodes responded" do
          @stats.discovered_agents ["foo"]
          @stats.node_responded "foo"
          @stats.finish_request

          @stats.no_response_report.should == ""
        end

        it "should list all nodes that did not respond" do
          @stats.discovered_agents ["foo", "bar"]
          @stats.finish_request

          @stats.no_response_report.should match(Regexp.new(/No response from.+bar\s+foo/m))
        end
      end

      describe "#text_for_aggregates" do
        let(:aggregate){mock()}

        before :each do
          aggregate.stubs(:result).returns({:output => "success"})
          aggregate.stubs(:action).returns("action")
        end

        it "should create the correct output text for aggregate functions" do
          @stats.aggregate_summary = [aggregate]
          aggregate.stubs(:is_a?).returns(true)
          @stats.text_for_aggregates.should =~ /Summary of.*/
        end

        it "should display an error message for a failed statup hook" do
          @stats.aggregate_failures = [{:name => "rspec", :type => :startup}]
          @stats.text_for_aggregates.should =~  /exception raised while processing startup hook/
        end

        it "should display an error message for an unspecified output" do
          @stats.aggregate_failures = [{:name => "rspec", :type => :create}]
          @stats.text_for_aggregates.should =~  /unspecified output 'rspec' for the action/
        end

        it "should display an error message for a failed process_result" do
          @stats.aggregate_failures = [{:name => "rspec", :type => :process_result}]
          @stats.text_for_aggregates.should =~  /exception raised while processing result data/
        end

        it "should display an error message for a failed summarize" do
          @stats.aggregate_failures = [{:name => "rspec", :type => :summarize}]
          @stats.text_for_aggregates.should =~  /exception raised while summarizing/
        end
      end
    end
  end
end