Description

The adapter can be used to connect to the AMI interface of an (remote) Asterisk instance.
It does an automatic reconnect on TCP error.
AMI events will be parsed and returned as a structured map.
AMI actions can be executed and the server response is returned synchronously as a structured map.

API

*NewAMIAdapter(ip string) (AMIAdapter, error)
- Creates a new instance of the adapter
Login(username string, password string) (chan map[string]string, error)
- Login to (remote) asterisk and returns a channel on which key-value based AMI events can be received
Exec(action map[string]string) map[string]string
- Executes an action and returns the key-value based response from the server

Example Usage

import (
	"fmt"
	"github.com/markose/amiConnect"
	"log"
)

func main() {

	var err error
	var a *amiConnect.AMIAdapter
	var events chan map[string]string

	a, err = amiConnect.NewAMIAdapter("127.0.0.1")
	if err != nil {
		log.Fatalln(err)
	}

	events, err = a.Login("testuser", "testsecret")
	if err != nil {
		log.Fatalln(err)
	}

	go func() {
		for {
			var event = <-events

			log.Println("---EVENT---")
			for e := range event {
				log.Println(e + ":" + event[e])
			}
			log.Println("------------")
		}
	}()

	var action = map[string]string{
		"Action":   "Setvar",
		"ActionID": "Setvar_1234",
		"Channel":  "SOME_CHANNEL",
		"Variable": "SOME_VAR",
		"Value":    "SOME_VALUE",
	}

	result := a.Exec(action)

	if result["Response"] == "Success" {
		fmt.Printf("SUCCESS: Set variable")
	} else if result["Response"] == "Error" {
		fmt.Printf("ERROR: Set variable")
	}
}