~gz/hydrazine/use_bzr_config_email_561211

#!/usr/bin/python

 

USAGE = """\

usage: %prog SOURCE-PPA DESTINATION-PPA

 

A PPA should be expressed as PERSON/PPA-NAME - e.g. bzr/proposed or bzr/ppa

 

Finds all sources that have successfully built in one PPA, and copies them into

another, only if the destination does not already contain the same or greater

version."""

 

import itertools

import optparse

import os

import sys

import time

import urllib2

 

import apt_pkg; apt_pkg.init()

 

import hydrazine

 

 

def promote(lp, archive_from, archive_to):

    from_team, from_ppa = archive_from.split('/')

    to_team, to_ppa = archive_to.split('/')

    sourcepub_elts = []

 

    destination_sourcepubs = {}

    

    print "Querying destination PPA..."

    to_archive = lp.people[to_team].getPPAByName(name=to_ppa)

    dest_sources = list(itertools.chain(

        to_archive.getPublishedSources(status="Published"),

        to_archive.getPublishedSources(status="Pending"),

        ))

    buildsumm = to_archive.getBuildSummariesForSourceIds(source_ids=[x.self_link.split('/')[-1] for x in dest_sources])

    for spph in dest_sources:

        value = spph.self_link.split('/')[-1]

        package = spph.source_package_name

        version = spph.source_package_version

        series = spph.distro_series_link.split('/')[-1]

        status = spph.status

        buildstate = buildsumm[value]['status']

        print value, package, series, version, status, buildstate

        destination_sourcepubs[package, series] = version

 

    print "Querying source PPA..."

    from_archive = lp.people[from_team].getPPAByName(name=from_ppa)

    src_sources = from_archive.getPublishedSources(status="Published")

    buildsumm = from_archive.getBuildSummariesForSourceIds(source_ids=[x.self_link.split('/')[-1] for x in src_sources])

    for spph in src_sources:

        value = spph.self_link.split('/')[-1]

        package = spph.source_package_name

        version = spph.source_package_version

        series = spph.distro_series_link.split('/')[-1]

        status = spph.status

        buildstate = buildsumm[value]['status']

        dest_version = destination_sourcepubs.get((package, series))

        note = ""

        if buildstate != 'FULLYBUILT':

            pass

        elif dest_version is None:

            sourcepub_elts.append((package, version, series))

            note = "*** REQUESTING PROMOTION (NEW) ***"

        else:

            c = apt_pkg.version_compare(version, dest_version)

            if c > 0:

                sourcepub_elts.append((package, version, series))

                note = "*** REQUESTING PROMOTION ***"

            elif c < 0:

                note = "*** NEWER IN DESTINATION ***"

        print value, package, series, version, status, buildstate, note

 

    for name, version, series in sourcepub_elts:

        print "syncSource(%s, %s, %s)..." % (name, version, series)

        to_archive.syncSource(from_archive=from_archive, include_binaries=True,

                source_name=name, to_pocket="Release", to_series=series,

                version=version)

 

 

def main():

    parser = optparse.OptionParser(USAGE)

    opts, args = parser.parse_args()

    if len(args) != 2:

        parser.error("incorrect number of arguments: %d required, %d given"

                % (2, len(args)))

    from_archive, to_archive = args

    lp = hydrazine.create_session()

    promote(lp, from_archive, to_archive)

 

 

if __name__ == '__main__':

    main()