#!/usr/bin/env python

# Manipulate suite tags
# Copyright (C) 2000, 2001, 2002  James Troup <james@nocrew.org>
# $Id: heidi,v 1.15 2002-10-16 02:47:32 troup Exp $

# 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
# the Free Software Foundation; either version 2 of the License, or
# (at your option) any later version.

# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU General Public License for more details.

# You should have received a copy of the GNU General Public License
# along with this program; if not, write to the Free Software
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

#######################################################################################

# 8to6Guy: "Wow, Bob, You look rough!"
# BTAF: "Mbblpmn..."
# BTAF <.oO>: "You moron! This is what you get for staying up all night drinking vodka and salad dressing!"
# BTAF <.oO>: "This coffee I.V. drip is barely even keeping me awake! I need something with more kick! But what?"
# BTAF: "OMIGOD! I OVERDOSED ON HEROIN"
# CoWorker#n: "Give him air!!"
# CoWorker#n+1: "We need a syringe full of adrenaline!"
# CoWorker#n+2: "Stab him in the heart!"
# BTAF: "*YES!*"
# CoWorker#n+3: "Bob's been overdosing quite a bit lately..."
# CoWorker#n+4: "Third time this week."

# -- http://www.angryflower.com/8to6.gif

#######################################################################################

# Adds or removes packages from a suite.  Takes the list of files
# either from stdin or as a command line argument.  Special action
# "set", will reset the suite (!) and add all packages from scratch.

#######################################################################################

import pg, sys;
import apt_pkg;
import utils, db_access, logging;

#######################################################################################

Cnf = None;
projectB = None;
Logger = None;

################################################################################

def usage (exit_code=0):
    print """Usage: heidi [OPTIONS] [FILE]
Display or alter the contents of a suite using FILE(s), or stdin.

  -a, --add=SUITE            add to SUITE
  -l, --list=SUITE           list the contents of SUITE
  -r, --remove=SUITE         remove from SUITE
  -s, --set=SUITE            set SUITE
  -h, --help                 show this help and exit"""

    sys.exit(exit_code)

#######################################################################################

def get_id (package, version, architecture):
    if architecture == "source":
        q = projectB.query("SELECT id FROM source WHERE source = '%s' AND version = '%s'" % (package, version))
    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();
    if not ql:
        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;

#######################################################################################

def set_suite (file, suite_id):
    lines = file.readlines();

    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();
    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();
    for i in ql:
        key = " ".join(i[:2]) + " source";
        current[key] = i[2];

    # Build up a dictionary of what should be in the suite
    desired = {};
    for line in lines:
        split_line = line[:-1].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] = "";

    # 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];
            if architecture == "source":
                q = projectB.query("DELETE FROM src_associations WHERE id = %s" % (id));
            else:
                q = projectB.query("DELETE FROM bin_associations WHERE id = %s" % (id));
            Logger.log(["removed",key,id]);

    # 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;
            if architecture == "source":
                q = projectB.query("INSERT INTO src_associations (suite, source) VALUES (%s, %s)" % (suite_id, id));
            else:
                q = projectB.query("INSERT INTO bin_associations (suite, bin) VALUES (%s, %s)" % (suite_id, id));
            Logger.log(["added",key,id]);

    projectB.query("COMMIT WORK");

#######################################################################################

def process_file (file, suite, action):

    suite_id = db_access.get_suite_id(suite);

    if action == "set":
        set_suite (file, suite_id);
        return;

    lines = file.readlines();

    projectB.query("BEGIN WORK");

    for line in lines:
        split_line = line[:-1].strip().split();
        if len(split_line) != 3:
            utils.warn("'%s' does not break into 'package version architecture'." % (line[:-1]));
            continue;

        (package, version, architecture) = split_line;

        id = get_id(package, version, architecture);
        if not id:
            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();
            if not ql:
                assoication_id = None;
            else:
                assoication_id = ql[0][0];
            # Take action
            if action == "add":
                if assoication_id != None:
                    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));
            elif action == "remove":
                if assoication_id == None:
                    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));
        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();
            if not ql:
                assoication_id = None;
            else:
                assoication_id = ql[0][0];
            # Take action
            if action == "add":
                if assoication_id != None:
                    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));
            elif action == "remove":
                if assoication_id == None:
                    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));

    projectB.query("COMMIT WORK");

#######################################################################################

def get_list (suite):
    suite_id = db_access.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();
    for i in ql:
        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();
    for i in ql:
        print " ".join(i) + " source";

#######################################################################################

def main ():
    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")];

    for i in ["add", "help", "list", "remove", "set", "version" ]:
	if not Cnf.has_key("Heidi::Options::%s" % (i)):
	    Cnf["Heidi::Options::%s" % (i)] = "";

    file_list = apt_pkg.ParseCommandLine(Cnf,Arguments,sys.argv);
    Options = Cnf.SubTree("Heidi::Options")

    if Options["Help"]:
	usage();

    projectB = pg.connect(Cnf["DB::Name"], Cnf["DB::Host"],int(Cnf["DB::Port"]));

    db_access.init(Cnf, projectB);

    action = None;

    for i in ("add", "list", "remove", "set"):
        if Cnf["Heidi::Options::%s" % (i)] != "":
            suite = Cnf["Heidi::Options::%s" % (i)];
            if not Cnf.has_key("Suite::%s" % (suite)):
                utils.fubar("Unknown suite '%s'." %(suite));
            else:
                if action != None:
                    utils.fubar("Can only perform one action at a time.");
                action = i;

    # Need an action...
    if action == None:
        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 == "list":
        get_list(suite);
    else:
        Logger = logging.Logger(Cnf, "heidi");
        if file_list:
            for file in file_list:
                process_file(utils.open_file(file), suite, action);
        else:
            process_file(sys.stdin, suite, action);
        Logger.close();

#######################################################################################

if __name__ == '__main__':
    main()