Function FetchScripts

internal/plugins/communityscripts/scripts.go:434–487

FetchScripts fetches all available scripts from the repository.

()

// FetchScripts fetches all available scripts from the repository.
func FetchScripts() ([]Script, error) {
	c := getPluginCache()

	var cachedScripts []Script
	found, err := c.Get(ScriptListCacheKey, &cachedScripts)
	if err != nil {
		getScriptsLogger().Debug("Cache error for fetched scripts: %v", err)
	} else if found && len(cachedScripts) > 0 {
		getScriptsLogger().Debug("Using cached fetched scripts (%d items)", len(cachedScripts))

		return cachedScripts, nil
	}

	const perPage = 200
	var (
		page    = 1
		scripts []Script
	)

	for {
		endpoint := fmt.Sprintf("%s/script_scripts/records?perPage=%d&page=%d&sort=slug&expand=type", MetadataPocketBaseAPI, perPage, page)

		var response pocketBaseResponse
		if err := fetchPocketBase(endpoint, &response); err != nil {
			return nil, fmt.Errorf("failed to fetch script metadata from PocketBase: %w", err)
		}

		for _, item := range response.Items {
			script := mapPocketBaseRecord(item)
			if script.ScriptPath == "" {
				getScriptsLogger().Debug("Skipping script %s with unsupported type %q", script.Name, item.Expand.Type.Type)
				continue
			}

			scripts = append(scripts, script)
		}

		if page >= response.TotalPages || len(response.Items) == 0 {
			break
		}

		page++
	}

	if len(scripts) == 0 {
		return nil, fmt.Errorf("no valid scripts found in PocketBase metadata")
	}

	if err := c.Set(ScriptListCacheKey, scripts, ScriptListTTL); err != nil {
		getScriptsLogger().Debug("Failed to cache fetched scripts: %v", err)
	}

	return scripts, nil
}

// SearchScripts returns scripts whose name, slug, or description contains query.
func SearchScripts(scripts []Script, query string) []Script {