mirror of
https://github.com/turbot/steampipe.git
synced 2026-02-25 05:01:06 -05:00
23 lines
889 B
Go
23 lines
889 B
Go
package plugin
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"github.com/turbot/pipe-fittings/ociinstaller"
|
|
"github.com/turbot/pipe-fittings/plugin"
|
|
"github.com/turbot/pipe-fittings/versionfile"
|
|
)
|
|
|
|
// GetInstalledPlugins returns the list of plugins keyed by the shortname (org/name) and its specific version
|
|
// Does not validate/check of available connections
|
|
func GetInstalledPlugins(ctx context.Context, pluginVersions map[string]*versionfile.InstalledVersion) (map[string]*plugin.PluginVersionString, error) {
|
|
installedPlugins := make(map[string]*plugin.PluginVersionString)
|
|
installedPluginsData, _ := List(ctx, nil, pluginVersions)
|
|
for _, plugin := range installedPluginsData {
|
|
org, name, _ := ociinstaller.NewImageRef(plugin.Name).GetOrgNameAndStream()
|
|
pluginShortName := fmt.Sprintf("%s/%s", org, name)
|
|
installedPlugins[pluginShortName] = plugin.Version
|
|
}
|
|
return installedPlugins, nil
|
|
}
|