services

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

type A2UIComponent struct {
	ID         string                 `json:"id"`
	Type       string                 `json:"type"`
	Attributes map[string]interface{} `json:"attributes,omitempty"`
	Children   []string               `json:"children,omitempty"`
}

type A2UIMessage struct {
	Components []A2UIComponent `json:"components"`
}

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

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

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

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

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

type ChatService struct {
	Registry       *registry.Registry
	EntityService  IEntityService
	SchemaService  *SchemaService
	A2UIService    *A2UIService
	SessionService session.Service
}

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

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

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

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

type IA2AService interface {
	GetHandler() a2asrv.RequestHandler
	GetAgentCard() *a2a.AgentCard
}

type IA2UIService interface {
	UpdateComponent(ctx context.Context, component A2UIComponent)
	GetComponent(id string) (A2UIComponent, bool)
	GetFullState() []A2UIComponent
	Subscribe() (chan []A2UIComponent, string)
	Unsubscribe(id string)
}

type IAssetService interface {
	Save(ctx context.Context, asset *descriptors.Asset) (*descriptors.Asset, error)
	UpdateAssetsLinks(ctx context.Context, oldAssetIds []int64, newAssetPaths []string, entityName string, recordId int64) error
	GetAssetByPath(ctx context.Context, path string) (*descriptors.Asset, error)
}

type IAuditService interface {
	List(ctx context.Context, pagination datamodels.Pagination) ([]*descriptors.AuditLog, error)
	ById(ctx context.Context, id int64) (*descriptors.AuditLog, error)
	Log(ctx context.Context, log *descriptors.AuditLog) error
}

type IAuthService interface {
	Register(ctx context.Context, email, password string) (*descriptors.User, error)
	Login(ctx context.Context, email, password string) (string, error)
	LoginByChannel(ctx context.Context, channelType descriptors.ChannelType, identifier string, token string, ip, ua string) (string, error)
	Me(ctx context.Context, userId int64) (*descriptors.User, error)
	ValidateToken(token string) (int64, []string, error)
	ValidateChannelToken(ctx context.Context, channelType descriptors.ChannelType, token string) (int64, string, error)
	GetRoleByName(ctx context.Context, name string) (*descriptors.Role, error)
}

type IChannelService interface {
	RegisterChannel(ctx context.Context, userId int64, channelType descriptors.ChannelType, identifier string, metadata map[string]interface{}) (*descriptors.UserChannel, error)
	VerifyChannel(ctx context.Context, userId int64, channelType descriptors.ChannelType, token string) (bool, error)
	GetChannelsByUserId(ctx context.Context, userId int64) ([]*descriptors.UserChannel, error)
	LogAuthAttempt(ctx context.Context, log *descriptors.AuthLog) error
	GetAuthLogs(ctx context.Context, userId int64, pagination datamodels.Pagination) ([]*descriptors.AuthLog, int64, error)
	SendNotification(ctx context.Context, userId int64, message string, preferredChannels []descriptors.ChannelType) error
	HandleInbound(ctx context.Context, channelType descriptors.ChannelType, identifier string, payload map[string]interface{}) error
}

type ICommentService interface {
	List(ctx context.Context, entityName string, recordId int64, pagination datamodels.Pagination) ([]*descriptors.Comment, error)
	Single(ctx context.Context, id string) (*descriptors.Comment, error)
	Save(ctx context.Context, comment *descriptors.Comment) (*descriptors.Comment, error)
	Delete(ctx context.Context, userId, id string) error
}

type IEngagementService interface {
	Track(ctx context.Context, status *descriptors.EngagementStatus) error
}

type IEntityService interface {
	List(ctx context.Context, name string, pagination datamodels.Pagination, filters []datamodels.Filter, sorts []datamodels.Sort) ([]datamodels.Record, int64, error)
	Single(ctx context.Context, name string, id interface{}) (datamodels.Record, error)
	Insert(ctx context.Context, name string, data datamodels.Record) (datamodels.Record, error)
	Update(ctx context.Context, name string, data datamodels.Record) (datamodels.Record, error)
	Delete(ctx context.Context, name string, id interface{}) error

	CollectionList(ctx context.Context, name, id, attr string, pagination datamodels.Pagination, filters []datamodels.Filter, sorts []datamodels.Sort) ([]datamodels.Record, int64, error)
	CollectionInsert(ctx context.Context, name, id, attr string, data datamodels.Record) (datamodels.Record, error)

	JunctionList(ctx context.Context, name, id, attr string, exclude bool, pagination datamodels.Pagination, filters []datamodels.Filter, sorts []datamodels.Sort) ([]datamodels.Record, int64, error)
	JunctionSave(ctx context.Context, name, id, attr string, targetIds []interface{}) error
	JunctionDelete(ctx context.Context, name, id, attr string, targetIds []interface{}) error
}

type IGraphQLService interface {
	Query(ctx context.Context, query string, variables map[string]interface{}) (interface{}, error)
	ExecuteStoredQuery(ctx context.Context, name string, variables map[string]interface{}) (interface{}, error)
}

type IMCPService interface {
	GetServer() *mcp.Server
}

type INotificationService interface {
	List(ctx context.Context, userId string, pagination datamodels.Pagination) ([]*descriptors.Notification, error)
	Send(ctx context.Context, notification *descriptors.Notification) error
	MarkAsRead(ctx context.Context, userId string, id int64) error
	MarkAllAsRead(ctx context.Context, userId string) error
}

type IPageService interface {
	Render(ctx context.Context, path string, strArgs datamodels.StrArgs) (string, error)
}

type IPermissionService interface {
	HasAccess(ctx context.Context, userId int64, roles []string, entityName, action string) (bool, error)
	GetRowFilters(ctx context.Context, userId int64, entityName string) ([]datamodels.Filter, error)
	GetFieldPermissions(ctx context.Context, entityName string, roles []string) (map[string]map[string]bool, error)
}

type ISchemaService interface {
	All(ctx context.Context, schemaType *descriptors.SchemaType, names []string, status *descriptors.PublicationStatus) ([]*descriptors.Schema, error)
	ById(ctx context.Context, id int64) (*descriptors.Schema, error)
	BySchemaId(ctx context.Context, schemaId string) (*descriptors.Schema, error)
	ByNameOrDefault(ctx context.Context, name string, schemaType descriptors.SchemaType, status *descriptors.PublicationStatus) (*descriptors.Schema, error)
	ByStartsOrDefault(ctx context.Context, name string, schemaType descriptors.SchemaType, status *descriptors.PublicationStatus) (*descriptors.Schema, error)
	LoadEntity(ctx context.Context, name string) (*descriptors.Entity, error)
	LoadLoadedEntity(ctx context.Context, name string) (*descriptors.LoadedEntity, error)
	Save(ctx context.Context, schema *descriptors.Schema, asPublished bool) (*descriptors.Schema, error)
	Delete(ctx context.Context, schemaId string) error
}

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

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

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

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

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