core

type APIClient struct {
	Server         string        // kiteworks host name.
	ApplicationID  string        // Application ID set for kiteworks custom app.
	RedirectURI    string        // Redirect URI for kiteworks custom app.
	AgentString    string        // Agent-String header for calls to kiteworks.
	VerifySSL      bool          // Verify certificate for connections.
	ProxyURI       string        // Proxy for outgoing https requests.
	Snoop          bool          // Flag to snoop API calls
	RequestTimeout time.Duration // Timeout for request to be answered from kiteworks server.
	ConnectTimeout time.Duration // Timeout for TLS connection to kiteworks server.
	MaxChunkSize   int64         // Max Upload Chunksize in bytes, min = 1M, max = 68M
	Retries        uint          // Max retries on a failed call
	TokenStore     TokenStore    // TokenStore for reading and writing auth tokens securely.

	NewToken        func(username string) (*Auth, error) // Provides new access_token.
	ErrorScanner    func(body []byte) APIError           // Reads body of response and interprets any errors.
	RetryErrorCodes []string                             // Error codes ("ERR_INTERNAL_SERVER_ERROR"), that should induce a retry. (will automatically try TokenErrorCodes as well)
	TokenErrorCodes []string                             // Error codes ("ERR_INVALID_GRANT"), that should indicate a problem with the current access token.
	// contains filtered or unexported fields
}

type APIError interface {
	Register(code, message string)
	NoErrors() bool
	Error() string
}

type APIRequest struct {
	Version int
	Header  http.Header
	Method  string
	Path    string
	Params  []interface{}
	Output  interface{}
}

type Auth struct {
	AccessToken  string `json:"access_token"`
	Scope        string `json:"scope"`
	RefreshToken string `json:"refresh_token"`
	Expires      int64  `json:"expires_in"`
}

type BitFlag = xsync.BitFlag

type ConfigStore = cfg.Store

type DBase struct {
	Store kvlite.Store
}

type Database interface {
	Sub(prefix string) SubStore
	Shared(table string) SubStore
	Drop(table string)
	CryptSet(table, key string, value interface{})
	Set(table, key string, value interface{})
	Unset(table, key string)
	Get(table, key string, output interface{}) bool
	Keys(table string) []string
	CountKeys(table string) int
	Tables() []string
	Table(table string) Table
}

type Error string

type FileInfo interface {
	Name() string
	Size() int64
	ModTime() time.Time
}

type FlagSet struct {
	FlagArgs []string
	*eflag.EFlagSet
}

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

type KWAPI struct {
	*APIClient
}

type KWProfile struct {
	Features struct {
		AllowSFTP    bool  `json:"allowSftp"`
		MaxStorage   int64 `json:"maxStorage"`
		SendExternal bool  `json:"sendExternal`
		FolderCreate int   `json:"folderCreate"`
	} `json:"features"`
}

type KWSession struct {
	Username string
	*KWAPI
}

type KiteBrokerTask struct {
	Flags  FlagSet
	DB     SubStore
	Report *TaskReport
	KW     KWSession
}

type KiteLinks struct {
	Relationship string `json:"rel"`
	Entity       string `json:"entity"`
	ID           int    `json:"id"`
	URL          string `json:"href"`
}

type KiteMember struct {
	ID     int            `json:"objectId"`
	RoleID int            `json:"roleId`
	User   KiteUser       `json:"user"`
	Role   KitePermission `json:"role"`
}

type KiteObject struct {
	Type                  string         `json:"type"`
	Status                string         `json:"status"`
	ID                    int            `json:"id"`
	Name                  string         `json:"name"`
	Description           string         `json:"description"`
	Created               string         `json:"created"`
	Modified              string         `json:"modified"`
	ClientCreated         string         `json:"clientCreated"`
	ClientModified        string         `json:"clientModified"`
	Deleted               bool           `json:"deleted"`
	PermDeleted           bool           `json:"permDeleted"`
	Expire                interface{}    `json:"expire"`
	Path                  string         `json:"path"`
	ParentID              int            `json:"parentId"`
	UserID                int            `json:"userId"`
	Permalink             string         `json:"permalink"`
	Secure                bool           `json:"secure"`
	LockUser              int            `json:"lockUser"`
	Fingerprint           string         `json:"fingerprint"`
	ProfileID             int            `json:"typeID`
	Size                  int64          `json:"size"`
	Mime                  string         `json:"mime"`
	AVStatus              string         `json:"avStatus"`
	DLPStatus             string         `json:"dlpStatus"`
	AdminQuarantineStatus string         `json:"adminQuarantineStatus`
	Quarantined           bool           `json:"quarantined"`
	DLPLocked             bool           `json:"dlpLocked"`
	FileLifetime          int            `json:"fileLifetime"`
	MailID                int            `json:"mail_id"`
	Links                 []KiteLinks    `json:"links"`
	CurrentUserRole       KitePermission `json:"currentUserRole"`
}

type KitePermission struct {
	ID         int    `json:"id"`
	Name       string `json:"name"`
	Rank       int    `json:"rank"`
	Modifiable bool   `json:"modifiable"`
	Disabled   bool   `json:"disabled"`
}

type KiteUser struct {
	ID          int    `json:"id"`
	Active      bool   `json:"active"`
	Deactivated bool   `json:"deactivated"`
	Suspended   bool   `json:"suspended"`
	BaseDirID   int    `json:"basedirId"`
	Deleted     bool   `json:"deleted"`
	Email       string `json:"email"`
	MyDirID     int    `json:"mydirId"`
	Name        string `json:"name"`
	SyncDirID   int    `json:"syncdirId"`
	UserTypeID  int    `json:"userTypeId"`
	Verified    bool   `json:"verified"`
	Internal    bool   `json:"internal"`
}

type LimitGroup = xsync.LimitGroup

type PostForm map[string]interface{}

type PostJSON map[string]interface{}

type Query map[string]interface{}

type ReadSeekCloser = nfo.ReadSeekCloser

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

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

type Tally struct {
	Format func(val int64) string
	// contains filtered or unexported fields
}

type Task interface {
	New() Task
	Name() string
	Desc() string
	Init() error
	Main() error
	KiteBrokerTask_set_flags(Flags FlagSet)
	KiteBrokerTask_set_db(DB SubStore)
	KiteBrokerTask_set_report(*TaskReport)
	KiteBrokerTask_set_session(user KWSession)
	KiteBrokerTask_report_summary(error uint32)
}

type TaskArgs map[string]interface{}

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

type TokenStore interface {
	Save(username string, auth *Auth) error
	Load(username string) (*Auth, error)
	Delete(username string) error
}