3
3
import argparse
4
4
import os
5
5
import shutil
6
+ import json
6
7
import subprocess
7
8
import sys
8
9
import tempfile
9
10
import time
11
+ import rpm
10
12
from multiprocessing import Process
11
13
12
14
from dataclasses import dataclass
@@ -24,11 +26,78 @@ class DiffBuildTarget:
24
26
id : str
25
27
dir : str
26
28
meta : dict
29
+ commitmeta : dict
27
30
28
31
@staticmethod
29
32
def from_build (builds , build , arch ):
30
33
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 ]
32
101
33
102
34
103
class OSTreeImport (IntEnum ):
@@ -175,6 +244,89 @@ def diff_rpms_rpm_ostree(diff_from, diff_to, json):
175
244
runcmd (cmd )
176
245
177
246
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
+
178
330
def diff_ostree_ls (diff_from , diff_to ):
179
331
commit_from = diff_from .meta ['ostree-commit' ]
180
332
commit_to = diff_to .meta ['ostree-commit' ]
@@ -483,6 +635,10 @@ DIFFERS = [
483
635
needs_ostree = OSTreeImport .FULL , function = diff_rpms_rpm_ostree_no_json ),
484
636
Differ ("rpms-json" , "Diff RPMs, output JSON" ,
485
637
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 ),
486
642
Differ ("source-control" , "Diff config and COSA input commits" ,
487
643
needs_ostree = OSTreeImport .NO , function = diff_source_control ),
488
644
Differ ("ostree-ls" , "Diff OSTree contents using 'ostree diff'" ,
0 commit comments