Method trackGitReferences

internal/tracker/tracker.go:177–228

(ctx context.Context, urls []string, freshen bool)

}

func (t *Tracker) trackGitReferences(ctx context.Context, urls []string, freshen bool) error {
	if freshen {
		log.Debug("Freshen is enabled")

		tmp := make([]string, len(urls), len(urls)+len(t.TrustedTasks))
		copy(tmp, urls)
		urls = tmp
		for u := range t.TrustedTasks {
			if strings.HasPrefix(u, "git+") {
				urls = append(urls, u)
			}
		}
	}

	g := NewGitTracker()
	defer g.Close(ctx)

	for _, u := range urls {
		schemeSepIdx := strings.Index(u, "//")
		pathSepIdx := strings.LastIndex(u, "//")

		if pathSepIdx <= schemeSepIdx {
			return fmt.Errorf("expected %q to contain the `//` to separate the repository from the path, e.g. git+https://github.com/org/repository//task/0.1/task.yaml@f0cacc1a", u)
		}

		repository := u[0:pathSepIdx]
		rest := u[pathSepIdx+2:]

		path, rev, found := strings.Cut(rest, "@")
		if !found {
			if !freshen {
				return fmt.Errorf("expected %q to contain the revision information following the `@`, e.g. git+https://github.com/org/repository//task/0.1/task.yaml@f0cacc1a, to fetch the latest revision from a remote URL provide the --freshen parameter", u)
			}
			var err error
			rev, err = g.GitResolve(ctx, repository, rest)
			if err != nil {
				return err
			}
			path = rest
		} else if freshen {
			// nothing prevents the user using --freshen and revision, so log what revision is being used.
			log.Debugf("--freshen used, but a revision is also provided. Using provided revision: %q", rev)
		}

		t.addTrustedTaskRecord("", taskRecord{
			Repository: fmt.Sprintf("%s//%s", repository, path),
			Ref:        rev,
		})
	}

	return nil
}

func inputBundleTags(ctx context.Context, t Tracker) ([]image.ImageReference, error) {
	uniqueTagRefs := map[string]bool{}