Add GetEvents function to decode and receive events from AMI

ami/manager.go

@@ -443,3 +443,16 @@ func ShowDialPlan(socket *Socket, actionID, extension, context string) (map[stri
 	}
 	return getMessage(socket, command, actionID)
 }
+
+//	GetEvents
+//		Get events from current socket connection
+//		It is mandatory set 'events' of ami.Login with "system,call,all,user", to received
+//		events
+//
+func GetEvents(socket *Socket) (map[string]string, error) {
+	message, err := decode(socket)
+	if err != nil {
+		return nil, err
+	}
+	return message, nil
+}

example/events.go

@@ -0,0 +1,52 @@
+// Copyright 2014 Helton Marques
+//
+//	Use of this source code is governed by a LGPL
+//	license that can be found in the LICENSE file.
+//
+
+package main
+
+import (
+	"fmt"
+	"github.com/heltonmarx/goami/ami"
+)
+
+func main() {
+	socket, err := ami.NewSocket("127.0.0.1:5038")
+	if err != nil {
+		fmt.Printf("socket error: %v\n", err)
+		return
+	}
+	if _, err := ami.Connect(socket); err != nil {
+		return
+	}
+	var ret bool
+
+	//Login
+	uuid, _ := ami.GetUUID()
+	ret, err = ami.Login(socket, "admin", "admin", "system,call,all,user", uuid)
+	if err != nil || ret == false {
+		fmt.Printf("login error (%v)\n", err)
+		return
+	}
+	fmt.Printf("login ok!\n")
+
+	//Events
+	for {
+		events, err := ami.GetEvents(socket)
+		if err != nil {
+			fmt.Printf("events error (%v)\n", err)
+			return
+		}
+		fmt.Printf("recv event: %v\n", events)
+	}
+
+	//Logoff
+	fmt.Printf("logoff\n")
+	ret, err = ami.Logoff(socket, uuid)
+	if err != nil || ret == false {
+		fmt.Printf("logoff error: (%v)\n", err)
+		return
+	}
+	fmt.Printf("goodbye !\n")
+}