Function listModuleVersions

query.go:460–496

listModuleVersions invokes the Perseus API to retrieve a list of module versions that match the provided filter options.

(ctx context.Context, ps perseusapiconnect.PerseusServiceClient, req listModuleVersionsRequest)

// listModuleVersions invokes the Perseus API to retrieve a list of module versions that match the provided
// filter options.
func listModuleVersions(ctx context.Context, ps perseusapiconnect.PerseusServiceClient, req listModuleVersionsRequest) (results []dependencyItem, err error) {
	var pageToken string
	for done := false; !done; {
		req.updateStatus("retrieving module versions")
		apiRequest := connect.NewRequest(&perseusapi.ListModuleVersionsRequest{
			ModuleFilter:      req.modulePattern,
			VersionFilter:     req.versionPattern,
			IncludePrerelease: req.includePrerelease,
			VersionOption:     perseusapi.ModuleVersionOption_all,
			PageToken:         pageToken,
		})
		if req.latestOnly {
			apiRequest.Msg.VersionOption = perseusapi.ModuleVersionOption_latest
		}
		req.updateStatus(fmt.Sprintf("retreiving versions for modules matching %q", req.modulePattern))
		resp, err := retryOp(func() (*connect.Response[perseusapi.ListModuleVersionsResponse], error) {
			return ps.ListModuleVersions(ctx, apiRequest)
		})
		if err != nil {
			return nil, fmt.Errorf("todo: %w", err)
		}

		// API response is 1 result per module with a list of versions
		// - flatten to 1 dependencyItem per module/version pair
		for _, mod := range resp.Msg.Modules {
			for _, ver := range mod.Versions {
				results = append(results, dependencyItem{
					Path:    mod.GetName(),
					Version: ver,
				})
			}
		}
		pageToken = resp.Msg.GetNextPageToken()
		done = (pageToken != "")
	}
	return results, nil
}

// flattenTree converts the nested tree of module dependencies into a flat list of unique modules
// sorted by module name then by highest to lowest semantic version