Ensure that the AMI version is reported on the Stream

CHANGELOG.md

@@ -1,4 +1,5 @@
 # [develop](https://github.com/adhearsion/ruby_ami)
+  # Feature: Reveal the AMI version for a `Stream` via `Stream#version`
 
 # [2.3.0](https://github.com/adhearsion/ruby_ami/compare/v2.2.1...v2.3.0) - [2015-06-01](https://rubygems.org/gems/ruby_ami/versions/2.3.0)
   * Feature: Allow optional error handler when calling `send_action`

features/lexer.feature

@@ -5,10 +5,10 @@ Feature: Lexing AMI
 
   Scenario: Lexing only the initial AMI version header
     Given a new lexer
-    And a version header for AMI 1.0
+    And a version header for AMI 2.8.0
 
     Then the protocol should have lexed without syntax errors
-    And the version should be set to 1.0
+    And the version should be set to 2.8.0
 
   Scenario: Lexing the initial AMI header and a login attempt
     Given a new lexer

features/step_definitions/lexer_steps.rb

@@ -17,7 +17,7 @@
 end
 
 Given "a version header for AMI $version" do |version|
-  @lexer << "Asterisk Call Manager/1.0\r\n"
+  @lexer << "Asterisk Call Manager/#{version}\r\n"
 end
 
 Given "a normal login success with events" do

lib/ruby_ami/lexer.rb

@@ -3,7 +3,7 @@
 module RubyAMI
   class Lexer
     STANZA_BREAK      = "\r\n\r\n"
-    PROMPT            = /Asterisk Call Manager\/(\d+\.\d+)\r\n/
+    PROMPT            = /Asterisk Call Manager\/(\d+(\.\d+)*)\r\n/
     KEYVALUEPAIR      = /^([[[:alnum:]]-_ ]+): *(.*)\r\n/
     FOLLOWSDELIMITER  = /\r?\n?--END COMMAND--\r\n\r\n/
     SUCCESS           = /response: *success/i

lib/ruby_ami/stream.rb

@@ -57,6 +57,10 @@ def post_init
       login @username, @password if @username && @password
     end
 
+    def version
+      @lexer.ami_version
+    end
+
     def send_data(data)
       @socket.write data
     end

spec/ruby_ami/stream_spec.rb

@@ -59,6 +59,25 @@ def expect_disconnected_event
         mocked_server 0, -> { @stream.started?.should be_true }
       end
 
+      it "stores the reported AMI version" do
+        expect_connected_event
+        expect_disconnected_event
+        mocked_server(1, lambda {
+          @stream.send_action('Command') # Just to get the server kicked in to replying using the below block
+          expect(@stream.version).to eq('2.8.0')
+        }) do |val, server|
+          server.send_data "Asterisk Call Manager/2.8.0\n"
+
+          # Just to unblock the above command before the actor shuts down
+          server.send_data <<-EVENT
+Response: Success
+ActionID: #{RubyAMI.new_uuid}
+Message: Recording started
+
+          EVENT
+        end
+      end
+
       it "can send an action" do
         expect_connected_event
         expect_disconnected_event