← Back to branch summary

~launchpad-pqm/launchpad/devel

« back to all changes in this revision

Viewing changes to lib/lp/soyuz/scripts/packagecopier.py

  • Committer: Curtis Hovey
  • Date: 2011-05-27 21:03:22 UTC
  • mto: This revision was merged to the branch mainline in revision 13136.
  • Revision ID: curtis.hovey@canonical.com-20110527210322-yv1o7vkwr9u25t34
Moved templates to the packages that use them.

Show diffs side-by-side

added added

removed removed

Lines of Context:
lib/lp/soyuz/scripts/packagecopier.py
28
28
from canonical.librarian.utils import copy_and_close
29
29
from lp.app.errors import NotFoundError
30
30
from lp.buildmaster.enums import BuildStatus
31
 
from lp.soyuz.adapters.notification import notify
32
31
from lp.soyuz.adapters.packagelocation import build_package_location
33
32
from lp.soyuz.enums import (
34
33
    ArchivePurpose,
510
509
 
511
510
 
512
511
def do_copy(sources, archive, series, pocket, include_binaries=False,
513
 
            allow_delayed_copies=True, person=None, check_permissions=True,
514
 
            overrides=None, send_email=False):
 
512
            allow_delayed_copies=True, person=None, check_permissions=True):
515
513
    """Perform the complete copy of the given sources incrementally.
516
514
 
517
515
    Verifies if each copy can be performed using `CopyChecker` and
536
534
    :param person: the requester `IPerson`.
537
535
    :param check_permissions: boolean indicating whether or not the
538
536
        requester's permissions to copy should be checked.
539
 
    :param overrides: A list of `IOverride` as returned from one of the copy
540
 
        policies which will be used as a manual override insyead of using the
541
 
        default override returned by IArchive.getOverridePolicy().  There
542
 
        must be the same number of overrides as there are sources and each
543
 
        override must be for the corresponding source in the sources list.
544
 
        Overrides will be ignored for delayed copies.
545
 
    :param send_email: Should we notify for the copy performed?
546
537
 
547
538
    :raise CannotCopy when one or more copies were not allowed. The error
548
539
        will contain the reason why each copy was denied.
571
562
    if len(errors) != 0:
572
563
        raise CannotCopy("\n".join(errors))
573
564
 
574
 
    overrides_index = 0
575
565
    for source in copy_checker.getCheckedCopies():
576
566
        if series is None:
577
567
            destination_series = source.distroseries
579
569
            destination_series = series
580
570
        if source.delayed:
581
571
            delayed_copy = _do_delayed_copy(
582
 
                source, archive, destination_series, pocket,
583
 
                include_binaries)
 
572
                source, archive, destination_series, pocket, include_binaries)
584
573
            sub_copies = [delayed_copy]
585
574
        else:
586
 
            override = None
587
 
            if overrides:
588
 
                override = overrides[overrides_index]
589
575
            sub_copies = _do_direct_copy(
590
 
                source, archive, destination_series, pocket,
591
 
                include_binaries, override)
592
 
            if send_email:
593
 
                notify(
594
 
                    person, source.sourcepackagerelease, [], [], archive,
595
 
                    destination_series, pocket, changes=None,
596
 
                    action='accepted')
 
576
                source, archive, destination_series, pocket, include_binaries)
597
577
 
598
 
        overrides_index += 1
599
578
        copies.extend(sub_copies)
600
579
 
601
580
    return copies
602
581
 
603
582
 
604
 
def _do_direct_copy(source, archive, series, pocket, include_binaries,
605
 
                    override=None):
 
583
def _do_direct_copy(source, archive, series, pocket, include_binaries):
606
584
    """Copy publishing records to another location.
607
585
 
608
586
    Copy each item of the given list of `SourcePackagePublishingHistory`
620
598
    :param include_binaries: optional boolean, controls whether or
621
599
        not the published binaries for each given source should be also
622
600
        copied along with the source.
623
 
    :param override: An `IOverride` as per do_copy().
624
601
 
625
602
    :return: a list of `ISourcePackagePublishingHistory` and
626
603
        `BinaryPackagePublishingHistory` corresponding to the copied
629
606
    copies = []
630
607
 
631
608
    # Copy source if it's not yet copied.
 
609
    policy = archive.getOverridePolicy()
632
610
    source_in_destination = archive.getPublishedSources(
633
611
        name=source.sourcepackagerelease.name, exact_match=True,
634
612
        version=source.sourcepackagerelease.version,
635
613
        status=active_publishing_status,
636
614
        distroseries=series, pocket=pocket)
637
 
    policy = archive.getOverridePolicy()
638
615
    if source_in_destination.is_empty():
639
 
        # If no manual overrides were specified and the archive has an
640
 
        # override policy then use that policy to get overrides.
641
 
        if override is None and policy is not None:
642
 
            package_names = (source.sourcepackagerelease.sourcepackagename,)
643
 
            # Only one override can be returned so take the first
644
 
            # element of the returned list.
645
 
            overrides = policy.calculateSourceOverrides(
646
 
                archive, series, pocket, package_names)
647
 
            # Only one override can be returned so take the first
648
 
            # element of the returned list.
649
 
            assert len(overrides) == 1, (
650
 
                "More than one override encountered, something is wrong.")
651
 
            override = overrides[0]
652
 
        source_copy = source.copyTo(series, pocket, archive, override)
 
616
        source_copy = source.copyTo(series, pocket, archive, policy=policy)
653
617
        close_bugs_for_sourcepublication(source_copy)
654
618
        copies.append(source_copy)
655
619
    else: