client-sdk-go

README

IPRON-NE 를 이용하기 위한 golang용 client SDK

본 SDK에는 IPRON-NE 의 콜제어 상태 모니터링을 위한 것입니다.

SDK 를 이용하기 위해서는 가입계정 또는 발급된 APP KEY 가 필요합니다.

데모 예제에서는 다음의 환경정보를 참조합니다.

export IPRON_NE_APPKEY=""
export IPRON_NE_API_URL=""
export IPRON_NE_GRPCAPI_URL=""

콜제어 & 정보조회

초기화 & 로그인

import (
	"log"
	"os"

	"github.com/ipron-ne/client-sdk-go/code"
	"github.com/ipron-ne/client-sdk-go/config"
	"github.com/ipron-ne/client-sdk-go/service"
	"github.com/ipron-ne/client-sdk-go/service/auth"
	"github.com/ipron-ne/client-sdk-go/types"
)

func main() {
	// 접속환경 설정
	cfg := config.NewConfig(
		config.WithBaseURL(API_URL),
		config.WithDebug(true),
	)

	// Client 생성
	client := service.NewFromConfig(cfg)

	// Client 인스턴스로 인증 서비스 생성
	auth := auth.NewFromClient(client)

	// 사용자 로그인
	err := auth.Login(UserID, Passwd, TenantName, []code.MediaType{code.Media.Voice},
		code.AgentStatus.NotReady,
		code.AgentStateCauseType("00"), // code.AgentStateCause.NotReady.Idle,
		DN,
		handlerEvent, handlerError,
	)
	if err != nil {
		panic(err)
	}

	time.Sleep(10 * time.Second)

	err = auth.Logout(client.GetTenantID(), auth.GetUserID(), []code.MediaType{code.Media.Voice}, 
		code.AgentStateCauseType("00")
	)
	if err != nil {
		panic(err)
	}
}

func handlerEvent(e types.Data) {
	log.Println(e)
}

func handlerError(err error) {
	log.Println(err)
}

정보조회

• Group 목록 조회

	// Client 인스턴스로 정보조회 서비스 생성
	info := info.NewFromClient(client)

	// Group List 조회
	groupList, err := info.GetGroupList(client.GetTenantID())
	if err != nil {
		log.Println(err)
	}
	for i, v := range groupList {
		log.Printf("[%02d] %+v\n", i, v)
	}

• Flow 목록 조회

	// Flow List 조회
	flowList, err = info.GetFlowList(client.GetTenantID())
	if err != nil {
		log.Println(err)
	}
	for i, v := range flowList {
		log.Printf("[%02d] %+v\n", i, v)
	}

모니터링

초기화

import (
	"log"
	"os"

	"github.com/ipron-ne/client-sdk-go/monitoring/sse"
	"github.com/ipron-ne/client-sdk-go/service"
	"github.com/ipron-ne/client-sdk-go/utils"
)

func main() {
	var (
		API_URL    = os.Getenv("IPRON_NE_URL")
		TenantID   = os.Getenv("IPRON_NE_TENANTID")
		AppToken   = os.Getenv("IPRON_NE_APPKEY")
	)

	cfg := config.NewConfig(
		config.WithBaseURL(API_URL),
		config.WithAppToken(AppToken),
		config.WithDebug(true),
		config.WithTenantID(TenantID),
	)

	client := service.NewFromConfig(cfg)
}

모니터링용 데이터셋 목록 조회

func listDatasets(client types.Client) {
	monitor := sse.NewFromClient(client)

	log.Printf("\n\n[Datasets List]\n")
	resp, err := monitor.GetDatasets(utils.NewParam("tntId", TenantID))
	if err != nil {
		log.Panic(err)
	}
	for _, item := range resp.Dataset {
		log.Printf("%+v\n", item)
	}
}

모니터링용 지정 데이터셋 항목 조회

func listDataset(client types.Client, datasetName string) {
	monitor := sse.NewFromClient(client)

	log.Printf("\n\n[Dataset List:%s]\n", datasetName)
	resp, err := monitor.GetDataset(datasetName, utils.NewParam("tntId", TenantID))
	if err != nil {
		log.Panic(err)
	}
	dataset := resp
	for _, item := range dataset {
		log.Printf("[%s] %s\n", item.Name, item.Desc)
	}
}

모리터링용 데이터셋 전체 조회

func listDatasource(client types.Client) {
	monitor := sse.NewFromClient(client)

	log.Printf("\n\n[Datasource]\n")
	resp, err := monitor.GetDatasource(utils.NewParam("tntId", TenantID))
	if err != nil {
		log.Panic(err)
	}
	for _, dataset := range resp {
		setName := dataset.DatasetName
		fields := monitor.GetDatasourceFields(dataset)

		log.Printf("[%s] \n", setName)
		for _, item := range fields {
			log.Printf("  - %s [%s] %s\n", item.Name, item.Type, item.Desc)
		}
	}
}

모니터링 변경 데이터 수신

func moniEvent(client types.Client, resource []string) {
	monitor := sse.NewFromClient(client)

	log.Printf("\n\n[EventListen]\n")

	params := map[string]any{
		"tntId": TenantID,
		"colFilter": []string{
			"flowName", "mediaType", "ivr1000", "ivr1010", "ivr1020", "ivr1040", "ivrmon1000",
		},
		"rowFilter": map[string]any{
			"flowId": resource,
			"mediaType": []string{
				"voice",
			},
		},
	}

	eventSubs, err := monitor.GetEventSource("flow", params)
	if err != nil {
		log.Panic(err)
	}
	eventSubs.OnMessage(func(e utils.Event){
		data := utils.JSONParse(e.Data())
		for _, v := range data.Array() {
			log.Printf("%+v\n", v.Object())
		}
	})

	eventSubs.EventLoop()
}

예제코드

• 상담사로그인
• 콜이벤트수신
• Flow Gateway
• Directory
• Message Gateway
• Omni Gateway
• Media Stream