systemfetcher

type APIClient interface {
	Do(*http.Request, string) (*http.Response, error)
}

type APIConfig struct {
	Endpoint        string        `envconfig:"APP_SYSTEM_INFORMATION_ENDPOINT"`
	FilterCriteria  string        `envconfig:"APP_SYSTEM_INFORMATION_FILTER_CRITERIA"`
	Timeout         time.Duration `envconfig:"APP_SYSTEM_INFORMATION_FETCH_TIMEOUT"`
	PageSize        uint64        `envconfig:"APP_SYSTEM_INFORMATION_PAGE_SIZE"`
	PagingSkipParam string        `envconfig:"APP_SYSTEM_INFORMATION_PAGE_SKIP_PARAM"`
	PagingSizeParam string        `envconfig:"APP_SYSTEM_INFORMATION_PAGE_SIZE_PARAM"`
	SystemSourceKey string        `envconfig:"APP_SYSTEM_INFORMATION_SOURCE_KEY"`
	SystemRPSLimit  uint64        `envconfig:"default=15,APP_SYSTEM_INFORMATION_RPS_LIMIT"`
}

type AggregationResource struct {
	TenantIDs      []string `json:"tenantIDs"`
	SkipReschedule bool     `json:"skipReschedule"`
}

type Authenticator interface {
	GetAuthorization(ctx context.Context) (string, error)
}

type BusinessTenantMappingService interface {
	List(ctx context.Context) ([]*model.BusinessTenantMapping, error)
	GetTenantByID(ctx context.Context, id string) (*model.BusinessTenantMapping, error)
	GetTenantByExternalID(ctx context.Context, id string) (*model.BusinessTenantMapping, error)
}

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

type Config struct {
	DirectorGraphqlURL        string        `envconfig:"APP_DIRECTOR_GRAPHQL_URL"`
	DirectorRequestTimeout    time.Duration `envconfig:"default=30s,APP_DIRECTOR_REQUEST_TIMEOUT"`
	DirectorSkipSSLValidation bool          `envconfig:"default=false,APP_DIRECTOR_SKIP_SSL_VALIDATION"`

	EnableSystemDeletion   bool   `envconfig:"default=true,APP_ENABLE_SYSTEM_DELETION"`
	OperationalMode        string `envconfig:"APP_OPERATIONAL_MODE"`
	AsyncRequestProcessors int    `envconfig:"default=100,APP_ASYNC_REQUEST_PROCESSORS"`
	TemplatesFileLocation  string `envconfig:"optional,APP_TEMPLATES_FILE_LOCATION"`
	VerifyTenant           string `envconfig:"optional,APP_VERIFY_TENANT"`
}

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

type DirectorGraphClient struct {
	*gcli.Client
	Authenticator Authenticator
}

type Expression struct {
	Key       string
	Operation string
	Value     string
}

type Filter struct {
	Expressions []Expression
}

type FilterBuilder struct {
	Filters []Filter
}

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

type OperationMaintainer interface {
	Maintain(ctx context.Context) error
}

type OperationService interface {
	CreateMultiple(ctx context.Context, in []*model.OperationInput) error
	DeleteMultiple(ctx context.Context, ids []string) error
	ListAllByType(ctx context.Context, opType model.OperationType) ([]*model.Operation, error)
}

type OperationsManager interface {
	FindOperationByData(ctx context.Context, data interface{}) (*model.Operation, error)
	CreateOperation(ctx context.Context, in *model.OperationInput) (string, error)
	RescheduleOperation(ctx context.Context, operationID string) error
}

type OperationsProcessor struct {
	SystemFetcherSvc SystemFetcherService
}

type PlaceholderMapping struct {
	PlaceholderName string `json:"placeholder_name"`
	SystemKey       string `json:"system_key"`
	Optional        bool   `json:"optional"`
}

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

type System struct {
	SystemPayload   map[string]interface{}
	TemplateID      string                           `json:"-"`
	StatusCondition model.ApplicationStatusCondition `json:"-"`
}

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

type SystemFetcherOperationData struct {
	TenantID string `json:"tenantID"`
}

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

type SystemFetcherService interface {
	ProcessTenant(ctx context.Context, tenantID string) error
	SetTemplateRenderer(templateRenderer TemplateRenderer)
}

type SystemSynchronizationTimestamp struct {
	ID                string
	LastSyncTimestamp time.Time
}

type SystemsSyncService interface {
	ListByTenant(ctx context.Context, tenant string) ([]*model.SystemSynchronizationTimestamp, error)
	Upsert(ctx context.Context, in *model.SystemSynchronizationTimestamp) error
}

type TemplateMapping struct {
	AppTemplate *model.ApplicationTemplate
	Labels      map[string]*model.Label
	Renderer    TemplateRenderer
}

type TemplateMappingKey struct {
	Label  string
	Region string
}

type TemplateRenderer interface {
	GenerateAppRegisterInput(ctx context.Context, sc System, appTemplate *model.ApplicationTemplate, overridePlaceholders bool) (*model.ApplicationRegisterInput, error)
	ApplicationRegisterInputFromTemplate(ctx context.Context, sc System) (*model.ApplicationRegisterInput, error)
}