Function downloadSupportBundle

internal/cli/support.go:267–323

(
	ctx context.Context,
	client DaemonClient,
	operationID string,
	path string,
)

}

func downloadSupportBundle(
	ctx context.Context,
	client DaemonClient,
	operationID string,
	path string,
) (err error) {
	if strings.TrimSpace(path) == "" {
		return errors.New("cli: support bundle output path is required")
	}
	if err := os.MkdirAll(filepath.Dir(path), 0o700); err != nil {
		return fmt.Errorf("cli: create support bundle output directory: %w", err)
	}
	if _, err := os.Stat(path); err == nil {
		return fmt.Errorf("cli: support bundle output already exists: %s", path)
	} else if !errors.Is(err, os.ErrNotExist) {
		return fmt.Errorf("cli: inspect support bundle output: %w", err)
	}

	tmpPath := path + ".tmp-" + strings.TrimSpace(operationID)
	file, err := os.OpenFile(tmpPath, os.O_CREATE|os.O_EXCL|os.O_WRONLY, 0o600)
	if err != nil {
		return fmt.Errorf("cli: create support bundle temp file: %w", err)
	}
	committed := false
	defer func() {
		if closeErr := file.Close(); closeErr != nil {
			closeErr = fmt.Errorf("cli: close support bundle temp file: %w", closeErr)
			if err == nil {
				err = closeErr
			} else {
				err = errors.Join(err, closeErr)
			}
		}
		if !committed {
			if removeErr := os.Remove(tmpPath); removeErr != nil && !errors.Is(removeErr, os.ErrNotExist) {
				removeErr = fmt.Errorf("cli: remove support bundle temp file: %w", removeErr)
				if err == nil {
					err = removeErr
				} else {
					err = errors.Join(err, removeErr)
				}
			}
		}
	}()

	if err := client.DownloadSupportBundle(ctx, operationID, file); err != nil {
		return err
	}
	if err := file.Sync(); err != nil {
		return fmt.Errorf("cli: sync support bundle temp file: %w", err)
	}
	if err := os.Rename(tmpPath, path); err != nil {
		return fmt.Errorf("cli: move support bundle into place: %w", err)
	}
	committed = true
	return nil
}