Added an attempt to write a urpmi backend ported open_db

1 files changed, 317 insertions, 0 deletions

diff --git a/lib/ManaTools/Shared/urpmi_backend/DB.pm b/lib/ManaTools/Shared/urpmi_backend/DB.pm
new file mode 100644
index 0000000..ea5d52a
--- /dev/null
+++ b/lib/ManaTools/Shared/urpmi_backend/DB.pm
@@ -0,0 +1,317 @@
+# vim: set et ts=4 sw=4:
+package ManaTools::Shared::urpmi_backend::DB;
+#*****************************************************************************
+#
+#  Copyright (c) 2015 Angelo Naselli <anaselli@linux.it>
+#  from Rpmdrake::open_db:
+#       Copyright (c) 2002 Guillaume Cottenceau
+#       Copyright (C) 2008 Aurelien Lefebvre <alkh@mandriva.org>
+#       Copyright (c) 2002-2014 Thierry Vignaud <thierry.vignaud@gmail.com>
+#       Copyright (c) 2003, 2004, 2005 MandrakeSoft SA
+#       Copyright (c) 2005-2007 Mandriva SA
+#
+#  This program is free software; you can redistribute it and/or modify
+#  it under the terms of the GNU General Public License version 2, as
+#  published by the Free Software Foundation.
+#
+#  This program is distributed in the hope that it will be useful,
+#  but WITHOUT ANY WARRANTY; without even the implied warranty of
+#  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+#  GNU General Public License for more details.
+#
+#  You should have received a copy of the GNU General Public License
+#  along with this program; if not, write to the Free Software
+#  Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
+#
+#*****************************************************************************
+
+use Moose;
+
+use MDK::Common::File qw(cat_ mkdir_p);
+use MDK::Common::Func qw(if_);
+
+use urpm;
+use urpm::media;
+use urpm::select;
+use urpm::mirrors;
+
+use URPM;
+use feature 'state';
+
+# TODO evaluate if managing urpm object inside
+#      left as a parameter to back compatibility by now.
+#
+
+#=============================================================
+
+=head2 new - optional parameters
+
+=head3 urpmi_root
+
+    optional parameter urpmi_root directory,
+    default value is undef
+
+=cut
+
+#=============================================================
+has 'urpmi_root' => (
+    is => 'rw',
+    isa => 'Str'
+);
+
+#=============================================================
+
+=head2 new - optional parameters
+
+=head3 rpm_root
+
+    optional parameter rpm_root directory,
+    default value is undef
+
+=cut
+
+#=============================================================
+has 'rpm_root'   => (
+    is => 'rw',
+    isa => 'Str'
+);
+
+# product_id contains the product id file pathname
+has 'product_id' => (
+    is        => 'ro',
+    isa       => 'Str',
+    init_arg  => undef,
+    lazy    => 1,
+    builder => '_product_id_init',
+);
+
+sub _product_id_init {
+    my $self = shift;
+
+    return  ($self->urpmi_root() || '') . '/etc/product.id',
+}
+
+#=============================================================
+
+=head2 open_rpm_db
+
+=head3 OUTPUT
+
+URPM::DB: an URPM opened dataase
+
+=head3 DESCRIPTION
+
+    this method return an URPM::DB object
+
+=cut
+
+#=============================================================
+sub open_rpm_db {
+    my $self = shift;
+
+    URPM::DB::open($self->rpm_root() ||'')  or die "Couldn't open RPM DB " . ($self->rpm_root() ||'');
+}
+
+#=============================================================
+
+=head2 fast_open_urpmi_db
+
+=head3 OUTPUT
+
+urpm: an urpm object
+
+=head3 DESCRIPTION
+
+    this method return an urpm object
+
+=cut
+
+#=============================================================
+sub fast_open_urpmi_db {
+    my $self = shift;
+
+    my $urpm = urpm->new;
+
+    urpm::set_files($urpm, $self->urpmi_root()) if $self->urpmi_root();
+    my $rpm_root = $self->rpm_root() || $self->urpmi_root();
+    urpm::args::set_root($urpm, $rpm_root) if $rpm_root;
+
+    $urpm->get_global_options;
+    urpm::media::read_config($urpm);
+    $urpm;
+}
+
+#=============================================================
+
+=head2 is_it_a_devel_distro
+
+=head3 DESCRIPTION
+
+    This method returns if current distro is not stable
+
+=cut
+
+#=============================================================
+sub is_it_a_devel_distro {
+    my $self = shift;
+    state $res;
+
+    return $res if defined $res;
+    $res = urpm::mirrors::parse_LDAP_namespace_structure(cat_($self->product_id()))->{branch} eq 'Devel';
+    return $res;
+}
+
+#=============================================================
+
+=head2 get_backport_media
+
+=head3 INPUT
+
+    $urpm: an urpm object
+
+=head3 DESCRIPTION
+
+    This method returns a list of backport media
+
+=cut
+
+#=============================================================
+sub get_backport_media {
+    my ($self, $urpm) = @_;
+
+    grep { $_->{name} =~ /backport/i &&
+           $_->{name} !~ /debug|sources|testing/i } @{$urpm->{media}};
+}
+
+
+#=============================================================
+
+=head2 get_inactive_backport_media
+
+=head3 INPUT
+
+    $urpm: an urpm object
+
+=head3 DESCRIPTION
+
+    This method returns a list of inactive backport media
+
+=cut
+
+#=============================================================
+sub get_inactive_backport_media {
+    my ($self, $urpm) = @_;
+    map { $_->{name} } grep { $_->{ignore} } $self->get_backport_media($urpm);
+}
+
+#=============================================================
+
+=head2 get_update_medias
+
+=head3 INPUT
+
+    $urpm: an urpm object
+
+=head3 DESCRIPTION
+
+    This method returns a list of update media
+
+=cut
+
+#=============================================================
+sub get_update_medias {
+    my ($self, $urpm) = @_;
+    if ($self->is_it_a_devel_distro()) {
+        grep { !$_->{ignore} } @{$urpm->{media}};
+    } else {
+        grep { !$_->{ignore} && $_->{update} } @{$urpm->{media}};
+    }
+}
+
+#=============================================================
+
+=head2 open_urpmi_db
+
+=head3 INPUT
+
+    %urpmi_options: urpmi options used to open and lock urpmi
+                    db.
+
+=head3 DESCRIPTION
+
+    This method returns an urpm option with a lcok on db
+
+=cut
+
+#=============================================================
+sub open_urpmi_db {
+    my ($self, %urpmi_options) = @_;
+    my $urpm = $self->fast_open_urpmi_db();
+
+    my $searchmedia = $urpmi_options{update} ? undef : join(',', $self->get_inactive_backport_media($urpm));
+
+    $self->lock($urpm);
+
+    #next part could be changed in extended implementation on media and priority
+    urpm::select::set_priority_upgrade_option($urpm, ());
+    urpm::media::configure($urpm, media => '', if_($searchmedia, searchmedia => $searchmedia), %urpmi_options);
+
+    $urpm;
+}
+
+
+#=============================================================
+
+=head2 lock
+
+=head3 INPUT
+
+    $urpm: urpm object
+
+=head3 OUTPUT
+
+    0 if already locked, 1 otherwhise
+
+=head3 DESCRIPTION
+
+    This method locks the db passed into urpm object
+
+=cut
+
+#=============================================================
+sub lock {
+    my ($self, $urpm) = @_;
+
+    return 0 if $urpm->{lock}; # already locked
+
+    $urpm->{lock} = urpm::lock::urpmi_db($urpm, undef, wait => $urpm->{options}{wait_lock});
+
+    return 1;
+}
+
+#=============================================================
+
+=head2 lock
+
+=head3 INPUT
+
+    $urpm: urpm object
+
+=head3 DESCRIPTION
+
+    This method unlocks the db passed into urpm object
+
+=cut
+
+#=============================================================
+sub unlock {
+    my ($self, $urpm) = @_;
+
+    $urpm->{lock} = undef;
+
+    return;
+}
+
+1;
+
+