#!/usr/bin/env python
-# Manipulate suite tags
-# Copyright (C) 2000, 2001, 2002, 2003, 2004, 2005 James Troup <james@nocrew.org>
-# $Id: heidi,v 1.19 2005-11-15 09:50:32 ajt Exp $
+""" Manipulate suite tags """
+# Copyright (C) 2000, 2001, 2002, 2003, 2004, 2005, 2006 James Troup <james@nocrew.org>
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
#######################################################################################
-import pg, sys;
-import apt_pkg;
-import utils, db_access, logging;
+import pg, sys
+import apt_pkg
+from daklib import database
+from daklib import logging
+from daklib import utils
#######################################################################################
-Cnf = None;
-projectB = None;
-Logger = None;
+Cnf = None
+projectB = None
+Logger = None
################################################################################
def usage (exit_code=0):
- print """Usage: heidi [OPTIONS] [FILE]
+ print """Usage: dak control-suite [OPTIONS] [FILE]
Display or alter the contents of a suite using FILE(s), or stdin.
-a, --add=SUITE add to SUITE
else:
q = projectB.query("SELECT b.id FROM binaries b, architecture a WHERE b.package = '%s' AND b.version = '%s' AND (a.arch_string = '%s' OR a.arch_string = 'all') AND b.architecture = a.id" % (package, version, architecture))
- ql = q.getresult();
+ ql = q.getresult()
if not ql:
- utils.warn("Couldn't find '%s~%s~%s'." % (package, version, architecture));
- return None;
+ utils.warn("Couldn't find '%s_%s_%s'." % (package, version, architecture))
+ return None
if len(ql) > 1:
- utils.warn("Found more than one match for '%s~%s~%s'." % (package, version, architecture));
- return None;
- id = ql[0][0];
- return id;
+ utils.warn("Found more than one match for '%s_%s_%s'." % (package, version, architecture))
+ return None
+ return ql[0][0]
#######################################################################################
def set_suite (file, suite_id):
- lines = file.readlines();
+ lines = file.readlines()
- projectB.query("BEGIN WORK");
+ projectB.query("BEGIN WORK")
# Build up a dictionary of what is currently in the suite
- current = {};
- q = projectB.query("SELECT b.package, b.version, a.arch_string, ba.id FROM binaries b, bin_associations ba, architecture a WHERE ba.suite = %s AND ba.bin = b.id AND b.architecture = a.id" % (suite_id));
- ql = q.getresult();
+ current = {}
+ q = projectB.query("SELECT b.package, b.version, a.arch_string, ba.id FROM binaries b, bin_associations ba, architecture a WHERE ba.suite = %s AND ba.bin = b.id AND b.architecture = a.id" % (suite_id))
+ ql = q.getresult()
for i in ql:
- key = " ".join(i[:3]);
- current[key] = i[3];
- q = projectB.query("SELECT s.source, s.version, sa.id FROM source s, src_associations sa WHERE sa.suite = %s AND sa.source = s.id" % (suite_id));
- ql = q.getresult();
+ key = " ".join(i[:3])
+ current[key] = i[3]
+ q = projectB.query("SELECT s.source, s.version, sa.id FROM source s, src_associations sa WHERE sa.suite = %s AND sa.source = s.id" % (suite_id))
+ ql = q.getresult()
for i in ql:
- key = " ".join(i[:2]) + " source";
- current[key] = i[2];
+ key = " ".join(i[:2]) + " source"
+ current[key] = i[2]
# Build up a dictionary of what should be in the suite
- desired = {};
+ desired = {}
for line in lines:
- split_line = line.strip().split();
+ split_line = line.strip().split()
if len(split_line) != 3:
- utils.warn("'%s' does not break into 'package version architecture'." % (line[:-1]));
- continue;
- key = " ".join(split_line);
- desired[key] = "";
+ utils.warn("'%s' does not break into 'package version architecture'." % (line[:-1]))
+ continue
+ key = " ".join(split_line)
+ desired[key] = ""
# Check to see which packages need removed and remove them
for key in current.keys():
if not desired.has_key(key):
- (package, version, architecture) = key.split();
- id = current[key];
+ (package, version, architecture) = key.split()
+ pkid = current[key]
if architecture == "source":
- q = projectB.query("DELETE FROM src_associations WHERE id = %s" % (id));
+ q = projectB.query("DELETE FROM src_associations WHERE id = %s" % (pkid))
else:
- q = projectB.query("DELETE FROM bin_associations WHERE id = %s" % (id));
- Logger.log(["removed",key,id]);
+ q = projectB.query("DELETE FROM bin_associations WHERE id = %s" % (pkid))
+ Logger.log(["removed", key, pkid])
# Check to see which packages need added and add them
for key in desired.keys():
if not current.has_key(key):
- (package, version, architecture) = key.split();
- id = get_id (package, version, architecture);
- if not id:
- continue;
+ (package, version, architecture) = key.split()
+ pkid = get_id (package, version, architecture)
+ if not pkid:
+ continue
if architecture == "source":
- q = projectB.query("INSERT INTO src_associations (suite, source) VALUES (%s, %s)" % (suite_id, id));
+ q = projectB.query("INSERT INTO src_associations (suite, source) VALUES (%s, %s)" % (suite_id, pkid))
else:
- q = projectB.query("INSERT INTO bin_associations (suite, bin) VALUES (%s, %s)" % (suite_id, id));
- Logger.log(["added",key,id]);
+ q = projectB.query("INSERT INTO bin_associations (suite, bin) VALUES (%s, %s)" % (suite_id, pkid))
+ Logger.log(["added", key, pkid])
- projectB.query("COMMIT WORK");
+ projectB.query("COMMIT WORK")
#######################################################################################
def process_file (file, suite, action):
- suite_id = db_access.get_suite_id(suite);
+ suite_id = database.get_suite_id(suite)
if action == "set":
- set_suite (file, suite_id);
- return;
+ set_suite (file, suite_id)
+ return
- lines = file.readlines();
+ lines = file.readlines()
- projectB.query("BEGIN WORK");
+ projectB.query("BEGIN WORK")
for line in lines:
- split_line = line.strip().split();
+ split_line = line.strip().split()
if len(split_line) != 3:
- utils.warn("'%s' does not break into 'package version architecture'." % (line[:-1]));
- continue;
+ utils.warn("'%s' does not break into 'package version architecture'." % (line[:-1]))
+ continue
- (package, version, architecture) = split_line;
+ (package, version, architecture) = split_line
- id = get_id(package, version, architecture);
- if not id:
- continue;
+ pkid = get_id(package, version, architecture)
+ if not pkid:
+ continue
if architecture == "source":
# Find the existing assoications ID, if any
- q = projectB.query("SELECT id FROM src_associations WHERE suite = %s and source = %s" % (suite_id, id));
- ql = q.getresult();
+ q = projectB.query("SELECT id FROM src_associations WHERE suite = %s and source = %s" % (suite_id, pkid))
+ ql = q.getresult()
if not ql:
- assoication_id = None;
+ assoication_id = None
else:
- assoication_id = ql[0][0];
+ assoication_id = ql[0][0]
# Take action
if action == "add":
if assoication_id:
- utils.warn("'%s~%s~%s' already exists in suite %s." % (package, version, architecture, suite));
- continue;
+ utils.warn("'%s_%s_%s' already exists in suite %s." % (package, version, architecture, suite))
+ continue
else:
- q = projectB.query("INSERT INTO src_associations (suite, source) VALUES (%s, %s)" % (suite_id, id));
+ q = projectB.query("INSERT INTO src_associations (suite, source) VALUES (%s, %s)" % (suite_id, pkid))
elif action == "remove":
if assoication_id == None:
- utils.warn("'%s~%s~%s' doesn't exist in suite %s." % (package, version, architecture, suite));
- continue;
+ utils.warn("'%s_%s_%s' doesn't exist in suite %s." % (package, version, architecture, suite))
+ continue
else:
- q = projectB.query("DELETE FROM src_associations WHERE id = %s" % (assoication_id));
+ q = projectB.query("DELETE FROM src_associations WHERE id = %s" % (assoication_id))
else:
# Find the existing assoications ID, if any
- q = projectB.query("SELECT id FROM bin_associations WHERE suite = %s and bin = %s" % (suite_id, id));
- ql = q.getresult();
+ q = projectB.query("SELECT id FROM bin_associations WHERE suite = %s and bin = %s" % (suite_id, pkid))
+ ql = q.getresult()
if not ql:
- assoication_id = None;
+ assoication_id = None
else:
- assoication_id = ql[0][0];
+ assoication_id = ql[0][0]
# Take action
if action == "add":
if assoication_id:
- utils.warn("'%s~%s~%s' already exists in suite %s." % (package, version, architecture, suite));
- continue;
+ utils.warn("'%s_%s_%s' already exists in suite %s." % (package, version, architecture, suite))
+ continue
else:
- q = projectB.query("INSERT INTO bin_associations (suite, bin) VALUES (%s, %s)" % (suite_id, id));
+ q = projectB.query("INSERT INTO bin_associations (suite, bin) VALUES (%s, %s)" % (suite_id, pkid))
elif action == "remove":
if assoication_id == None:
- utils.warn("'%s~%s~%s' doesn't exist in suite %s." % (package, version, architecture, suite));
- continue;
+ utils.warn("'%s_%s_%s' doesn't exist in suite %s." % (package, version, architecture, suite))
+ continue
else:
- q = projectB.query("DELETE FROM bin_associations WHERE id = %s" % (assoication_id));
+ q = projectB.query("DELETE FROM bin_associations WHERE id = %s" % (assoication_id))
- projectB.query("COMMIT WORK");
+ projectB.query("COMMIT WORK")
#######################################################################################
def get_list (suite):
- suite_id = db_access.get_suite_id(suite);
+ suite_id = database.get_suite_id(suite)
# List binaries
- q = projectB.query("SELECT b.package, b.version, a.arch_string FROM binaries b, bin_associations ba, architecture a WHERE ba.suite = %s AND ba.bin = b.id AND b.architecture = a.id" % (suite_id));
- ql = q.getresult();
+ q = projectB.query("SELECT b.package, b.version, a.arch_string FROM binaries b, bin_associations ba, architecture a WHERE ba.suite = %s AND ba.bin = b.id AND b.architecture = a.id" % (suite_id))
+ ql = q.getresult()
for i in ql:
- print " ".join(i);
+ print " ".join(i)
# List source
- q = projectB.query("SELECT s.source, s.version FROM source s, src_associations sa WHERE sa.suite = %s AND sa.source = s.id" % (suite_id));
- ql = q.getresult();
+ q = projectB.query("SELECT s.source, s.version FROM source s, src_associations sa WHERE sa.suite = %s AND sa.source = s.id" % (suite_id))
+ ql = q.getresult()
for i in ql:
- print " ".join(i) + " source";
+ print " ".join(i) + " source"
#######################################################################################
def main ():
- global Cnf, projectB, Logger;
+ global Cnf, projectB, Logger
Cnf = utils.get_conf()
- Arguments = [('a',"add","Heidi::Options::Add", "HasArg"),
- ('h',"help","Heidi::Options::Help"),
- ('l',"list","Heidi::Options::List","HasArg"),
- ('r',"remove", "Heidi::Options::Remove", "HasArg"),
- ('s',"set", "Heidi::Options::Set", "HasArg")];
+ Arguments = [('a',"add","Control-Suite::Options::Add", "HasArg"),
+ ('h',"help","Control-Suite::Options::Help"),
+ ('l',"list","Control-Suite::Options::List","HasArg"),
+ ('r',"remove", "Control-Suite::Options::Remove", "HasArg"),
+ ('s',"set", "Control-Suite::Options::Set", "HasArg")]
for i in ["add", "help", "list", "remove", "set", "version" ]:
- if not Cnf.has_key("Heidi::Options::%s" % (i)):
- Cnf["Heidi::Options::%s" % (i)] = "";
+ if not Cnf.has_key("Control-Suite::Options::%s" % (i)):
+ Cnf["Control-Suite::Options::%s" % (i)] = ""
- file_list = apt_pkg.ParseCommandLine(Cnf,Arguments,sys.argv);
- Options = Cnf.SubTree("Heidi::Options")
+ try:
+ file_list = apt_pkg.ParseCommandLine(Cnf,Arguments,sys.argv);
+ except SystemError, e:
+ print "%s\n" % e
+ usage(1)
+ Options = Cnf.SubTree("Control-Suite::Options")
if Options["Help"]:
- usage();
+ usage()
- projectB = pg.connect(Cnf["DB::Name"], Cnf["DB::Host"],int(Cnf["DB::Port"]));
+ projectB = pg.connect(Cnf["DB::Name"], Cnf["DB::Host"],int(Cnf["DB::Port"]))
- db_access.init(Cnf, projectB);
+ database.init(Cnf, projectB)
- action = None;
+ action = None
for i in ("add", "list", "remove", "set"):
- if Cnf["Heidi::Options::%s" % (i)] != "":
- suite = Cnf["Heidi::Options::%s" % (i)];
- if db_access.get_suite_id(suite) == -1:
- utils.fubar("Unknown suite '%s'." %(suite));
+ if Cnf["Control-Suite::Options::%s" % (i)] != "":
+ suite = Cnf["Control-Suite::Options::%s" % (i)]
+ if database.get_suite_id(suite) == -1:
+ utils.fubar("Unknown suite '%s'." %(suite))
else:
if action:
- utils.fubar("Can only perform one action at a time.");
- action = i;
+ utils.fubar("Can only perform one action at a time.")
+ action = i
# Need an action...
if action == None:
- utils.fubar("No action specified.");
+ utils.fubar("No action specified.")
# Safety/Sanity check
- if action == "set" and suite != "testing":
- utils.fubar("Will not reset a suite other than testing.");
+ if action == "set" and suite not in ["testing", "etch-m68k", "lenny-r0"]:
+ utils.fubar("Will not reset suite %s" % (suite))
if action == "list":
- get_list(suite);
+ get_list(suite)
else:
- Logger = logging.Logger(Cnf, "heidi");
+ Logger = logging.Logger(Cnf, "control-suite")
if file_list:
- for file in file_list:
- process_file(utils.open_file(file), suite, action);
+ for f in file_list:
+ process_file(utils.open_file(f), suite, action)
else:
- process_file(sys.stdin, suite, action);
- Logger.close();
+ process_file(sys.stdin, suite, action)
+ Logger.close()
#######################################################################################
if __name__ == '__main__':
main()
-
projects / dak.git / blobdiff