service

type AuthService struct {
	JWTSecret []byte
	// contains filtered or unexported fields
}

type Claims struct {
	jwt.RegisteredClaims
	PublicKey string `json:"public_key"`
	TokenID   string `json:"token_id"`
	TokenType string `json:"token_type"`
}

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

type Fees interface {
	PublicKeyGetFeeInfo(ctx context.Context, publicKey string) ([]*vtypes.Fee, error)
	MarkFeesCollected(ctx context.Context, feeIDs []uint64, network, txHash string, amount uint64) error
	IssueCredit(ctx context.Context, publicKey string, amount uint64, reason string) error
	GetUserFees(ctx context.Context, publicKey string) (*vtypes.UserFeeStatus, error)
}

type Plugin interface {
	GetPluginWithRating(ctx context.Context, pluginId string) (*types.PluginWithRatings, error)
	CreatePluginReviewWithRating(ctx context.Context, reviewDto types.ReviewCreateDto, pluginId string) (*types.ReviewDto, error)
	GetPluginRecipeSpecification(ctx context.Context, pluginID string) (*rtypes.RecipeSchema, error)
	GetPluginRecipeSpecificationSuggest(
		ctx context.Context,
		pluginID string,
		configuration map[string]any,
	) (*rtypes.PolicySuggest, error)
	GetPluginRecipeFunctions(ctx context.Context, pluginID string) (types.RecipeFunctions, error)
	GetPluginTitlesByIDs(ctx context.Context, ids []string) (map[string]string, error)
	GetPluginSkills(ctx context.Context, pluginID string) (*PluginSkills, error)
}

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

type PluginServiceStorage interface {
	WithTransaction(ctx context.Context, fn func(ctx context.Context, tx pgx.Tx) error) error

	FindRatingByPluginId(ctx context.Context, dbTx pgx.Tx, pluginId string) ([]types.PluginRatingDto, error)
	FindAvgRatingByPluginID(ctx context.Context, pluginId string) (types.PluginAvgRatingDto, error)
	CreateRatingForPlugin(ctx context.Context, dbTx pgx.Tx, pluginId string) error
	UpdateRatingForPlugin(ctx context.Context, dbTx pgx.Tx, pluginId string, reviewRating int) error
	ChangeRatingForPlugin(ctx context.Context, dbTx pgx.Tx, pluginId string, oldRating int, newRating int) error

	CreateReview(ctx context.Context, dbTx pgx.Tx, reviewDto types.ReviewCreateDto, pluginId string) (string, error)
	UpdateReview(ctx context.Context, dbTx pgx.Tx, reviewId string, reviewDto types.ReviewCreateDto) error
	FindReviews(ctx context.Context, pluginId string, take int, skip int, sort string) (types.ReviewsDto, error)
	FindReviewById(ctx context.Context, db pgx.Tx, id string) (*types.ReviewDto, error)
	FindReviewByUserAndPlugin(ctx context.Context, dbTx pgx.Tx, pluginId string, userAddress string) (*types.ReviewDto, error)

	FindPluginById(ctx context.Context, dbTx pgx.Tx, id ptypes.PluginID) (*types.Plugin, error)
	GetAPIKeyByPluginId(ctx context.Context, pluginId string) (*types.APIKey, error)
	GetPluginTitlesByIDs(ctx context.Context, ids []string) (map[string]string, error)
}

type PluginSkills struct {
	PluginID string `json:"plugin_id"`
	SkillsMD string `json:"skills_md"`
}

type Policy interface {
	CreatePolicy(ctx context.Context, policy types.PluginPolicy) (*types.PluginPolicy, error)
	UpdatePolicy(ctx context.Context, policy types.PluginPolicy) (*types.PluginPolicy, error)
	DeletePolicy(ctx context.Context, policyID uuid.UUID, pluginID types.PluginID, signature string) error
	GetPluginPolicies(ctx context.Context, publicKey string, pluginID types.PluginID, take int, skip int, activeFilter *bool) (*itypes.PluginPolicyPaginatedList, error)
	GetPluginPolicy(ctx context.Context, policyID uuid.UUID) (*types.PluginPolicy, error)
	GetPluginInstallationsCount(ctx context.Context, pluginID types.PluginID) (itypes.PluginTotalCount, error)
	DeleteAllPolicies(ctx context.Context, pluginID types.PluginID, publicKey string) error
}

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

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

type ReportServiceStorage interface {
	UpsertReport(ctx context.Context, pluginID types.PluginID, publicKey, reason, details string, cooldown time.Duration) error
	GetReport(ctx context.Context, pluginID types.PluginID, publicKey string) (*itypes.PluginReport, error)
	CountReportsInWindow(ctx context.Context, pluginID types.PluginID, window time.Duration) (int, error)
	HasInstallation(ctx context.Context, pluginID types.PluginID, publicKey string) (bool, error)
	CountInstallations(ctx context.Context, pluginID types.PluginID) (int, error)
	IsPluginPaused(ctx context.Context, pluginID types.PluginID) (bool, error)
	PausePlugin(ctx context.Context, pluginID types.PluginID, record itypes.PauseHistoryRecord) error
}

type SafetySyncer interface {
	SyncSafetyToPlugin(ctx context.Context, pluginID types.PluginID, flags []psafety.ControlFlag) error
}

type TokenPair struct {
	AccessToken  string `json:"access_token"`
	RefreshToken string `json:"refresh_token"`
	ExpiresIn    int    `json:"expires_in"`
}