EnsureClaudeConvertInfo lazily creates and returns the mutable OpenAI→Claude stream conversion state. For non-nil receivers, the same instance must be

--------------------------------------------------------------------------- Read accessors (hot path, must be fast) ----------------------------------

GetBodyStorage 获取请求体存储对象（用于需要多次读取的场景）

GetUserQuota gets quota from Redis first, falls back to DB if needed

HasChannelMeta reports whether upstream channel information is attached; converters use it to decide if GetUpstreamModelName is meaningful.

Keys returns keys with valid values. In Redis, it returns all matching keys.

LookupEndpointCandidates returns every legacy provider implementation that can serve one shared model endpoint. Candidate order is deterministic and t

RecalculateTaskQuota 通用的异步差额结算。 actualQuota 是任务完成后的实际应扣额度，与预扣额度 (task.Quota) 做差额结算。 reason 用于日志记录（例如 "token重算" 或 "adaptor调整"）。 clamps 可选：若计算 actualQuo

func (info *RelayInfo) SetPromptTokens(promptTokens int) { info.promptTokens = promptTokens }

SetToolPriceForTest injects a tool price and rebuilds the lookup index. Tests only.

Source returns the embedded factory source for a task plugin key.

UserSubject is the casbin subject string for a single user.

ValidateV1Meta applies the metadata constraints published in docs/plugin-api/v1.schema.json to administrator uploads.

recordManageAuditFor 记录一条管理审计日志，日志归属于操作者；targetUserId 只表示被操作用户，用于在结构化参数中保留目标上下文。

ApplyTick maps bounded plugin semantics onto host-owned Responses events. taskStatus is the current durable DB status (for example, IN_PROGRESS, SUCCE

BuildTaskPluginView converts a persisted task into the deliberately narrow public shape permitted at JavaScript plugin boundaries.

DeleteMany accepts either fully namespaced keys or raw keys and deletes them. It returns a map keyed by fully namespaced keys.

Export returns one module export without exposing Sobek values outside the engine boundary. It is used for declarative exports such as meta.

PrepareMidjourneyTaskBilling sets the durable refund marker before the task is inserted.

Reset clears pending observations (used when a terminal response fails).

ResetProxyClientCache clears cached proxy and non-default direct policy clients and closes idle connections on every transport/shard. The package-leve

SaveToDB 将配置保存到数据库