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

"""

    rhodecode.tests.test_scm_operations

    ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

    Test suite for making push/pull operations.

    Run using::

     RC_WHOOSH_TEST_DISABLE=1 RC_NO_TMP_PATH=1 nosetests rhodecode/tests/scripts/test_vcs_operations.py

    :created_on: Dec 30, 2010

    :author: marcink

    :copyright: (C) 2010-2012 Marcin Kuzminski <marcin@python-works.com>

    :license: GPLv3, see COPYING for more details.

"""

# 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 3 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, see <http://www.gnu.org/licenses/>.

import os

import tempfile

import unittest

from os.path import join as jn

from os.path import dirname as dn

from tempfile import _RandomNameSequence

from subprocess import Popen, PIPE

from rhodecode.tests import *

from rhodecode.model.db import User, Repository, UserLog

from rhodecode.model.meta import Session

from rhodecode.model.repo import RepoModel

DEBUG = True

HOST = '127.0.0.1:5000'  # test host

class Command(object):

    def __init__(self, cwd):

        self.cwd = cwd

    def execute(self, cmd, *args):

        """

        Runs command on the system with given ``args``.

        """

        command = cmd + ' ' + ' '.join(args)

        if DEBUG:

            print '*** CMD %s ***' % command

        p = Popen(command, shell=True, stdout=PIPE, stderr=PIPE, cwd=self.cwd)

        stdout, stderr = p.communicate()

        if DEBUG:

            print stdout, stderr

        return stdout, stderr

def _get_tmp_dir():

    return tempfile.mkdtemp(prefix='rc_integration_test')

def _construct_url(repo, dest=None, **kwargs):

    if dest is None:

        #make temp clone

        dest = _get_tmp_dir()

    params = {

        'user': TEST_USER_ADMIN_LOGIN,

        'passwd': TEST_USER_ADMIN_PASS,

        'host': HOST,

        'cloned_repo': repo,

        'dest': dest

    }

    params.update(**kwargs)

    if params['user'] and params['passwd']:

        _url = 'http://%(user)s:%(passwd)s@%(host)s/%(cloned_repo)s %(dest)s' % params

    else:

        _url = 'http://(host)s/%(cloned_repo)s %(dest)s' % params

    return _url

#        assert msg in stderr

    def test_push_unlocks_repository_hg(self):

        # enable locking

        r = Repository.get_by_repo_name(HG_REPO)

        r.enable_locking = True

        Session().add(r)

        Session().commit()

        #clone some temp

        DEST = _get_tmp_dir()

        clone_url = _construct_url(HG_REPO, dest=DEST)

        stdout, stderr = Command('/tmp').execute('hg clone', clone_url)

        #check for lock repo after clone

        r = Repository.get_by_repo_name(HG_REPO)

        assert r.locked[0] == User.get_by_username(TEST_USER_ADMIN_LOGIN).user_id

        #push is ok and repo is now unlocked

        stdout, stderr = _add_files_and_push('hg', DEST)

        assert ('remote: Released lock on repo `%s`' % HG_REPO) in stdout

        #we need to cleanup the Session Here !

        Session.remove()

        r = Repository.get_by_repo_name(HG_REPO)

        assert r.locked == [None, None]

#TODO: fix me ! somehow during tests hooks don't get called on GIT

#    def test_push_unlocks_repository_git(self):

#        # enable locking

#        r = Repository.get_by_repo_name(GIT_REPO)

#        r.enable_locking = True

#        Session().add(r)

#        Session().commit()

#        #clone some temp

#        DEST = _get_tmp_dir()

#        clone_url = _construct_url(GIT_REPO, dest=DEST)

#        stdout, stderr = Command('/tmp').execute('git clone', clone_url)

#

#        #check for lock repo after clone

#        r = Repository.get_by_repo_name(GIT_REPO)

#        assert r.locked[0] == User.get_by_username(TEST_USER_ADMIN_LOGIN).user_id

#

#        #push is ok and repo is now unlocked

#        stdout, stderr = _add_files_and_push('git', DEST)

#        #assert ('remote: Released lock on repo `%s`' % GIT_REPO) in stdout

#        #we need to cleanup the Session Here !

#        Session.remove()

#        r = Repository.get_by_repo_name(GIT_REPO)

#        assert r.locked == [None, None]