Method runPullCommand

cmd/root/pull.go:37–74

(cmd *cobra.Command, args []string)

}

func (f *pullFlags) runPullCommand(cmd *cobra.Command, args []string) (commandErr error) {
	ctx := cmd.Context()
	telemetry.TrackCommand(ctx, "share", append([]string{"pull"}, args...))
	defer func() { // do not inline this defer so that commandErr is not resolved early
		telemetry.TrackCommandError(ctx, "share", append([]string{"pull"}, args...), commandErr)
	}()

	out := cli.NewPrinter(cmd.OutOrStdout())
	registryRef := args[0]
	slog.DebugContext(ctx, "Starting pull", "registry_ref", registryRef)

	out.Println("Pulling agent", registryRef)

	_, err := remote.Pull(ctx, registryRef, f.force)
	if err != nil {
		return fmt.Errorf("failed to pull artifact: %w", err)
	}

	store, err := content.NewStore()
	if err != nil {
		return fmt.Errorf("failed to open content store: %w", err)
	}
	yamlFile, err := store.GetArtifact(registryRef)
	if err != nil {
		return fmt.Errorf("failed to get agent yaml: %w", err)
	}

	agentName := strings.ReplaceAll(registryRef, "/", "_")
	fileName := agentName + ".yaml"

	if err := os.WriteFile(fileName, []byte(yamlFile), 0o644); err != nil { //nolint:gosec // pulled agent yaml is meant to be readable
		return err
	}

	out.Printf("Agent saved to %s\n", fileName)

	return nil
}