#!/usr/bin/env python

#-*- coding:utf-8 -*-

#

# Copyright © 2009 Germán Póo-Caamaño <gpoo@gnome.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

# 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 Library 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

"""

    Handle the git log output and dump the changesets into

    a CSV file.

"""

import os

import sys

import subprocess

from dataloader import load_modules_from_csv, cmp_version

from settings import settings

import csv

import dbdriver

def gitlog2csv(src, dst_prefix, force=False):

    config = settings['config']

    gitdm = os.path.join(settings['gitdm'])

    options = '-c %s -o /dev/null -p %s -s -u' % (config, dst_prefix)

    command = '%s %s' % (gitdm, options)

    if not force and os.path.isfile('%s-changesets.csv' % dst_prefix):

        return None

    if os.path.exists(src):

        proc_cat = subprocess.Popen(['cat', src], stdout=subprocess.PIPE)

        proc_dm = subprocess.Popen(command, shell=True, stdin=proc_cat.stdout,

                                stdout=subprocess.PIPE)

        output = proc_dm.communicate()[0]

        return output

    return None

def git2csv(releases, modules, input_path, ouput_path, force=False):

    if not os.path.exists(ouput_path):

        os.makedirs(ouput_path)

    for (repo, pkg) in modules.iteritems():

        print >> sys.stderr, '%20s:' % repo

        log_path = os.path.join(input_path, repo)

        versions = sorted(pkg['tags'].keys(), cmp_version, reverse=True)

        for i in range(0, len(versions)):

            cur_version = versions[i]

            log_name = '%s-%s.log' % (repo, cur_version)

            csv_name = '%s-%s' % (repo, cur_version)

            src = os.path.join(log_path, log_name)

            dst = os.path.join(ouput_path, csv_name)

            result = gitlog2csv(src, dst, force)

            if result:

                print

def load_db(releases, modules, db_name, db_user,

            db_password='', db_host=None, csv_path=''):

    # If there is not data directory, there is nothing to process

    if not os.path.exists(csv_path):

        return

    #db = dbdriver.sqlitedb(db_name)

    db = dbdriver.psqldb(db_name, db_user, db_password, db_host)

    db.drop_tables()

    db.create_tables()

    for (repo, pkg) in modules.iteritems():

        versions = sorted(pkg['tags'].keys(), cmp_version, reverse=True)

        status = ''

        for i in range(0, len(versions)):

            version = versions[i]

            changeset = '%s-%s-changesets.csv' % (repo, version)

            changeset = os.path.join(csv_path, changeset)

            filetype = '%s-%s-filetypes.csv' % (repo, version)

            filetype = os.path.join(csv_path, filetype)

            print >> sys.stderr, '%-20s:%s→%-6s\r' % (repo, status, version),

            if os.path.isfile(changeset):

                reader = csv.reader(open(changeset))

                db.changeset2db(reader, repo, version)

                status += (' %s' % version)

            if os.path.isfile(filetype):

                reader = csv.reader(open(filetype))

                db.filetype2db(reader, repo, version)

        print >> sys.stderr, '%-20s:%s %-6s\n' % (repo, status, 'done'),

if __name__ == '__main__':

    db_name = settings['db_name']

    db_user = settings['db_user']

    csv_path = os.path.join(settings['csvoutput'])

    log_path = settings['logoutput']   # Now it is the input

    releases, modules = load_modules_from_csv(settings['csvfile'])

    git2csv(releases, modules, log_path, csv_path, force=False)

    load_db(releases, modules, db_name, db_user, csv_path)