sdkutil

func BuildReasoningContinuationFingerprint ¶ added in v0.26.0

func BuildReasoningContinuationFingerprint(
	providerInfo *spec.ProviderParam,
) string

BuildReasoningContinuationFingerprint identifies the configured endpoint. Provider name, SDK type, model, API key, and CompletionKey are intentionally excluded.

func BuildToolChoiceNameMapping ¶

func BuildToolChoiceNameMapping(
	tools []spec.ToolChoice,
) (toolNames []toolName, toolNameMap map[string]spec.ToolChoice)

BuildToolChoiceNameMapping assigns short, human‑readable function names to tools.

Rules:

• base name is the sanitized tool slug (lower‑cased, [a‑z0‑9_-] only)
• first tool with a given slug gets "<slug>"
• subsequent tools with the same slug get "<slug>_2", "<slug>_3", ...
• names are truncated to 64 characters (OpenAI function-tool limit)

Returns:

• ordered: same cardinality/order as input tools, but with the derived function name for each tool.
• nameToTool: map[functionName] => FetchCompletionToolChoice; used to translate tool calls back to the original identity.

func ClampIntToInt32 ¶ added in v0.13.0

func ClampIntToInt32(v int) int32

func CloneBoolPtr ¶ added in v0.20.0

func CloneBoolPtr(p *bool) *bool

func CloneFetchCompletionRequest ¶ added in v0.11.0

func CloneFetchCompletionRequest(req *spec.FetchCompletionRequest) (*spec.FetchCompletionRequest, error)

func CloneFloat64Ptr ¶ added in v0.20.0

func CloneFloat64Ptr(in *float64) *float64

func CloneIntPtr ¶ added in v0.20.0

func CloneIntPtr(p *int) *int

func CloneStringMap ¶ added in v0.6.1

func CloneStringMap(in map[string]string) map[string]string

func CloneStringPtr ¶ added in v0.20.0

func CloneStringPtr(in *string) *string

func ComputeDataContractHash ¶ added in v0.26.0

func ComputeDataContractHash() (string, error)

ComputeDataContractHash recomputes the SHA-256 hash of the contract files' contents. It is intended for use in tests and development tooling.

NOTE: This function assumes it is run in a source checkout of the module where the paths in DataContractFiles exist on disk. It is not suitable for use in production binaries where the Go source tree might not be available.

func FilterMessagesByTokenCount ¶

func FilterMessagesByTokenCount(
	messages []spec.InputUnion,
	maxTokenCount int,
) []spec.InputUnion

func FilterReasoningInputsByContinuationFingerprint ¶ added in v0.26.0

func FilterReasoningInputsByContinuationFingerprint(
	inputs []spec.InputUnion,
	currentFingerprint string,
) []spec.InputUnion

FilterReasoningInputsByContinuationFingerprint preserves ordinary history and keeps only reasoning produced by the current provider route and model.

func IsInputUnionEmpty ¶

func IsInputUnionEmpty(in spec.InputUnion) bool

IsInputUnionEmpty reports whether an InputUnion has nothing "worth sending". Metadata-only messages (e.g. only IDs/roles with no actual content) are treated as empty. Adjust the helpers below if your semantics differ.

func NewBufferedStreamerWithError ¶ added in v0.22.9

func NewBufferedStreamerWithError(
	onDataFlush func(string) error,
	flushInterval time.Duration,
	maxSize int,
) (write func(string) error, flush func() error)

NewBufferedStreamerWithError buffers stream data while preserving callback errors from size-based, timer-based, and final flushes.

func NormalizeRequestForSDK ¶ added in v0.9.1

func NormalizeRequestForSDK(
	ctx context.Context,
	req *spec.FetchCompletionRequest,
	opts *spec.FetchCompletionOptions,
	sdkType spec.ProviderSDKType,
	providerCapabilities spec.ModelCapabilities,
) (cappedReq *spec.FetchCompletionRequest, effectiveCapabilities *spec.ModelCapabilities, warnings []spec.Warning, err error)

func Recover ¶

func Recover(msg string, fields ...any)

Recover logs a panic (if any) at error level and prevents it from bringing down the goroutine's caller. It does not modify any returned error.

func SafeCallStreamHandler ¶

func SafeCallStreamHandler(handler spec.StreamHandler, event spec.StreamEvent) (err error)

SafeCallStreamHandler invokes the provided StreamHandler and converts any panic into an error while logging the panic details. This prevents user callbacks from crashing the streaming loop.

func StampReasoningContinuationFingerprint ¶ added in v0.26.0

func StampReasoningContinuationFingerprint(
	response *spec.FetchCompletionResponse,
	fingerprint string,
)

StampReasoningContinuationFingerprint records the source route on every normalized reasoning output before it is returned to the caller.

func ToolDescription ¶

func ToolDescription(ct spec.ToolChoice) string

func ValidateDataContract ¶ added in v0.26.0

func ValidateDataContract() (string, error)

ValidateDataContract recomputes the hash and compares it to DataContractHash. Tests in this module should call this to enforce that any schema change in the contract files is accompanied by an explicit update of DataContractHash (and, if breaking, DataContractVersion).