Function Search

pkg/cmd/search/search.go:46–120

(ctx context.Context, term string, options types.SearchOptions)

}

func Search(ctx context.Context, term string, options types.SearchOptions) error {
	// Validate filters before making HTTP request
	filterMap, err := validateAndParseFilters(options.Filters)
	if err != nil {
		return err
	}

	registryHost, searchTerm := splitReposSearchTerm(term)

	parsedRef, err := referenceutil.Parse(registryHost)
	if err != nil {
		log.G(ctx).WithError(err).Debugf("failed to parse registry host %q, using as-is", registryHost)
	} else {
		registryHost = parsedRef.Domain
	}

	var dOpts []dockerconfigresolver.Opt

	if options.GOptions.InsecureRegistry {
		log.G(ctx).Warnf("skipping verifying HTTPS certs for %q", registryHost)
		dOpts = append(dOpts, dockerconfigresolver.WithSkipVerifyCerts(true))
	}

	dOpts = append(dOpts, dockerconfigresolver.WithHostsDirs(options.GOptions.HostsDir))

	hostOpts, err := dockerconfigresolver.NewHostOptions(ctx, registryHost, dOpts...)
	if err != nil {
		return fmt.Errorf("failed to create host options: %w", err)
	}

	username, password, err := hostOpts.Credentials(registryHost)
	if err != nil {
		log.G(ctx).WithError(err).Debug("no credentials found, searching anonymously")
	}

	scheme := "https"
	if hostOpts.DefaultScheme != "" {
		scheme = hostOpts.DefaultScheme
	}

	searchURL := buildSearchURL(registryHost, searchTerm, scheme)

	req, err := http.NewRequestWithContext(ctx, "GET", searchURL, nil)
	if err != nil {
		return err
	}

	if username != "" && password != "" {
		req.SetBasicAuth(username, password)
	}

	client := createHTTPClient(hostOpts)

	resp, err := client.Do(req)
	if err != nil {
		return err
	}
	defer resp.Body.Close()