Method InstallToTargets

internal/metadata/refresh.go:368–409

InstallToTargets installs an item into multiple target agents in one call. It downloads the source repo once, reads the resource content, then writes it to each target. Install status is recorded per successful target.

(ctx context.Context, kind, installKey string, targetApps []string)

// It downloads the source repo once, reads the resource content, then writes it
// to each target. Install status is recorded per successful target.
func (svc *Service) InstallToTargets(ctx context.Context, kind, installKey string, targetApps []string) error {
	if len(targetApps) == 0 {
		return fmt.Errorf("metadata: no target agents specified")
	}
	item, err := svc.store.GetItem(ctx, kind, installKey)
	if err != nil {
		return fmt.Errorf("metadata: item not found: %w", err)
	}

	entityKind := entities.Kind(item.Kind)
	content := svc.fetchResourceContent(item)

	entity := entities.Entity{
		Kind:        entityKind,
		Name:        item.Name,
		Description: item.Description,
		Content:     content,
		Repo: &entities.RepoRef{
			Owner:  item.RepoOwner,
			Name:   item.RepoName,
			Branch: item.RepoBranch,
			Path:   item.ItemPath,
		},
	}

	var installed []string
	var lastErr error
	for _, app := range targetApps {
		if _, err := entities.InstallToApp(entity, entityKind, app); err != nil {
			lastErr = fmt.Errorf("metadata: install to %s: %w", app, err)
			continue
		}
		installed = append(installed, app)
	}
	if len(installed) == 0 {
		return lastErr
	}
	if err := svc.store.MarkInstalled(ctx, kind, installKey, strings.Join(installed, ",")); err != nil {
		return err
	}
	return lastErr
}

// UninstallFromTargets removes an entity from the specified apps and updates
// the metadata store's installed status.