33import argparse
44import os
55import shutil
6+ import json
67import subprocess
78import sys
89import tempfile
910import time
11+ import rpm
1012from multiprocessing import Process
1113
1214from dataclasses import dataclass
@@ -24,11 +26,78 @@ class DiffBuildTarget:
2426 id : str
2527 dir : str
2628 meta : dict
29+ commitmeta : dict
2730
2831 @staticmethod
2932 def from_build (builds , build , arch ):
3033 return DiffBuildTarget (build , builds .get_build_dir (build , arch ),
31- builds .get_build_meta (build , arch ))
34+ builds .get_build_meta (build , arch ),
35+ builds .get_build_commitmeta (build , arch ))
36+
37+
38+ class PackageDiffType (IntEnum ):
39+ ADD = 0
40+ REMOVE = 1
41+ UPGRADE = 2
42+ DOWNGRADE = 3
43+
44+
45+ @dataclass
46+ class Package :
47+ name : str
48+ epoch : int
49+ v : str # Version
50+ r : str # Release
51+ a : str # Architecture
52+
53+ def evr (self ):
54+ epoch_string = "" if self .epoch == "0" else f"{ self .epoch } :"
55+ return f"{ epoch_string } { self .v } -{ self .r } "
56+
57+ # Compare versions
58+ # rc > 0 -> Newer; rc == 0 -> Same; rc < 0 -> Older
59+ @staticmethod
60+ def vercmp (from_pkg , to_pkg ):
61+ # pylint: disable=E1101
62+ return rpm .labelCompare ((to_pkg .epoch , to_pkg .v , to_pkg .r ),
63+ (from_pkg .epoch , from_pkg .v , from_pkg .r ))
64+
65+ # Return a data sctructure representing a diff entry from the
66+ # rpm-ostree db diff --json output.
67+ # "pkgdiff" : [
68+ # [
69+ # "NetworkManager",
70+ # 2,
71+ # {
72+ # "PreviousPackage" : [
73+ # "NetworkManager",
74+ # "1:1.52.0-5.el9_6",
75+ # "x86_64"
76+ # ],
77+ # "NewPackage" : [
78+ # "NetworkManager",
79+ # "1:1.52.0-7.el9_6",
80+ # "x86_64"
81+ # ]
82+ # }
83+ # ],
84+ @staticmethod
85+ def to_json_diff_entry (difftype : PackageDiffType , from_pkg , to_pkg ):
86+ name = from_pkg .name if from_pkg else to_pkg .name
87+ change = ""
88+ match difftype :
89+ case PackageDiffType .ADD :
90+ change = {"NewPackage" : [to_pkg .name , to_pkg .evr (), to_pkg .a ]}
91+ case PackageDiffType .REMOVE :
92+ change = {"PreviousPackage" : [from_pkg .name , from_pkg .evr (), from_pkg .a ]}
93+ case PackageDiffType .UPGRADE | PackageDiffType .DOWNGRADE :
94+ change = {
95+ "PreviousPackage" : [from_pkg .name , from_pkg .evr (), from_pkg .a ],
96+ "NewPackage" : [to_pkg .name , to_pkg .evr (), to_pkg .a ]
97+ }
98+ case _:
99+ raise Exception (f"Invalid PackageDiffType: { difftype } " )
100+ return [name , difftype , change ]
32101
33102
34103class OSTreeImport (IntEnum ):
@@ -175,6 +244,89 @@ def diff_rpms_rpm_ostree(diff_from, diff_to, json):
175244 runcmd (cmd )
176245
177246
247+ def diff_rpms_commitmeta_json (diff_from , diff_to ):
248+ diff_rpms_commitmeta (diff_from , diff_to , json_output = True )
249+
250+
251+ def diff_rpms_commitmeta_no_json (diff_from , diff_to ):
252+ diff_rpms_commitmeta (diff_from , diff_to , json_output = False )
253+
254+
255+ def diff_rpms_commitmeta (diff_from , diff_to , json_output = False ):
256+ """
257+ Diff the commitmeta.json files between two builds.
258+ """
259+ from_meta = diff_from .meta
260+ to_meta = diff_to .meta
261+ from_commitmeta = diff_from .commitmeta
262+ to_commitmeta = diff_to .commitmeta
263+
264+ # Gather info about upgraded, downgraded, added, removed RPMS
265+ from_rpms = {pkg [0 ]: Package (* pkg ) for pkg in from_commitmeta .get ('rpmostree.rpmdb.pkglist' , [])}
266+ to_rpms = {pkg [0 ]: Package (* pkg ) for pkg in to_commitmeta .get ('rpmostree.rpmdb.pkglist' , [])}
267+
268+ added_rpms = set (to_rpms .keys ()) - set (from_rpms .keys ())
269+ removed_rpms = set (from_rpms .keys ()) - set (to_rpms .keys ())
270+ common_rpms = set (from_rpms .keys ()) & set (to_rpms .keys ())
271+
272+ upgraded_rpms = []
273+ downgraded_rpms = []
274+ for name in common_rpms :
275+ from_pkg = from_rpms [name ]
276+ to_pkg = to_rpms [name ]
277+ rc = Package .vercmp (from_pkg , to_pkg )
278+ if rc > 0 :
279+ upgraded_rpms .append ((name , from_pkg , to_pkg ))
280+ elif rc == 0 :
281+ pass # They are equal versions
282+ elif rc < 0 :
283+ downgraded_rpms .append ((name , from_pkg , to_pkg ))
284+
285+ if json_output :
286+ diff = {
287+ "ostree-commit-from" : from_meta .get ('ostree-commit' ),
288+ "ostree-commit-to" : to_meta .get ('ostree-commit' ),
289+ "pkgdiff" : [],
290+ "advisories" : []
291+ }
292+ for name in sorted (added_rpms ):
293+ diff ['pkgdiff' ].append (Package .to_json_diff_entry (PackageDiffType .ADD , from_pkg = None , to_pkg = to_rpms [name ]))
294+ for name in sorted (removed_rpms ):
295+ diff ['pkgdiff' ].append (Package .to_json_diff_entry (PackageDiffType .REMOVE , from_pkg = from_rpms [name ], to_pkg = None ))
296+ for name , from_pkg , to_pkg in sorted (upgraded_rpms ):
297+ diff ['pkgdiff' ].append (Package .to_json_diff_entry (PackageDiffType .UPGRADE , from_pkg = from_pkg , to_pkg = to_pkg ))
298+ for name , from_pkg , to_pkg in sorted (downgraded_rpms ):
299+ diff ['pkgdiff' ].append (Package .to_json_diff_entry (PackageDiffType .DOWNGRADE , from_pkg = from_pkg , to_pkg = to_pkg ))
300+
301+ # Only add advisory info for the JSON output
302+ from_advisories = {adv [0 ]: adv for adv in from_commitmeta .get ('rpmostree.advisories' , [])}
303+ to_advisories = {adv [0 ]: adv for adv in to_commitmeta .get ('rpmostree.advisories' , [])}
304+ added_advisories = set (to_advisories .keys ()) - set (from_advisories .keys ())
305+ for name in added_advisories :
306+ diff ['advisories' ].append (to_advisories [name ])
307+ # Dump the JSON to stdout
308+ print (json .dumps (diff , indent = 2 ))
309+ else :
310+ print (f"ostree diff commit from: { diff_from .id } ({ from_meta .get ('ostree-commit' )} )" )
311+ print (f"ostree diff commit to: { diff_to .id } ({ to_meta .get ('ostree-commit' )} )" )
312+ if upgraded_rpms :
313+ print ("Upgraded:" )
314+ for name , from_pkg , to_pkg in sorted (upgraded_rpms ):
315+ print (f" { name } { from_pkg .evr ()} -> { to_pkg .evr ()} " )
316+ if downgraded_rpms :
317+ print ("Downgraded:" )
318+ for name , from_pkg , to_pkg in sorted (downgraded_rpms ):
319+ print (f" { name } { from_pkg .evr ()} -> { to_pkg .evr ()} " )
320+ if removed_rpms :
321+ print ("Removed:" )
322+ for name in sorted (removed_rpms ):
323+ print (f" { name } -{ from_rpms [name ].evr ()} " )
324+ if added_rpms :
325+ print ("Added:" )
326+ for name in sorted (added_rpms ):
327+ print (f" { name } -{ to_rpms [name ].evr ()} " )
328+
329+
178330def diff_ostree_ls (diff_from , diff_to ):
179331 commit_from = diff_from .meta ['ostree-commit' ]
180332 commit_to = diff_to .meta ['ostree-commit' ]
@@ -483,6 +635,10 @@ DIFFERS = [
483635 needs_ostree = OSTreeImport .FULL , function = diff_rpms_rpm_ostree_no_json ),
484636 Differ ("rpms-json" , "Diff RPMs, output JSON" ,
485637 needs_ostree = OSTreeImport .FULL , function = diff_rpms_rpm_ostree_json ),
638+ Differ ("rpms-commitmeta" , "Diff rpms from commitmeta.json" ,
639+ needs_ostree = OSTreeImport .NO , function = diff_rpms_commitmeta_no_json ),
640+ Differ ("rpms-json-commitmeta" , "Diff RPMS & Advisories from commitmeta.json, output JSON" ,
641+ needs_ostree = OSTreeImport .NO , function = diff_rpms_commitmeta_json ),
486642 Differ ("source-control" , "Diff config and COSA input commits" ,
487643 needs_ostree = OSTreeImport .NO , function = diff_source_control ),
488644 Differ ("ostree-ls" , "Diff OSTree contents using 'ostree diff'" ,
0 commit comments