sapling/eden/integration/rc_test.py
Adam Simpkins 8884b46b3f move integration tests to eden/integration
Summary:
Move the integration tests from eden/fs/integration up one directory, to
eden/integration.

The main benefit is that this makes it easy to run just the edenfs unit tests
by running "buck test eden/fs/...".  These unit tests complete much more
quickly than the full set of integration tests, providing a faster test suite
to re-run repeatedly during development.  The integration tests can be run with
"buck test eden/integration/...", and the full set of tests can still be run
with "buck test eden/..."

Reviewed By: wez

Differential Revision: D4490247

fbshipit-source-id: 5ceb5a19526f56e1cb926f352fa30ad2f1212c05
2017-01-31 14:41:14 -08:00

132 lines
4.9 KiB
Python

#!/usr/bin/env python3
#
# Copyright (c) 2016-present, Facebook, Inc.
# All rights reserved.
#
# This source code is licensed under the BSD-style license found in the
# LICENSE file in the root directory of this source tree. An additional grant
# of patent rights can be found in the PATENTS file in the same directory.
import os
import stat
import tempfile
from .lib import testcase
from eden.fs.cli import util
@testcase.eden_repo_test
class RCTest:
def populate_repo(self):
self.repo.write_file('readme.txt', 'test\n')
self.repo.commit('Initial commit.')
def test_eden_list(self):
mount_paths = self.eden.list_cmd().split('\n')[:-1]
self.assertEqual(1, len(mount_paths),
msg='There should only be 1 mount path')
self.assertEqual(self.mount, mount_paths[0])
self.eden.unmount(self.mount)
mount_paths = self.eden.list_cmd().split('\n')[:-1]
self.assertEqual(0, len(mount_paths),
msg='There should be 0 mount paths after unmount')
self.eden.clone(self.repo_name, self.mount)
mount_paths = self.eden.list_cmd().split('\n')[:-1]
self.assertEqual(1, len(mount_paths),
msg='There should be 1 mount path after clone')
self.assertEqual(self.mount, mount_paths[0])
def test_unmount_rmdir(self):
clients = os.path.join(self.eden_dir, 'clients')
client_names = os.listdir(clients)
self.assertEqual(1, len(client_names),
msg='There should only be 1 client')
test_client_dir = os.path.join(clients, client_names[0])
# Eden list command uses keys of directory map to get mount paths
mount_paths = self.eden.list_cmd().split('\n')[:-1]
self.assertEqual(1, len(mount_paths),
msg='There should only be 1 path in the directory map')
self.assertEqual(self.mount, mount_paths[0])
self.eden.unmount(self.mount)
self.assertFalse(os.path.isdir(test_client_dir))
# Check that _remove_path_from_directory_map in unmount is successful
mount_paths = self.eden.list_cmd().split('\n')[:-1]
self.assertEqual(0, len(mount_paths),
msg='There should be 0 paths in the directory map')
self.eden.clone(self.repo_name, self.mount)
self.assertTrue(os.path.isdir(test_client_dir),
msg='Client name should be restored verbatim because \
it should be a function of the mount point')
mount_paths = self.eden.list_cmd().split('\n')[:-1]
self.assertEqual(1, len(mount_paths),
msg='The client directory should have been restored')
self.assertEqual(self.mount, mount_paths[0],
msg='Client directory name should match client name')
def test_override_system_config(self):
system_repo = self.create_repo('system_repo', self.get_repo_class())
system_repo.write_file('hello.txt', 'hola\n')
system_repo.commit('Initial commit.')
system_repo_path, system_repo_type = \
util.get_repo_source_and_type(system_repo.path)
# Create temporary system config
f, path = tempfile.mkstemp(dir=self.system_config_dir)
# Add system_repo to system config file
config = '''\
[repository ''' + self.repo_name + ''']
path = ''' + system_repo_path + '''
type = ''' + system_repo_type + '''
'''
os.write(f, config.encode('utf-8'))
os.close(f)
# Clone repository
mount_path = os.path.join(self.mounts_dir, self.repo_name + '-1')
self.eden.clone(self.repo_name, mount_path)
# Verify that clone used repository data from user config
readme = os.path.join(mount_path, 'hello.txt')
self.assertFalse(os.path.exists(readme))
hello = os.path.join(mount_path, 'readme.txt')
st = os.lstat(hello)
self.assertTrue(stat.S_ISREG(st.st_mode))
with open(hello, 'r') as f:
self.assertEqual('test\n', f.read())
# Add system_repo to system config file with new name
repo_name = 'repo'
f = os.open(path, os.O_WRONLY)
config = '''\
[repository ''' + repo_name + ''']
path = ''' + system_repo_path + '''
type = ''' + system_repo_type + '''
'''
os.write(f, config.encode('utf-8'))
os.close(f)
# Clone repository
mount_path = os.path.join(self.mounts_dir, repo_name + '-1')
self.eden.clone(repo_name, mount_path)
# Verify that clone used repository data from system config
readme = os.path.join(mount_path, 'readme.txt')
self.assertFalse(os.path.exists(readme))
hello = os.path.join(mount_path, 'hello.txt')
st = os.lstat(hello)
self.assertTrue(stat.S_ISREG(st.st_mode))
with open(hello, 'r') as f:
self.assertEqual('hola\n', f.read())