#!/usr/bin/python
# -*- coding: utf-8 -*-
#
# Copyright (C) 2006,2007 TUBITAK/UEKAE
# 
# 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.
#
# Please read the COPYING file.
#

""" Standart Python Modules """
import os

import pisi.api
import pisi.fetcher
from pisi.delta import create_delta_package

""" BuildFarm Modules """
import config
import logger

""" Gettext Support """
import gettext
__trans = gettext.translation("buildfarm", fallback = True)
_  =  __trans.ugettext

class PisiApi:

    def __init__(self, outputDir = config.workDir):
        import pisi.config
        self.options = pisi.config.Options()
        self.options.output_dir = outputDir
        self.options.yes_all = True
        self.options.ignore_file_conflicts = True

        self.__newBinaryPackages = []
        self.__oldBinaryPackages = []

    def init(self, stdout, stderr):
        logger.info(_("Initialising PiSi API..."))
        pisi.api.init(options = self.options, stdout = stdout, stderr = stderr)

    def finalize(self):
        logger.info(_("Finalising PiSi API"))
        pisi.api.finalize()

    def build(self, pspec):
        pspec = os.path.join(config.localPspecRepo, pspec)
        if not os.path.exists(pspec):
            logger.error(_("'%s' does not exists!") % (pspec))
            raise _("'%s' does not exists!") % pspec

        logger.info(_("BUILD called for %s") % (pspec)) 

        __newBinaryPackages, __oldBinaryPackages = pisi.api.build(pspec)
        logger.info(_("Created package(s): %s") % (__newBinaryPackages)) 
        self.__newBinaryPackages += __newBinaryPackages
        self.__oldBinaryPackages += __oldBinaryPackages

        # Normalize paths to file names

        return (set(map(lambda x: os.path.basename(x), self.__newBinaryPackages)), \
                set(map(lambda x: os.path.basename(x), self.__oldBinaryPackages)))

    def delta(self, oldBinaryPackages, newBinaryPackages):

        # Sort the lists
        oldBinaryPackages = sorted(oldBinaryPackages)
        newBinaryPackages = sorted(newBinaryPackages)

        delta_packages = []

        for p in zip(oldBinaryPackages, newBinaryPackages):
            # deltaPath = '/var/pisi/b-1-2.delta.pisi'
            deltaPath = create_delta_package(os.path.join(config.binaryPath, p[0]), \
                                             os.path.join(config.workDir, p[1]))
            delta_packages.append(deltaPath)

        logger.info(_("Created delta package(s): %s") % delta_packages)
        return delta_packages

    def install(self, p):
        a = []
        a.append(p)
        pisi.api.install(a)