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