from daklib import utils
from daklib.dbconn import *
+from sqlalchemy.orm.exc import NoResultFound
################################################################################
Commands can use a long or abbreviated form:
+ config / c:
+ c db show db config
+ c db-shell show db config in a usable form for psql
+ c NAME show option NAME as set in configuration table
+
+ keyring / k:
+ k list-all list all keyrings
+ k list-binary list all keyrings with a NULL source acl
+ k list-source list all keyrings with a non NULL source acl
+
architecture / a:
a list show a list of architectures
a rm ARCH remove an architecture (will only work if
suite / s:
s list show a list of suites
s show SUITE show config details for a suite
+ s add SUITE VERSION [ label=LABEL ] [ description=DESCRIPTION ]
+ [ origin=ORIGIN ] [ codename=CODENAME ]
+ [ signingkey=SIGNINGKEY ]
+ add suite SUITE, version VERSION.
+ label, description, origin, codename
+ and signingkey are optional.
+
+ s add-all-arches SUITE VERSION... as "s add" but adds suite-architecture
+ relationships for all architectures
suite-architecture / s-a:
+ s-a list show the architectures for all suites
s-a list-suite ARCH show the suites an ARCH is in
s-a list-arch SUITE show the architectures in a SUITE
s-a add SUITE ARCH add ARCH to suite
s-a rm SUITE ARCH remove ARCH from suite (will only work if
no packages remain for the arch in the suite)
+
+ version-check / v-c:
+ v-c list show version checks for all suites
+ v-c list-suite SUITE show version checks for suite SUITE
+ v-c add SUITE CHECK REFERENCE add a version check for suite SUITE
+ v-c rm SUITE CHECK REFERENCE remove a version check
+ where
+ CHECK is one of Enhances, MustBeNewerThan, MustBeOlderThan
+ REFERENCE is another suite name
"""
sys.exit(exit_code)
sys.exit(0)
def __architecture_add(d, args):
- die_arglen(args, 3, "E: adding an architecture requires a name and a description")
+ die_arglen(args, 4, "E: adding an architecture requires a name and a description")
print "Adding architecture %s" % args[2]
suites = [str(x) for x in args[4:]]
- print suites
+ if len(suites) > 0:
+ print "Adding to suites %s" % ", ".join(suites)
if not dryrun:
try:
s = d.session()
a.description = str(args[3])
s.add(a)
for sn in suites:
- su = get_suite(sn ,s)
+ su = get_suite(sn, s)
if su is not None:
- archsu = SuiteArchitecture()
- archsu.arch_id = a.arch_id
- archsu.suite_id = su.suite_id
- s.add(archsu)
+ a.suites.append(su)
else:
warn("W: Cannot find suite %s" % su)
s.commit()
- except IntegrityError, e:
+ except IntegrityError as e:
die("E: Integrity error adding architecture %s (it probably already exists)" % args[2])
- except SQLAlchemyError, e:
+ except SQLAlchemyError as e:
die("E: Error adding architecture %s (%s)" % (args[2], e))
print "Architecture %s added" % (args[2])
die("E: Cannot find architecture %s" % args[2])
s.delete(a)
s.commit()
- except IntegrityError, e:
+ except IntegrityError as e:
die("E: Integrity error removing architecture %s (suite-arch entries probably still exist)" % args[2])
- except SQLAlchemyError, e:
+ except SQLAlchemyError as e:
die("E: Error removing architecture %s (%s)" % (args[2], e))
print "Architecture %s removed" % args[2]
print su.details()
+def __suite_add(d, args, addallarches=False):
+ die_arglen(args, 4, "E: adding a suite requires at least a name and a version")
+ suite_name = args[2].lower()
+ version = args[3]
+ rest = args[3:]
+
+ def get_field(field):
+ for varval in args:
+ if varval.startswith(field + '='):
+ return varval.split('=')[1]
+ return None
+
+ print "Adding suite %s" % suite_name
+ if not dryrun:
+ try:
+ s = d.session()
+ suite = Suite()
+ suite.suite_name = suite_name
+ suite.overridecodename = suite_name
+ suite.version = version
+ suite.label = get_field('label')
+ suite.description = get_field('description')
+ suite.origin = get_field('origin')
+ suite.codename = get_field('codename')
+ signingkey = get_field('signingkey')
+ if signingkey is not None:
+ suite.signingkeys = [signingkey.upper()]
+ suite.srcformats = s.query(SrcFormat).all()
+ s.add(suite)
+ s.flush()
+ except IntegrityError as e:
+ die("E: Integrity error adding suite %s (it probably already exists)" % suite_name)
+ except SQLAlchemyError as e:
+ die("E: Error adding suite %s (%s)" % (suite_name, e))
+ print "Suite %s added" % (suite_name)
+
+ if addallarches:
+ arches = []
+ q = s.query(Architecture).order_by('arch_string')
+ for arch in q.all():
+ suite.architectures.append(arch)
+ arches.append(arch.arch_string)
+
+ print "Architectures %s added to %s" % (','.join(arches), suite_name)
+
+ s.commit()
+
+
def suite(command):
args = [str(x) for x in command]
Cnf = utils.get_conf()
__suite_list(d, args)
elif mode == 'show':
__suite_show(d, args)
+ elif mode == 'add':
+ __suite_add(d, args, False)
+ elif mode == 'add-all-arches':
+ __suite_add(d, args, True)
else:
die("E: suite command unknown")
def __suite_architecture_list(d, args):
s = d.session()
- for j in s.query(Suite).order_by('suite_name').all():
- print j.suite_name + ' ' + \
- ','.join([a.architecture.arch_string for a in j.suitearchitectures])
+ for j in s.query(Suite).order_by('suite_name'):
+ architectures = j.get_architectures(skipsrc = True, skipall = True)
+ print j.suite_name + ': ' + \
+ ', '.join([a.arch_string for a in architectures])
def __suite_architecture_listarch(d, args):
die_arglen(args, 3, "E: suite-architecture list-arch requires a suite")
- a = get_suite_architectures(args[2].lower())
+ suite = get_suite(args[2].lower(), d.session())
+ if suite is None:
+ die('E: suite %s is invalid' % args[2].lower())
+ a = suite.get_architectures(skipsrc = True, skipall = True)
for j in a:
- # HACK: We should get rid of source from the arch table
- if j.arch_string != 'source':
- print j.arch_string
+ print j.arch_string
def __suite_architecture_listsuite(d, args):
die_arglen(args, 3, "E: suite-architecture list-suite requires an arch")
- for j in get_architecture_suites(args[2].lower()):
+ architecture = get_architecture(args[2].lower(), d.session())
+ if architecture is None:
+ die("E: architecture %s is invalid" % args[2].lower())
+ for j in architecture.suites:
print j.suite_name
if not dryrun:
try:
- sa = SuiteArchitecture()
- sa.arch_id = arch.arch_id
- sa.suite_id = suite.suite_id
- s.add(sa)
+ suite.architectures.append(arch)
s.commit()
- except IntegrityError, e:
+ except IntegrityError as e:
die("E: Can't add suite-architecture entry (%s, %s) - probably already exists" % (args[2].lower(), args[3].lower()))
- except SQLAlchemyError, e:
+ except SQLAlchemyError as e:
die("E: Can't add suite-architecture entry (%s, %s) - %s" % (args[2].lower(), args[3].lower(), e))
print "Added suite-architecture entry for %s, %s" % (args[2].lower(), args[3].lower())
s = d.session()
if not dryrun:
try:
- sa = get_suite_architecture(args[2].lower(), args[3].lower(), s)
- if sa is None:
- die("E: can't find suite-architecture entry for %s, %s" % (args[2].lower(), args[3].lower()))
- s.delete(sa)
+ suite_name = args[2].lower()
+ suite = get_suite(suite_name, s)
+ if suite is None:
+ die('E: no such suite %s' % suite_name)
+ arch_string = args[3].lower()
+ architecture = get_architecture(arch_string, s)
+ if architecture not in suite.architectures:
+ die("E: architecture %s not found in suite %s" % (arch_string, suite_name))
+ suite.architectures.remove(architecture)
s.commit()
- except IntegrityError, e:
+ except IntegrityError as e:
die("E: Can't remove suite-architecture entry (%s, %s) - it's probably referenced" % (args[2].lower(), args[3].lower()))
- except SQLAlchemyError, e:
+ except SQLAlchemyError as e:
die("E: Can't remove suite-architecture entry (%s, %s) - %s" % (args[2].lower(), args[3].lower(), e))
print "Removed suite-architecture entry for %s, %s" % (args[2].lower(), args[3].lower())
################################################################################
+def __version_check_list(d):
+ session = d.session()
+ for s in session.query(Suite).order_by('suite_name'):
+ __version_check_list_suite(d, s.suite_name)
+
+def __version_check_list_suite(d, suite_name):
+ vcs = get_version_checks(suite_name)
+ for vc in vcs:
+ print "%s %s %s" % (suite_name, vc.check, vc.reference.suite_name)
+
+def __version_check_add(d, suite_name, check, reference_name):
+ suite = get_suite(suite_name)
+ if not suite:
+ die("E: Could not find suite %s." % (suite_name))
+ reference = get_suite(reference_name)
+ if not reference:
+ die("E: Could not find reference suite %s." % (reference_name))
+
+ session = d.session()
+ vc = VersionCheck()
+ vc.suite = suite
+ vc.check = check
+ vc.reference = reference
+ session.add(vc)
+ session.commit()
+
+def __version_check_rm(d, suite_name, check, reference_name):
+ suite = get_suite(suite_name)
+ if not suite:
+ die("E: Could not find suite %s." % (suite_name))
+ reference = get_suite(reference_name)
+ if not reference:
+ die("E: Could not find reference suite %s." % (reference_name))
+
+ session = d.session()
+ try:
+ vc = session.query(VersionCheck).filter_by(suite=suite, check=check, reference=reference).one()
+ session.delete(vc)
+ session.commit()
+ except NoResultFound:
+ print "W: version-check not found."
+
+def version_check(command):
+ args = [str(x) for x in command]
+ Cnf = utils.get_conf()
+ d = DBConn()
+
+ die_arglen(args, 2, "E: version-check needs at least a command")
+ mode = args[1].lower()
+
+ if mode == 'list':
+ __version_check_list(d)
+ elif mode == 'list-suite':
+ if len(args) != 3:
+ die("E: version-check list-suite needs a single parameter")
+ __version_check_list_suite(d, args[2])
+ elif mode == 'add':
+ if len(args) != 5:
+ die("E: version-check add needs three parameters")
+ __version_check_add(d, args[2], args[3], args[4])
+ elif mode == 'rm':
+ if len(args) != 5:
+ die("E: version-check rm needs three parameters")
+ __version_check_rm(d, args[2], args[3], args[4])
+ else:
+ die("E: version-check command unknown")
+
+dispatch['version-check'] = version_check
+dispatch['v-c'] = version_check
+
+################################################################################
+
+def show_config(command):
+ args = [str(x) for x in command]
+ cnf = utils.get_conf()
+
+ die_arglen(args, 2, "E: config needs at least a command")
+
+ mode = args[1].lower()
+
+ if mode == 'db':
+ connstr = ""
+ if cnf.has_key("DB::Service"):
+ # Service mode
+ connstr = "postgresql://service=%s" % cnf["DB::Service"]
+ elif cnf.has_key("DB::Host"):
+ # TCP/IP
+ connstr = "postgres://%s" % cnf["DB::Host"]
+ if cnf.has_key("DB::Port") and cnf["DB::Port"] != "-1":
+ connstr += ":%s" % cnf["DB::Port"]
+ connstr += "/%s" % cnf["DB::Name"]
+ else:
+ # Unix Socket
+ connstr = "postgres:///%s" % cnf["DB::Name"]
+ if cnf["DB::Port"] and cnf["DB::Port"] != "-1":
+ connstr += "?port=%s" % cnf["DB::Port"]
+ print connstr
+ elif mode == 'db-shell':
+ e = []
+ if cnf.has_key("DB::Service"):
+ e.append('PGSERVICE')
+ print "PGSERVICE=%s" % cnf["DB::Service"]
+ if cnf.has_key("DB::Name"):
+ e.append('PGDATABASE')
+ print "PGDATABASE=%s" % cnf["DB::Name"]
+ if cnf.has_key("DB::Host"):
+ print "PGHOST=%s" % cnf["DB::Host"]
+ e.append('PGHOST')
+ if cnf.has_key("DB::Port") and cnf["DB::Port"] != "-1":
+ print "PGPORT=%s" % cnf["DB::Port"]
+ e.append('PGPORT')
+ print "export " + " ".join(e)
+ else:
+ session = DBConn().session()
+ try:
+ o = session.query(DBConfig).filter_by(name = mode).one()
+ print o.value
+ except NoResultFound:
+ print "W: option '%s' not set" % mode
+
+dispatch['config'] = show_config
+dispatch['c'] = show_config
+
+################################################################################
+
+def show_keyring(command):
+ args = [str(x) for x in command]
+ cnf = utils.get_conf()
+
+ die_arglen(args, 2, "E: keyring needs at least a command")
+
+ mode = args[1].lower()
+
+ d = DBConn()
+
+ q = d.session().query(Keyring).filter(Keyring.active == True)
+
+ if mode == 'list-all':
+ pass
+ elif mode == 'list-binary':
+ q = q.filter(Keyring.default_source_acl_id == None)
+ elif mode == 'list-source':
+ q = q.filter(Keyring.default_source_acl_id != None)
+ else:
+ die("E: keyring command unknown")
+
+ for k in q.all():
+ print k.keyring_name
+
+dispatch['keyring'] = show_keyring
+dispatch['k'] = show_keyring
+
+################################################################################
+
def main():
"""Perform administrative work on the dak database"""
global dryrun
projects / dak.git / blobdiff