dak/queue_report.py

   1 #!/usr/bin/env python
   2
   3 """ Produces a report on NEW and BYHAND packages """
   4 # Copyright (C) 2001, 2002, 2003, 2005, 2006  James Troup <james@nocrew.org>
   5
   6 # This program is free software; you can redistribute it and/or modify
   7 # it under the terms of the GNU General Public License as published by
   8 # the Free Software Foundation; either version 2 of the License, or
   9 # (at your option) any later version.
  10
  11 # This program is distributed in the hope that it will be useful,
  12 # but WITHOUT ANY WARRANTY; without even the implied warranty of
  13 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14 # GNU General Public License for more details.
  15
  16 # You should have received a copy of the GNU General Public License
  17 # along with this program; if not, write to the Free Software
  18 # Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  19
  20 ################################################################################
  21
  22 # <o-o> XP runs GCC, XFREE86, SSH etc etc,.,, I feel almost like linux....
  23 # <o-o> I am very confident that I can replicate any Linux application on XP
  24 # <willy> o-o: *boggle*
  25 # <o-o> building from source.
  26 # <o-o> Viiru: I already run GIMP under XP
  27 # <willy> o-o: why do you capitalise the names of all pieces of software?
  28 # <o-o> willy: because I want the EMPHASIZE them....
  29 # <o-o> grr s/the/to/
  30 # <willy> o-o: it makes you look like ZIPPY the PINHEAD
  31 # <o-o> willy: no idea what you are talking about.
  32 # <willy> o-o: do some research
  33 # <o-o> willy: for what reason?
  34
  35 ################################################################################
  36
  37 from copy import copy
  38 import glob, os, stat, sys, time
  39 import apt_pkg
  40 try:
  41     import rrdtool
  42 except ImportError:
  43     pass
  44
  45 from daklib import utils
  46 from daklib.dbconn import DBConn, DBSource, has_new_comment, PolicyQueue, \
  47                           get_uid_from_fingerprint
  48 from daklib.policy import PolicyQueueUploadHandler
  49 from daklib.textutils import fix_maintainer
  50 from daklib.utils import get_logins_from_ldap
  51 from daklib.dak_exceptions import *
  52
  53 Cnf = None
  54 direction = []
  55 row_number = 0
  56
  57 ################################################################################
  58
  59 def usage(exit_code=0):
  60     print """Usage: dak queue-report
  61 Prints a report of packages in queues (usually new and byhand).
  62
  63   -h, --help                show this help and exit.
  64   -8, --822                 writes 822 formated output to the location set in dak.conf
  65   -n, --new                 produce html-output
  66   -s, --sort=key            sort output according to key, see below.
  67   -a, --age=key             if using sort by age, how should time be treated?
  68                             If not given a default of hours will be used.
  69   -r, --rrd=key             Directory where rrd files to be updated are stored
  70   -d, --directories=key     A comma seperated list of queues to be scanned
  71
  72      Sorting Keys: ao=age,   oldest first.   an=age,   newest first.
  73                    na=name,  ascending       nd=name,  descending
  74                    nf=notes, first           nl=notes, last
  75
  76      Age Keys: m=minutes, h=hours, d=days, w=weeks, o=months, y=years
  77
  78 """
  79     sys.exit(exit_code)
  80
  81 ################################################################################
  82
  83 def plural(x):
  84     if x > 1:
  85         return "s"
  86     else:
  87         return ""
  88
  89 ################################################################################
  90
  91 def time_pp(x):
  92     if x < 60:
  93         unit="second"
  94     elif x < 3600:
  95         x /= 60
  96         unit="minute"
  97     elif x < 86400:
  98         x /= 3600
  99         unit="hour"
 100     elif x < 604800:
 101         x /= 86400
 102         unit="day"
 103     elif x < 2419200:
 104         x /= 604800
 105         unit="week"
 106     elif x < 29030400:
 107         x /= 2419200
 108         unit="month"
 109     else:
 110         x /= 29030400
 111         unit="year"
 112     x = int(x)
 113     return "%s %s%s" % (x, unit, plural(x))
 114
 115 ################################################################################
 116
 117 def sg_compare (a, b):
 118     a = a[1]
 119     b = b[1]
 120     """Sort by have pending action, have note, time of oldest upload."""
 121     # Sort by have pending action
 122     a_note_state = a["processed"]
 123     b_note_state = b["processed"]
 124     if a_note_state < b_note_state:
 125         return -1
 126     elif a_note_state > b_note_state:
 127         return 1
 128
 129     # Sort by have note
 130     a_note_state = a["note_state"]
 131     b_note_state = b["note_state"]
 132     if a_note_state < b_note_state:
 133         return -1
 134     elif a_note_state > b_note_state:
 135         return 1
 136
 137     # Sort by time of oldest upload
 138     return cmp(a["oldest"], b["oldest"])
 139
 140 ############################################################
 141
 142 def sortfunc(a,b):
 143     for sorting in direction:
 144         (sortkey, way, time) = sorting
 145         ret = 0
 146         if time == "m":
 147             x=int(a[sortkey]/60)
 148             y=int(b[sortkey]/60)
 149         elif time == "h":
 150             x=int(a[sortkey]/3600)
 151             y=int(b[sortkey]/3600)
 152         elif time == "d":
 153             x=int(a[sortkey]/86400)
 154             y=int(b[sortkey]/86400)
 155         elif time == "w":
 156             x=int(a[sortkey]/604800)
 157             y=int(b[sortkey]/604800)
 158         elif time == "o":
 159             x=int(a[sortkey]/2419200)
 160             y=int(b[sortkey]/2419200)
 161         elif time == "y":
 162             x=int(a[sortkey]/29030400)
 163             y=int(b[sortkey]/29030400)
 164         else:
 165             x=a[sortkey]
 166             y=b[sortkey]
 167         if x < y:
 168             ret = -1
 169         elif x > y:
 170             ret = 1
 171         if ret != 0:
 172             if way < 0:
 173                 ret = ret*-1
 174             return ret
 175     return 0
 176
 177 ############################################################
 178
 179 def header():
 180     print """<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN"
 181 "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">
 182 <html xmlns="http://www.w3.org/1999/xhtml" xml:lang="de" lang="de">
 183   <head>
 184     <meta http-equiv="content-type" content="text/xhtml+xml; charset=utf-8" />
 185     <link type="text/css" rel="stylesheet" href="style.css" />
 186     <link rel="shortcut icon" href="https://www.debian.org/favicon.ico" />
 187     <title>
 188       Debian NEW and BYHAND Packages
 189     </title>
 190     <script type="text/javascript">
 191     //<![CDATA[
 192     function togglePkg() {
 193         var children = document.getElementsByTagName("*");
 194         for (var i = 0; i < children.length; i++) {
 195             if(!children[i].hasAttribute("class"))
 196                 continue;
 197             c = children[i].getAttribute("class").split(" ");
 198             for(var j = 0; j < c.length; j++) {
 199                 if(c[j] == "sourceNEW") {
 200                     if (children[i].style.display == '')
 201                         children[i].style.display = 'none';
 202                     else children[i].style.display = '';
 203                 }
 204             }
 205         }
 206     }
 207     //]]>
 208     </script>
 209   </head>
 210   <body id="NEW">
 211     <div id="logo">
 212       <a href="https://www.debian.org/">
 213         <img src="https://www.debian.org/logos/openlogo-nd-50.png"
 214         alt="debian logo" /></a>
 215       <a href="https://www.debian.org/">
 216         <img src="https://www.debian.org/Pics/debian.png"
 217         alt="Debian Project" /></a>
 218     </div>
 219     <div id="titleblock">
 220
 221       <img src="https://www.debian.org/Pics/red-upperleft.png"
 222       id="red-upperleft" alt="corner image"/>
 223       <img src="https://www.debian.org/Pics/red-lowerleft.png"
 224       id="red-lowerleft" alt="corner image"/>
 225       <img src="https://www.debian.org/Pics/red-upperright.png"
 226       id="red-upperright" alt="corner image"/>
 227       <img src="https://www.debian.org/Pics/red-lowerright.png"
 228       id="red-lowerright" alt="corner image"/>
 229       <span class="title">
 230         Debian NEW and BYHAND Packages
 231       </span>
 232     </div>
 233     """
 234
 235 def footer():
 236     print "<p class=\"timestamp\">Timestamp: %s (UTC)</p>" % (time.strftime("%d.%m.%Y / %H:%M:%S", time.gmtime()))
 237     print "<p class=\"timestamp\">There are <a href=\"/stat.html\">graphs about the queues</a> available.</p>"
 238
 239     print """
 240     <div class="footer">
 241     <p>Hint: Age is the youngest upload of the package, if there is more than
 242     one version.<br />
 243     You may want to look at <a href="https://ftp-master.debian.org/REJECT-FAQ.html">the REJECT-FAQ</a>
 244       for possible reasons why one of the above packages may get rejected.</p>
 245     </div> </body> </html>
 246     """
 247
 248 def table_header(type, source_count, total_count):
 249     print "<h1 class='sourceNEW'>Summary for: %s</h1>" % (type)
 250     print "<h1 class='sourceNEW' style='display: none'>Summary for: binary-%s only</h1>" % (type)
 251     print """
 252     <p class="togglepkg" onclick="togglePkg()">Click to toggle all/binary-NEW packages</p>
 253     <table class="NEW">
 254       <caption class="sourceNEW">
 255     """
 256     print "Package count in <strong>%s</strong>: <em>%s</em>&nbsp;|&nbsp; Total Package count: <em>%s</em>" % (type, source_count, total_count)
 257     print """
 258       </caption>
 259       <thead>
 260         <tr>
 261           <th>Package</th>
 262           <th>Version</th>
 263           <th>Arch</th>
 264           <th>Distribution</th>
 265           <th>Age</th>
 266           <th>Upload info</th>
 267           <th>Closes</th>
 268         </tr>
 269       </thead>
 270       <tbody>
 271     """
 272
 273 def table_footer(type):
 274     print "</tbody></table>"
 275
 276
 277 def table_row(source, version, arch, last_mod, maint, distribution, closes, fingerprint, sponsor, changedby):
 278
 279     global row_number
 280
 281     trclass = "sid"
 282     session = DBConn().session()
 283     for dist in distribution:
 284         if dist == "experimental":
 285             trclass = "exp"
 286
 287     query = '''SELECT source
 288                FROM source_suite
 289                WHERE source = :source
 290                AND suite_name IN ('unstable', 'experimental')'''
 291     if not session.execute(query, {'source': source}).rowcount:
 292         trclass += " sourceNEW"
 293     session.commit()
 294
 295     if row_number % 2 != 0:
 296         print "<tr class=\"%s even\">" % (trclass)
 297     else:
 298         print "<tr class=\"%s odd\">" % (trclass)
 299
 300     if "sourceNEW" in trclass:
 301         print "<td class=\"package\">%s</td>" % (source)
 302     else:
 303         print "<td class=\"package\"><a href=\"https://tracker.debian.org/pkg/%(source)s\">%(source)s</a></td>" % {'source': source}
 304     print "<td class=\"version\">"
 305     for vers in version.split():
 306         print "<a href=\"new/%s_%s.html\">%s</a><br/>" % (source, utils.html_escape(vers), utils.html_escape(vers))
 307     print "</td>"
 308     print "<td class=\"arch\">%s</td>" % (arch)
 309     print "<td class=\"distribution\">"
 310     for dist in distribution:
 311         print "%s<br/>" % (dist)
 312     print "</td>"
 313     print "<td class=\"age\">%s</td>" % (last_mod)
 314     (name, mail) = maint.split(":", 1)
 315
 316     print "<td class=\"upload-data\">"
 317     print "<span class=\"maintainer\">Maintainer: <a href=\"https://qa.debian.org/developer.php?login=%s\">%s</a></span><br/>" % (utils.html_escape(mail), utils.html_escape(name))
 318     (name, mail) = changedby.split(":", 1)
 319     print "<span class=\"changed-by\">Changed-By: <a href=\"https://qa.debian.org/developer.php?login=%s\">%s</a></span><br/>" % (utils.html_escape(mail), utils.html_escape(name))
 320
 321     if sponsor:
 322         print "<span class=\"sponsor\">Sponsor: <a href=\"https://qa.debian.org/developer.php?login=%s\">%s</a>@debian.org</span><br/>" % (utils.html_escape(sponsor), utils.html_escape(sponsor))
 323
 324     print "<span class=\"signature\">Fingerprint: %s</span>" % (fingerprint)
 325     print "</td>"
 326
 327     print "<td class=\"closes\">"
 328     for close in closes:
 329         print "<a href=\"https://bugs.debian.org/cgi-bin/bugreport.cgi?bug=%s\">#%s</a><br/>" % (utils.html_escape(close), utils.html_escape(close))
 330     print "</td></tr>"
 331     row_number+=1
 332
 333 ############################################################
 334
 335 def update_graph_database(rrd_dir, type, n_source, n_binary):
 336     if not rrd_dir:
 337         return
 338
 339     rrd_file = os.path.join(rrd_dir, type.lower()+'.rrd')
 340     update = [rrd_file, "N:%s:%s" % (n_source, n_binary)]
 341
 342     try:
 343         rrdtool.update(*update)
 344     except rrdtool.error:
 345         create = [rrd_file]+"""
 346 --step
 347 300
 348 --start
 349 0
 350 DS:ds0:GAUGE:7200:0:1000
 351 DS:ds1:GAUGE:7200:0:1000
 352 RRA:AVERAGE:0.5:1:599
 353 RRA:AVERAGE:0.5:6:700
 354 RRA:AVERAGE:0.5:24:775
 355 RRA:AVERAGE:0.5:288:795
 356 RRA:MAX:0.5:1:600
 357 RRA:MAX:0.5:6:700
 358 RRA:MAX:0.5:24:775
 359 RRA:MAX:0.5:288:795
 360 """.strip().split("\n")
 361         try:
 362             rc = rrdtool.create(*create)
 363             ru = rrdtool.update(*update)
 364         except rrdtool.error as e:
 365             print('warning: queue_report: rrdtool error, skipping %s.rrd: %s' % (type, e))
 366     except NameError:
 367         pass
 368
 369 ############################################################
 370
 371 def process_queue(queue, log, rrd_dir):
 372     msg = ""
 373     type = queue.queue_name
 374     session = DBConn().session()
 375
 376     # Divide the .changes into per-source groups
 377     per_source = {}
 378     total_pending = 0
 379     for upload in queue.uploads:
 380         source = upload.changes.source
 381         if source not in per_source:
 382             per_source[source] = {}
 383             per_source[source]["list"] = []
 384             per_source[source]["processed"] = ""
 385             handler = PolicyQueueUploadHandler(upload, session)
 386             if handler.get_action():
 387                 per_source[source]["processed"] = "PENDING %s" % handler.get_action()
 388                 total_pending += 1
 389         per_source[source]["list"].append(upload)
 390         per_source[source]["list"].sort(lambda x, y: cmp(x.changes.created, y.changes.created), reverse=True)
 391     # Determine oldest time and have note status for each source group
 392     for source in per_source.keys():
 393         source_list = per_source[source]["list"]
 394         first = source_list[0]
 395         oldest = time.mktime(first.changes.created.timetuple())
 396         have_note = 0
 397         for d in per_source[source]["list"]:
 398             mtime = time.mktime(d.changes.created.timetuple())
 399             if Cnf.has_key("Queue-Report::Options::New"):
 400                 if mtime > oldest:
 401                     oldest = mtime
 402             else:
 403                 if mtime < oldest:
 404                     oldest = mtime
 405             have_note += has_new_comment(d.policy_queue, d.changes.source, d.changes.version)
 406         per_source[source]["oldest"] = oldest
 407         if not have_note:
 408             per_source[source]["note_state"] = 0; # none
 409         elif have_note < len(source_list):
 410             per_source[source]["note_state"] = 1; # some
 411         else:
 412             per_source[source]["note_state"] = 2; # all
 413     per_source_items = per_source.items()
 414     per_source_items.sort(sg_compare)
 415
 416     update_graph_database(rrd_dir, type, len(per_source_items), len(queue.uploads))
 417
 418     entries = []
 419     max_source_len = 0
 420     max_version_len = 0
 421     max_arch_len = 0
 422     try:
 423         logins = get_logins_from_ldap()
 424     except:
 425         logins = dict()
 426     for i in per_source_items:
 427         maintainer = {}
 428         maint=""
 429         distribution=""
 430         closes=""
 431         fingerprint=""
 432         changeby = {}
 433         changedby=""
 434         sponsor=""
 435         filename=i[1]["list"][0].changes.changesname
 436         last_modified = time.time()-i[1]["oldest"]
 437         source = i[1]["list"][0].changes.source
 438         if len(source) > max_source_len:
 439             max_source_len = len(source)
 440         binary_list = i[1]["list"][0].binaries
 441         binary = ', '.join([ b.package for b in binary_list ])
 442         arches = set()
 443         versions = set()
 444         for j in i[1]["list"]:
 445             dbc = j.changes
 446             changesbase = dbc.changesname
 447
 448             if Cnf.has_key("Queue-Report::Options::New") or Cnf.has_key("Queue-Report::Options::822"):
 449                 try:
 450                     (maintainer["maintainer822"], maintainer["maintainer2047"],
 451                     maintainer["maintainername"], maintainer["maintaineremail"]) = \
 452                     fix_maintainer (dbc.maintainer)
 453                 except ParseMaintError as msg:
 454                     print "Problems while parsing maintainer address\n"
 455                     maintainer["maintainername"] = "Unknown"
 456                     maintainer["maintaineremail"] = "Unknown"
 457                 maint="%s:%s" % (maintainer["maintainername"], maintainer["maintaineremail"])
 458                 # ...likewise for the Changed-By: field if it exists.
 459                 try:
 460                     (changeby["changedby822"], changeby["changedby2047"],
 461                      changeby["changedbyname"], changeby["changedbyemail"]) = \
 462                      fix_maintainer (dbc.changedby)
 463                 except ParseMaintError as msg:
 464                     (changeby["changedby822"], changeby["changedby2047"],
 465                      changeby["changedbyname"], changeby["changedbyemail"]) = \
 466                      ("", "", "", "")
 467                 changedby="%s:%s" % (changeby["changedbyname"], changeby["changedbyemail"])
 468
 469                 distribution=dbc.distribution.split()
 470                 closes=dbc.closes
 471
 472                 fingerprint = dbc.fingerprint
 473                 sponsor_name = get_uid_from_fingerprint(fingerprint).name
 474                 sponsor_login = get_uid_from_fingerprint(fingerprint).uid
 475                 if '@' in sponsor_login:
 476                     if fingerprint in logins:
 477                         sponsor_login = logins[fingerprint]
 478                 if (sponsor_name != maintainer["maintainername"] and
 479                   sponsor_name != changeby["changedbyname"] and
 480                   sponsor_login + '@debian.org' != maintainer["maintaineremail"] and
 481                   sponsor_name != changeby["changedbyemail"]):
 482                     sponsor = sponsor_login
 483
 484             for arch in dbc.architecture.split():
 485                 arches.add(arch)
 486             versions.add(dbc.version)
 487         arches_list = list(arches)
 488         arches_list.sort(utils.arch_compare_sw)
 489         arch_list = " ".join(arches_list)
 490         version_list = " ".join(sorted(versions, reverse=True))
 491         if len(version_list) > max_version_len:
 492             max_version_len = len(version_list)
 493         if len(arch_list) > max_arch_len:
 494             max_arch_len = len(arch_list)
 495         if i[1]["note_state"]:
 496             note = " | [N]"
 497         else:
 498             note = ""
 499         entries.append([source, binary, version_list, arch_list, per_source[source]["processed"], note, last_modified, maint, distribution, closes, fingerprint, sponsor, changedby, filename])
 500
 501     # direction entry consists of "Which field, which direction, time-consider" where
 502     # time-consider says how we should treat last_modified. Thats all.
 503
 504     # Look for the options for sort and then do the sort.
 505     age = "h"
 506     if Cnf.has_key("Queue-Report::Options::Age"):
 507         age =  Cnf["Queue-Report::Options::Age"]
 508     if Cnf.has_key("Queue-Report::Options::New"):
 509     # If we produce html we always have oldest first.
 510         direction.append([6,-1,"ao"])
 511     else:
 512         if Cnf.has_key("Queue-Report::Options::Sort"):
 513             for i in Cnf["Queue-Report::Options::Sort"].split(","):
 514                 if i == "ao":
 515                     # Age, oldest first.
 516                     direction.append([6,-1,age])
 517                 elif i == "an":
 518                     # Age, newest first.
 519                     direction.append([6,1,age])
 520                 elif i == "na":
 521                     # Name, Ascending.
 522                     direction.append([0,1,0])
 523                 elif i == "nd":
 524                     # Name, Descending.
 525                     direction.append([0,-1,0])
 526                 elif i == "nl":
 527                     # Notes last.
 528                     direction.append([5,1,0])
 529                 elif i == "nf":
 530                     # Notes first.
 531                     direction.append([5,-1,0])
 532     entries.sort(lambda x, y: sortfunc(x, y))
 533     # Yes, in theory you can add several sort options at the commandline with. But my mind is to small
 534     # at the moment to come up with a real good sorting function that considers all the sidesteps you
 535     # have with it. (If you combine options it will simply take the last one at the moment).
 536     # Will be enhanced in the future.
 537
 538     if Cnf.has_key("Queue-Report::Options::822"):
 539         # print stuff out in 822 format
 540         for entry in entries:
 541             (source, binary, version_list, arch_list, processed, note, last_modified, maint, distribution, closes, fingerprint, sponsor, changedby, changes_file) = entry
 542
 543             # We'll always have Source, Version, Arch, Mantainer, and Dist
 544             # For the rest, check to see if we have them, then print them out
 545             log.write("Source: " + source + "\n")
 546             log.write("Binary: " + binary + "\n")
 547             log.write("Version: " + version_list + "\n")
 548             log.write("Architectures: ")
 549             log.write( (", ".join(arch_list.split(" "))) + "\n")
 550             log.write("Age: " + time_pp(last_modified) + "\n")
 551             log.write("Last-Modified: " + str(int(time.time()) - int(last_modified)) + "\n")
 552             log.write("Queue: " + type + "\n")
 553
 554             (name, mail) = maint.split(":", 1)
 555             log.write("Maintainer: " + name + " <"+mail+">" + "\n")
 556             if changedby:
 557                (name, mail) = changedby.split(":", 1)
 558                log.write("Changed-By: " + name + " <"+mail+">" + "\n")
 559             if sponsor:
 560                log.write("Sponsored-By: %s@debian.org\n" % sponsor)
 561             log.write("Distribution:")
 562             for dist in distribution:
 563                log.write(" " + dist)
 564             log.write("\n")
 565             log.write("Fingerprint: " + fingerprint + "\n")
 566             if closes:
 567                 bug_string = ""
 568                 for bugs in closes:
 569                     bug_string += "#"+bugs+", "
 570                 log.write("Closes: " + bug_string[:-2] + "\n")
 571             log.write("Changes-File: " + os.path.basename(changes_file) + "\n")
 572             log.write("\n")
 573
 574     total_count = len(queue.uploads)
 575     source_count = len(per_source_items)
 576
 577     if Cnf.has_key("Queue-Report::Options::New"):
 578         direction.append([6,1,"ao"])
 579         entries.sort(lambda x, y: sortfunc(x, y))
 580     # Output for a html file. First table header. then table_footer.
 581     # Any line between them is then a <tr> printed from subroutine table_row.
 582         if len(entries) > 0:
 583             table_header(type.upper(), source_count, total_count)
 584             for entry in entries:
 585                 (source, binary, version_list, arch_list, processed, note, last_modified, maint, distribution, closes, fingerprint, sponsor, changedby, undef) = entry
 586                 table_row(source, version_list, arch_list, time_pp(last_modified), maint, distribution, closes, fingerprint, sponsor, changedby)
 587             table_footer(type.upper())
 588     elif not Cnf.has_key("Queue-Report::Options::822"):
 589     # The "normal" output without any formatting.
 590         msg = ""
 591         for entry in entries:
 592             (source, binary, version_list, arch_list, processed, note, last_modified, undef, undef, undef, undef, undef, undef, undef) = entry
 593             if processed:
 594                 format="%%-%ds | %%-%ds | %%-%ds | %%s\n" % (max_source_len, max_version_len, max_arch_len)
 595                 msg += format % (source, version_list, arch_list, processed)
 596             else:
 597                 format="%%-%ds | %%-%ds | %%-%ds%%s | %%s old\n" % (max_source_len, max_version_len, max_arch_len)
 598                 msg += format % (source, version_list, arch_list, note, time_pp(last_modified))
 599
 600         if msg:
 601             print type.upper()
 602             print "-"*len(type)
 603             print
 604             print msg
 605             print ("%s %s source package%s / %s %s package%s in total / %s %s package%s to be processed." %
 606                    (source_count, type, plural(source_count),
 607                     total_count, type, plural(total_count),
 608                     total_pending, type, plural(total_pending)))
 609             print
 610
 611 ################################################################################
 612
 613 def main():
 614     global Cnf
 615
 616     Cnf = utils.get_conf()
 617     Arguments = [('h',"help","Queue-Report::Options::Help"),
 618                  ('n',"new","Queue-Report::Options::New"),
 619                  ('8','822',"Queue-Report::Options::822"),
 620                  ('s',"sort","Queue-Report::Options::Sort", "HasArg"),
 621                  ('a',"age","Queue-Report::Options::Age", "HasArg"),
 622                  ('r',"rrd","Queue-Report::Options::Rrd", "HasArg"),
 623                  ('d',"directories","Queue-Report::Options::Directories", "HasArg")]
 624     for i in [ "help" ]:
 625         if not Cnf.has_key("Queue-Report::Options::%s" % (i)):
 626             Cnf["Queue-Report::Options::%s" % (i)] = ""
 627
 628     apt_pkg.parse_commandline(Cnf, Arguments, sys.argv)
 629
 630     Options = Cnf.subtree("Queue-Report::Options")
 631     if Options["Help"]:
 632         usage()
 633
 634     if Cnf.has_key("Queue-Report::Options::New"):
 635         header()
 636
 637     queue_names = []
 638
 639     if Cnf.has_key("Queue-Report::Options::Directories"):
 640         for i in Cnf["Queue-Report::Options::Directories"].split(","):
 641             queue_names.append(i)
 642     elif Cnf.has_key("Queue-Report::Directories"):
 643         queue_names = Cnf.value_list("Queue-Report::Directories")
 644     else:
 645         queue_names = [ "byhand", "new" ]
 646
 647     if Cnf.has_key("Queue-Report::Options::Rrd"):
 648         rrd_dir = Cnf["Queue-Report::Options::Rrd"]
 649     elif Cnf.has_key("Dir::Rrd"):
 650         rrd_dir = Cnf["Dir::Rrd"]
 651     else:
 652         rrd_dir = None
 653
 654     f = None
 655     if Cnf.has_key("Queue-Report::Options::822"):
 656         # Open the report file
 657         f = sys.stdout
 658         filename822 = Cnf.get("Queue-Report::ReportLocations::822Location")
 659         if filename822:
 660             f = open(filename822, "w")
 661
 662     session = DBConn().session()
 663
 664     for queue_name in queue_names:
 665         queue = session.query(PolicyQueue).filter_by(queue_name=queue_name).first()
 666         if queue is not None:
 667             process_queue(queue, f, rrd_dir)
 668         else:
 669             utils.warn("Cannot find queue %s" % queue_name)
 670
 671     if Cnf.has_key("Queue-Report::Options::822"):
 672         f.close()
 673
 674     if Cnf.has_key("Queue-Report::Options::New"):
 675         footer()
 676
 677 ################################################################################
 678
 679 if __name__ == '__main__':
 680     main()