ngsilib

type Broker struct {
	BrokerHost   string `json:"brokerHost,omitempty"`
	NgsiType     string `json:"ngsiType,omitempty"`
	APIPath      string `json:"apiPath,omitempty"`
	IdmType      string `json:"idmType,omitempty"`
	IdmHost      string `json:"idmHost,omitempty"`
	Token        string `json:"token,omitempty"`
	Username     string `json:"username,omitempty"`
	Password     string `json:"password,omitempty"`
	ClientID     string `json:"clientId,omitempty"`
	ClientSecret string `json:"clientSecret,omitempty"`
	Context      string `json:"context,omitempty"`
	Tenant       string `json:"tenant,omitempty"`
	Scope        string `json:"scope,omitempty"`
	SafeString   string `json:"safeString,omitempty"`
	XAuthToken   string `json:"xAuthToken,omitempty"`
}

type BrokerList map[string]*Broker

type Client struct {
	Broker        *Broker
	URL           *url.URL
	Headers       map[string]string
	Token         string
	Tenant        string
	Scope         string
	APIPathBefore string
	APIPathAfter  string
	NgsiType      int
	SafeString    bool
	XAuthToken    bool
	Link          *string
	HTTP          HTTPRequest
}

type CmdFlags struct {
	Token      *string
	Tenant     *string
	Scope      *string
	SafeString *string
	XAuthToken bool
	Link       *string
}

type ContextsInfo map[string]string

type FileLib interface {
	Open(path string) error
	Close() error
	FilePathAbs(path string) (string, error)
	ReadAll(r io.Reader) ([]byte, error)
	ReadFile(filename string) ([]byte, error)
	SetReader(r io.Reader)
	File() io.Reader
}

type HTTPRequest interface {
	Request(method string, url *url.URL, headers map[string]string, body interface{}) (*http.Response, []byte, error)
}

type IoLib interface {
	Open() error
	OpenFile(flag int, perm os.FileMode) error
	Truncate(size int64) error
	Close() error
	Decode(v interface{}) error
	Encode(v interface{}) error
	MkdirAll(path string, perm os.FileMode) error
	Stat(name string) (os.FileInfo, error)
	UserConfigDir() (string, error)
	UserHomeDir() (string, error)
	SetFileName(filename *string)
	FileName() *string
	Getenv(key string) string
	FilePathAbs(path string) (string, error)
	FilePathJoin(elem ...string) string
}

type JSONLib interface {
	Decode(r io.Reader, v interface{}) error
	Encode(w io.Writer, v interface{}) error
}

type LogWriter struct {
	Writer   io.Writer
	LogLevel int
}

type NGSI struct {
	LogLevel      int
	ConfigFile    IoLib
	CacheFile     IoLib
	StdReader     io.Reader
	StdWriter     io.Writer
	LogWriter     io.Writer
	FileReader    FileLib
	JSONConverter JSONLib
	Host          string
	Destination   string
	Margin        int64
	Maxsize       int
	Timeout       time.Duration
	PreviousArgs  *Settings
	Updated       bool
	HTTP          HTTPRequest
	Stderr        *os.File
	OsType        string
	SyslogLib     SyslogLib
	TimeLib       TimeLib
	BatchFlag     *bool
	// contains filtered or unexported fields
}

type NgsiConfig struct {
	DefaultValues Settings     `json:"settings"`
	Brokers       BrokerList   `json:"brokers"`
	Contexts      ContextsInfo `json:"contexts"`
}

type NgsiLibError struct {
	Function string
	ErrNo    int
	Message  string
	Err      error
}

type Settings struct {
	UsePreviousArgs bool   `json:"usePreviousArgs"`
	Syslog          string `json:"syslog"`
	Stderr          string `json:"stderr"`
	Logfile         string `json:"logfile"`
	Loglevel        string `json:"loglevel"`
	CacheFile       string `json:"cachefile"`
	Host            string `json:"host"`
	Tenant          string `json:"tenant"`
	Scope           string `json:"scope"`
	Token           string `json:"token"`
}

type SyslogLib interface {
	New() (io.Writer, error)
}

type TimeLib interface {
	Now() time.Time
	NowUnix() int64
}

type Token struct {
	AccessToken  string   `json:"access_token"`
	ExpiresIn    int64    `json:"expires_in"`
	RefreshToken string   `json:"refresh_token"`
	Scope        []string `json:"scope"`
	TokenType    string   `json:"token_type"`
}

type TokenInfo struct {
	Expires int64 `json:"expires"`
	Token   Token `json:"token"`
}