# -*- coding: utf-8 -*-
#
# Copyright (C) 2005-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.
#

# PiSİ module for YALI

import os
import time

import comar
import pisi
import pisi.api
import pisi.config
import pisi.util
import pisi.context as ctx

import yali.postinstall
from yali.constants import consts

def initialize(ui, with_comar=False):

    options = pisi.config.Options()
    options.destdir = consts.target_dir
    options.yes_all = True
    # giving "comar = false" isn't enough for pisi 
    if with_comar:
        # wait for chroot_comar to initialize
        # generally we don't need this but I think this is safer
        for i in range(20):
            try:
                comar.Link(sockname=consts.comar_socket_file)
                break
            except:
                time.sleep(1)
                print "wait comar for 1 second..."

        pisi.api.init(options = options, comar = with_comar, database = True, ui = ui,
                      comar_sockname=consts.comar_socket_file, signal_handling = False)
    else:
        options.ignore_comar = True
        pisi.api.init(options = options, comar = with_comar, database = True, ui = ui,
                      signal_handling = False)

def add_repo(name, uri):
    print "add",name,uri
    pisi.api.add_repo(name, uri)

def add_cd_repo():
    cd_repo_name = consts.cd_repo_name
    cd_repo_uri = consts.cd_repo_uri

    if not ctx.repodb.has_repo(cd_repo_name):
        add_repo(cd_repo_name, cd_repo_uri)
        update_repo(cd_repo_name)

def add_remote_repo(name, uri):
    if not ctx.repodb.has_repo(name):
        add_repo(name, uri)
        update_repo(name)

def switch_to_pardus_repo():
    cd_repo_name = consts.cd_repo_name 
    pardus_repo_name = consts.pardus_repo_name
    pardus_repo_uri = consts.pardus_repo_uri

    remove_repo(cd_repo_name)
    add_repo(pardus_repo_name, pardus_repo_uri)

def update_repo(name):
    print "update repo", name
    pisi.api.update_repo(consts.cd_repo_name)

def remove_repo(name):
    print "remove", name
    pisi.api.remove_repo(name)

def finalize():
    pisi.api.finalize()

def install(pkg_name_list):
    pisi.api.install(pkg_name_list)

def install_all():
    install(get_available())

def get_available():
    l = ctx.packagedb.list_packages()

    return l

def get_available_len():
    return len(get_available())

def get_pending():
    import pisi.context as ctx

    l = ctx.installdb.list_pending()
    return l

def get_pending_len():
    return len(get_pending())
    

def configure_pending():
    print "configure pending postinstall"

    # dirty hack for COMAR to find scripts.
    os.symlink("/",
               consts.target_dir + consts.target_dir)

    pisi.api.configure_pending()

    os.unlink(consts.target_dir + consts.target_dir)


def check_package_hash(pkg_name):
    repo_path = os.path.dirname(consts.cd_repo_uri)

    pkg = ctx.packagedb.get_package(pkg_name)
    file_name = pisi.util.package_name(pkg.name,
                                       pkg.version,
                                       pkg.release,
                                       pkg.build)
    file_hash = pisi.util.sha1_file(
        os.path.join(repo_path, file_name))

    if pkg.packageHash == file_hash:
        return True

    return False