service

type AuditService interface {
	Init(config *model.AppConfig)
}

type AuthenticationService interface {
	Init(config *model.AppConfig)
	Authenticate(ctx context.Context, username string, password string, term model.TokenTerm, minimizeToken bool) (*model.Token, error)
	AuthenticateWithoutPassword(ctx context.Context, username string, term model.TokenTerm) (*model.Token, error)
	RenewToken(ctx context.Context, token string, term model.TokenTerm) (*model.Token, error)
	GetToken(ctx context.Context) (*jwt_model.UserDetails, error)
	ParseAndVerifyToken(token string) (*jwt_model.UserDetails, error)
	AuthenticationDisabled() bool
}

type AuthorizationService interface {
	CheckRecordAccess(ctx context.Context, params CheckRecordAccessParams) error
	CheckRecordAccessWithRecordSelector(ctx context.Context, params CheckRecordAccessParams) (*resource_model.BooleanExpression, error)
	CheckIsExtensionController(ctx context.Context) error
}

type BackendProviderService interface {
	abs.BackendRecordsInterface
	abs.BackendActionExecutor
	DestroyDataSource(ctx context.Context, dataSourceName string) error
	ListEntities(ctx context.Context, dataSourceId string) ([]*model.DataSourceCatalog, error)
	PrepareResourceFromEntity(ctx context.Context, dataSourceName string, catalog, entity string) (*model.Resource, error)
	UpgradeResource(ctx context.Context, dataSourceName string, params abs.UpgradeResourceParams) error
	GetStatus(ctx context.Context, dataSourceId string) (connectionAlreadyInitiated bool, testConnection bool, err error)
	Init(config *model.AppConfig)
	SetSchema(schema *abs.Schema)
}

type CheckRecordAccessParams struct {
	Resource  *model.Resource
	Records   *[]*model.Record
	Operation resource_model.PermissionOperation
}

type Container interface {
	GetRecordService() RecordService
	GetEventChannelService() EventChannelService
	GetAuthenticationService() AuthenticationService
	GetAuthorizationService() AuthorizationService
	GetResourceService() ResourceService
	GetResourceMigrationService() ResourceMigrationService
	GetDataSourceService() DataSourceService
	GetWatchService() WatchService
	GetExtensionService() ExtensionService
	GetBackendProviderService() BackendProviderService
	GetBackendEventHandler() interface{}
	GetAppConfig() *model.AppConfig
}

type DataSourceService interface {
	Init(config *model.AppConfig)
	ListEntities(ctx context.Context, id string) ([]*model.DataSourceCatalog, error)
	GetStatus(ctx context.Context, id string) (connectionAlreadyInitiated bool, testConnection bool, err error)
	PrepareResourceFromEntity(ctx context.Context, dataSourceId string, catalog, entity string) (*model.Resource, error)
	Delete(ctx context.Context, ids []string) error
}

type EventChannelService interface {
	Exec(ctx context.Context, channelKey string, event *model.Event) (*model.Event, error)
	PollEvents(ctx context.Context, channelKey string) (chan *model.Event, error)
	WriteEvent(ctx context.Context, proto *model.Event) error
	Init(config *model.AppConfig)
}

type ExecuteActionParams struct {
	Namespace  string
	Resource   string
	Id         string
	ActionName string
	Input      unstructured.Unstructured
}

type ExtensionService interface {
	RegisterExtension(*resource_model.Extension)
	UnRegisterExtension(*resource_model.Extension)
	Init(config *model.AppConfig)
	Reload()
}

type ExternalService interface {
	Call(ctx context.Context, all resource_model.ExternalCall, event *model.Event) (*model.Event, error)
}

type Module interface {
	Init()
}

type ModuleConstructor func(container Container) Module

type RecordCreateParams struct {
	Namespace string
	Resource  string
	Records   []*model.Record
}

type RecordDeleteParams struct {
	Namespace string
	Resource  string
	Ids       []string
}

type RecordGetParams struct {
	Namespace         string
	Resource          string
	Id                string
	ResolveReferences []string
}

type RecordListParams struct {
	Query             *model.BooleanExpression
	Namespace         string
	Resource          string
	Limit             uint32
	Offset            uint64
	UseHistory        bool
	ResolveReferences []string
	ResultChan        chan<- *model.Record
	PackRecords       bool
	Filters           map[string]interface{}
	Aggregation       *model.Aggregation
	Sorting           *model.Sorting
}

type RecordLoadParams struct {
	UseHistory        bool
	ResolveReferences []string
}

type RecordService interface {
	Init(config *model.AppConfig)
	PrepareQuery(resource *model.Resource, queryMap map[string]interface{}) (*model.BooleanExpression, error)
	GetRecord(ctx context.Context, namespace, resourceName, id string, references []string) (*model.Record, error)
	FindBy(ctx context.Context, namespace, resourceName, propertyName string, value string) (*model.Record, error)
	ResolveReferences(ctx context.Context, resource *model.Resource, records []*model.Record, referencesToResolve []string) error
	List(ctx context.Context, params RecordListParams) ([]*model.Record, uint32, error)
	Create(ctx context.Context, params RecordCreateParams) ([]*model.Record, error)
	Update(ctx context.Context, params RecordUpdateParams) ([]*model.Record, error)
	Apply(ctx context.Context, params RecordUpdateParams) ([]*model.Record, error)
	Get(ctx context.Context, params RecordGetParams) (*model.Record, error)
	Delete(ctx context.Context, params RecordDeleteParams) error
	Load(ctx context.Context, namespace string, name string, properties map[string]*structpb.Value, listParams RecordLoadParams) (*model.Record, error)
}

type RecordUpdateParams struct {
	Namespace string
	Resource  string
	Records   []*model.Record
}

type ResourceMigrationService interface {
	PreparePlan(ctx context.Context, existingResource *model.Resource, resource *model.Resource) (*model.ResourceMigrationPlan, error)
}

type ResourceService interface {
	Init(config *model.AppConfig)
	GetResourceByName(ctx context.Context, namespace, resource string) (*model.Resource, error)
	GetSystemResourceByName(ctx context.Context, resourceName string) (*model.Resource, error)
	Create(ctx context.Context, resource *model.Resource, doMigration bool, forceMigration bool) (*model.Resource, error)
	Update(ctx context.Context, resource *model.Resource, doMigration bool, forceMigration bool) error
	Delete(ctx context.Context, ids []string, doMigration bool, forceMigration bool) error
	List(ctx context.Context) ([]*model.Resource, error)
	Get(ctx context.Context, id string) (*model.Resource, error)
	GetSchema() *abs.Schema
	PrepareResourceMigrationPlan(ctx context.Context, resources []*model.Resource, prepareFromDataSource bool) ([]*model.ResourceMigrationPlan, error)
	LocateReferences(resource *model.Resource, resolve []string) []string
	LocateLocalReferences(resource *model.Resource) []string
	LocateResourceByReference(resource *model.Resource, reference *model.Reference) *model.Resource
}

type StatsService interface {
	Init(config *model.AppConfig)
}

type WatchParams struct {
	Selector   *model.EventSelector
	BufferSize int
}

type WatchResourceParams struct {
	Selector   *model.EventSelector
	BufferSize int
}

type WatchService interface {
	Watch(ctx context.Context, params WatchParams) (<-chan *model.Event, error)
	WatchResource(ctx context.Context, params WatchParams) (<-chan *model.Event, error)
}