CreateOAuthCredential creates a new OAuth credential

EncryptJSON encrypts a JSON-serializable structure for a specific region.

ErrorResponse creates an error response with the given message

GetAPIKeyByID retrieves an API key by ID

GetAdapterReaderFacade returns the contract facade for external modules

GetByIdentifier returns a provider by identifier

GetBySupID retrieves a user by sup id

GetInvocationByID returns an invocation by ID

GetOAuthURL generates an OAuth authorization URL for a provider

GetPermissionIdentifiersFromScopes gets the permission identifiers from the scopes

GetProviderWithTranslation retrieves Provider information by identifier with translation

Provider metadata access without translation support

GetScopesFromPermissions gets the scopes from the permissions

List retrieves users with pagination

ListBasicProviders returns all providers without operations

ListByIDs returns a list of providers by IDs

ListByProviderID returns all operations for a provider

ListByUserID retrieves API keys for a user with pagination

ListInvocationsByUserID returns invocations for a user

ListTaskGroups returns all registered task groups

LoadProvider load a single provider

NewMCPConfigBuilder creates a new configuration builder

NewMCPGoClient creates a new mcp-go based client

NewMappingApplier creates a new mapping applier

RefreshAccessTokenIfNeeded refreshes the access token if needed

RegisterOperation registers the parameter schema and handler for an operation.

RegisterOperation registers a single operation, linking its ID, user parameter schema, and the handler function that translates user params to interna

RegisterTaskGroup registers a task group with its schedule

RespondWithSuccess sends a success response with the given data and HTTP status code

SetSuccess marks the invocation as successful

Stop gracefully stops the cron scheduler

StoreStateData stores it with associated data

Update updates an invocation

Update updates an OAuth credential

ValidateRedirectURL validates that a redirect URL is safe and allowed

Simplified broadcast function - in a real implementation you'd manage WebSocket connections

buildMCPClientConfig creates MCP client configuration with credential and parameter injection

createOAuth2Config creates the oauth2.Config object.

Helper methods for creating test data

emitAPIKeyEvent emits an API key-related event

formatEmbeddingForPostgres converts a float64 slice to PostgreSQL vector format

* 为动态页面生成多语言 URL

generateEmbedding generates embedding for the given text using OpenAI API

generateOperationsSQL generates INSERT statements for the operations table

generateProvidersSQL generates INSERT statements for the providers table

generateRandomOAuthCodeVerifier generates a cryptographically secure random code verifier string

getLimiter gets or creates a limiter for the given key

getPreferredLanguage extracts the preferred language from context (set by middleware) Falls back to parsing Accept-Language header if middleware is no

getVersionInfo returns complete version information

handleInvocationError updates the invocation record with an error

loadCredentialDetails loads and decrypts the complete credential information based on the base credential

loadProviderFromNewStructure loads a provider from the new directory structure (provider_name/manifest.json + i18n/*.json)

mapPermissionsToResponse maps permission DTOs to response format

mapProviderToBriefResponse maps a domain provider to a brief provider response

mapToDomain converts an invocation model to a domain invocation

mapToDomain maps a user info model to a domain user info

mapToDomain converts OAuthStateModel to OAuthStateData

mapToDomain maps credential models to a domain OAuth credential

mapToModel converts a domain invocation to an invocation model

mapToModel maps a domain user info to a user info model

mapToModel maps a domain API key to an API key model

mapToModel maps a domain operation to an operation model

mapToModel maps a domain provider to a provider model

mapToModel converts a domain model to a persistence model

mapToModel converts OAuthStateData to OAuthStateModel

mapToModel maps a domain OAuth credential to an OAuth credential model

parseMCPConfig parses MCP-specific configuration from custom config using JSON marshal/unmarshal

refreshTokenCore execute token refresh core logic

removeOldest evicts the least recently used item.