voicestats/icsconf/icsconf.go

package icsconf

import (
	"encoding/xml"
	"fmt"
	"os"
	"strings"
	"sync"

	"gitlab.com/ics_cinnamon/voiceStatistics/icserror"
)

type IcsConfig struct {
	XMLName    xml.Name   `xml:"ICSVS"`
	Version    string     `xml:"version,attr"`
	InfoConfig InfoConfig `xml:"INFO"`
	LogConfig  LogConfig  `xml:"LOG"`
	Linger     int        `xml:"LINGER"`
	Target     Target     `xml:"TARGET"`
	Target1    Target1    `xml:"TARGET1"`
	HomeDir    string
}

type InfoConfig struct {
	Product  string `xml:"PRODUCT"`
	TenentID string `xml:"TENENTID"`
	ServerID int    `xml:"SERVERID"`
	ServerIP string `xml:"SERVERIP"`
}

type Target struct {
	Transport  string `xml:"transport,attr"`
	TargetPort int    `xml:"port,attr"`
}

type Target1 struct {
	Transport  string `xml:"transport,attr"`
	TargetPort int    `xml:"port,attr"`
}

type LogConfig struct {
	Path         string       `xml:"PATH"`
	Disklimit    int          `xml:"DISKLIMIT"`
	Level        string       `xml:"LEVEL"`
	Output       string       `xml:"OUTPUT"`
	RotateConfig RotateConfig `xml:"ROTATE"`
	DelConfig    DelConfig    `xml:"DELPERIOD"`
	HomeDir      string
}

type DelConfig struct {
	DelDay  int `xml:"day,attr"`
	DelHour int `xml:"hour,attr"`
}

type RotateConfig struct {
	Size  string `xml:"size,attr"`
	Num   string `xml:"num,attr"`
	YesNo string `xml:"yesno,attr"`
}

var gIcsConfig *IcsConfig
var onceConfig sync.Once

func OpenConfig(ConfigFileName string, homeDir string) (*IcsConfig, *icserror.IcsError) {
	var gerr *icserror.IcsError = nil

	onceConfig.Do(func() {
		fi, err := os.Open(ConfigFileName)
		if err != nil {
			icserror.ICSERRCONFOpenFile.SetError(err)
			gerr = icserror.ICSERRCONFOpenFile
			return
		}
		defer fi.Close()

		FI, _ := os.Stat(ConfigFileName)
		FileLength := FI.Size()

		configdata := make([]byte, FileLength)
		cnt, err := fi.Read(configdata)
		if cnt == 0 || err != nil {
			icserror.ICSERRCONFFileNotFound.SetError(err)
			gerr = icserror.ICSERRCONFFileNotFound
			return
		}

		gIcsConfig = &IcsConfig{}
		gIcsConfig.HomeDir = homeDir

		err = xml.Unmarshal([]byte(configdata), gIcsConfig)
		if err != nil {
			icserror.ICSERRCONFUnmarshal.SetError(err)
			gerr = icserror.ICSERRCONFUnmarshal
			gIcsConfig = nil
			return
		}

		if !strings.HasPrefix(gIcsConfig.LogConfig.Path, "/") {
			gIcsConfig.LogConfig.Path = fmt.Sprintf("%s/%s", homeDir, gIcsConfig.LogConfig.Path)
		}
		//default setting
		if gIcsConfig.LogConfig.DelConfig.DelDay == 0 {
			gIcsConfig.LogConfig.DelConfig.DelHour = 90
		}
		if gIcsConfig.LogConfig.DelConfig.DelHour == 0 {
			gIcsConfig.LogConfig.DelConfig.DelHour = 2
		}

		gIcsConfig.LogConfig.HomeDir = homeDir
	})

	if gerr != nil {
		return nil, gerr
	}

	return gIcsConfig, nil
}

func ReloadConfig(ConfigFileName string, homeDir string) (*IcsConfig, *icserror.IcsError) {
	fi, err := os.Open(ConfigFileName)
	if err != nil {
		icserror.ICSERRCONFOpenFile.SetError(err)
		return nil, icserror.ICSERRCONFOpenFile
	}
	defer fi.Close()

	FI, _ := os.Stat(ConfigFileName)
	FileLength := FI.Size()

	configdata := make([]byte, FileLength)
	cnt, err := fi.Read(configdata)
	if cnt == 0 || err != nil {
		icserror.ICSERRCONFFileNotFound.SetError(err)
		return nil, icserror.ICSERRCONFFileNotFound
	}

	gIcsConfig = &IcsConfig{}
	gIcsConfig.HomeDir = homeDir

	err = xml.Unmarshal([]byte(configdata), gIcsConfig)
	if err != nil {
		icserror.ICSERRCONFUnmarshal.SetError(err)
		return nil, icserror.ICSERRCONFUnmarshal
	}

	if !strings.HasPrefix(gIcsConfig.LogConfig.Path, "/") {
		gIcsConfig.LogConfig.Path = fmt.Sprintf("%s/%s", homeDir, gIcsConfig.LogConfig.Path)
	}
	//default setting
	if gIcsConfig.LogConfig.DelConfig.DelDay == 0 {
		gIcsConfig.LogConfig.DelConfig.DelHour = 90
	}
	if gIcsConfig.LogConfig.DelConfig.DelHour == 0 {
		gIcsConfig.LogConfig.DelConfig.DelHour = 2
	}

	gIcsConfig.LogConfig.HomeDir = homeDir

	return gIcsConfig, nil
}

func (c IcsConfig) GetHomeDir() string {
	return c.HomeDir
}

func (c IcsConfig) GetChannelID() string {
	return c.InfoConfig.TenentID
}

func (c IcsConfig) GetServerID() int {
	return c.InfoConfig.ServerID
}

//from LogConfig struct
func (c LogConfig) GetHomeDir() string {
	return c.HomeDir
}

func (c *IcsConfig) SetHomeDir(homeDir string) {
	c.HomeDir = homeDir
}

func GetIcsConfig() *IcsConfig {
	return gIcsConfig
}

func (c IcsConfig) ShowConfig() string {
	fmt.Printf("Log Level : %s\n", c.LogConfig.Level)
	fmt.Printf("Log Path : %s\n", c.LogConfig.Path)
	fmt.Printf("Log Disk Space Size : %dMB\n", c.LogConfig.Disklimit)
	fmt.Printf("Log Del Day : %d\n", c.LogConfig.DelConfig.DelDay)
	fmt.Printf("Log Del Hour : %d\n", c.LogConfig.DelConfig.DelHour)
	fmt.Printf("Log Output : %s\n", c.LogConfig.Output)
	fmt.Printf("Log Rotate : %s\n", c.LogConfig.RotateConfig.YesNo)
	fmt.Printf("Log Rotate File Size : %sMB\n", c.LogConfig.RotateConfig.Size)
	fmt.Printf("Log Rotate File Number : %s\n\n", c.LogConfig.RotateConfig.Num)
	fmt.Printf("Log Del Day : %d\n", c.LogConfig.DelConfig.DelDay)
	fmt.Printf("Log Del Hour : %d\n", c.LogConfig.DelConfig.DelHour)
	/*
		for iter := 0; iter < len(c.AgentConfig); iter++ {
			fmt.Printf("==========================\n")
			fmt.Printf("Agent Name: %s, Use? %s\n", c.AgentConfig[iter].Name, c.AgentConfig[iter].Value)
			fmt.Printf("Agent Media media: %s\n", c.AgentConfig[iter].MediaConfig.Media)
			fmt.Printf("Agent Media Port: %d\n", c.AgentConfig[iter].MediaConfig.Port)
			fmt.Printf("Agent Media Format: %s\n", c.AgentConfig[iter].MediaConfig.Format)
			fmt.Printf("Register value: %s\n", c.AgentConfig[iter].RegisterConfig.RegisterValue)
			fmt.Printf("Register Transport: %s\n", c.AgentConfig[iter].RegisterConfig.RegisterTransport)
			fmt.Printf("Register Expire: %d\n", c.AgentConfig[iter].RegisterConfig.RegisterExpire)
			fmt.Printf("Register Username: %s\n", c.AgentConfig[iter].RegisterConfig.RegisterUserName)
			fmt.Printf("Options Use? %s\n", c.AgentConfig[iter].OptionsConfig.OptionsValue)
			fmt.Printf("Options Interval: %d\n\n", c.AgentConfig[iter].OptionsConfig.OptionsInterval)
		}
	*/

	/*
		confmsg += fmt.Sprintf("iComsys Voice Agent Address : %s[%d:%d]\n",
			c.VoiceAgentConfig.AgentAddr.VoiceAgentIP, c.VoiceAgentConfig.AgentAddr.CallSignalPort, c.VoiceAgentConfig.AgentAddr.VoicePort)
	*/
	confmsg := fmt.Sprintf("Log Level : %s\n", c.LogConfig.Level)
	confmsg += fmt.Sprintf("Log Path : %s\n", c.LogConfig.Path)
	confmsg += fmt.Sprintf("Log Disk Space Size : %dMB\n", c.LogConfig.Disklimit)
	confmsg += fmt.Sprintf("Log Del Day : %d\n", c.LogConfig.DelConfig.DelDay)
	confmsg += fmt.Sprintf("Log Del Hour : %d\n", c.LogConfig.DelConfig.DelHour)
	confmsg += fmt.Sprintf("Log Output : %s\n", c.LogConfig.Output)
	confmsg += fmt.Sprintf("Log Rotate : %s\n", c.LogConfig.RotateConfig.YesNo)
	confmsg += fmt.Sprintf("Log Rotate File Size : %sMB\n", c.LogConfig.RotateConfig.Size)
	confmsg += fmt.Sprintf("Log Rotate File Number : %s\n\n", c.LogConfig.RotateConfig.Num)

	return confmsg
}

//////////////////////////////////////////
/////////////// simulator ////////////////
//////////////////////////////////////////

type SimConfig struct {
	XMLName           xml.Name          `xml:"SIMVC"`
	Version           string            `xml:"version,attr"`
	IsCaller          string            `xml:"ISCALLER"`
	Repeat            int               `xml:"REPEAT"`
	Channels          int               `xml:"CHANNELS"`
	TargetPhoneConfig TargetPhoneConfig `xml:"TARGET"`
	SimPhoneConfig    SimPhoneConfig    `xml:"SIM"`
	InOut             string            `xml:"INOUT"`
	LogConfig         LogConfig         `xml:"LOG"`
	RegiCount         int               `xml:"REGICOUNT"`
	MediaConfig       []SimMediaConfig  `xml:"MEDIA"`
	HomeDir           string
}

type TargetPhoneConfig struct {
	TargetIP string `xml:"ip,attr"`
	TSIPPort int    `xml:"sipport,attr"`
	TRTPPort int    `xml:"rtpport,attr"`
}

type SimPhoneConfig struct {
	MYIP    string `xml:"myip,attr"`
	SIPPort int    `xml:"sipport,attr"`
	RTPPort int    `xml:"rtpport,attr"`
}

type SimMediaConfig struct {
	Media  string `xml:"m,attr"`
	Port   int    `xml:"port,attr"`
	Format string `xml:"format,attr"`
}

type SimScenarioConfig struct {
	XMLName       xml.Name `xml:"SIMSCEN"`
	Version       string   `xml:"version,attr"`
	ScenarioCount int      `xml:"SCENARIOCOUNT"`
	SipOrder      SipOrder `xml:"ORDER"`
}

type SipOrder struct {
	Order    []string `xml:"METHOD"`
	StopTime int      `xml:"STOPTIME"`
}

func OpenSimConfig(ConfigFileName string, homeDir string) (*SimConfig, *icserror.IcsError) {
	fi, err := os.Open(ConfigFileName)
	if err != nil {
		icserror.ICSERRCONFOpenFile.SetError(err)
		return nil, icserror.ICSERRCONFOpenFile
	}
	defer fi.Close()

	FI, _ := os.Stat(ConfigFileName)
	FileLength := FI.Size()

	configdata := make([]byte, FileLength)
	cnt, err := fi.Read(configdata)
	if cnt == 0 || err != nil {
		icserror.ICSERRCONFFileNotFound.SetError(err)
		return nil, icserror.ICSERRCONFFileNotFound
	}

	conf := SimConfig{}
	conf.HomeDir = homeDir

	err = xml.Unmarshal([]byte(configdata), &conf)
	if err != nil {
		icserror.ICSERRCONFUnmarshal.SetError(err)
		return nil, icserror.ICSERRCONFUnmarshal
	}

	/*
		fmt.Printf("Configuration> xml name: %s, version: %s\n", conf.XMLName.Local, conf.Version)
		fmt.Println(conf.LicenseConfig)
		fmt.Println(conf.LogConfig)
		fmt.Println(conf.LogConfig.RotateConfig)
		fmt.Println(conf.CaptureConfig)
	*/

	conf.LogConfig.HomeDir = homeDir

	gSimConfig = &conf

	return &conf, nil
}

func OpenSimScenarioConfig(ConfigFileName string, homeDir string) (*SimScenarioConfig, *icserror.IcsError) {
	fi, err := os.Open(ConfigFileName)
	if err != nil {
		icserror.ICSERRCONFOpenFile.SetError(err)
		return nil, icserror.ICSERRCONFOpenFile
	}
	defer fi.Close()

	FI, _ := os.Stat(ConfigFileName)
	FileLength := FI.Size()

	configdata := make([]byte, FileLength)
	cnt, err := fi.Read(configdata)
	if cnt == 0 || err != nil {
		icserror.ICSERRCONFFileNotFound.SetError(err)
		return nil, icserror.ICSERRCONFFileNotFound
	}

	SimScenarioConf := SimScenarioConfig{}

	err = xml.Unmarshal([]byte(configdata), &SimScenarioConf)
	if err != nil {
		icserror.ICSERRCONFUnmarshal.SetError(err)
		return nil, icserror.ICSERRCONFUnmarshal
	}

	fmt.Println()

	gSimScenarioConfig = &SimScenarioConf
	return &SimScenarioConf, nil
}

func (c SimConfig) GetSimChannels() int {
	return c.Channels
}

func (c SimConfig) GetSimTargetIP() string {
	return c.TargetPhoneConfig.TargetIP
}

func (c SimConfig) GetSimTargetPort() int {
	return c.TargetPhoneConfig.TSIPPort
}

func (c SimConfig) ShowConfig() string {
	fmt.Printf("Home Path : %s\n", c.HomeDir)
	fmt.Printf("INOUT : %s\n", c.InOut)
	fmt.Printf("Channel number : %d\n", c.Channels)
	fmt.Printf("Repeat number : %d\n", c.Repeat)
	fmt.Printf("iComsys SIM Phone Address : %s\n", c.SimPhoneConfig.MYIP)
	fmt.Printf("iComsys Target Phone Address : %s\n", c.GetSimTargetIP())
	fmt.Printf("Log Level : %s\n", c.LogConfig.Level)
	fmt.Printf("Log Path : %s\n", c.LogConfig.Path)
	fmt.Printf("Log Disk Space Limitation : %dMB\n", c.LogConfig.Disklimit)
	fmt.Printf("Log Output : %s\n", c.LogConfig.Output)
	fmt.Printf("Log Rotate : %s\n", c.LogConfig.RotateConfig.YesNo)
	fmt.Printf("Log Rotate File Size : %s\n", c.LogConfig.RotateConfig.Size)
	fmt.Printf("Log Rotate File Number : %s\n", c.LogConfig.RotateConfig.Num)
	fmt.Printf("SIP Port: %d\n", c.SimPhoneConfig.SIPPort)
	fmt.Printf("RTP Port: %d\n", c.SimPhoneConfig.RTPPort)

	confmsg := ""
	confmsg += fmt.Sprintf("Home Path : %s\n", c.HomeDir)
	confmsg += fmt.Sprintf("Caller : %s\n", c.IsCaller)
	confmsg += fmt.Sprintf("Channel number : %d\n", c.Channels)
	confmsg += fmt.Sprintf("iComsys SIM Phone Address : %s\n", c.SimPhoneConfig.MYIP)
	confmsg += fmt.Sprintf("iComsys Target Phone Address : %s\n", c.GetSimTargetIP())
	confmsg += fmt.Sprintf("Log Level : %s\n", c.LogConfig.Level)
	confmsg += fmt.Sprintf("Log Path : %s\n", c.LogConfig.Path)
	confmsg += fmt.Sprintf("Log Disk Space Limitation : %dMB\n", c.LogConfig.Disklimit)
	confmsg += fmt.Sprintf("Log Output : %s\n", c.LogConfig.Output)
	confmsg += fmt.Sprintf("Log Rotate : %s\n\n", c.LogConfig.RotateConfig.YesNo)
	confmsg += fmt.Sprintf("Log Rotate File Size : %s\n", c.LogConfig.RotateConfig.Size)
	confmsg += fmt.Sprintf("Log Rotate File Number : %s\n", c.LogConfig.RotateConfig.Num)
	confmsg += fmt.Sprintf("SIP Port: %d\n", c.SimPhoneConfig.SIPPort)
	confmsg += fmt.Sprintf("RTP Port: %d\n\n", c.SimPhoneConfig.RTPPort)

	return confmsg
}

var gSimConfig *SimConfig
var gSimScenarioConfig *SimScenarioConfig

func GetSimConfig() *SimConfig {
	return gSimConfig
}

func GetSimScenarioConfig() *SimScenarioConfig {
	return gSimScenarioConfig
}