Class MigrationRunner

dev-tools/scripts/changes2logchange.py:886–1007

Orchestrates the complete migration process.

class MigrationRunner:
    """Orchestrates the complete migration process."""

    def __init__(self, changes_file_path: str, output_base_dir: str, last_released_version: Optional[str] = None):
        self.changes_file_path = changes_file_path
        self.output_base_dir = Path(output_base_dir)
        self.parser = ChangesParser(changes_file_path)

        # Fetch release dates and latest version
        self.version_dates, detected_latest = ReleaseDate.fetch_release_dates_and_latest()

        # Use provided version or detected latest
        self.last_released_version = last_released_version or detected_latest

        if self.last_released_version:
            print(f"Latest released version: {self.last_released_version}", file=sys.stderr)

        self.stats = {
            'versions_processed': 0,
            'entries_migrated': 0,
            'entries_skipped': 0,
            'files_created': 0,
            'release_dates_written': 0,
            'unreleased_entries': 0,
        }

    def run(self):
        """Execute the migration."""
        print(f"Parsing CHANGES.txt from: {self.changes_file_path}")
        self.parser.parse()

        print(f"Found {len(self.parser.versions)} versions")

        for version_section in self.parser.versions:
            self._process_version(version_section)

        self._print_summary()

    def _process_version(self, version_section: VersionSection):
        """Process all entries for a single version."""
        from packaging import version as pkg_version

        # Determine if this version should go to unreleased folder
        is_unreleased = False
        if self.last_released_version:
            try:
                current_ver = pkg_version.parse(version_section.version)
                latest_ver = pkg_version.parse(self.last_released_version)
                is_unreleased = current_ver > latest_ver
            except Exception:
                # If parsing fails, treat as unreleased (conservative approach)
                is_unreleased = True

        # Route to appropriate directory
        if is_unreleased:
            version_dir = self.output_base_dir / "unreleased"
            print(f"\nProcessing version {version_section.version} (unreleased):")
            self.stats['unreleased_entries'] += len(version_section.entries)