package main

import (
	"fmt"
	"github.com/zhouhailin/freeswitch-esl-go/esl"
	"os"
	"strconv"
	"time"
)

type EslEventListener struct {
}

func printlnEslEvent(event *esl.EslEvent) {
	fmt.Println("###### messageHeaders ")
	for name, value := range *event.GetMessageHeaders() {
		fmt.Printf("name : [%s], value : [%s]\n", name, value)
	}
	fmt.Println("###### eventHeaders ")
	for name, value := range *event.GetEventHeaders() {
		fmt.Printf("name : [%s], value : [%s]\n", name, value)
	}
	fmt.Println("###### eventBody ")
	for index, line := range *event.GetEventBodyLines() {
		fmt.Printf(" [%d] : [%s]\n", index, line)
	}
}

func (l *EslEventListener) EventReceived(event *esl.EslEvent) error {
	fmt.Println("######## eventReceived : " + event.ToString())
	printlnEslEvent(event)
	return nil
}

func (l *EslEventListener) BackgroundJobResultReceived(event *esl.EslEvent) error {
	fmt.Println("######## backgroundJobResultReceived : " + event.ToString())
	printlnEslEvent(event)
	return nil
}

type EslConnectionListener struct {
}

func (l *EslConnectionListener) ConnectFailure(c *esl.Client) {
	fmt.Println("ConnectFailure")
}
func (l *EslConnectionListener) Connected(c *esl.Client) {
	fmt.Println("Connected")
}
func (l *EslConnectionListener) Authenticated(authenticated bool, c *esl.Client) {
	fmt.Println("Authenticated : " + strconv.FormatBool(authenticated))
}
func (l *EslConnectionListener) Disconnected(c *esl.Client) {
	fmt.Println("Disconnected")
}

func main() {
	eventListener := EslEventListener{}
	eslConnectionListener := EslConnectionListener{}
	env, b := os.LookupEnv("PATH")
	println(env, b)
	client := esl.NewClient("127.0.0.1", 8021, "ClueCon", 5, &esl.Options{
		Level: esl.DebugLevel,
	})
	fmt.Println(client)
	client.AddEventListener(&eventListener)
	client.AddConnectionListener(&eslConnectionListener)
	err := client.Connect()
	if err != nil {
		fmt.Printf("%v\n", err)
		return
	}
	subscriptions, err := client.SetEventSubscriptions("plain", "ALL")
	if err != nil {
		fmt.Printf("%v\n", err)
		return
	}
	fmt.Println(subscriptions)
	fmt.Println(client)
	time.Sleep(200 * time.Second)
}

package main

import (
	"fmt"
	"github.com/zhouhailin/freeswitch-esl-go/esl"
	"os"
	"strconv"
	"time"
)

type EslEventListener struct {
}

func printlnEslEvent(event *esl.EslEvent) {
	fmt.Println("###### messageHeaders ")
	for name, value := range *event.GetMessageHeaders() {
		fmt.Printf("name : [%s], value : [%s]\n", name, value)
	}
	fmt.Println("###### eventHeaders ")
	for name, value := range *event.GetEventHeaders() {
		fmt.Printf("name : [%s], value : [%s]\n", name, value)
	}
	fmt.Println("###### eventBody ")
	for index, line := range *event.GetEventBodyLines() {
		fmt.Printf(" [%d] : [%s]\n", index, line)
	}
}

func (l *EslEventListener) EventReceived(event *esl.EslEvent) error {
	fmt.Println("######## eventReceived : " + event.ToString())
	printlnEslEvent(event)
	return nil
}

func (l *EslEventListener) BackgroundJobResultReceived(event *esl.EslEvent) error {
	fmt.Println("######## backgroundJobResultReceived : " + event.ToString())
	printlnEslEvent(event)
	return nil
}

type EslConnectionListener struct {
}

func (l *EslConnectionListener) ConnectFailure(c *esl.Client) {
	fmt.Println("ConnectFailure")
}
func (l *EslConnectionListener) Connected(client *esl.Client) {
	fmt.Println("Connected")
}
func (l *EslConnectionListener) Authenticated(authenticated bool, client *esl.Client) {
	fmt.Println("Authenticated : " + strconv.FormatBool(authenticated))
	if authenticated {
		subscriptions, err := client.SetEventSubscriptions("plain", "ALL")
		if err != nil {
			fmt.Printf("%v\n", err)
			return
		}
		fmt.Println(subscriptions)
	}
}
func (l *EslConnectionListener) Disconnected(c *esl.Client) {
	fmt.Println("Disconnected")
}

func main() {
	eventListener := EslEventListener{}
	eslConnectionListener := EslConnectionListener{}
	env, b := os.LookupEnv("PATH")
	println(env, b)
	client := esl.NewClient("127.0.0.1", 8021, "ClueCon", 5, &esl.Options{
		AutoReconnection:         true,
		ReconnectIntervalSeconds: 3,
		MaxReconnectAttempts:     100,
		Level:                    esl.DebugLevel,
	})
	fmt.Println(client)
	client.AddEventListener(&eventListener)
	client.AddConnectionListener(&eslConnectionListener)
	err := client.Connect()
	if err != nil {
		fmt.Printf("%v\n", err)
	}
	fmt.Println(client)
	time.Sleep(200 * time.Second)
}