ngsilib

type Client struct {
	Server        *Server
	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
	Path          string
}

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

type ContextsInfo map[string]interface{}

type EntitiesRespose []map[string]interface{}

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() bufio.Reader
}

type FilePathLib interface {
	FilePathAbs(path string) (string, error)
	FilePathJoin(elem ...string) string
	FilePathBase(path string) string
}

type GetReaderFunc func(s string) (FileLib, error)

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

type IdmParams struct {
	IdmType        string
	IdmHost        string
	Username       string
	Password       string
	ClientID       string
	ClientSecret   string
	HeaderName     string
	HeaderValue    string
	HeaderEnvValue string
	TokenScope     string
}

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 IoutilLib interface {
	Copy(dst io.Writer, src io.Reader) (int64, error)
	ReadFull(r io.Reader, buf []byte) (n int, err error)
	WriteFile(filename string, data []byte, perm os.FileMode) error
	ReadFile(filename string) ([]byte, error)
}

type JSONLib interface {
	Decode(r io.Reader, v interface{}) error
	Encode(w io.Writer, v interface{}) error
	Indent(dst *bytes.Buffer, src []byte, prefix, indent string) error
	Valid(data []byte) bool
}

type JsonBuffer struct {
	// contains filtered or unexported fields
}

type KeyStoneToken struct {
	Token struct {
		Domain struct {
			ID   string `json:"id"`
			Name string `json:"name"`
		} `json:"domain"`
		Methods   []string          `json:"methods"`
		Roles     []keyStoneRole    `json:"roles"`
		ExpiresAt string            `json:"expires_at"`
		Catalog   []keyStoneCatalog `json:"catalog"`
		Extras    struct {
			PasswordCreationTime   string `json:"password_creation_time"`
			LastLoginAttemptTime   string `json:"last_login_attempt_time"`
			PwdUserInBlacklist     bool   `json:"pwd_user_in_blacklist"`
			PasswordExpirationTime string `json:"password_expiration_time"`
		} `json:"extras"`
		User struct {
			PasswordExpiresAt string `json:"password_expires_at"`
			Domain            struct {
				ID   string `json:"id"`
				Name string `json:"name"`
			} `json:"domain"`
			ID   string `json:"id"`
			Name string `json:"name"`
		} `json:"user"`
		AuditIds []string `json:"audit_ids"`
		IssuedAt string   `json:"issued_at"`
	} `json:"token"`
}

type KeycloakToken struct {
	AccessToken      string `json:"access_token"`
	ExpiresIn        int    `json:"expires_in"`
	RefreshExpiresIn int    `json:"refresh_expires_in"`
	RefreshToken     string `json:"refresh_token"`
	TokenType        string `json:"token_type"`
	IDToken          string `json:"id_token"`
	NotBeforePolicy  int    `json:"not-before-policy"`
	SessionState     string `json:"session_state"`
	Scope            string `json:"scope"`
}

type KeyrockIDMToken struct {
	Token struct {
		Methods   []string `json:"methods"`
		ExpiresAt string   `json:"expires_at"`
	} `json:"token"`
	IdmAuthorizationConfig struct {
		Level      string `json:"level"`
		Authzforce bool   `json:"authzforce"`
	} `json:"idm_authorization_config"`
}

type KeyrockToken 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 KongToken struct {
	ExpiresIn   int64  `json:"expires_in"`
	AccessToken string `json:"access_token"`
	TokenType   string `json:"token_type"`
}

type LogWriter struct {
	Writer   io.Writer
	LogLevel int
}

type MultiPart interface {
	NewWriter(w io.Writer) MultiPartLib
}

type MultiPartLib interface {
	CreatePart(header textproto.MIMEHeader) (io.Writer, error)
	FormDataContentType() string
	Close() error
}

type NGSI struct {
	ServerList ServerList

	ConfigDir     *string
	ConfigFile    IoLib
	CacheFile     IoLib
	StdReader     io.Reader
	StdWriter     io.Writer
	LogWriter     io.Writer
	FileReader    FileLib
	JSONConverter JSONLib
	FilePath      FilePathLib
	Ioutil        IoutilLib
	ZipLib        ZipLib
	SyslogLib     SyslogLib
	TimeLib       TimeLib
	MultiPart     MultiPart
	ReadAll       ReadAllFunc
	GetReader     GetReaderFunc
	HTTP          HTTPRequest
	NetLib        NetLib

	Host               string
	Destination        string
	LogLevel           int
	Margin             int64
	Maxsize            int64
	Timeout            time.Duration
	PreviousArgs       *Settings
	Updated            bool
	Stderr             io.Writer
	OsType             string
	BatchFlag          *bool
	InsecureSkipVerify bool
	// contains filtered or unexported fields
}

type NetLib interface {
	InterfaceAddrs() ([]net.Addr, error)
	ListenAndServe(addr string, handler http.Handler) error
	ListenAndServeTLS(addr, certFile, keyFile string, handler http.Handler) error
}

type NgsiConfig struct {
	Version           string       `json:"version"`
	DefaultValues     Settings     `json:"settings"`
	DeprecatedBrokers ServerList   `json:"brokers,omitempty"`
	Servers           ServerList   `json:"servers"`
	Contexts          ContextsInfo `json:"contexts"`
}

type NgsiEntities []NgsiEntity

type NgsiEntity map[string]interface{}

type OAuthToken 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 Option struct {
	Name        string
	Description string
}

type ReadAllFunc func(s string) (bytes []byte, err error)

type Server struct {
	ServerType           string `json:"serverType,omitempty"`
	DeprecatedBrokerHost string `json:"brokerHost,omitempty"`
	ServerHost           string `json:"serverHost,omitempty"`
	BrokerType           string `json:"brokerType,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"`
	HeaderName           string `json:"headerName,omitempty"`
	HeaderValue          string `json:"headerValue,omitempty"`
	HeaderEnvValue       string `json:"headerEnvValue,omitempty"`
	TokenScope           string `json:"tokenScope,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 ServerList map[string]*Server

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
	Unix(sec int64, nsec int64) time.Time
	Format(layout string) string
}

type TokenInfo struct {
	Type          string           `json:"type"`
	Token         string           `json:"token"`
	RefreshToken  string           `json:"refresh_token"`
	Expires       time.Time        `json:"expires"`
	OAuth         *OAuthToken      `json:"oauth,omitempty"`
	KeyrockIDM    *KeyrockIDMToken `json:"keyrock_idm,omitempty"`
	Keyrock       *KeyrockToken    `json:"keyrock,omitempty"`
	TokenProxy    *TokenProxy      `json:"tokenproxy,omitempty"`
	TokenProvider *TokenProvider   `json:"tokenprovider,omitempty"`
	Keystone      *KeyStoneToken   `json:"keystone,omitempty"`
	Keycloak      *KeycloakToken   `json:"keycloak,omitempty"`
	WSO2          *WSO2Token       `json:"wso2,omitempty"`
	Kong          *KongToken       `json:"kong,omitempty"`
}

type TokenPlugin interface {
	// contains filtered or unexported methods
}

type TokenProvider struct {
	AccessToken string `json:"access_token"`
}

type TokenProxy 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 V1ContextElement map[string]interface{}

type V1Request struct {
	ContextElements []V1ContextElement `json:"contextElements"`
	UpdateAction    string             `json:"updateAction"`
}

type V1Response struct {
	ContextResponses []struct {
		ContextElement V1ContextElement `json:"contextElement"`
		StatusCode     struct {
			Code         string `json:"code"`
			ReasonPhrase string `json:"reasonPhrase"`
		} `json:"statusCode"`
	} `json:"contextResponses"`
	ErrorCode struct {
		Code         string `json:"code"`
		ReasonPhrase string `json:"reasonPhrase"`
		Details      string `json:"details"`
	} `json:"errorCode"`
}

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

type ZipLib interface {
	NewReader(r io.ReaderAt, size int64) (*zip.Reader, error)
}