chserver

type APIListener struct {
	*logger.Logger

	*Server
	// contains filtered or unexported fields
}

type AuthProviderInfo struct {
	AuthProvider      string `json:"auth_provider"`
	SettingsURI       string `json:"settings_uri"`
	DeviceSettingsURI string `json:"device_settings_uri"`
	MaxTokenLifetime  int    `json:"max_token_lifetime"`
}

type AuthSettings struct {
	AuthProvider string           `json:"auth_provider"`
	LoginInfo    *oauth.LoginInfo `json:"details"`
}

type ClientGroupPayload struct {
	ID                  *string               `json:"id,omitempty"`
	Description         *string               `json:"description,omitempty"`
	Params              *cgroups.ClientParams `json:"params,omitempty" db:"params"`
	AllowedUserGroups   *types.StringSlice    `json:"allowed_user_groups,omitempty"`
	ClientIDs           *[]string             `json:"client_ids,omitempty" db:"-"`
	NumClients          *int                  `json:"num_clients,omitempty" db:"-"`
	NumClientsConnected *int                  `json:"num_clients_connected,omitempty" db:"-"`
}

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

type ClientTagPayload struct {
	Tag       *string   `json:"tag,omitempty"`
	ClientIDs *[]string `json:"client_ids,omitempty"`
	// contains filtered or unexported fields
}

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

type DeviceAuthSettings struct {
	AuthProvider string                 `json:"auth_provider"`
	LoginInfo    *oauth.DeviceLoginInfo `json:"details"`
}

type EffectiveExtendedPermissions struct {
	TunnelsRestricted  []extperm.PermissionParams `json:"tunnels_restricted"`
	CommandsRestricted []extperm.PermissionParams `json:"commands_restricted"`
}

type JobProvider interface {
	GetByJID(clientID, jid string) (*models.Job, error)
	List(ctx context.Context, options *query.ListOptions) ([]*models.Job, error)
	Count(ctx context.Context, options *query.ListOptions) (int, error)
	// SaveJob creates or updates a job
	SaveJob(job *models.Job) error
	// CreateJob creates a new job. If already exist with a given JID - do nothing and return nil
	CreateJob(job *models.Job) error
	GetMultiJob(ctx context.Context, jid string) (*models.MultiJob, error)
	GetMultiJobSummaries(ctx context.Context, options *query.ListOptions) ([]*models.MultiJobSummary, error)
	CountMultiJobs(ctx context.Context, options *query.ListOptions) (int, error)
	SaveMultiJob(multiJob *models.MultiJob) error
	CleanupJobsMultiJobs(context.Context, int) error
	Close() error
}

type Resp struct {
	OK string `json:"ok"`
}

type Server struct {
	*logger.Logger
	// contains filtered or unexported fields
}

type ServerOpts struct {
	FilesAPI    files.FileAPI
	PlusManager rportplus.Manager
}

type TargetingParams interface {
	GetClientIDs() (ids []string)
	GetGroupIDs() (ids []string)
	GetClientTags() (clientTags *models.JobClientTags)
}

type TotP struct {
	Secret        string   `json:"secret"`
	QRImageBase64 string   `json:"qr"`
	TotPKey       *otp.Key `json:"-"`
	// contains filtered or unexported fields
}

type TotPInput struct {
	Issuer      string
	AccountName string
}

type TotPKeyStatus uint

type TunnelPayload struct {
	models.Remote
	ID        string    `json:"id"`
	ClientID  string    `json:"client_id"`
	CreatedAt time.Time `json:"created_at"`
}

type TwoFAService struct {
	TokenTTL    time.Duration
	MsgSrv      message.Service
	UserSrv     UserService
	SendTimeout time.Duration
	// contains filtered or unexported fields
}

type UploadOutput struct {
	ClientID string `json:"client_id"`
	*models.UploadResponse
}

type UploadRequest struct {
	File       multipart.File
	FileHeader *multipart.FileHeader
	ClientIDs  []string
	GroupIDs   []string
	ClientTags *models.JobClientTags

	Clients []*clientdata.Client
	*models.UploadedFile
	// contains filtered or unexported fields
}

type UserPayload struct {
	Username                     string                       `json:"username"`
	PasswordExpired              bool                         `json:"password_expired"`
	Groups                       []string                     `json:"groups"`
	TwoFASendTo                  string                       `json:"two_fa_send_to"`
	EffectiveUserPermissions     map[string]bool              `json:"effective_user_permissions"`
	EffectiveExtendedPermissions EffectiveExtendedPermissions `json:"effective_extended_permissions"`
	GroupPermissionsEnabled      bool                         `json:"group_permissions_enabled"`
}

type UserService interface {
	GetAll() ([]*users.User, error)
	GetByUsername(username string) (*users.User, error)
	Change(*users.User, string) error
	Delete(string) error
	ExistGroups([]string) error
	GetProviderType() enums.ProviderSource
	ListGroups() ([]users.Group, error)
	GetGroup(string) (users.Group, error)
	UpdateGroup(string, users.Group) (users.Group, error)
	DeleteGroup(string) error
	CheckPermission(*users.User, string) error
	SupportsGroupPermissions() bool
	GetEffectiveUserPermissions(*users.User) (map[string]bool, error)
	GetEffectiveUserExtendedPermissions(*users.User) ([]extperm.PermissionParams, []extperm.PermissionParams)
}