Method RecordTools

internal/sessions/session.go:135–204

RecordTools parses the tools from a raw JSON request and stores them in the session.

(rawJSON []byte, format string)

// RecordTools parses the tools from a raw JSON request and stores them in the session.
func (s *Session) RecordTools(rawJSON []byte, format string) {
	tools := gjson.GetBytes(rawJSON, "tools")
	if !tools.Exists() || !tools.IsArray() {
		log.Debugf("[sessions] RecordTools: no tools array in request for session %s", s.ID)
		return
	}

	now := time.Now()
	var parsed []observedtools.ObservedTool

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

		switch format {
		case "openai":
			name = tool.Get("function.name").String()
			schemaRaw = tool.Get("function.parameters")
		case "openai-responses":
			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)
		}

		parsed = append(parsed, observedtools.ObservedTool{
			Name:      name,
			Schema:    schema,
			Format:    format,
			UpdatedAt: now,
		})
		return true
	})

	if len(parsed) == 0 {
		log.Debugf("[sessions] RecordTools: tools array present but 0 tools parsed for session %s (format=%s)", s.ID, format)
		return
	}

	s.mu.Lock()
	defer s.mu.Unlock()

	// Only update tools if we have at least as many as before.
	// Prevents partial tool lists from overwriting a complete snapshot.
	if len(parsed) >= len(s.Tools) {
		s.Tools = parsed
		s.toolProfile = nil // invalidate cached profile
	}