Function getUpstreamToolsForGaps

runner/metadata.go:181–216

getUpstreamToolsForGaps returns upstream cached tools for os/arch combinations not already covered by object store tools. If osType and osArch are non-nil, only the matching platform is considered (instance-scoped). If nil, all platforms are considered (admin-scoped).

(objectStoreTools []params.GARMAgentTool, osType *commonParams.OSType, osArch *commonParams.OSArch)

// only the matching platform is considered (instance-scoped). If nil, all
// platforms are considered (admin-scoped).
func getUpstreamToolsForGaps(objectStoreTools []params.GARMAgentTool, osType *commonParams.OSType, osArch *commonParams.OSArch) []params.GARMAgentTool {
	ctrlInfo := cache.ControllerInfo()

	// Check staleness - don't use cached data older than 24 hours
	if ctrlInfo.CachedGARMAgentReleaseFetchedAt == nil {
		return nil
	}
	if time.Since(*ctrlInfo.CachedGARMAgentReleaseFetchedAt) > 24*time.Hour {
		return nil
	}
	if ctrlInfo.CachedGARMAgentTools == nil {
		return nil
	}

	// Build set of os_type/os_arch keys already covered by object store tools
	covered := make(map[string]bool, len(objectStoreTools))
	for _, tool := range objectStoreTools {
		covered[string(tool.OSType)+"/"+string(tool.OSArch)] = true
	}

	var result []params.GARMAgentTool
	for key, tool := range ctrlInfo.CachedGARMAgentTools {
		if covered[key] {
			continue
		}
		// For instance-scoped calls, only include matching os/arch
		if osType != nil && osArch != nil {
			if tool.OSType != *osType || tool.OSArch != *osArch {
				continue
			}
		}
		tool.Source = params.ToolSourceUpstream
		result = append(result, tool)
	}
	return result
}

// getInstanceAgentTool retrieves the GARM agent tool for the given instance.
// It first checks the local object store, then falls back to upstream cached tools.