| Index: tests/fake_repos.py
|
| diff --git a/tests/fake_repos.py b/tests/fake_repos.py
|
| deleted file mode 100755
|
| index 2828cba3f410c3552943bed49fe33be7ed9140fc..0000000000000000000000000000000000000000
|
| --- a/tests/fake_repos.py
|
| +++ /dev/null
|
| @@ -1,752 +0,0 @@
|
| -#!/usr/bin/env python
|
| -# Copyright (c) 2011 The Chromium Authors. All rights reserved.
|
| -# Use of this source code is governed by a BSD-style license that can be
|
| -# found in the LICENSE file.
|
| -
|
| -"""Generate fake repositories for testing."""
|
| -
|
| -import atexit
|
| -import datetime
|
| -import errno
|
| -import logging
|
| -import os
|
| -import pprint
|
| -import re
|
| -import socket
|
| -import sys
|
| -import tempfile
|
| -import time
|
| -
|
| -# trial_dir must be first for non-system libraries.
|
| -from tests import trial_dir
|
| -import gclient_utils
|
| -import scm
|
| -import subprocess2
|
| -
|
| -
|
| -def write(path, content):
|
| - f = open(path, 'wb')
|
| - f.write(content)
|
| - f.close()
|
| -
|
| -
|
| -join = os.path.join
|
| -
|
| -
|
| -def read_tree(tree_root):
|
| - """Returns a dict of all the files in a tree. Defaults to self.root_dir."""
|
| - tree = {}
|
| - for root, dirs, files in os.walk(tree_root):
|
| - for d in filter(lambda x: x.startswith('.'), dirs):
|
| - dirs.remove(d)
|
| - for f in [join(root, f) for f in files if not f.startswith('.')]:
|
| - filepath = f[len(tree_root) + 1:].replace(os.sep, '/')
|
| - assert len(filepath), f
|
| - tree[filepath] = open(join(root, f), 'rU').read()
|
| - return tree
|
| -
|
| -
|
| -def dict_diff(dict1, dict2):
|
| - diff = {}
|
| - for k, v in dict1.iteritems():
|
| - if k not in dict2:
|
| - diff[k] = v
|
| - elif v != dict2[k]:
|
| - diff[k] = (v, dict2[k])
|
| - for k, v in dict2.iteritems():
|
| - if k not in dict1:
|
| - diff[k] = v
|
| - return diff
|
| -
|
| -
|
| -def commit_svn(repo, usr, pwd):
|
| - """Commits the changes and returns the new revision number."""
|
| - to_add = []
|
| - to_remove = []
|
| - for status, filepath in scm.SVN.CaptureStatus(repo):
|
| - if status[0] == '?':
|
| - to_add.append(filepath)
|
| - elif status[0] == '!':
|
| - to_remove.append(filepath)
|
| - if to_add:
|
| - subprocess2.check_output(
|
| - ['svn', 'add', '--no-auto-props', '-q'] + to_add, cwd=repo)
|
| - if to_remove:
|
| - subprocess2.check_output(['svn', 'remove', '-q'] + to_remove, cwd=repo)
|
| -
|
| - out = subprocess2.check_output(
|
| - ['svn', 'commit', repo, '-m', 'foo', '--non-interactive',
|
| - '--no-auth-cache',
|
| - '--username', usr, '--password', pwd],
|
| - cwd=repo)
|
| - match = re.search(r'(\d+)', out)
|
| - if not match:
|
| - raise Exception('Commit failed', out)
|
| - rev = match.group(1)
|
| - status = subprocess2.check_output(['svn', 'status'], cwd=repo)
|
| - assert len(status) == 0, status
|
| - logging.debug('At revision %s' % rev)
|
| - return rev
|
| -
|
| -
|
| -def commit_git(repo):
|
| - """Commits the changes and returns the new hash."""
|
| - subprocess2.check_call(['git', 'add', '-A', '-f'], cwd=repo)
|
| - subprocess2.check_call(['git', 'commit', '-q', '--message', 'foo'], cwd=repo)
|
| - rev = subprocess2.check_output(
|
| - ['git', 'show-ref', '--head', 'HEAD'], cwd=repo).split(' ', 1)[0]
|
| - logging.debug('At revision %s' % rev)
|
| - return rev
|
| -
|
| -
|
| -def test_port(host, port):
|
| - s = socket.socket()
|
| - try:
|
| - return s.connect_ex((host, port)) == 0
|
| - finally:
|
| - s.close()
|
| -
|
| -
|
| -def find_free_port(host, base_port):
|
| - """Finds a listening port free to listen to."""
|
| - while base_port < (2<<16):
|
| - if not test_port(host, base_port):
|
| - return base_port
|
| - base_port += 1
|
| - assert False, 'Having issues finding an available port'
|
| -
|
| -
|
| -def wait_for_port_to_bind(host, port, process):
|
| - sock = socket.socket()
|
| -
|
| - if sys.platform == 'darwin':
|
| - # On Mac SnowLeopard, if we attempt to connect to the socket
|
| - # immediately, it fails with EINVAL and never gets a chance to
|
| - # connect (putting us into a hard spin and then failing).
|
| - # Linux doesn't need this.
|
| - time.sleep(0.1)
|
| -
|
| - try:
|
| - start = datetime.datetime.utcnow()
|
| - maxdelay = datetime.timedelta(seconds=30)
|
| - while (datetime.datetime.utcnow() - start) < maxdelay:
|
| - try:
|
| - sock.connect((host, port))
|
| - logging.debug('%d is now bound' % port)
|
| - return
|
| - except (socket.error, EnvironmentError):
|
| - pass
|
| - logging.debug('%d is still not bound' % port)
|
| - finally:
|
| - sock.close()
|
| - # The process failed to bind. Kill it and dump its ouput.
|
| - process.kill()
|
| - logging.error('%s' % process.communicate()[0])
|
| - assert False, '%d is still not bound' % port
|
| -
|
| -
|
| -def wait_for_port_to_free(host, port):
|
| - start = datetime.datetime.utcnow()
|
| - maxdelay = datetime.timedelta(seconds=30)
|
| - while (datetime.datetime.utcnow() - start) < maxdelay:
|
| - try:
|
| - sock = socket.socket()
|
| - sock.connect((host, port))
|
| - logging.debug('%d was bound, waiting to free' % port)
|
| - except (socket.error, EnvironmentError):
|
| - logging.debug('%d now free' % port)
|
| - return
|
| - finally:
|
| - sock.close()
|
| - assert False, '%d is still bound' % port
|
| -
|
| -
|
| -_FAKE_LOADED = False
|
| -
|
| -class FakeReposBase(object):
|
| - """Generate both svn and git repositories to test gclient functionality.
|
| -
|
| - Many DEPS functionalities need to be tested: Var, File, From, deps_os, hooks,
|
| - use_relative_paths.
|
| -
|
| - And types of dependencies: Relative urls, Full urls, both svn and git.
|
| -
|
| - populateSvn() and populateGit() need to be implemented by the subclass.
|
| - """
|
| - # Hostname
|
| - NB_GIT_REPOS = 1
|
| - USERS = [
|
| - ('user1@example.com', 'foo'),
|
| - ('user2@example.com', 'bar'),
|
| - ]
|
| -
|
| - def __init__(self, host=None):
|
| - global _FAKE_LOADED
|
| - if _FAKE_LOADED:
|
| - raise Exception('You can only start one FakeRepos at a time.')
|
| - _FAKE_LOADED = True
|
| -
|
| - self.trial = trial_dir.TrialDir('repos')
|
| - self.host = host or '127.0.0.1'
|
| - # Format is [ None, tree, tree, ...]
|
| - # i.e. revisions are 1-based.
|
| - self.svn_revs = [None]
|
| - # Format is { repo: [ None, (hash, tree), (hash, tree), ... ], ... }
|
| - # so reference looks like self.git_hashes[repo][rev][0] for hash and
|
| - # self.git_hashes[repo][rev][1] for it's tree snapshot.
|
| - # For consistency with self.svn_revs, it is 1-based too.
|
| - self.git_hashes = {}
|
| - self.svnserve = None
|
| - self.gitdaemon = None
|
| - self.git_pid_file = None
|
| - self.git_root = None
|
| - self.svn_checkout = None
|
| - self.svn_repo = None
|
| - self.git_dirty = False
|
| - self.svn_dirty = False
|
| - self.svn_port = None
|
| - self.git_port = None
|
| - self.svn_base = None
|
| - self.git_base = None
|
| -
|
| - @property
|
| - def root_dir(self):
|
| - return self.trial.root_dir
|
| -
|
| - def set_up(self):
|
| - """All late initialization comes here."""
|
| - self.cleanup_dirt()
|
| - if not self.root_dir:
|
| - try:
|
| - # self.root_dir is not set before this call.
|
| - self.trial.set_up()
|
| - self.git_root = join(self.root_dir, 'git')
|
| - self.svn_checkout = join(self.root_dir, 'svn_checkout')
|
| - self.svn_repo = join(self.root_dir, 'svn')
|
| - finally:
|
| - # Registers cleanup.
|
| - atexit.register(self.tear_down)
|
| -
|
| - def cleanup_dirt(self):
|
| - """For each dirty repository, destroy it."""
|
| - if self.svn_dirty:
|
| - if not self.tear_down_svn():
|
| - logging.error('Using both leaking checkout and svn dirty checkout')
|
| - if self.git_dirty:
|
| - if not self.tear_down_git():
|
| - logging.error('Using both leaking checkout and git dirty checkout')
|
| -
|
| - def tear_down(self):
|
| - """Kills the servers and delete the directories."""
|
| - self.tear_down_svn()
|
| - self.tear_down_git()
|
| - # This deletes the directories.
|
| - self.trial.tear_down()
|
| - self.trial = None
|
| -
|
| - def tear_down_svn(self):
|
| - if self.svnserve:
|
| - logging.debug('Killing svnserve pid %s' % self.svnserve.pid)
|
| - try:
|
| - self.svnserve.kill()
|
| - except OSError, e:
|
| - if e.errno != errno.ESRCH: # no such process
|
| - raise
|
| - wait_for_port_to_free(self.host, self.svn_port)
|
| - self.svnserve = None
|
| - self.svn_port = None
|
| - self.svn_base = None
|
| - if not self.trial.SHOULD_LEAK:
|
| - logging.debug('Removing %s' % self.svn_repo)
|
| - gclient_utils.rmtree(self.svn_repo)
|
| - logging.debug('Removing %s' % self.svn_checkout)
|
| - gclient_utils.rmtree(self.svn_checkout)
|
| - else:
|
| - return False
|
| - return True
|
| -
|
| - def tear_down_git(self):
|
| - if self.gitdaemon:
|
| - logging.debug('Killing git-daemon pid %s' % self.gitdaemon.pid)
|
| - self.gitdaemon.kill()
|
| - self.gitdaemon = None
|
| - if self.git_pid_file:
|
| - pid = int(self.git_pid_file.read())
|
| - self.git_pid_file.close()
|
| - logging.debug('Killing git daemon pid %s' % pid)
|
| - subprocess2.kill_pid(pid)
|
| - self.git_pid_file = None
|
| - wait_for_port_to_free(self.host, self.git_port)
|
| - self.git_port = None
|
| - self.git_base = None
|
| - if not self.trial.SHOULD_LEAK:
|
| - logging.debug('Removing %s' % self.git_root)
|
| - gclient_utils.rmtree(self.git_root)
|
| - else:
|
| - return False
|
| - return True
|
| -
|
| - @staticmethod
|
| - def _genTree(root, tree_dict):
|
| - """For a dictionary of file contents, generate a filesystem."""
|
| - if not os.path.isdir(root):
|
| - os.makedirs(root)
|
| - for (k, v) in tree_dict.iteritems():
|
| - k_os = k.replace('/', os.sep)
|
| - k_arr = k_os.split(os.sep)
|
| - if len(k_arr) > 1:
|
| - p = os.sep.join([root] + k_arr[:-1])
|
| - if not os.path.isdir(p):
|
| - os.makedirs(p)
|
| - if v is None:
|
| - os.remove(join(root, k))
|
| - else:
|
| - write(join(root, k), v)
|
| -
|
| - def set_up_svn(self):
|
| - """Creates subversion repositories and start the servers."""
|
| - self.set_up()
|
| - if self.svnserve:
|
| - return True
|
| - try:
|
| - subprocess2.check_call(['svnadmin', 'create', self.svn_repo])
|
| - except (OSError, subprocess2.CalledProcessError):
|
| - return False
|
| - write(join(self.svn_repo, 'conf', 'svnserve.conf'),
|
| - '[general]\n'
|
| - 'anon-access = read\n'
|
| - 'auth-access = write\n'
|
| - 'password-db = passwd\n')
|
| - text = '[users]\n'
|
| - text += ''.join('%s = %s\n' % (usr, pwd) for usr, pwd in self.USERS)
|
| - write(join(self.svn_repo, 'conf', 'passwd'), text)
|
| -
|
| - # Mac 10.6 ships with a buggy subversion build and we need this line
|
| - # to work around the bug.
|
| - write(join(self.svn_repo, 'db', 'fsfs.conf'),
|
| - '[rep-sharing]\n'
|
| - 'enable-rep-sharing = false\n')
|
| -
|
| - # Start the daemon.
|
| - self.svn_port = find_free_port(self.host, 10000)
|
| - logging.debug('Using port %d' % self.svn_port)
|
| - cmd = ['svnserve', '-d', '--foreground', '-r', self.root_dir,
|
| - '--listen-port=%d' % self.svn_port]
|
| - if self.host == '127.0.0.1':
|
| - cmd.append('--listen-host=' + self.host)
|
| - self.check_port_is_free(self.svn_port)
|
| - self.svnserve = subprocess2.Popen(
|
| - cmd,
|
| - cwd=self.svn_repo,
|
| - stdout=subprocess2.PIPE,
|
| - stderr=subprocess2.PIPE)
|
| - wait_for_port_to_bind(self.host, self.svn_port, self.svnserve)
|
| - self.svn_base = 'svn://%s:%d/svn/' % (self.host, self.svn_port)
|
| - self.populateSvn()
|
| - self.svn_dirty = False
|
| - return True
|
| -
|
| - def set_up_git(self):
|
| - """Creates git repositories and start the servers."""
|
| - self.set_up()
|
| - if self.gitdaemon:
|
| - return True
|
| - assert self.git_pid_file == None
|
| - try:
|
| - subprocess2.check_output(['git', '--version'])
|
| - except (OSError, subprocess2.CalledProcessError):
|
| - return False
|
| - for repo in ['repo_%d' % r for r in range(1, self.NB_GIT_REPOS + 1)]:
|
| - subprocess2.check_call(['git', 'init', '-q', join(self.git_root, repo)])
|
| - self.git_hashes[repo] = [None]
|
| - self.git_port = find_free_port(self.host, 20000)
|
| - self.git_base = 'git://%s:%d/git/' % (self.host, self.git_port)
|
| - # Start the daemon.
|
| - self.git_pid_file = tempfile.NamedTemporaryFile()
|
| - cmd = ['git', 'daemon',
|
| - '--export-all',
|
| - '--reuseaddr',
|
| - '--base-path=' + self.root_dir,
|
| - '--pid-file=' + self.git_pid_file.name,
|
| - '--port=%d' % self.git_port]
|
| - if self.host == '127.0.0.1':
|
| - cmd.append('--listen=' + self.host)
|
| - self.check_port_is_free(self.git_port)
|
| - self.gitdaemon = subprocess2.Popen(
|
| - cmd,
|
| - cwd=self.root_dir,
|
| - stdout=subprocess2.PIPE,
|
| - stderr=subprocess2.PIPE)
|
| - wait_for_port_to_bind(self.host, self.git_port, self.gitdaemon)
|
| - self.populateGit()
|
| - self.git_dirty = False
|
| - return True
|
| -
|
| - def _commit_svn(self, tree):
|
| - self._genTree(self.svn_checkout, tree)
|
| - commit_svn(self.svn_checkout, self.USERS[0][0], self.USERS[0][1])
|
| - if self.svn_revs and self.svn_revs[-1]:
|
| - new_tree = self.svn_revs[-1].copy()
|
| - new_tree.update(tree)
|
| - else:
|
| - new_tree = tree.copy()
|
| - self.svn_revs.append(new_tree)
|
| -
|
| - def _commit_git(self, repo, tree):
|
| - repo_root = join(self.git_root, repo)
|
| - self._genTree(repo_root, tree)
|
| - commit_hash = commit_git(repo_root)
|
| - if self.git_hashes[repo][-1]:
|
| - new_tree = self.git_hashes[repo][-1][1].copy()
|
| - new_tree.update(tree)
|
| - else:
|
| - new_tree = tree.copy()
|
| - self.git_hashes[repo].append((commit_hash, new_tree))
|
| -
|
| - def check_port_is_free(self, port):
|
| - sock = socket.socket()
|
| - try:
|
| - sock.connect((self.host, port))
|
| - # It worked, throw.
|
| - assert False, '%d shouldn\'t be bound' % port
|
| - except (socket.error, EnvironmentError):
|
| - pass
|
| - finally:
|
| - sock.close()
|
| -
|
| - def populateSvn(self):
|
| - raise NotImplementedError()
|
| -
|
| - def populateGit(self):
|
| - raise NotImplementedError()
|
| -
|
| -
|
| -class FakeRepos(FakeReposBase):
|
| - """Implements populateSvn() and populateGit()."""
|
| - NB_GIT_REPOS = 4
|
| -
|
| - def populateSvn(self):
|
| - """Creates a few revisions of changes including DEPS files."""
|
| - # Repos
|
| - subprocess2.check_call(
|
| - ['svn', 'checkout', self.svn_base, self.svn_checkout,
|
| - '-q', '--non-interactive', '--no-auth-cache',
|
| - '--username', self.USERS[0][0], '--password', self.USERS[0][1]])
|
| - assert os.path.isdir(join(self.svn_checkout, '.svn'))
|
| - def file_system(rev, DEPS, DEPS_ALT=None):
|
| - fs = {
|
| - 'origin': 'svn@%(rev)d\n',
|
| - 'trunk/origin': 'svn/trunk@%(rev)d\n',
|
| - 'trunk/src/origin': 'svn/trunk/src@%(rev)d\n',
|
| - 'trunk/src/third_party/origin': 'svn/trunk/src/third_party@%(rev)d\n',
|
| - 'trunk/other/origin': 'src/trunk/other@%(rev)d\n',
|
| - 'trunk/third_party/origin': 'svn/trunk/third_party@%(rev)d\n',
|
| - 'trunk/third_party/foo/origin': 'svn/trunk/third_party/foo@%(rev)d\n',
|
| - 'trunk/third_party/prout/origin': 'svn/trunk/third_party/foo@%(rev)d\n',
|
| - }
|
| - for k in fs.iterkeys():
|
| - fs[k] = fs[k] % { 'rev': rev }
|
| - fs['trunk/src/DEPS'] = DEPS
|
| - if DEPS_ALT:
|
| - fs['trunk/src/DEPS.alt'] = DEPS_ALT
|
| - return fs
|
| -
|
| - # Testing:
|
| - # - dependency disapear
|
| - # - dependency renamed
|
| - # - versioned and unversioned reference
|
| - # - relative and full reference
|
| - # - deps_os
|
| - # - var
|
| - # - hooks
|
| - # - From
|
| - # - File
|
| - # TODO(maruel):
|
| - # - $matching_files
|
| - # - use_relative_paths
|
| - DEPS = """
|
| -vars = {
|
| - 'DummyVariable': 'third_party',
|
| -}
|
| -deps = {
|
| - 'src/other': '%(svn_base)strunk/other@1',
|
| - 'src/third_party/fpp': '/trunk/' + Var('DummyVariable') + '/foo',
|
| -}
|
| -deps_os = {
|
| - 'mac': {
|
| - 'src/third_party/prout': '/trunk/third_party/prout',
|
| - },
|
| -}""" % { 'svn_base': self.svn_base }
|
| -
|
| - DEPS_ALT = """
|
| -deps = {
|
| - 'src/other2': '%(svn_base)strunk/other@2'
|
| -}
|
| -""" % { 'svn_base': self.svn_base }
|
| -
|
| - fs = file_system(1, DEPS, DEPS_ALT)
|
| - self._commit_svn(fs)
|
| -
|
| - fs = file_system(2, """
|
| -deps = {
|
| - 'src/other': '%(svn_base)strunk/other',
|
| - # Load another DEPS and load a dependency from it. That's an example of
|
| - # WebKit's chromium checkout flow. Verify it works out of order.
|
| - 'src/third_party/foo': From('src/file/other', 'foo/bar'),
|
| - 'src/file/other': File('%(svn_base)strunk/other/DEPS'),
|
| -}
|
| -# I think this is wrong to have the hooks run from the base of the gclient
|
| -# checkout. It's maybe a bit too late to change that behavior.
|
| -hooks = [
|
| - {
|
| - 'pattern': '.',
|
| - 'action': ['python', '-c',
|
| - 'open(\\'src/svn_hooked1\\', \\'w\\').write(\\'svn_hooked1\\')'],
|
| - },
|
| - {
|
| - # Should not be run.
|
| - 'pattern': 'nonexistent',
|
| - 'action': ['python', '-c',
|
| - 'open(\\'src/svn_hooked2\\', \\'w\\').write(\\'svn_hooked2\\')'],
|
| - },
|
| -]
|
| -""" % { 'svn_base': self.svn_base })
|
| - fs['trunk/other/DEPS'] = """
|
| -deps = {
|
| - 'foo/bar': '/trunk/third_party/foo@1',
|
| - # Only the requested deps should be processed.
|
| - 'invalid': '/does_not_exist',
|
| -}
|
| -"""
|
| - # WebKit abuses this.
|
| - fs['trunk/webkit/.gclient'] = """
|
| -solutions = [
|
| - {
|
| - 'name': './',
|
| - 'url': None,
|
| - },
|
| -]
|
| -"""
|
| - fs['trunk/webkit/DEPS'] = """
|
| -deps = {
|
| - 'foo/bar': '%(svn_base)strunk/third_party/foo@1'
|
| -}
|
| -
|
| -hooks = [
|
| - {
|
| - 'pattern': '.*',
|
| - 'action': ['echo', 'foo'],
|
| - },
|
| -]
|
| -""" % { 'svn_base': self.svn_base }
|
| - self._commit_svn(fs)
|
| -
|
| - def populateGit(self):
|
| - # Testing:
|
| - # - dependency disapear
|
| - # - dependency renamed
|
| - # - versioned and unversioned reference
|
| - # - relative and full reference
|
| - # - deps_os
|
| - # - var
|
| - # - hooks
|
| - # - From
|
| - # TODO(maruel):
|
| - # - File: File is hard to test here because it's SVN-only. It's
|
| - # implementation should probably be replaced to use urllib instead.
|
| - # - $matching_files
|
| - # - use_relative_paths
|
| - self._commit_git('repo_3', {
|
| - 'origin': 'git/repo_3@1\n',
|
| - })
|
| -
|
| - self._commit_git('repo_3', {
|
| - 'origin': 'git/repo_3@2\n',
|
| - })
|
| -
|
| - self._commit_git('repo_1', {
|
| - 'DEPS': """
|
| -vars = {
|
| - 'DummyVariable': 'repo',
|
| -}
|
| -deps = {
|
| - 'src/repo2': '%(git_base)srepo_2',
|
| - 'src/repo2/repo3': '/' + Var('DummyVariable') + '_3@%(hash3)s',
|
| -}
|
| -deps_os = {
|
| - 'mac': {
|
| - 'src/repo4': '/repo_4',
|
| - },
|
| -}""" % {
|
| - 'git_base': self.git_base,
|
| - # See self.__init__() for the format. Grab's the hash of the first
|
| - # commit in repo_2. Only keep the first 7 character because of:
|
| - # TODO(maruel): http://crosbug.com/3591 We need to strip the hash..
|
| - # duh.
|
| - 'hash3': self.git_hashes['repo_3'][1][0][:7]
|
| - },
|
| - 'origin': 'git/repo_1@1\n',
|
| - })
|
| -
|
| - self._commit_git('repo_2', {
|
| - 'origin': 'git/repo_2@1\n',
|
| - 'DEPS': """
|
| -deps = {
|
| - 'foo/bar': '/repo_3',
|
| -}
|
| -""",
|
| - })
|
| -
|
| - self._commit_git('repo_2', {
|
| - 'origin': 'git/repo_2@2\n',
|
| - })
|
| -
|
| - self._commit_git('repo_4', {
|
| - 'origin': 'git/repo_4@1\n',
|
| - })
|
| -
|
| - self._commit_git('repo_4', {
|
| - 'origin': 'git/repo_4@2\n',
|
| - })
|
| -
|
| - self._commit_git('repo_1', {
|
| - 'DEPS': """
|
| -deps = {
|
| - 'src/repo2': '%(git_base)srepo_2@%(hash)s',
|
| - #'src/repo2/repo_renamed': '/repo_3',
|
| - 'src/repo2/repo_renamed': From('src/repo2', 'foo/bar'),
|
| -}
|
| -# I think this is wrong to have the hooks run from the base of the gclient
|
| -# checkout. It's maybe a bit too late to change that behavior.
|
| -hooks = [
|
| - {
|
| - 'pattern': '.',
|
| - 'action': ['python', '-c',
|
| - 'open(\\'src/git_hooked1\\', \\'w\\').write(\\'git_hooked1\\')'],
|
| - },
|
| - {
|
| - # Should not be run.
|
| - 'pattern': 'nonexistent',
|
| - 'action': ['python', '-c',
|
| - 'open(\\'src/git_hooked2\\', \\'w\\').write(\\'git_hooked2\\')'],
|
| - },
|
| -]
|
| -""" % {
|
| - 'git_base': self.git_base,
|
| - # See self.__init__() for the format. Grab's the hash of the first
|
| - # commit in repo_2. Only keep the first 7 character because of:
|
| - # TODO(maruel): http://crosbug.com/3591 We need to strip the hash.. duh.
|
| - 'hash': self.git_hashes['repo_2'][1][0][:7]
|
| - },
|
| - 'origin': 'git/repo_1@2\n',
|
| - })
|
| -
|
| -
|
| -class FakeReposTestBase(trial_dir.TestCase):
|
| - """This is vaguely inspired by twisted."""
|
| - # static FakeRepos instance. Lazy loaded.
|
| - FAKE_REPOS = None
|
| - # Override if necessary.
|
| - FAKE_REPOS_CLASS = FakeRepos
|
| -
|
| - def setUp(self):
|
| - super(FakeReposTestBase, self).setUp()
|
| - if not FakeReposTestBase.FAKE_REPOS:
|
| - # Lazy create the global instance.
|
| - FakeReposTestBase.FAKE_REPOS = self.FAKE_REPOS_CLASS()
|
| - # No need to call self.FAKE_REPOS.setUp(), it will be called by the child
|
| - # class.
|
| - # Do not define tearDown(), since super's version does the right thing and
|
| - # FAKE_REPOS is kept across tests.
|
| -
|
| - @property
|
| - def svn_base(self):
|
| - """Shortcut."""
|
| - return self.FAKE_REPOS.svn_base
|
| -
|
| - @property
|
| - def git_base(self):
|
| - """Shortcut."""
|
| - return self.FAKE_REPOS.git_base
|
| -
|
| - def checkString(self, expected, result, msg=None):
|
| - """Prints the diffs to ease debugging."""
|
| - if expected != result:
|
| - # Strip the begining
|
| - while expected and result and expected[0] == result[0]:
|
| - expected = expected[1:]
|
| - result = result[1:]
|
| - # The exception trace makes it hard to read so dump it too.
|
| - if '\n' in result:
|
| - print result
|
| - self.assertEquals(expected, result, msg)
|
| -
|
| - def check(self, expected, results):
|
| - """Checks stdout, stderr, returncode."""
|
| - self.checkString(expected[0], results[0])
|
| - self.checkString(expected[1], results[1])
|
| - self.assertEquals(expected[2], results[2])
|
| -
|
| - def assertTree(self, tree, tree_root=None):
|
| - """Diff the checkout tree with a dict."""
|
| - if not tree_root:
|
| - tree_root = self.root_dir
|
| - actual = read_tree(tree_root)
|
| - diff = dict_diff(tree, actual)
|
| - if diff:
|
| - logging.debug('Actual %s\n%s' % (tree_root, pprint.pformat(actual)))
|
| - logging.debug('Expected\n%s' % pprint.pformat(tree))
|
| - logging.debug('Diff\n%s' % pprint.pformat(diff))
|
| - self.assertEquals(diff, [])
|
| -
|
| - def mangle_svn_tree(self, *args):
|
| - """Creates a 'virtual directory snapshot' to compare with the actual result
|
| - on disk."""
|
| - result = {}
|
| - for item, new_root in args:
|
| - old_root, rev = item.split('@', 1)
|
| - tree = self.FAKE_REPOS.svn_revs[int(rev)]
|
| - for k, v in tree.iteritems():
|
| - if not k.startswith(old_root):
|
| - continue
|
| - item = k[len(old_root) + 1:]
|
| - if item.startswith('.'):
|
| - continue
|
| - result[join(new_root, item).replace(os.sep, '/')] = v
|
| - return result
|
| -
|
| - def mangle_git_tree(self, *args):
|
| - """Creates a 'virtual directory snapshot' to compare with the actual result
|
| - on disk."""
|
| - result = {}
|
| - for item, new_root in args:
|
| - repo, rev = item.split('@', 1)
|
| - tree = self.gittree(repo, rev)
|
| - for k, v in tree.iteritems():
|
| - result[join(new_root, k)] = v
|
| - return result
|
| -
|
| - def githash(self, repo, rev):
|
| - """Sort-hand: Returns the hash for a git 'revision'."""
|
| - return self.FAKE_REPOS.git_hashes[repo][int(rev)][0]
|
| -
|
| - def gittree(self, repo, rev):
|
| - """Sort-hand: returns the directory tree for a git 'revision'."""
|
| - return self.FAKE_REPOS.git_hashes[repo][int(rev)][1]
|
| -
|
| -
|
| -def main(argv):
|
| - fake = FakeRepos()
|
| - print 'Using %s' % fake.root_dir
|
| - try:
|
| - fake.set_up_svn()
|
| - fake.set_up_git()
|
| - print('Fake setup, press enter to quit or Ctrl-C to keep the checkouts.')
|
| - sys.stdin.readline()
|
| - except KeyboardInterrupt:
|
| - trial_dir.TrialDir.SHOULD_LEAK.leak = True
|
| - return 0
|
| -
|
| -
|
| -if __name__ == '__main__':
|
| - sys.exit(main(sys.argv))
|
|
|