#! /usr/bin/perl

use XML::Simple;
use LWP::UserAgent;
use Data::Dumper;
use Algorithm::Diff qw(diff sdiff);

my $ua = LWP::UserAgent->new;
$ua->agent("generate-reminder.pl");
$ua->timeout(180);
$ua->max_size(100000000);
my $baseurl = "https://build.opensuse.org";

my %ringed;
my %toignore;
for my $i (qw(kernel-syms kernel-xen glibc.i686 openSUSE-release kernel-desktop kernel-default kernel-pae Test-DVD-x86_64 kiwi-image-livecd-gnome.x86_64 kiwi-image-livecd-kde.x86_64 package-lists-kde.x86_64 package-lists-gnome.x86_64)) {
    $toignore{$i} = 1;
}

sub fetch_api($) {
  my $route = shift;
  my $mywork = $ua->get("$baseurl$route");
  unless ($mywork->is_success) { die "$route - " . $mywork->status_line; }

  return $mywork->decoded_content;
}

sub fetch_prj($) {
    my $prj = shift;

    my $packages = XMLin(fetch_api("/status/project/$prj"))->{package};
    my %ret;
    for my $p (keys %${packages}) {
      next if defined $toignore{$p} || $p =~ /AGGR/;
      $ret{$p} = $packages->{$p}->{verifymd5} || $packages->{$p}->{srcmd5};
    }
    return \%ret;
  }

my %pkgdeps;
my %bin2src;

sub fill_arrays($$$) {
  my $prj = shift;
  my $repo = shift;
  my $arch = shift;

  my $dinfo = XMLin(fetch_api("/build/$prj/$repo/$arch/_builddepinfo"));
  $dinfo = $dinfo->{'package'};
  for my $key (keys %$dinfo) {
      my $p = $dinfo->{$key};
      my $source = $p->{'source'};
      if ($key =~ m/^preinstall/) {
	  delete $dinfo->{$key};
	  next;
      }
      my $subpkgs = $p->{'subpkg'};
      if (!ref($subpkgs)) {
	  $subpkgs = [$subpkgs];
      }
      for my $s (@$subpkgs) {
	  if (defined $bin2src{$s}) {
	      warn "bin $s defined twice\n";
	  }
	  $bin2src{$s} = $source;
      }
  }
  return $dinfo;
}

sub check_depinfo_ring($$) {
  my $prj = shift;
  my $nextprj = shift;

  my $dinfo = fill_arrays($prj, 'standard', 'x86_64');
  if ($prj eq 'openSUSE:Factory:Core') {
      $dinfo->{MYdvd} = {};
      $dinfo->{MYdvd}->{pkgdep} = ();
      $dinfo->{MYdvd}->{source} = 'MYdvd';
      my $dvd = XMLin(fetch_api("/build/openSUSE:Factory:Core/images/x86_64/Test-DVD-x86_64/_buildinfo"));
      for my $bdep (@{$dvd->{bdep}}) {
	  push(@{$dinfo->{MYdvd}->{pkgdep}}, $bdep->{name});
      }
  }

  my @pi;
  for my $line (split("\n", fetch_api("/build/$prj/standard/_buildconfig"))) {
    if ($line =~ m/^Preinstall:/ || $line =~ m/^Support:/) {
      $line =~ s,^Preinstall:,,;
      $line =~ s,^Support:,,;
      for my $prein (split(/\s+/, $line)) {
	chomp $prein;
	next unless $prein;
	push(@pi, $prein);
      }
    }
  }
  
  $dinfo->{MYinstall} = {};
  $dinfo->{MYinstall}->{source} = 'MYinstall';
  $dinfo->{MYinstall}->{pkgdep} = \@pi;
  for my $key (keys %$dinfo) {
    my $p = $dinfo->{$key};
    for my $s (@{$p->{'pkgdep'}}) {
      my $b = $bin2src{$s};
      $pkgdeps{$b} = $p->{source};
    }
  }

  for my $key (keys %$dinfo) {
    next if ($key =~ m/^MY/ || $key =~ m/^texlive-specs-/ || $key =~ m/^kernel-/);
    if (!defined $pkgdeps{$key}) {
      print "osc rdelete -m cleanup $prj $key\n";
      if ($nextprj) {
	print "osc linkpac -c openSUSE:Factory $key $nextprj\n";
      }
    }
  }
}

check_depinfo_ring('openSUSE:Factory:Build', 'openSUSE:Factory:Core');
check_depinfo_ring('openSUSE:Factory:Core', 'openSUSE:Factory:MainDesktops');

my $fact = fetch_prj('openSUSE:Factory');

sub check_ring($) {
  my $ringprj = shift;

my $ring = fetch_prj($ringprj);

PACKAGE: for my $p (keys %${ring}) {
	#print "checking $ringprj $p $ring->{$p} $fact->{$p}\n";
  if ($ringed{$p}) {
    print "osc rdelete $ringprj $p -m 'in two rings'\n";
    next;
  }
  $ringed{$p} = $ring->{$p};
  if ($ring->{$p} ne $fact->{$p}) {
    
    eval {
    my $fxml = XMLin(fetch_api("/source/openSUSE:Factory/$p?view=info"));
    my $rxml = XMLin(fetch_api("/source/$ringprj/$p?view=info"));

    next if ($fxml->{verifymd5} eq $rxml->{verifymd5});
    };
    if ($@) {
      print "# $@";
      print "osc rdelete -m 'gone away' $ringprj $p\n";
      next;
    }

    eval {
    my @ftext = split(/\n/, fetch_api("/source/openSUSE:Factory/$p/$p.changes?expand=1"));
    my @rtext = split(/\n/, fetch_api("/source/$ringprj/$p/$p.changes?expand=1"));
  
    my @d = sdiff( \@ftext, \@rtext );
    if (!length(@d)) {
     print "# no changes diff in $p\n";
     next;
    }
    # first chunk
    for my $d (@d) {
      my @e = @$d;
      my $c = shift @e;
      next if ($c eq 'u');
      if ($c eq '+') {
        print "# diff is +: osc rdiff openSUSE:Factory $p $ringprj $p - " . join('', @e) . "\n";
        next PACKAGE;
      }
    }
    };
    warn $@ if $@;
    #system("osc rdiff openSUSE:Factory $p openSUSE:Factory:Core $p");
    print "osc linkpac -f -c openSUSE:Factory $p $ringprj\n";
  }
}
}

check_ring("openSUSE:Factory:Build");
check_ring("openSUSE:Factory:Core");
check_ring("openSUSE:Factory:MainDesktops");
check_ring("openSUSE:Factory:DVD");

sub check_package($$$) {
  my $package = shift; 
  my $spkg = shift;
  my $tpkg = shift;

  my $p1 = XMLin(fetch_api("/source/$spkg/$package?view=info"));
  my $p2 = XMLin(fetch_api("/source/$tpkg/$package?view=info"));

  return if ($p1->{verifymd5} eq $p2->{verifymd5});
  print "osc linkpac -f -r $p1->{srcmd5} $spkg $package $tpkg\n";
}

check_package('Test-DVD-x86_64', 'openSUSE:Factory', 'openSUSE:Factory:Core');
check_package('kiwi-image-livecd-gnome.x86_64', 'openSUSE:Factory:Live', 'openSUSE:Factory:MainDesktops');
check_package('kiwi-image-livecd-kde.x86_64', 'openSUSE:Factory:Live', 'openSUSE:Factory:MainDesktops');
check_package('package-lists-gnome.x86_64', 'openSUSE:Factory:Live', 'openSUSE:Factory:MainDesktops');
check_package('package-lists-kde.x86_64', 'openSUSE:Factory:Live', 'openSUSE:Factory:MainDesktops');