Method Record

internal/observedtools/store.go:36–82

Record parses the tools array from a raw JSON request body and stores each tool's name and schema. format must be "openai" or "claude".

(rawJSON []byte, format string)

// Record parses the tools array from a raw JSON request body and stores
// each tool's name and schema. format must be "openai" or "claude".
func (s *Store) Record(rawJSON []byte, format string) {
	tools := gjson.GetBytes(rawJSON, "tools")
	if !tools.Exists() || !tools.IsArray() {
		return
	}

	now := time.Now()
	s.mu.Lock()
	defer s.mu.Unlock()

	tools.ForEach(func(_, tool gjson.Result) bool {
		var name string
		var schemaRaw gjson.Result

		switch format {
		case "openai":
			// Chat Completions: {"type":"function","function":{"name":"...","parameters":{...}}}
			name = tool.Get("function.name").String()
			schemaRaw = tool.Get("function.parameters")
		case "openai-responses":
			// Responses API: {"type":"function","name":"...","parameters":{...}}
			name = tool.Get("name").String()
			schemaRaw = tool.Get("parameters")
		default: // claude
			name = tool.Get("name").String()
			schemaRaw = tool.Get("input_schema")
		}

		if name == "" {
			return true
		}

		var schema map[string]any
		if schemaRaw.Exists() && schemaRaw.Raw != "" {
			_ = json.Unmarshal([]byte(schemaRaw.Raw), &schema)
		}

		key := format + ":" + name
		s.tools[key] = ObservedTool{
			Name:      name,
			Schema:    schema,
			Format:    format,
			UpdatedAt: now,
		}
		return true
	})
}

// List returns all observed tools sorted by format then name.
func (s *Store) List() []ObservedTool {