api_prompts.go

package langfuse

import (
	"context"
	"fmt"
	"net/url"
)

// --- Request types ---

// PromptsListParams configures the query for listing prompts.
type PromptsListParams struct {
	Page   int
	Limit  int
	Name   string
	Label  string
	Tag    string
}

// --- Response types ---

// APIPrompt represents a prompt returned by the Langfuse public API.
type APIPrompt struct {
	Name      string         `json:"name"`
	Version   int            `json:"version"`
	Prompt    any            `json:"prompt"`
	Type      string         `json:"type"` // "text" or "chat"
	Config    map[string]any `json:"config"`
	Labels    []string       `json:"labels"`
	Tags      []string       `json:"tags"`
	CreatedAt string         `json:"createdAt"`
	UpdatedAt string         `json:"updatedAt"`
	CreatedBy string         `json:"createdBy"`
	ProjectID string         `json:"projectId"`
}

// PromptsListResponse is the paginated response from GET /api/public/prompts.
type PromptsListResponse struct {
	Data []APIPrompt `json:"data"`
	Meta ListMeta    `json:"meta"`
}

// --- Methods ---

// ListPrompts retrieves a paginated list of prompts.
// GET /api/public/prompts
func (c *Client) ListPrompts(ctx context.Context, p PromptsListParams) (*PromptsListResponse, error) {
	v := url.Values{}
	addOptionalInt(v, "page", p.Page)
	addOptionalInt(v, "limit", p.Limit)
	addOptionalString(v, "name", p.Name)
	addOptionalString(v, "label", p.Label)
	addOptionalString(v, "tag", p.Tag)

	body, err := c.Get(ctx, "/api/public/v2/prompts", v)
	if err != nil {
		return nil, err
	}
	return decodeJSON[*PromptsListResponse](body)
}

// GetPrompt retrieves a specific prompt by name. Optionally filter by version or label.
// GET /api/public/v2/prompts/{promptName}
func (c *Client) GetPrompt(ctx context.Context, promptName string, version int, label string) (*APIPrompt, error) {
	v := url.Values{}
	addOptionalInt(v, "version", version)
	addOptionalString(v, "label", label)

	body, err := c.Get(ctx, fmt.Sprintf("/api/public/v2/prompts/%s", url.PathEscape(promptName)), v)
	if err != nil {
		return nil, err
	}
	return decodeJSON[*APIPrompt](body)
}