/brz/remove-bazaar : contents of bzrlib/tests/test_transport_implementations.py at revision 2776.4.14

: (revision 2776.4.14)

To get this branch, use:

bzr branch
http://gegoxaren.bato24.eu/bzr/brz/remove-bazaar

2018.18.22 by Martin Pool merge bzr.dev	1	# Copyright (C) 2004, 2005, 2006, 2007 Canonical Ltd
1887.1.1 by Adeodato Simó Do not separate paragraphs in the copyright statement with blank lines,	2	#
1530.1.3 by Robert Collins transport implementations now tested consistently.	3	# This program is free software; you can redistribute it and/or modify
	4	# it under the terms of the GNU General Public License as published by
	5	# the Free Software Foundation; either version 2 of the License, or
	6	# (at your option) any later version.
1887.1.1 by Adeodato Simó Do not separate paragraphs in the copyright statement with blank lines,	7	#
1530.1.3 by Robert Collins transport implementations now tested consistently.	8	# This program is distributed in the hope that it will be useful,
	9	# but WITHOUT ANY WARRANTY; without even the implied warranty of
	10	# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	11	# GNU General Public License for more details.
1887.1.1 by Adeodato Simó Do not separate paragraphs in the copyright statement with blank lines,	12	#
1530.1.3 by Robert Collins transport implementations now tested consistently.	13	# You should have received a copy of the GNU General Public License
	14	# along with this program; if not, write to the Free Software
	15	# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
	16
	17	"""Tests for Transport implementations.
	18
	19	Transport implementations tested here are supplied by
	20	TransportTestProviderAdapter.
	21	"""
	22
	23	import os
	24	from cStringIO import StringIO
2018.5.131 by Andrew Bennetts Be strict about unicode passed to transport.put_{bytes,file} and SmartClient.call_with_body_bytes, fixing part of TestLockableFiles_RemoteLockDir.test_read_write.	25	from StringIO import StringIO as pyStringIO
1530.1.15 by Robert Collins Move put mode tests into test_transport_implementation.	26	import stat
	27	import sys
2553.2.5 by Robert Collins And overhaul TransportTestProviderAdapter too.	28	import unittest
1530.1.3 by Robert Collins transport implementations now tested consistently.	29
1755.3.7 by John Arbash Meinel Clean up and write tests for permissions. Now we use fstat which should be cheap, and lets us check the permissions and the file size	30	from bzrlib import (
2001.3.2 by John Arbash Meinel Force all transports to raise ShortReadvError if they can	31	errors,
1755.3.7 by John Arbash Meinel Clean up and write tests for permissions. Now we use fstat which should be cheap, and lets us check the permissions and the file size	32	osutils,
	33	urlutils,
	34	)
2400.2.1 by Robert Collins Split out the improvement to Transport.local_abspath to raise NotLocalURL from the hpss-faster-copy branch. (Martin Pool, Ian Clatworthy)	35	from bzrlib.errors import (ConnectionError,
	36	DirectoryNotEmpty,
	37	FileExists,
	38	InvalidURL,
	39	LockError,
	40	NoSmartServer,
	41	NoSuchFile,
	42	NotLocalUrl,
	43	PathError,
	44	TransportNotPossible,
	45	)
1685.1.9 by John Arbash Meinel Updated LocalTransport so that it's base is now a URL rather than a local path. This helps consistency with all other functions. To do so, I added local_abspath() which returns the local path, and local_path_to/from_url	46	from bzrlib.osutils import getcwd
2018.5.139 by Andrew Bennetts Merge from bzr.dev, resolving conflicts.	47	from bzrlib.smart import medium
2553.2.5 by Robert Collins And overhaul TransportTestProviderAdapter too.	48	from bzrlib.tests import TestCaseInTempDir, TestScenarioApplier, TestSkipped
1871.1.2 by Robert Collins Reduce code duplication in transport-parameterised tests.	49	from bzrlib.tests.test_transport import TestTransportImplementation
2485.8.25 by Vincent Ladeuil Separate abspath from _remote_path, the intents are different.	50	from bzrlib.transport import (
	51	ConnectedTransport,
	52	get_transport,
2485.8.50 by Vincent Ladeuil merge bzr.dev @ 2584 resolving conflicts	53	_get_transport_modules,
2485.8.25 by Vincent Ladeuil Separate abspath from _remote_path, the intents are different.	54	)
	55	from bzrlib.transport.memory import MemoryTransport
1530.1.3 by Robert Collins transport implementations now tested consistently.	56
	57
2553.2.5 by Robert Collins And overhaul TransportTestProviderAdapter too.	58	class TransportTestProviderAdapter(TestScenarioApplier):
	59	"""A tool to generate a suite testing all transports for a single test.
	60
	61	This is done by copying the test once for each transport and injecting
	62	the transport_class and transport_server classes into each copy. Each copy
	63	is also given a new id() to make it easy to identify.
	64	"""
	65
	66	def __init__(self):
	67	self.scenarios = self._test_permutations()
	68
	69	def get_transport_test_permutations(self, module):
	70	"""Get the permutations module wants to have tested."""
	71	if getattr(module, 'get_test_permutations', None) is None:
	72	raise AssertionError("transport module %s doesn't provide get_test_permutations()"
	73	% module.__name__)
	74	##warning("transport module %s doesn't provide get_test_permutations()"
	75	## % module.__name__)
	76	return []
	77	return module.get_test_permutations()
	78
	79	def _test_permutations(self):
	80	"""Return a list of the klass, server_factory pairs to test."""
	81	result = []
	82	for module in _get_transport_modules():
	83	try:
	84	permutations = self.get_transport_test_permutations(
	85	reduce(getattr, (module).split('.')[1:], __import__(module)))
	86	for (klass, server_factory) in permutations:
	87	scenario = (server_factory.__name__,
	88	{"transport_class":klass,
	89	"transport_server":server_factory})
	90	result.append(scenario)
	91	except errors.DependencyNotPresent, e:
	92	# Continue even if a dependency prevents us
	93	# from running this test
	94	pass
	95	return result
	96
	97
	98
1871.1.2 by Robert Collins Reduce code duplication in transport-parameterised tests.	99	class TransportTests(TestTransportImplementation):
	100
2018.5.24 by Andrew Bennetts Setting NO_SMART_VFS in environment will disable VFS methods in the smart server. (Robert Collins, John Arbash Meinel, Andrew Bennetts)	101	def setUp(self):
	102	super(TransportTests, self).setUp()
2402.1.2 by Andrew Bennetts Deal with review comments.	103	self._captureVar('BZR_NO_SMART_VFS', None)
2018.5.24 by Andrew Bennetts Setting NO_SMART_VFS in environment will disable VFS methods in the smart server. (Robert Collins, John Arbash Meinel, Andrew Bennetts)	104
1530.1.3 by Robert Collins transport implementations now tested consistently.	105	def check_transport_contents(self, content, transport, relpath):
	106	"""Check that transport.get(relpath).read() == content."""
1530.1.21 by Robert Collins Review feedback fixes.	107	self.assertEqualDiff(content, transport.get(relpath).read())
1530.1.15 by Robert Collins Move put mode tests into test_transport_implementation.	108
2475.3.2 by John Arbash Meinel Add Transport.ensure_base()	109	def test_ensure_base_missing(self):
	110	""".ensure_base() should create the directory if it doesn't exist"""
	111	t = self.get_transport()
	112	t_a = t.clone('a')
	113	if t_a.is_readonly():
	114	self.assertRaises(TransportNotPossible,
	115	t_a.ensure_base)
	116	return
	117	self.assertTrue(t_a.ensure_base())
	118	self.assertTrue(t.has('a'))
	119
	120	def test_ensure_base_exists(self):
	121	""".ensure_base() should just be happy if it already exists"""
	122	t = self.get_transport()
	123	if t.is_readonly():
	124	return
	125
	126	t.mkdir('a')
	127	t_a = t.clone('a')
	128	# ensure_base returns False if it didn't create the base
	129	self.assertFalse(t_a.ensure_base())
	130
	131	def test_ensure_base_missing_parent(self):
	132	""".ensure_base() will fail if the parent dir doesn't exist"""
	133	t = self.get_transport()
	134	if t.is_readonly():
	135	return
	136
	137	t_a = t.clone('a')
	138	t_b = t_a.clone('b')
	139	self.assertRaises(NoSuchFile, t_b.ensure_base)
	140
2634.1.1 by Robert Collins (robertc) Reinstate the accidentally backed out external_url patch.	141	def test_external_url(self):
	142	""".external_url either works or raises InProcessTransport."""
	143	t = self.get_transport()
	144	try:
	145	t.external_url()
	146	except errors.InProcessTransport:
	147	pass
	148
1530.1.3 by Robert Collins transport implementations now tested consistently.	149	def test_has(self):
	150	t = self.get_transport()
	151
	152	files = ['a', 'b', 'e', 'g', '%']
	153	self.build_tree(files, transport=t)
	154	self.assertEqual(True, t.has('a'))
	155	self.assertEqual(False, t.has('c'))
1685.1.45 by John Arbash Meinel Moved url functions into bzrlib.urlutils	156	self.assertEqual(True, t.has(urlutils.escape('%')))
1530.1.3 by Robert Collins transport implementations now tested consistently.	157	self.assertEqual(list(t.has_multi(['a', 'b', 'c', 'd', 'e', 'f', 'g', 'h'])),
	158	[True, True, False, False, True, False, True, False])
	159	self.assertEqual(True, t.has_any(['a', 'b', 'c']))
1685.1.45 by John Arbash Meinel Moved url functions into bzrlib.urlutils	160	self.assertEqual(False, t.has_any(['c', 'd', 'f', urlutils.escape('%%')]))
1530.1.3 by Robert Collins transport implementations now tested consistently.	161	self.assertEqual(list(t.has_multi(iter(['a', 'b', 'c', 'd', 'e', 'f', 'g', 'h']))),
	162	[True, True, False, False, True, False, True, False])
	163	self.assertEqual(False, t.has_any(['c', 'c', 'c']))
	164	self.assertEqual(True, t.has_any(['b', 'b', 'b']))
	165
1986.1.10 by Robert Collins Merge from bzr.dev, fixing found bugs handling 'has('/')' in MemoryTransport and SFTP transports.	166	def test_has_root_works(self):
	167	current_transport = self.get_transport()
	168	self.assertTrue(current_transport.has('/'))
	169	root = current_transport.clone('/')
	170	self.assertTrue(root.has(''))
	171
1530.1.3 by Robert Collins transport implementations now tested consistently.	172	def test_get(self):
	173	t = self.get_transport()
	174
	175	files = ['a', 'b', 'e', 'g']
	176	contents = ['contents of a\n',
	177	'contents of b\n',
	178	'contents of e\n',
	179	'contents of g\n',
	180	]
1551.2.39 by abentley Fix line endings in tests	181	self.build_tree(files, transport=t, line_endings='binary')
1530.1.3 by Robert Collins transport implementations now tested consistently.	182	self.check_transport_contents('contents of a\n', t, 'a')
	183	content_f = t.get_multi(files)
	184	for content, f in zip(contents, content_f):
	185	self.assertEqual(content, f.read())
	186
	187	content_f = t.get_multi(iter(files))
	188	for content, f in zip(contents, content_f):
	189	self.assertEqual(content, f.read())
	190
	191	self.assertRaises(NoSuchFile, t.get, 'c')
	192	self.assertListRaises(NoSuchFile, t.get_multi, ['a', 'b', 'c'])
	193	self.assertListRaises(NoSuchFile, t.get_multi, iter(['a', 'b', 'c']))
	194
2052.6.2 by Robert Collins Merge bzr.dev.	195	def test_get_directory_read_gives_ReadError(self):
2052.6.2 by Robert Collins Merge bzr.dev.	196	"""consistent errors for read() on a file returned by get()."""
2052.6.1 by Robert Collins ``Transport.get`` has had its interface made more clear for ease of use.	197	t = self.get_transport()
	198	if t.is_readonly():
	199	self.build_tree(['a directory/'])
	200	else:
	201	t.mkdir('a%20directory')
	202	# getting the file must either work or fail with a PathError
	203	try:
	204	a_file = t.get('a%20directory')
2052.6.2 by Robert Collins Merge bzr.dev.	205	except (errors.PathError, errors.RedirectRequested):
2052.6.1 by Robert Collins ``Transport.get`` has had its interface made more clear for ease of use.	206	# early failure return immediately.
	207	return
	208	# having got a file, read() must either work (i.e. http reading a dir listing) or
	209	# fail with ReadError
	210	try:
	211	a_file.read()
	212	except errors.ReadError:
	213	pass
	214
1955.3.3 by John Arbash Meinel Implement and test 'get_bytes'	215	def test_get_bytes(self):
	216	t = self.get_transport()
	217
	218	files = ['a', 'b', 'e', 'g']
	219	contents = ['contents of a\n',
	220	'contents of b\n',
	221	'contents of e\n',
	222	'contents of g\n',
	223	]
	224	self.build_tree(files, transport=t, line_endings='binary')
	225	self.check_transport_contents('contents of a\n', t, 'a')
	226
	227	for content, fname in zip(contents, files):
	228	self.assertEqual(content, t.get_bytes(fname))
	229
	230	self.assertRaises(NoSuchFile, t.get_bytes, 'c')
	231
2671.3.9 by Robert Collins Review feedback and fix VFat emulated transports to not claim to have unix permissions.	232	def test_get_with_open_write_stream_sees_all_content(self):
2671.3.4 by Robert Collins Sync up with open file streams on get/get_bytes.	233	t = self.get_transport()
	234	if t.is_readonly():
	235	return
2671.3.9 by Robert Collins Review feedback and fix VFat emulated transports to not claim to have unix permissions.	236	handle = t.open_write_stream('foo')
2671.3.4 by Robert Collins Sync up with open file streams on get/get_bytes.	237	try:
2671.3.6 by Robert Collins Review feedback.	238	handle.write('b')
2671.3.4 by Robert Collins Sync up with open file streams on get/get_bytes.	239	self.assertEqual('b', t.get('foo').read())
	240	finally:
2671.3.6 by Robert Collins Review feedback.	241	handle.close()
2671.3.4 by Robert Collins Sync up with open file streams on get/get_bytes.	242
2671.3.9 by Robert Collins Review feedback and fix VFat emulated transports to not claim to have unix permissions.	243	def test_get_bytes_with_open_write_stream_sees_all_content(self):
2671.3.4 by Robert Collins Sync up with open file streams on get/get_bytes.	244	t = self.get_transport()
	245	if t.is_readonly():
	246	return
2671.3.9 by Robert Collins Review feedback and fix VFat emulated transports to not claim to have unix permissions.	247	handle = t.open_write_stream('foo')
2671.3.4 by Robert Collins Sync up with open file streams on get/get_bytes.	248	try:
2671.3.6 by Robert Collins Review feedback.	249	handle.write('b')
2671.3.4 by Robert Collins Sync up with open file streams on get/get_bytes.	250	self.assertEqual('b', t.get_bytes('foo'))
	251	self.assertEqual('b', t.get('foo').read())
	252	finally:
2671.3.6 by Robert Collins Review feedback.	253	handle.close()
2671.3.4 by Robert Collins Sync up with open file streams on get/get_bytes.	254
1955.3.1 by John Arbash Meinel Add put_bytes() and a base-level implementation for it	255	def test_put_bytes(self):
	256	t = self.get_transport()
	257
	258	if t.is_readonly():
	259	self.assertRaises(TransportNotPossible,
	260	t.put_bytes, 'a', 'some text for a\n')
	261	return
	262
	263	t.put_bytes('a', 'some text for a\n')
	264	self.failUnless(t.has('a'))
	265	self.check_transport_contents('some text for a\n', t, 'a')
	266
	267	# The contents should be overwritten
	268	t.put_bytes('a', 'new text for a\n')
	269	self.check_transport_contents('new text for a\n', t, 'a')
	270
	271	self.assertRaises(NoSuchFile,
	272	t.put_bytes, 'path/doesnt/exist/c', 'contents')
1530.1.3 by Robert Collins transport implementations now tested consistently.	273
1955.3.27 by John Arbash Meinel rename non_atomic_put_* to put_*non_atomic, and re-order the functions	274	def test_put_bytes_non_atomic(self):
	275	t = self.get_transport()
	276
	277	if t.is_readonly():
	278	self.assertRaises(TransportNotPossible,
	279	t.put_bytes_non_atomic, 'a', 'some text for a\n')
	280	return
	281
	282	self.failIf(t.has('a'))
	283	t.put_bytes_non_atomic('a', 'some text for a\n')
	284	self.failUnless(t.has('a'))
	285	self.check_transport_contents('some text for a\n', t, 'a')
	286	# Put also replaces contents
	287	t.put_bytes_non_atomic('a', 'new\ncontents for\na\n')
	288	self.check_transport_contents('new\ncontents for\na\n', t, 'a')
	289
	290	# Make sure we can create another file
	291	t.put_bytes_non_atomic('d', 'contents for\nd\n')
	292	# And overwrite 'a' with empty contents
	293	t.put_bytes_non_atomic('a', '')
	294	self.check_transport_contents('contents for\nd\n', t, 'd')
	295	self.check_transport_contents('', t, 'a')
	296
	297	self.assertRaises(NoSuchFile, t.put_bytes_non_atomic, 'no/such/path',
	298	'contents\n')
	299	# Now test the create_parent flag
	300	self.assertRaises(NoSuchFile, t.put_bytes_non_atomic, 'dir/a',
	301	'contents\n')
	302	self.failIf(t.has('dir/a'))
	303	t.put_bytes_non_atomic('dir/a', 'contents for dir/a\n',
	304	create_parent_dir=True)
	305	self.check_transport_contents('contents for dir/a\n', t, 'dir/a')
	306
	307	# But we still get NoSuchFile if we can't make the parent dir
	308	self.assertRaises(NoSuchFile, t.put_bytes_non_atomic, 'not/there/a',
	309	'contents\n',
	310	create_parent_dir=True)
	311
	312	def test_put_bytes_permissions(self):
	313	t = self.get_transport()
	314
	315	if t.is_readonly():
	316	return
	317	if not t._can_roundtrip_unix_modebits():
	318	# Can't roundtrip, so no need to run this test
	319	return
	320	t.put_bytes('mode644', 'test text\n', mode=0644)
	321	self.assertTransportMode(t, 'mode644', 0644)
	322	t.put_bytes('mode666', 'test text\n', mode=0666)
	323	self.assertTransportMode(t, 'mode666', 0666)
	324	t.put_bytes('mode600', 'test text\n', mode=0600)
	325	self.assertTransportMode(t, 'mode600', 0600)
	326	# Yes, you can put_bytes a file such that it becomes readonly
	327	t.put_bytes('mode400', 'test text\n', mode=0400)
	328	self.assertTransportMode(t, 'mode400', 0400)
	329
	330	# The default permissions should be based on the current umask
	331	umask = osutils.get_umask()
	332	t.put_bytes('nomode', 'test text\n', mode=None)
	333	self.assertTransportMode(t, 'nomode', 0666 & ~umask)
	334
	335	def test_put_bytes_non_atomic_permissions(self):
	336	t = self.get_transport()
	337
338	if t.is_readonly():
339	return
340	if not t._can_roundtrip_unix_modebits():
341	# Can't roundtrip, so no need to run this test
342	return
343	t.put_bytes_non_atomic('mode644', 'test text\n', mode=0644)
344	self.assertTransportMode(t, 'mode644', 0644)
345	t.put_bytes_non_atomic('mode666', 'test text\n', mode=0666)
346	self.assertTransportMode(t, 'mode666', 0666)
347	t.put_bytes_non_atomic('mode600', 'test text\n', mode=0600)
348	self.assertTransportMode(t, 'mode600', 0600)
349	t.put_bytes_non_atomic('mode400', 'test text\n', mode=0400)
350	self.assertTransportMode(t, 'mode400', 0400)
351
352	# The default permissions should be based on the current umask
353	umask = osutils.get_umask()
354	t.put_bytes_non_atomic('nomode', 'test text\n', mode=None)
355	self.assertTransportMode(t, 'nomode', 0666 & ~umask)
1946.2.12 by John Arbash Meinel Add ability to pass a directory mode to non_atomic_put	356
	357	# We should also be able to set the mode for a parent directory
	358	# when it is created
	359	t.put_bytes_non_atomic('dir700/mode664', 'test text\n', mode=0664,
	360	dir_mode=0700, create_parent_dir=True)
	361	self.assertTransportMode(t, 'dir700', 0700)
	362	t.put_bytes_non_atomic('dir770/mode664', 'test text\n', mode=0664,
	363	dir_mode=0770, create_parent_dir=True)
	364	self.assertTransportMode(t, 'dir770', 0770)
	365	t.put_bytes_non_atomic('dir777/mode664', 'test text\n', mode=0664,
	366	dir_mode=0777, create_parent_dir=True)
	367	self.assertTransportMode(t, 'dir777', 0777)
1955.3.27 by John Arbash Meinel rename non_atomic_put_* to put_*non_atomic, and re-order the functions	368
	369	def test_put_file(self):
	370	t = self.get_transport()
	371
	372	if t.is_readonly():
	373	self.assertRaises(TransportNotPossible,
	374	t.put_file, 'a', StringIO('some text for a\n'))
	375	return
	376
2853.1.1 by Robert Collins * ``bzrlib.transport.Transport.put_file`` now returns the number of bytes	377	result = t.put_file('a', StringIO('some text for a\n'))
	378	# put_file returns the length of the data written
	379	self.assertEqual(16, result)
1955.3.27 by John Arbash Meinel rename non_atomic_put_* to put_*non_atomic, and re-order the functions	380	self.failUnless(t.has('a'))
	381	self.check_transport_contents('some text for a\n', t, 'a')
	382	# Put also replaces contents
2853.1.1 by Robert Collins * ``bzrlib.transport.Transport.put_file`` now returns the number of bytes	383	result = t.put_file('a', StringIO('new\ncontents for\na\n'))
	384	self.assertEqual(19, result)
1955.3.27 by John Arbash Meinel rename non_atomic_put_* to put_*non_atomic, and re-order the functions	385	self.check_transport_contents('new\ncontents for\na\n', t, 'a')
	386	self.assertRaises(NoSuchFile,
	387	t.put_file, 'path/doesnt/exist/c',
	388	StringIO('contents'))
	389
	390	def test_put_file_non_atomic(self):
	391	t = self.get_transport()
	392
	393	if t.is_readonly():
	394	self.assertRaises(TransportNotPossible,
	395	t.put_file_non_atomic, 'a', StringIO('some text for a\n'))
	396	return
	397
	398	self.failIf(t.has('a'))
	399	t.put_file_non_atomic('a', StringIO('some text for a\n'))
	400	self.failUnless(t.has('a'))
	401	self.check_transport_contents('some text for a\n', t, 'a')
	402	# Put also replaces contents
	403	t.put_file_non_atomic('a', StringIO('new\ncontents for\na\n'))
	404	self.check_transport_contents('new\ncontents for\na\n', t, 'a')
	405
	406	# Make sure we can create another file
	407	t.put_file_non_atomic('d', StringIO('contents for\nd\n'))
	408	# And overwrite 'a' with empty contents
	409	t.put_file_non_atomic('a', StringIO(''))
	410	self.check_transport_contents('contents for\nd\n', t, 'd')
	411	self.check_transport_contents('', t, 'a')
	412
	413	self.assertRaises(NoSuchFile, t.put_file_non_atomic, 'no/such/path',
	414	StringIO('contents\n'))
	415	# Now test the create_parent flag
	416	self.assertRaises(NoSuchFile, t.put_file_non_atomic, 'dir/a',
	417	StringIO('contents\n'))
	418	self.failIf(t.has('dir/a'))
	419	t.put_file_non_atomic('dir/a', StringIO('contents for dir/a\n'),
1955.3.20 by John Arbash Meinel Add non_atomic_put_bytes() and tests for it	420	create_parent_dir=True)
1946.1.8 by John Arbash Meinel Update non_atomic_put to have a create_parent_dir flag	421	self.check_transport_contents('contents for dir/a\n', t, 'dir/a')
	422
	423	# But we still get NoSuchFile if we can't make the parent dir
1955.3.27 by John Arbash Meinel rename non_atomic_put_* to put_*non_atomic, and re-order the functions	424	self.assertRaises(NoSuchFile, t.put_file_non_atomic, 'not/there/a',
1955.3.20 by John Arbash Meinel Add non_atomic_put_bytes() and tests for it	425	StringIO('contents\n'),
	426	create_parent_dir=True)
	427
1955.3.7 by John Arbash Meinel Fix the deprecation warnings in the transport tests themselves	428	def test_put_file_permissions(self):
1955.3.18 by John Arbash Meinel [merge] Transport.non_atomic_put()	429
1530.1.15 by Robert Collins Move put mode tests into test_transport_implementation.	430	t = self.get_transport()
	431
	432	if t.is_readonly():
	433	return
1711.4.32 by John Arbash Meinel Skip permission tests on win32 no modebits	434	if not t._can_roundtrip_unix_modebits():
	435	# Can't roundtrip, so no need to run this test
	436	return
1955.3.7 by John Arbash Meinel Fix the deprecation warnings in the transport tests themselves	437	t.put_file('mode644', StringIO('test text\n'), mode=0644)
1530.1.21 by Robert Collins Review feedback fixes.	438	self.assertTransportMode(t, 'mode644', 0644)
1955.3.7 by John Arbash Meinel Fix the deprecation warnings in the transport tests themselves	439	t.put_file('mode666', StringIO('test text\n'), mode=0666)
1530.1.21 by Robert Collins Review feedback fixes.	440	self.assertTransportMode(t, 'mode666', 0666)
1955.3.7 by John Arbash Meinel Fix the deprecation warnings in the transport tests themselves	441	t.put_file('mode600', StringIO('test text\n'), mode=0600)
1530.1.21 by Robert Collins Review feedback fixes.	442	self.assertTransportMode(t, 'mode600', 0600)
1530.1.15 by Robert Collins Move put mode tests into test_transport_implementation.	443	# Yes, you can put a file such that it becomes readonly
1955.3.7 by John Arbash Meinel Fix the deprecation warnings in the transport tests themselves	444	t.put_file('mode400', StringIO('test text\n'), mode=0400)
1530.1.21 by Robert Collins Review feedback fixes.	445	self.assertTransportMode(t, 'mode400', 0400)
1755.3.7 by John Arbash Meinel Clean up and write tests for permissions. Now we use fstat which should be cheap, and lets us check the permissions and the file size	446	# The default permissions should be based on the current umask
	447	umask = osutils.get_umask()
1955.3.7 by John Arbash Meinel Fix the deprecation warnings in the transport tests themselves	448	t.put_file('nomode', StringIO('test text\n'), mode=None)
1755.3.7 by John Arbash Meinel Clean up and write tests for permissions. Now we use fstat which should be cheap, and lets us check the permissions and the file size	449	self.assertTransportMode(t, 'nomode', 0666 & ~umask)
1530.1.16 by Robert Collins Move mkdir and copy_to permissions tests to test_transport_impleentation.	450
1955.3.27 by John Arbash Meinel rename non_atomic_put_* to put_*non_atomic, and re-order the functions	451	def test_put_file_non_atomic_permissions(self):
	452	t = self.get_transport()
	453
	454	if t.is_readonly():
	455	return
	456	if not t._can_roundtrip_unix_modebits():
	457	# Can't roundtrip, so no need to run this test
	458	return
	459	t.put_file_non_atomic('mode644', StringIO('test text\n'), mode=0644)
	460	self.assertTransportMode(t, 'mode644', 0644)
	461	t.put_file_non_atomic('mode666', StringIO('test text\n'), mode=0666)
	462	self.assertTransportMode(t, 'mode666', 0666)
	463	t.put_file_non_atomic('mode600', StringIO('test text\n'), mode=0600)
	464	self.assertTransportMode(t, 'mode600', 0600)
	465	# Yes, you can put_file_non_atomic a file such that it becomes readonly
	466	t.put_file_non_atomic('mode400', StringIO('test text\n'), mode=0400)
	467	self.assertTransportMode(t, 'mode400', 0400)
	468
	469	# The default permissions should be based on the current umask
	470	umask = osutils.get_umask()
	471	t.put_file_non_atomic('nomode', StringIO('test text\n'), mode=None)
	472	self.assertTransportMode(t, 'nomode', 0666 & ~umask)
	473
1946.2.12 by John Arbash Meinel Add ability to pass a directory mode to non_atomic_put	474	# We should also be able to set the mode for a parent directory
	475	# when it is created
	476	sio = StringIO()
	477	t.put_file_non_atomic('dir700/mode664', sio, mode=0664,
	478	dir_mode=0700, create_parent_dir=True)
	479	self.assertTransportMode(t, 'dir700', 0700)
	480	t.put_file_non_atomic('dir770/mode664', sio, mode=0664,
	481	dir_mode=0770, create_parent_dir=True)
	482	self.assertTransportMode(t, 'dir770', 0770)
	483	t.put_file_non_atomic('dir777/mode664', sio, mode=0664,
	484	dir_mode=0777, create_parent_dir=True)
	485	self.assertTransportMode(t, 'dir777', 0777)
	486
2018.5.131 by Andrew Bennetts Be strict about unicode passed to transport.put_{bytes,file} and SmartClient.call_with_body_bytes, fixing part of TestLockableFiles_RemoteLockDir.test_read_write.	487	def test_put_bytes_unicode(self):
	488	# Expect put_bytes to raise AssertionError or UnicodeEncodeError if
	489	# given unicode "bytes". UnicodeEncodeError doesn't really make sense
	490	# (we don't want to encode unicode here at all, callers should be
	491	# strictly passing bytes to put_bytes), but we allow it for backwards
	492	# compatibility. At some point we should use a specific exception.
2414.1.2 by Andrew Bennetts Deal with review comments.	493	# See https://bugs.launchpad.net/bzr/+bug/106898.
2018.5.131 by Andrew Bennetts Be strict about unicode passed to transport.put_{bytes,file} and SmartClient.call_with_body_bytes, fixing part of TestLockableFiles_RemoteLockDir.test_read_write.	494	t = self.get_transport()
	495	if t.is_readonly():
	496	return
	497	unicode_string = u'\u1234'
	498	self.assertRaises(
	499	(AssertionError, UnicodeEncodeError),
	500	t.put_bytes, 'foo', unicode_string)
	501
	502	def test_put_file_unicode(self):
	503	# Like put_bytes, except with a StringIO.StringIO of a unicode string.
	504	# This situation can happen (and has) if code is careless about the type
	505	# of "string" they initialise/write to a StringIO with. We cannot use
	506	# cStringIO, because it never returns unicode from read.
	507	# Like put_bytes, UnicodeEncodeError isn't quite the right exception to
	508	# raise, but we raise it for hysterical raisins.
	509	t = self.get_transport()
	510	if t.is_readonly():
	511	return
	512	unicode_file = pyStringIO(u'\u1234')
	513	self.assertRaises(UnicodeEncodeError, t.put_file, 'foo', unicode_file)
	514
1530.1.3 by Robert Collins transport implementations now tested consistently.	515	def test_mkdir(self):
	516	t = self.get_transport()
	517
	518	if t.is_readonly():
	519	# cannot mkdir on readonly transports. We're not testing for
	520	# cache coherency because cache behaviour is not currently
	521	# defined for the transport interface.
	522	self.assertRaises(TransportNotPossible, t.mkdir, '.')
	523	self.assertRaises(TransportNotPossible, t.mkdir, 'new_dir')
	524	self.assertRaises(TransportNotPossible, t.mkdir_multi, ['new_dir'])
	525	self.assertRaises(TransportNotPossible, t.mkdir, 'path/doesnt/exist')
	526	return
	527	# Test mkdir
	528	t.mkdir('dir_a')
	529	self.assertEqual(t.has('dir_a'), True)
	530	self.assertEqual(t.has('dir_b'), False)
	531
	532	t.mkdir('dir_b')
	533	self.assertEqual(t.has('dir_b'), True)
	534
	535	t.mkdir_multi(['dir_c', 'dir_d'])
	536
	537	t.mkdir_multi(iter(['dir_e', 'dir_f']))
	538	self.assertEqual(list(t.has_multi(
	539	['dir_a', 'dir_b', 'dir_c', 'dir_q',
	540	'dir_d', 'dir_e', 'dir_f', 'dir_b'])),
	541	[True, True, True, False,
	542	True, True, True, True])
	543
	544	# we were testing that a local mkdir followed by a transport
	545	# mkdir failed thusly, but given that we * in one process * do not
	546	# concurrently fiddle with disk dirs and then use transport to do
	547	# things, the win here seems marginal compared to the constraint on
	548	# the interface. RBC 20051227
	549	t.mkdir('dir_g')
	550	self.assertRaises(FileExists, t.mkdir, 'dir_g')
	551
	552	# Test get/put in sub-directories
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	553	t.put_bytes('dir_a/a', 'contents of dir_a/a')
	554	t.put_file('dir_b/b', StringIO('contents of dir_b/b'))
1530.1.3 by Robert Collins transport implementations now tested consistently.	555	self.check_transport_contents('contents of dir_a/a', t, 'dir_a/a')
	556	self.check_transport_contents('contents of dir_b/b', t, 'dir_b/b')
	557
1530.1.4 by Robert Collins integrate Memory tests into transport interface tests.	558	# mkdir of a dir with an absent parent
	559	self.assertRaises(NoSuchFile, t.mkdir, 'missing/dir')
	560
1530.1.16 by Robert Collins Move mkdir and copy_to permissions tests to test_transport_impleentation.	561	def test_mkdir_permissions(self):
	562	t = self.get_transport()
	563	if t.is_readonly():
	564	return
1608.2.7 by Martin Pool Rename supports_unix_modebits to _can_roundtrip_unix_modebits for clarity	565	if not t._can_roundtrip_unix_modebits():
1608.2.5 by Martin Pool Add Transport.supports_unix_modebits, so tests can	566	# no sense testing on this transport
	567	return
1530.1.16 by Robert Collins Move mkdir and copy_to permissions tests to test_transport_impleentation.	568	# Test mkdir with a mode
	569	t.mkdir('dmode755', mode=0755)
1530.1.21 by Robert Collins Review feedback fixes.	570	self.assertTransportMode(t, 'dmode755', 0755)
1530.1.16 by Robert Collins Move mkdir and copy_to permissions tests to test_transport_impleentation.	571	t.mkdir('dmode555', mode=0555)
1530.1.21 by Robert Collins Review feedback fixes.	572	self.assertTransportMode(t, 'dmode555', 0555)
1530.1.16 by Robert Collins Move mkdir and copy_to permissions tests to test_transport_impleentation.	573	t.mkdir('dmode777', mode=0777)
1530.1.21 by Robert Collins Review feedback fixes.	574	self.assertTransportMode(t, 'dmode777', 0777)
1530.1.16 by Robert Collins Move mkdir and copy_to permissions tests to test_transport_impleentation.	575	t.mkdir('dmode700', mode=0700)
1530.1.21 by Robert Collins Review feedback fixes.	576	self.assertTransportMode(t, 'dmode700', 0700)
1530.1.16 by Robert Collins Move mkdir and copy_to permissions tests to test_transport_impleentation.	577	t.mkdir_multi(['mdmode755'], mode=0755)
1530.1.21 by Robert Collins Review feedback fixes.	578	self.assertTransportMode(t, 'mdmode755', 0755)
1530.1.16 by Robert Collins Move mkdir and copy_to permissions tests to test_transport_impleentation.	579
1755.3.7 by John Arbash Meinel Clean up and write tests for permissions. Now we use fstat which should be cheap, and lets us check the permissions and the file size	580	# Default mode should be based on umask
	581	umask = osutils.get_umask()
	582	t.mkdir('dnomode', mode=None)
	583	self.assertTransportMode(t, 'dnomode', 0777 & ~umask)
	584
2671.3.2 by Robert Collins Start open_file_stream logic.	585	def test_opening_a_file_stream_creates_file(self):
	586	t = self.get_transport()
	587	if t.is_readonly():
	588	return
2671.3.9 by Robert Collins Review feedback and fix VFat emulated transports to not claim to have unix permissions.	589	handle = t.open_write_stream('foo')
2671.3.2 by Robert Collins Start open_file_stream logic.	590	try:
	591	self.assertEqual('', t.get_bytes('foo'))
	592	finally:
2671.3.6 by Robert Collins Review feedback.	593	handle.close()
2671.3.2 by Robert Collins Start open_file_stream logic.	594
2671.3.3 by Robert Collins Add mode parameter to Transport.open_file_stream.	595	def test_opening_a_file_stream_can_set_mode(self):
	596	t = self.get_transport()
	597	if t.is_readonly():
	598	return
	599	if not t._can_roundtrip_unix_modebits():
	600	# Can't roundtrip, so no need to run this test
	601	return
	602	def check_mode(name, mode, expected):
2671.3.9 by Robert Collins Review feedback and fix VFat emulated transports to not claim to have unix permissions.	603	handle = t.open_write_stream(name, mode=mode)
2671.3.6 by Robert Collins Review feedback.	604	handle.close()
2671.3.3 by Robert Collins Add mode parameter to Transport.open_file_stream.	605	self.assertTransportMode(t, name, expected)
	606	check_mode('mode644', 0644, 0644)
	607	check_mode('mode666', 0666, 0666)
	608	check_mode('mode600', 0600, 0600)
	609	# The default permissions should be based on the current umask
	610	check_mode('nomode', None, 0666 & ~osutils.get_umask())
	611
1530.1.3 by Robert Collins transport implementations now tested consistently.	612	def test_copy_to(self):
1534.4.21 by Robert Collins Extend the copy_to tests to smoke test server-to-same-server copies to catch optimised code paths, and fix sftps optimised code path by removing dead code.	613	# FIXME: test: same server to same server (partly done)
	614	# same protocol two servers
	615	# and different protocols (done for now except for MemoryTransport.
	616	# - RBC 20060122
	617
	618	def simple_copy_files(transport_from, transport_to):
	619	files = ['a', 'b', 'c', 'd']
	620	self.build_tree(files, transport=transport_from)
1563.2.3 by Robert Collins Change the return signature of transport.append and append_multi to return the length of the pre-append content.	621	self.assertEqual(4, transport_from.copy_to(files, transport_to))
1534.4.21 by Robert Collins Extend the copy_to tests to smoke test server-to-same-server copies to catch optimised code paths, and fix sftps optimised code path by removing dead code.	622	for f in files:
	623	self.check_transport_contents(transport_to.get(f).read(),
	624	transport_from, f)
	625
1530.1.3 by Robert Collins transport implementations now tested consistently.	626	t = self.get_transport()
1685.1.42 by John Arbash Meinel A couple more fixes to make sure memory:/// works correctly.	627	temp_transport = MemoryTransport('memory:///')
1534.4.21 by Robert Collins Extend the copy_to tests to smoke test server-to-same-server copies to catch optimised code paths, and fix sftps optimised code path by removing dead code.	628	simple_copy_files(t, temp_transport)
	629	if not t.is_readonly():
	630	t.mkdir('copy_to_simple')
	631	t2 = t.clone('copy_to_simple')
	632	simple_copy_files(t, t2)
1530.1.3 by Robert Collins transport implementations now tested consistently.	633
	634
	635	# Test that copying into a missing directory raises
	636	# NoSuchFile
	637	if t.is_readonly():
1530.1.21 by Robert Collins Review feedback fixes.	638	self.build_tree(['e/', 'e/f'])
1530.1.3 by Robert Collins transport implementations now tested consistently.	639	else:
	640	t.mkdir('e')
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	641	t.put_bytes('e/f', 'contents of e')
1530.1.3 by Robert Collins transport implementations now tested consistently.	642	self.assertRaises(NoSuchFile, t.copy_to, ['e/f'], temp_transport)
	643	temp_transport.mkdir('e')
	644	t.copy_to(['e/f'], temp_transport)
	645
	646	del temp_transport
1685.1.42 by John Arbash Meinel A couple more fixes to make sure memory:/// works correctly.	647	temp_transport = MemoryTransport('memory:///')
1530.1.3 by Robert Collins transport implementations now tested consistently.	648
	649	files = ['a', 'b', 'c', 'd']
	650	t.copy_to(iter(files), temp_transport)
	651	for f in files:
	652	self.check_transport_contents(temp_transport.get(f).read(),
	653	t, f)
	654	del temp_transport
	655
1530.1.16 by Robert Collins Move mkdir and copy_to permissions tests to test_transport_impleentation.	656	for mode in (0666, 0644, 0600, 0400):
1685.1.42 by John Arbash Meinel A couple more fixes to make sure memory:/// works correctly.	657	temp_transport = MemoryTransport("memory:///")
1530.1.16 by Robert Collins Move mkdir and copy_to permissions tests to test_transport_impleentation.	658	t.copy_to(files, temp_transport, mode=mode)
	659	for f in files:
1530.1.21 by Robert Collins Review feedback fixes.	660	self.assertTransportMode(temp_transport, f, mode)
1530.1.16 by Robert Collins Move mkdir and copy_to permissions tests to test_transport_impleentation.	661
1955.3.15 by John Arbash Meinel Deprecate 'Transport.append' in favor of Transport.append_file or Transport.append_bytes	662	def test_append_file(self):
	663	t = self.get_transport()
	664
	665	if t.is_readonly():
1530.1.3 by Robert Collins transport implementations now tested consistently.	666	self.assertRaises(TransportNotPossible,
1955.3.15 by John Arbash Meinel Deprecate 'Transport.append' in favor of Transport.append_file or Transport.append_bytes	667	t.append_file, 'a', 'add\nsome\nmore\ncontents\n')
1955.3.2 by John Arbash Meinel Implement and test 'Transport.append_bytes', cleanup the tests of plain append	668	return
1955.3.10 by John Arbash Meinel clean up append, append_bytes, and append_multi tests	669	t.put_bytes('a', 'diff\ncontents for\na\n')
	670	t.put_bytes('b', 'contents\nfor b\n')
1955.3.2 by John Arbash Meinel Implement and test 'Transport.append_bytes', cleanup the tests of plain append	671
	672	self.assertEqual(20,
1955.3.15 by John Arbash Meinel Deprecate 'Transport.append' in favor of Transport.append_file or Transport.append_bytes	673	t.append_file('a', StringIO('add\nsome\nmore\ncontents\n')))
1530.1.3 by Robert Collins transport implementations now tested consistently.	674
	675	self.check_transport_contents(
	676	'diff\ncontents for\na\nadd\nsome\nmore\ncontents\n',
	677	t, 'a')
	678
1955.3.10 by John Arbash Meinel clean up append, append_bytes, and append_multi tests	679	# a file with no parent should fail..
	680	self.assertRaises(NoSuchFile,
1955.3.15 by John Arbash Meinel Deprecate 'Transport.append' in favor of Transport.append_file or Transport.append_bytes	681	t.append_file, 'missing/path', StringIO('content'))
1955.3.10 by John Arbash Meinel clean up append, append_bytes, and append_multi tests	682
	683	# And we can create new files, too
	684	self.assertEqual(0,
1955.3.15 by John Arbash Meinel Deprecate 'Transport.append' in favor of Transport.append_file or Transport.append_bytes	685	t.append_file('c', StringIO('some text\nfor a missing file\n')))
1955.3.10 by John Arbash Meinel clean up append, append_bytes, and append_multi tests	686	self.check_transport_contents('some text\nfor a missing file\n',
	687	t, 'c')
	688
	689	def test_append_bytes(self):
	690	t = self.get_transport()
	691
	692	if t.is_readonly():
	693	self.assertRaises(TransportNotPossible,
	694	t.append_bytes, 'a', 'add\nsome\nmore\ncontents\n')
	695	return
	696
	697	self.assertEqual(0, t.append_bytes('a', 'diff\ncontents for\na\n'))
	698	self.assertEqual(0, t.append_bytes('b', 'contents\nfor b\n'))
	699
	700	self.assertEqual(20,
	701	t.append_bytes('a', 'add\nsome\nmore\ncontents\n'))
	702
	703	self.check_transport_contents(
	704	'diff\ncontents for\na\nadd\nsome\nmore\ncontents\n',
	705	t, 'a')
	706
	707	# a file with no parent should fail..
	708	self.assertRaises(NoSuchFile,
	709	t.append_bytes, 'missing/path', 'content')
	710
	711	def test_append_multi(self):
	712	t = self.get_transport()
	713
	714	if t.is_readonly():
	715	return
	716	t.put_bytes('a', 'diff\ncontents for\na\n'
	717	'add\nsome\nmore\ncontents\n')
	718	t.put_bytes('b', 'contents\nfor b\n')
	719
1955.3.2 by John Arbash Meinel Implement and test 'Transport.append_bytes', cleanup the tests of plain append	720	self.assertEqual((43, 15),
	721	t.append_multi([('a', StringIO('and\nthen\nsome\nmore\n')),
	722	('b', StringIO('some\nmore\nfor\nb\n'))]))
	723
1530.1.3 by Robert Collins transport implementations now tested consistently.	724	self.check_transport_contents(
	725	'diff\ncontents for\na\n'
	726	'add\nsome\nmore\ncontents\n'
	727	'and\nthen\nsome\nmore\n',
	728	t, 'a')
	729	self.check_transport_contents(
	730	'contents\nfor b\n'
	731	'some\nmore\nfor\nb\n',
	732	t, 'b')
	733
1955.3.2 by John Arbash Meinel Implement and test 'Transport.append_bytes', cleanup the tests of plain append	734	self.assertEqual((62, 31),
	735	t.append_multi(iter([('a', StringIO('a little bit more\n')),
	736	('b', StringIO('from an iterator\n'))])))
1530.1.3 by Robert Collins transport implementations now tested consistently.	737	self.check_transport_contents(
	738	'diff\ncontents for\na\n'
	739	'add\nsome\nmore\ncontents\n'
	740	'and\nthen\nsome\nmore\n'
	741	'a little bit more\n',
	742	t, 'a')
	743	self.check_transport_contents(
	744	'contents\nfor b\n'
	745	'some\nmore\nfor\nb\n'
	746	'from an iterator\n',
	747	t, 'b')
	748
1955.3.2 by John Arbash Meinel Implement and test 'Transport.append_bytes', cleanup the tests of plain append	749	self.assertEqual((80, 0),
	750	t.append_multi([('a', StringIO('some text in a\n')),
	751	('d', StringIO('missing file r\n'))]))
	752
1530.1.3 by Robert Collins transport implementations now tested consistently.	753	self.check_transport_contents(
	754	'diff\ncontents for\na\n'
	755	'add\nsome\nmore\ncontents\n'
	756	'and\nthen\nsome\nmore\n'
	757	'a little bit more\n'
	758	'some text in a\n',
	759	t, 'a')
	760	self.check_transport_contents('missing file r\n', t, 'd')
	761
1955.3.15 by John Arbash Meinel Deprecate 'Transport.append' in favor of Transport.append_file or Transport.append_bytes	762	def test_append_file_mode(self):
1955.3.10 by John Arbash Meinel clean up append, append_bytes, and append_multi tests	763	"""Check that append accepts a mode parameter"""
1666.1.6 by Robert Collins Make knit the default format.	764	# check append accepts a mode
	765	t = self.get_transport()
	766	if t.is_readonly():
1955.3.10 by John Arbash Meinel clean up append, append_bytes, and append_multi tests	767	self.assertRaises(TransportNotPossible,
1955.3.15 by John Arbash Meinel Deprecate 'Transport.append' in favor of Transport.append_file or Transport.append_bytes	768	t.append_file, 'f', StringIO('f'), mode=None)
1666.1.6 by Robert Collins Make knit the default format.	769	return
1955.3.15 by John Arbash Meinel Deprecate 'Transport.append' in favor of Transport.append_file or Transport.append_bytes	770	t.append_file('f', StringIO('f'), mode=None)
1666.1.6 by Robert Collins Make knit the default format.	771
1955.3.2 by John Arbash Meinel Implement and test 'Transport.append_bytes', cleanup the tests of plain append	772	def test_append_bytes_mode(self):
	773	# check append_bytes accepts a mode
	774	t = self.get_transport()
	775	if t.is_readonly():
1955.3.10 by John Arbash Meinel clean up append, append_bytes, and append_multi tests	776	self.assertRaises(TransportNotPossible,
	777	t.append_bytes, 'f', 'f', mode=None)
1955.3.2 by John Arbash Meinel Implement and test 'Transport.append_bytes', cleanup the tests of plain append	778	return
1955.3.10 by John Arbash Meinel clean up append, append_bytes, and append_multi tests	779	t.append_bytes('f', 'f', mode=None)
1955.3.2 by John Arbash Meinel Implement and test 'Transport.append_bytes', cleanup the tests of plain append	780
1530.1.3 by Robert Collins transport implementations now tested consistently.	781	def test_delete(self):
	782	# TODO: Test Transport.delete
	783	t = self.get_transport()
	784
	785	# Not much to do with a readonly transport
	786	if t.is_readonly():
1534.4.9 by Robert Collins Add a readonly decorator for transports.	787	self.assertRaises(TransportNotPossible, t.delete, 'missing')
1530.1.3 by Robert Collins transport implementations now tested consistently.	788	return
	789
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	790	t.put_bytes('a', 'a little bit of text\n')
1530.1.3 by Robert Collins transport implementations now tested consistently.	791	self.failUnless(t.has('a'))
	792	t.delete('a')
	793	self.failIf(t.has('a'))
	794
	795	self.assertRaises(NoSuchFile, t.delete, 'a')
	796
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	797	t.put_bytes('a', 'a text\n')
	798	t.put_bytes('b', 'b text\n')
	799	t.put_bytes('c', 'c text\n')
1530.1.3 by Robert Collins transport implementations now tested consistently.	800	self.assertEqual([True, True, True],
	801	list(t.has_multi(['a', 'b', 'c'])))
	802	t.delete_multi(['a', 'c'])
	803	self.assertEqual([False, True, False],
	804	list(t.has_multi(['a', 'b', 'c'])))
	805	self.failIf(t.has('a'))
	806	self.failUnless(t.has('b'))
	807	self.failIf(t.has('c'))
	808
	809	self.assertRaises(NoSuchFile,
	810	t.delete_multi, ['a', 'b', 'c'])
	811
	812	self.assertRaises(NoSuchFile,
	813	t.delete_multi, iter(['a', 'b', 'c']))
	814
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	815	t.put_bytes('a', 'another a text\n')
	816	t.put_bytes('c', 'another c text\n')
1530.1.3 by Robert Collins transport implementations now tested consistently.	817	t.delete_multi(iter(['a', 'b', 'c']))
	818
	819	# We should have deleted everything
	820	# SftpServer creates control files in the
	821	# working directory, so we can just do a
	822	# plain "listdir".
	823	# self.assertEqual([], os.listdir('.'))
	824
2671.3.1 by Robert Collins * New method ``bzrlib.transport.Transport.get_recommended_page_size``.	825	def test_recommended_page_size(self):
	826	"""Transports recommend a page size for partial access to files."""
	827	t = self.get_transport()
	828	self.assertIsInstance(t.recommended_page_size(), int)
	829
1534.4.15 by Robert Collins Remove shutil dependency in upgrade - create a delete_tree method for transports.	830	def test_rmdir(self):
	831	t = self.get_transport()
	832	# Not much to do with a readonly transport
	833	if t.is_readonly():
	834	self.assertRaises(TransportNotPossible, t.rmdir, 'missing')
	835	return
	836	t.mkdir('adir')
	837	t.mkdir('adir/bdir')
	838	t.rmdir('adir/bdir')
1948.3.12 by Vincent LADEUIL Fix Aaron's third review remarks.	839	# ftp may not be able to raise NoSuchFile for lack of
	840	# details when failing
	841	self.assertRaises((NoSuchFile, PathError), t.rmdir, 'adir/bdir')
1534.4.15 by Robert Collins Remove shutil dependency in upgrade - create a delete_tree method for transports.	842	t.rmdir('adir')
1948.3.12 by Vincent LADEUIL Fix Aaron's third review remarks.	843	self.assertRaises((NoSuchFile, PathError), t.rmdir, 'adir')
1534.4.15 by Robert Collins Remove shutil dependency in upgrade - create a delete_tree method for transports.	844
1553.5.10 by Martin Pool New DirectoryNotEmpty exception, and raise this from local and memory	845	def test_rmdir_not_empty(self):
	846	"""Deleting a non-empty directory raises an exception
	847
	848	sftp (and possibly others) don't give us a specific "directory not
	849	empty" exception -- we can just see that the operation failed.
	850	"""
	851	t = self.get_transport()
	852	if t.is_readonly():
	853	return
	854	t.mkdir('adir')
	855	t.mkdir('adir/bdir')
	856	self.assertRaises(PathError, t.rmdir, 'adir')
	857
2338.5.1 by Andrew Bennetts Fix bug in MemoryTransport.rmdir.	858	def test_rmdir_empty_but_similar_prefix(self):
	859	"""rmdir does not get confused by sibling paths.
	860
	861	A naive implementation of MemoryTransport would refuse to rmdir
	862	".bzr/branch" if there is a ".bzr/branch-format" directory, because it
	863	uses "path.startswith(dir)" on all file paths to determine if directory
	864	is empty.
	865	"""
	866	t = self.get_transport()
	867	if t.is_readonly():
	868	return
	869	t.mkdir('foo')
	870	t.put_bytes('foo-bar', '')
	871	t.mkdir('foo-baz')
	872	t.rmdir('foo')
	873	self.assertRaises((NoSuchFile, PathError), t.rmdir, 'foo')
	874	self.failUnless(t.has('foo-bar'))
	875
1553.5.13 by Martin Pool New Transport.rename that mustn't overwrite	876	def test_rename_dir_succeeds(self):
	877	t = self.get_transport()
	878	if t.is_readonly():
	879	raise TestSkipped("transport is readonly")
	880	t.mkdir('adir')
	881	t.mkdir('adir/asubdir')
	882	t.rename('adir', 'bdir')
	883	self.assertTrue(t.has('bdir/asubdir'))
	884	self.assertFalse(t.has('adir'))
	885
	886	def test_rename_dir_nonempty(self):
	887	"""Attempting to replace a nonemtpy directory should fail"""
	888	t = self.get_transport()
	889	if t.is_readonly():
	890	raise TestSkipped("transport is readonly")
	891	t.mkdir('adir')
	892	t.mkdir('adir/asubdir')
	893	t.mkdir('bdir')
	894	t.mkdir('bdir/bsubdir')
1910.7.17 by Andrew Bennetts Various cosmetic changes.	895	# any kind of PathError would be OK, though we normally expect
1910.7.17 by Andrew Bennetts Various cosmetic changes.	896	# DirectoryNotEmpty
1553.5.13 by Martin Pool New Transport.rename that mustn't overwrite	897	self.assertRaises(PathError, t.rename, 'bdir', 'adir')
	898	# nothing was changed so it should still be as before
	899	self.assertTrue(t.has('bdir/bsubdir'))
	900	self.assertFalse(t.has('adir/bdir'))
	901	self.assertFalse(t.has('adir/bsubdir'))
	902
1534.4.15 by Robert Collins Remove shutil dependency in upgrade - create a delete_tree method for transports.	903	def test_delete_tree(self):
	904	t = self.get_transport()
	905
	906	# Not much to do with a readonly transport
	907	if t.is_readonly():
	908	self.assertRaises(TransportNotPossible, t.delete_tree, 'missing')
	909	return
	910
	911	# and does it like listing ?
	912	t.mkdir('adir')
	913	try:
	914	t.delete_tree('adir')
	915	except TransportNotPossible:
	916	# ok, this transport does not support delete_tree
	917	return
	918
	919	# did it delete that trivial case?
	920	self.assertRaises(NoSuchFile, t.stat, 'adir')
	921
	922	self.build_tree(['adir/',
	923	'adir/file',
	924	'adir/subdir/',
	925	'adir/subdir/file',
	926	'adir/subdir2/',
	927	'adir/subdir2/file',
	928	], transport=t)
	929
	930	t.delete_tree('adir')
	931	# adir should be gone now.
	932	self.assertRaises(NoSuchFile, t.stat, 'adir')
	933
1530.1.3 by Robert Collins transport implementations now tested consistently.	934	def test_move(self):
	935	t = self.get_transport()
	936
	937	if t.is_readonly():
	938	return
	939
	940	# TODO: I would like to use os.listdir() to
	941	# make sure there are no extra files, but SftpServer
	942	# creates control files in the working directory
	943	# perhaps all of this could be done in a subdirectory
	944
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	945	t.put_bytes('a', 'a first file\n')
1530.1.3 by Robert Collins transport implementations now tested consistently.	946	self.assertEquals([True, False], list(t.has_multi(['a', 'b'])))
	947
	948	t.move('a', 'b')
	949	self.failUnless(t.has('b'))
	950	self.failIf(t.has('a'))
	951
	952	self.check_transport_contents('a first file\n', t, 'b')
	953	self.assertEquals([False, True], list(t.has_multi(['a', 'b'])))
	954
	955	# Overwrite a file
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	956	t.put_bytes('c', 'c this file\n')
1530.1.3 by Robert Collins transport implementations now tested consistently.	957	t.move('c', 'b')
	958	self.failIf(t.has('c'))
	959	self.check_transport_contents('c this file\n', t, 'b')
	960
	961	# TODO: Try to write a test for atomicity
	962	# TODO: Test moving into a non-existant subdirectory
	963	# TODO: Test Transport.move_multi
	964
	965	def test_copy(self):
	966	t = self.get_transport()
	967
	968	if t.is_readonly():
	969	return
	970
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	971	t.put_bytes('a', 'a file\n')
1530.1.3 by Robert Collins transport implementations now tested consistently.	972	t.copy('a', 'b')
	973	self.check_transport_contents('a file\n', t, 'b')
	974
	975	self.assertRaises(NoSuchFile, t.copy, 'c', 'd')
	976	os.mkdir('c')
	977	# What should the assert be if you try to copy a
	978	# file over a directory?
	979	#self.assertRaises(Something, t.copy, 'a', 'c')
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	980	t.put_bytes('d', 'text in d\n')
1530.1.3 by Robert Collins transport implementations now tested consistently.	981	t.copy('d', 'b')
	982	self.check_transport_contents('text in d\n', t, 'b')
	983
	984	# TODO: test copy_multi
	985
	986	def test_connection_error(self):
1910.7.17 by Andrew Bennetts Various cosmetic changes.	987	"""ConnectionError is raised when connection is impossible.
	988
	989	The error may be raised from either the constructor or the first
	990	operation on the transport.
	991	"""
1530.1.9 by Robert Collins Test bogus urls with http in the new infrastructure.	992	try:
	993	url = self._server.get_bogus_url()
	994	except NotImplementedError:
	995	raise TestSkipped("Transport %s has no bogus URL support." %
	996	self._server.__class__)
2485.8.38 by Vincent Ladeuil Finish sftp refactoring. Test suite passing.	997	t = get_transport(url)
	998	self.assertRaises((ConnectionError, NoSuchFile), t.get, '.bzr/branch')
1530.1.3 by Robert Collins transport implementations now tested consistently.	999
	1000	def test_stat(self):
	1001	# TODO: Test stat, just try once, and if it throws, stop testing
	1002	from stat import S_ISDIR, S_ISREG
	1003
	1004	t = self.get_transport()
	1005
	1006	try:
	1007	st = t.stat('.')
	1008	except TransportNotPossible, e:
	1009	# This transport cannot stat
	1010	return
	1011
	1012	paths = ['a', 'b/', 'b/c', 'b/d/', 'b/d/e']
	1013	sizes = [14, 0, 16, 0, 18]
1551.2.39 by abentley Fix line endings in tests	1014	self.build_tree(paths, transport=t, line_endings='binary')
1530.1.3 by Robert Collins transport implementations now tested consistently.	1015
	1016	for path, size in zip(paths, sizes):
	1017	st = t.stat(path)
	1018	if path.endswith('/'):
	1019	self.failUnless(S_ISDIR(st.st_mode))
	1020	# directory sizes are meaningless
	1021	else:
	1022	self.failUnless(S_ISREG(st.st_mode))
	1023	self.assertEqual(size, st.st_size)
	1024
	1025	remote_stats = list(t.stat_multi(paths))
	1026	remote_iter_stats = list(t.stat_multi(iter(paths)))
	1027
	1028	self.assertRaises(NoSuchFile, t.stat, 'q')
	1029	self.assertRaises(NoSuchFile, t.stat, 'b/a')
	1030
	1031	self.assertListRaises(NoSuchFile, t.stat_multi, ['a', 'c', 'd'])
	1032	self.assertListRaises(NoSuchFile, t.stat_multi, iter(['a', 'c', 'd']))
1534.4.15 by Robert Collins Remove shutil dependency in upgrade - create a delete_tree method for transports.	1033	self.build_tree(['subdir/', 'subdir/file'], transport=t)
	1034	subdir = t.clone('subdir')
	1035	subdir.stat('./file')
1534.4.26 by Robert Collins Move working tree initialisation out from Branch.initialize, deprecated Branch.initialize to Branch.create.	1036	subdir.stat('.')
1530.1.3 by Robert Collins transport implementations now tested consistently.	1037
	1038	def test_list_dir(self):
	1039	# TODO: Test list_dir, just try once, and if it throws, stop testing
	1040	t = self.get_transport()
	1041
	1042	if not t.listable():
	1043	self.assertRaises(TransportNotPossible, t.list_dir, '.')
	1044	return
	1045
	1046	def sorted_list(d):
	1047	l = list(t.list_dir(d))
	1048	l.sort()
	1049	return l
	1050
1910.7.1 by Andrew Bennetts Make sure list_dir always returns url-escaped names.	1051	self.assertEqual([], sorted_list('.'))
1534.4.15 by Robert Collins Remove shutil dependency in upgrade - create a delete_tree method for transports.	1052	# c2 is precisely one letter longer than c here to test that
	1053	# suffixing is not confused.
1959.2.1 by John Arbash Meinel David Allouche: Make transports return escaped paths	1054	# a%25b checks that quoting is done consistently across transports
	1055	tree_names = ['a', 'a%25b', 'b', 'c/', 'c/d', 'c/e', 'c2/']
2120.3.1 by John Arbash Meinel Fix MemoryTransport.list_dir() implementation, and update tests	1056
1534.4.9 by Robert Collins Add a readonly decorator for transports.	1057	if not t.is_readonly():
1959.2.1 by John Arbash Meinel David Allouche: Make transports return escaped paths	1058	self.build_tree(tree_names, transport=t)
1534.4.9 by Robert Collins Add a readonly decorator for transports.	1059	else:
2120.3.1 by John Arbash Meinel Fix MemoryTransport.list_dir() implementation, and update tests	1060	self.build_tree(tree_names)
1530.1.3 by Robert Collins transport implementations now tested consistently.	1061
1959.2.1 by John Arbash Meinel David Allouche: Make transports return escaped paths	1062	self.assertEqual(
1959.2.3 by John Arbash Meinel Remove some unicode string notations	1063	['a', 'a%2525b', 'b', 'c', 'c2'], sorted_list('.'))
1910.7.1 by Andrew Bennetts Make sure list_dir always returns url-escaped names.	1064	self.assertEqual(['d', 'e'], sorted_list('c'))
1530.1.3 by Robert Collins transport implementations now tested consistently.	1065
1534.4.9 by Robert Collins Add a readonly decorator for transports.	1066	if not t.is_readonly():
	1067	t.delete('c/d')
	1068	t.delete('b')
	1069	else:
2120.3.1 by John Arbash Meinel Fix MemoryTransport.list_dir() implementation, and update tests	1070	os.unlink('c/d')
	1071	os.unlink('b')
1534.4.9 by Robert Collins Add a readonly decorator for transports.	1072
1959.2.3 by John Arbash Meinel Remove some unicode string notations	1073	self.assertEqual(['a', 'a%2525b', 'c', 'c2'], sorted_list('.'))
1910.7.1 by Andrew Bennetts Make sure list_dir always returns url-escaped names.	1074	self.assertEqual(['e'], sorted_list('c'))
1530.1.3 by Robert Collins transport implementations now tested consistently.	1075
1662.1.12 by Martin Pool Translate unknown sftp errors to PathError, no NoSuchFile	1076	self.assertListRaises(PathError, t.list_dir, 'q')
	1077	self.assertListRaises(PathError, t.list_dir, 'c/f')
	1078	self.assertListRaises(PathError, t.list_dir, 'a')
1530.1.3 by Robert Collins transport implementations now tested consistently.	1079
1910.7.1 by Andrew Bennetts Make sure list_dir always returns url-escaped names.	1080	def test_list_dir_result_is_url_escaped(self):
	1081	t = self.get_transport()
	1082	if not t.listable():
	1083	raise TestSkipped("transport not listable")
	1084
	1085	if not t.is_readonly():
	1086	self.build_tree(['a/', 'a/%'], transport=t)
	1087	else:
	1088	self.build_tree(['a/', 'a/%'])
	1089
1910.7.2 by Andrew Bennetts Also assert that list_dir returns plain str objects.	1090	names = list(t.list_dir('a'))
	1091	self.assertEqual(['%25'], names)
	1092	self.assertIsInstance(names[0], str)
1910.7.1 by Andrew Bennetts Make sure list_dir always returns url-escaped names.	1093
2485.8.25 by Vincent Ladeuil Separate abspath from _remote_path, the intents are different.	1094	def test_clone_preserve_info(self):
	1095	t1 = self.get_transport()
	1096	if not isinstance(t1, ConnectedTransport):
	1097	raise TestSkipped("not a connected transport")
	1098
	1099	t2 = t1.clone('subdir')
	1100	self.assertEquals(t1._scheme, t2._scheme)
	1101	self.assertEquals(t1._user, t2._user)
	1102	self.assertEquals(t1._password, t2._password)
	1103	self.assertEquals(t1._host, t2._host)
	1104	self.assertEquals(t1._port, t2._port)
	1105
2485.8.39 by Vincent Ladeuil Add tests around connection reuse.	1106	def test__reuse_for(self):
	1107	t = self.get_transport()
	1108	if not isinstance(t, ConnectedTransport):
	1109	raise TestSkipped("not a connected transport")
	1110
	1111	def new_url(scheme=None, user=None, password=None,
	1112	host=None, port=None, path=None):
	1113	"""Build a new url from t.base chaging only parts of it.
	1114
	1115	Only the parameters different from None will be changed.
	1116	"""
2485.8.53 by Vincent Ladeuil Apply test_connection_sharing to all transports to make smart	1117	if scheme is None: scheme = t._scheme
	1118	if user is None: user = t._user
2485.8.39 by Vincent Ladeuil Add tests around connection reuse.	1119	if password is None: password = t._password
2485.8.53 by Vincent Ladeuil Apply test_connection_sharing to all transports to make smart	1120	if user is None: user = t._user
	1121	if host is None: host = t._host
	1122	if port is None: port = t._port
	1123	if path is None: path = t._path
2485.8.39 by Vincent Ladeuil Add tests around connection reuse.	1124	return t._unsplit_url(scheme, user, password, host, port, path)
	1125
	1126	self.assertIsNot(t, t._reuse_for(new_url(scheme='foo')))
	1127	if t._user == 'me':
	1128	user = 'you'
	1129	else:
	1130	user = 'me'
	1131	self.assertIsNot(t, t._reuse_for(new_url(user=user)))
	1132	# passwords are not taken into account because:
	1133	# - it makes no sense to have two different valid passwords for the
	1134	# same user
	1135	# - _password in ConnectedTransport is intended to collect what the
	1136	# user specified from the command-line and there are cases where the
	1137	# new url can contain no password (if the url was built from an
	1138	# existing transport.base for example)
	1139	# - password are considered part of the credentials provided at
	1140	# connection creation time and as such may not be present in the url
	1141	# (they may be typed by the user when prompted for example)
	1142	self.assertIs(t, t._reuse_for(new_url(password='from space')))
	1143	# We will not connect, we can use a invalid host
	1144	self.assertIsNot(t, t._reuse_for(new_url(host=t._host + 'bar')))
	1145	if t._port == 1234:
	1146	port = 4321
	1147	else:
	1148	port = 1234
	1149	self.assertIsNot(t, t._reuse_for(new_url(port=port)))
	1150
2485.8.53 by Vincent Ladeuil Apply test_connection_sharing to all transports to make smart	1151	def test_connection_sharing(self):
	1152	t = self.get_transport()
	1153	if not isinstance(t, ConnectedTransport):
	1154	raise TestSkipped("not a connected transport")
	1155
	1156	c = t.clone('subdir')
2485.8.54 by Vincent Ladeuil Refactor medium uses by making a distinction betweem shared and real medium.	1157	# Some transports will create the connection only when needed
2485.8.53 by Vincent Ladeuil Apply test_connection_sharing to all transports to make smart	1158	t.has('surely_not') # Force connection
	1159	self.assertIs(t._get_connection(), c._get_connection())
	1160
2485.8.54 by Vincent Ladeuil Refactor medium uses by making a distinction betweem shared and real medium.	1161	# Temporary failure, we need to create a new dummy connection
2485.8.53 by Vincent Ladeuil Apply test_connection_sharing to all transports to make smart	1162	new_connection = object()
	1163	t._set_connection(new_connection)
2485.8.54 by Vincent Ladeuil Refactor medium uses by making a distinction betweem shared and real medium.	1164	# Check that both transports use the same connection
2485.8.53 by Vincent Ladeuil Apply test_connection_sharing to all transports to make smart	1165	self.assertIs(new_connection, t._get_connection())
	1166	self.assertIs(new_connection, c._get_connection())
	1167
2485.8.39 by Vincent Ladeuil Add tests around connection reuse.	1168	def test_reuse_connection_for_various_paths(self):
	1169	t = self.get_transport()
	1170	if not isinstance(t, ConnectedTransport):
	1171	raise TestSkipped("not a connected transport")
	1172
	1173	t.has('surely_not') # Force connection
	1174	self.assertIsNot(None, t._get_connection())
	1175
	1176	subdir = t._reuse_for(t.base + 'whatever/but/deep/down/the/path')
	1177	self.assertIsNot(t, subdir)
	1178	self.assertIs(t._get_connection(), subdir._get_connection())
	1179
	1180	home = subdir._reuse_for(t.base + 'home')
	1181	self.assertIs(t._get_connection(), home._get_connection())
	1182	self.assertIs(subdir._get_connection(), home._get_connection())
	1183
1530.1.3 by Robert Collins transport implementations now tested consistently.	1184	def test_clone(self):
	1185	# TODO: Test that clone moves up and down the filesystem
	1186	t1 = self.get_transport()
	1187
	1188	self.build_tree(['a', 'b/', 'b/c'], transport=t1)
	1189
	1190	self.failUnless(t1.has('a'))
	1191	self.failUnless(t1.has('b/c'))
	1192	self.failIf(t1.has('c'))
	1193
	1194	t2 = t1.clone('b')
	1195	self.assertEqual(t1.base + 'b/', t2.base)
	1196
	1197	self.failUnless(t2.has('c'))
	1198	self.failIf(t2.has('a'))
	1199
	1200	t3 = t2.clone('..')
	1201	self.failUnless(t3.has('a'))
	1202	self.failIf(t3.has('c'))
	1203
	1204	self.failIf(t1.has('b/d'))
	1205	self.failIf(t2.has('d'))
	1206	self.failIf(t3.has('b/d'))
	1207
	1208	if t1.is_readonly():
	1209	open('b/d', 'wb').write('newfile\n')
	1210	else:
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	1211	t2.put_bytes('d', 'newfile\n')
1530.1.3 by Robert Collins transport implementations now tested consistently.	1212
	1213	self.failUnless(t1.has('b/d'))
	1214	self.failUnless(t2.has('d'))
	1215	self.failUnless(t3.has('b/d'))
	1216
1910.15.1 by Andrew Bennetts More tests for abspath and clone behaviour	1217	def test_clone_to_root(self):
	1218	orig_transport = self.get_transport()
	1219	# Repeatedly go up to a parent directory until we're at the root
	1220	# directory of this transport
	1221	root_transport = orig_transport
1986.1.10 by Robert Collins Merge from bzr.dev, fixing found bugs handling 'has('/')' in MemoryTransport and SFTP transports.	1222	new_transport = root_transport.clone("..")
2245.6.1 by Alexander Belchenko win32 UNC path: recursive cloning UNC path to root stops on //HOST, not on //	1223	# as we are walking up directories, the path must be
1986.1.10 by Robert Collins Merge from bzr.dev, fixing found bugs handling 'has('/')' in MemoryTransport and SFTP transports.	1224	# growing less, except at the top
	1225	self.assertTrue(len(new_transport.base) < len(root_transport.base)
	1226	or new_transport.base == root_transport.base)
	1227	while new_transport.base != root_transport.base:
	1228	root_transport = new_transport
	1229	new_transport = root_transport.clone("..")
2245.6.1 by Alexander Belchenko win32 UNC path: recursive cloning UNC path to root stops on //HOST, not on //	1230	# as we are walking up directories, the path must be
1986.1.10 by Robert Collins Merge from bzr.dev, fixing found bugs handling 'has('/')' in MemoryTransport and SFTP transports.	1231	# growing less, except at the top
	1232	self.assertTrue(len(new_transport.base) < len(root_transport.base)
	1233	or new_transport.base == root_transport.base)
1910.15.1 by Andrew Bennetts More tests for abspath and clone behaviour	1234
	1235	# Cloning to "/" should take us to exactly the same location.
	1236	self.assertEqual(root_transport.base, orig_transport.clone("/").base)
1986.1.10 by Robert Collins Merge from bzr.dev, fixing found bugs handling 'has('/')' in MemoryTransport and SFTP transports.	1237	# the abspath of "/" from the original transport should be the same
	1238	# as the base at the root:
	1239	self.assertEqual(orig_transport.abspath("/"), root_transport.base)
1910.15.1 by Andrew Bennetts More tests for abspath and clone behaviour	1240
1910.15.5 by Andrew Bennetts Transport behaviour at the root of the URL is now defined and tested.	1241	# At the root, the URL must still end with / as its a directory
	1242	self.assertEqual(root_transport.base[-1], '/')
	1243
	1244	def test_clone_from_root(self):
	1245	"""At the root, cloning to a simple dir should just do string append."""
	1246	orig_transport = self.get_transport()
	1247	root_transport = orig_transport.clone('/')
	1248	self.assertEqual(root_transport.base + '.bzr/',
	1249	root_transport.clone('.bzr').base)
	1250
1910.15.1 by Andrew Bennetts More tests for abspath and clone behaviour	1251	def test_base_url(self):
	1252	t = self.get_transport()
	1253	self.assertEqual('/', t.base[-1])
	1254
1530.1.3 by Robert Collins transport implementations now tested consistently.	1255	def test_relpath(self):
	1256	t = self.get_transport()
	1257	self.assertEqual('', t.relpath(t.base))
	1258	# base ends with /
	1259	self.assertEqual('', t.relpath(t.base[:-1]))
	1260	# subdirs which dont exist should still give relpaths.
	1261	self.assertEqual('foo', t.relpath(t.base + 'foo'))
	1262	# trailing slash should be the same.
	1263	self.assertEqual('foo', t.relpath(t.base + 'foo/'))
	1264
1636.1.1 by Robert Collins Fix calling relpath() and abspath() on transports at their root.	1265	def test_relpath_at_root(self):
	1266	t = self.get_transport()
	1267	# clone all the way to the top
	1268	new_transport = t.clone('..')
	1269	while new_transport.base != t.base:
	1270	t = new_transport
	1271	new_transport = t.clone('..')
	1272	# we must be able to get a relpath below the root
	1273	self.assertEqual('', t.relpath(t.base))
	1274	# and a deeper one should work too
	1275	self.assertEqual('foo/bar', t.relpath(t.base + 'foo/bar'))
	1276
1530.1.3 by Robert Collins transport implementations now tested consistently.	1277	def test_abspath(self):
	1278	# smoke test for abspath. Corner cases for backends like unix fs's
	1279	# that have aliasing problems like symlinks should go in backend
	1280	# specific test cases.
	1281	transport = self.get_transport()
2485.8.21 by Vincent Ladeuil Simplify debug.	1282
1530.1.3 by Robert Collins transport implementations now tested consistently.	1283	self.assertEqual(transport.base + 'relpath',
	1284	transport.abspath('relpath'))
	1285
1910.15.1 by Andrew Bennetts More tests for abspath and clone behaviour	1286	# This should work without raising an error.
	1287	transport.abspath("/")
	1288
	1289	# the abspath of "/" and "/foo/.." should result in the same location
	1290	self.assertEqual(transport.abspath("/"), transport.abspath("/foo/.."))
	1291
2070.3.1 by Andrew Bennetts Fix memory_transport.abspath('/foo')	1292	self.assertEqual(transport.clone("/").abspath('foo'),
	1293	transport.abspath("/foo"))
	1294
1685.1.9 by John Arbash Meinel Updated LocalTransport so that it's base is now a URL rather than a local path. This helps consistency with all other functions. To do so, I added local_abspath() which returns the local path, and local_path_to/from_url	1295	def test_local_abspath(self):
	1296	transport = self.get_transport()
	1297	try:
	1298	p = transport.local_abspath('.')
2018.18.4 by Martin Pool Change Transport.local_abspath to raise NotLocalUrl, and test.	1299	except (errors.NotLocalUrl, TransportNotPossible), e:
2018.18.22 by Martin Pool merge bzr.dev	1300	# should be formattable
2018.18.4 by Martin Pool Change Transport.local_abspath to raise NotLocalUrl, and test.	1301	s = str(e)
1685.1.9 by John Arbash Meinel Updated LocalTransport so that it's base is now a URL rather than a local path. This helps consistency with all other functions. To do so, I added local_abspath() which returns the local path, and local_path_to/from_url	1302	else:
	1303	self.assertEqual(getcwd(), p)
	1304
1636.1.1 by Robert Collins Fix calling relpath() and abspath() on transports at their root.	1305	def test_abspath_at_root(self):
	1306	t = self.get_transport()
	1307	# clone all the way to the top
	1308	new_transport = t.clone('..')
	1309	while new_transport.base != t.base:
	1310	t = new_transport
	1311	new_transport = t.clone('..')
	1312	# we must be able to get a abspath of the root when we ask for
	1313	# t.abspath('..') - this due to our choice that clone('..')
	1314	# should return the root from the root, combined with the desire that
	1315	# the url from clone('..') and from abspath('..') should be the same.
	1316	self.assertEqual(t.base, t.abspath('..'))
	1317	# '' should give us the root
	1318	self.assertEqual(t.base, t.abspath(''))
	1319	# and a path should append to the url
	1320	self.assertEqual(t.base + 'foo', t.abspath('foo'))
	1321
1530.1.3 by Robert Collins transport implementations now tested consistently.	1322	def test_iter_files_recursive(self):
1530.1.4 by Robert Collins integrate Memory tests into transport interface tests.	1323	transport = self.get_transport()
	1324	if not transport.listable():
1553.5.13 by Martin Pool New Transport.rename that mustn't overwrite	1325	self.assertRaises(TransportNotPossible,
1530.1.4 by Robert Collins integrate Memory tests into transport interface tests.	1326	transport.iter_files_recursive)
	1327	return
1553.5.13 by Martin Pool New Transport.rename that mustn't overwrite	1328	self.build_tree(['isolated/',
1530.1.4 by Robert Collins integrate Memory tests into transport interface tests.	1329	'isolated/dir/',
	1330	'isolated/dir/foo',
	1331	'isolated/dir/bar',
1959.2.1 by John Arbash Meinel David Allouche: Make transports return escaped paths	1332	'isolated/dir/b%25z', # make sure quoting is correct
1530.1.4 by Robert Collins integrate Memory tests into transport interface tests.	1333	'isolated/bar'],
	1334	transport=transport)
1530.1.3 by Robert Collins transport implementations now tested consistently.	1335	paths = set(transport.iter_files_recursive())
1553.5.13 by Martin Pool New Transport.rename that mustn't overwrite	1336	# nb the directories are not converted
	1337	self.assertEqual(paths,
	1338	set(['isolated/dir/foo',
	1339	'isolated/dir/bar',
1959.2.1 by John Arbash Meinel David Allouche: Make transports return escaped paths	1340	'isolated/dir/b%2525z',
1553.5.13 by Martin Pool New Transport.rename that mustn't overwrite	1341	'isolated/bar']))
	1342	sub_transport = transport.clone('isolated')
	1343	paths = set(sub_transport.iter_files_recursive())
1959.2.1 by John Arbash Meinel David Allouche: Make transports return escaped paths	1344	self.assertEqual(paths,
	1345	set(['dir/foo', 'dir/bar', 'dir/b%2525z', 'bar']))
	1346
	1347	def test_copy_tree(self):
	1348	# TODO: test file contents and permissions are preserved. This test was
	1349	# added just to ensure that quoting was handled correctly.
	1350	# -- David Allouche 2006-08-11
	1351	transport = self.get_transport()
	1352	if not transport.listable():
	1353	self.assertRaises(TransportNotPossible,
	1354	transport.iter_files_recursive)
	1355	return
	1356	if transport.is_readonly():
	1357	return
	1358	self.build_tree(['from/',
	1359	'from/dir/',
	1360	'from/dir/foo',
	1361	'from/dir/bar',
	1362	'from/dir/b%25z', # make sure quoting is correct
	1363	'from/bar'],
	1364	transport=transport)
	1365	transport.copy_tree('from', 'to')
	1366	paths = set(transport.iter_files_recursive())
	1367	self.assertEqual(paths,
	1368	set(['from/dir/foo',
	1369	'from/dir/bar',
	1370	'from/dir/b%2525z',
	1371	'from/bar',
	1372	'to/dir/foo',
	1373	'to/dir/bar',
	1374	'to/dir/b%2525z',
	1375	'to/bar',]))
1185.85.76 by John Arbash Meinel Adding an InvalidURL so transports can report they expect utf-8 quoted paths. Updated tests	1376
	1377	def test_unicode_paths(self):
1685.1.57 by Martin Pool [broken] Skip unicode blackbox tests if not supported by filesystem	1378	"""Test that we can read/write files with Unicode names."""
1185.85.76 by John Arbash Meinel Adding an InvalidURL so transports can report they expect utf-8 quoted paths. Updated tests	1379	t = self.get_transport()
	1380
1711.7.36 by John Arbash Meinel Use different filenames to avoid path collisions on win32 w/ FAT32	1381	# With FAT32 and certain encodings on win32
	1382	# '\xe5' and '\xe4' actually map to the same file
	1383	# adding a suffix kicks in the 'preserving but insensitive'
	1384	# route, and maintains the right files
	1385	files = [u'\xe5.1', # a w/ circle iso-8859-1
	1386	u'\xe4.2', # a w/ dots iso-8859-1
1185.85.76 by John Arbash Meinel Adding an InvalidURL so transports can report they expect utf-8 quoted paths. Updated tests	1387	u'\u017d', # Z with umlat iso-8859-2
	1388	u'\u062c', # Arabic j
	1389	u'\u0410', # Russian A
	1390	u'\u65e5', # Kanji person
	1391	]
	1392
1685.1.72 by Wouter van Heyst StubSFTPServer should use bytestreams rather than unicode	1393	try:
1711.4.13 by John Arbash Meinel Use line_endings='binary' for win32	1394	self.build_tree(files, transport=t, line_endings='binary')
1685.1.72 by Wouter van Heyst StubSFTPServer should use bytestreams rather than unicode	1395	except UnicodeError:
	1396	raise TestSkipped("cannot handle unicode paths in current encoding")
1185.85.76 by John Arbash Meinel Adding an InvalidURL so transports can report they expect utf-8 quoted paths. Updated tests	1397
	1398	# A plain unicode string is not a valid url
	1399	for fname in files:
	1400	self.assertRaises(InvalidURL, t.get, fname)
	1401
	1402	for fname in files:
	1403	fname_utf8 = fname.encode('utf-8')
	1404	contents = 'contents of %s\n' % (fname_utf8,)
1685.1.45 by John Arbash Meinel Moved url functions into bzrlib.urlutils	1405	self.check_transport_contents(contents, t, urlutils.escape(fname))
1185.85.76 by John Arbash Meinel Adding an InvalidURL so transports can report they expect utf-8 quoted paths. Updated tests	1406
1534.4.26 by Robert Collins Move working tree initialisation out from Branch.initialize, deprecated Branch.initialize to Branch.create.	1407	def test_connect_twice_is_same_content(self):
2485.8.21 by Vincent Ladeuil Simplify debug.	1408	# check that our server (whatever it is) is accessible reliably
1534.4.26 by Robert Collins Move working tree initialisation out from Branch.initialize, deprecated Branch.initialize to Branch.create.	1409	# via get_transport and multiple connections share content.
	1410	transport = self.get_transport()
	1411	if transport.is_readonly():
	1412	return
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	1413	transport.put_bytes('foo', 'bar')
2485.8.21 by Vincent Ladeuil Simplify debug.	1414	transport3 = self.get_transport()
2485.8.21 by Vincent Ladeuil Simplify debug.	1415	self.check_transport_contents('bar', transport3, 'foo')
1534.4.26 by Robert Collins Move working tree initialisation out from Branch.initialize, deprecated Branch.initialize to Branch.create.	1416	# its base should be usable.
2485.8.25 by Vincent Ladeuil Separate abspath from _remote_path, the intents are different.	1417	transport4 = get_transport(transport.base)
2485.8.21 by Vincent Ladeuil Simplify debug.	1418	self.check_transport_contents('bar', transport4, 'foo')
1534.4.26 by Robert Collins Move working tree initialisation out from Branch.initialize, deprecated Branch.initialize to Branch.create.	1419
	1420	# now opening at a relative url should give use a sane result:
	1421	transport.mkdir('newdir')
2485.8.25 by Vincent Ladeuil Separate abspath from _remote_path, the intents are different.	1422	transport5 = get_transport(transport.base + "newdir")
2485.8.21 by Vincent Ladeuil Simplify debug.	1423	transport6 = transport5.clone('..')
2485.8.21 by Vincent Ladeuil Simplify debug.	1424	self.check_transport_contents('bar', transport6, 'foo')
1534.4.26 by Robert Collins Move working tree initialisation out from Branch.initialize, deprecated Branch.initialize to Branch.create.	1425
	1426	def test_lock_write(self):
1910.16.1 by Andrew Bennetts lock_read and lock_write may raise TransportNotPossible.	1427	"""Test transport-level write locks.
	1428
	1429	These are deprecated and transports may decline to support them.
	1430	"""
1534.4.26 by Robert Collins Move working tree initialisation out from Branch.initialize, deprecated Branch.initialize to Branch.create.	1431	transport = self.get_transport()
	1432	if transport.is_readonly():
	1433	self.assertRaises(TransportNotPossible, transport.lock_write, 'foo')
	1434	return
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	1435	transport.put_bytes('lock', '')
1910.16.1 by Andrew Bennetts lock_read and lock_write may raise TransportNotPossible.	1436	try:
	1437	lock = transport.lock_write('lock')
1752.3.6 by Andrew Bennetts Merge from test-tweaks	1438	except TransportNotPossible:
1910.16.1 by Andrew Bennetts lock_read and lock_write may raise TransportNotPossible.	1439	return
1534.4.26 by Robert Collins Move working tree initialisation out from Branch.initialize, deprecated Branch.initialize to Branch.create.	1440	# TODO make this consistent on all platforms:
	1441	# self.assertRaises(LockError, transport.lock_write, 'lock')
	1442	lock.unlock()
	1443
	1444	def test_lock_read(self):
1910.16.1 by Andrew Bennetts lock_read and lock_write may raise TransportNotPossible.	1445	"""Test transport-level read locks.
	1446
	1447	These are deprecated and transports may decline to support them.
	1448	"""
1534.4.26 by Robert Collins Move working tree initialisation out from Branch.initialize, deprecated Branch.initialize to Branch.create.	1449	transport = self.get_transport()
	1450	if transport.is_readonly():
	1451	file('lock', 'w').close()
	1452	else:
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	1453	transport.put_bytes('lock', '')
1910.16.1 by Andrew Bennetts lock_read and lock_write may raise TransportNotPossible.	1454	try:
	1455	lock = transport.lock_read('lock')
1752.3.6 by Andrew Bennetts Merge from test-tweaks	1456	except TransportNotPossible:
1910.16.1 by Andrew Bennetts lock_read and lock_write may raise TransportNotPossible.	1457	return
1534.4.26 by Robert Collins Move working tree initialisation out from Branch.initialize, deprecated Branch.initialize to Branch.create.	1458	# TODO make this consistent on all platforms:
	1459	# self.assertRaises(LockError, transport.lock_read, 'lock')
	1460	lock.unlock()
1185.85.80 by John Arbash Meinel [merge] jam-integration 1527, including branch-formats, help text, misc bug fixes.	1461
1594.2.5 by Robert Collins Readv patch from Johan Rydberg giving knits partial download support.	1462	def test_readv(self):
	1463	transport = self.get_transport()
	1464	if transport.is_readonly():
	1465	file('a', 'w').write('0123456789')
	1466	else:
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	1467	transport.put_bytes('a', '0123456789')
1185.85.76 by John Arbash Meinel Adding an InvalidURL so transports can report they expect utf-8 quoted paths. Updated tests	1468
2004.1.22 by v.ladeuil+lp at free Implements Range header handling for GET requests. Fix a test.	1469	d = list(transport.readv('a', ((0, 1),)))
	1470	self.assertEqual(d[0], (0, '0'))
	1471
1594.2.17 by Robert Collins Better readv coalescing, now with test, and progress during knit index reading.	1472	d = list(transport.readv('a', ((0, 1), (1, 1), (3, 2), (9, 1))))
1594.2.5 by Robert Collins Readv patch from Johan Rydberg giving knits partial download support.	1473	self.assertEqual(d[0], (0, '0'))
1594.2.17 by Robert Collins Better readv coalescing, now with test, and progress during knit index reading.	1474	self.assertEqual(d[1], (1, '1'))
	1475	self.assertEqual(d[2], (3, '34'))
	1476	self.assertEqual(d[3], (9, '9'))
1786.1.8 by John Arbash Meinel [merge] Johan Rydberg test updates	1477
1864.5.2 by John Arbash Meinel always read in sorted order, and return in requested order, but only cache what is currently out of order	1478	def test_readv_out_of_order(self):
	1479	transport = self.get_transport()
	1480	if transport.is_readonly():
	1481	file('a', 'w').write('0123456789')
	1482	else:
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	1483	transport.put_bytes('a', '01234567890')
1864.5.2 by John Arbash Meinel always read in sorted order, and return in requested order, but only cache what is currently out of order	1484
	1485	d = list(transport.readv('a', ((1, 1), (9, 1), (0, 1), (3, 2))))
	1486	self.assertEqual(d[0], (1, '1'))
	1487	self.assertEqual(d[1], (9, '9'))
	1488	self.assertEqual(d[2], (0, '0'))
	1489	self.assertEqual(d[3], (3, '34'))
1752.2.40 by Andrew Bennetts Merge from bzr.dev.	1490
2671.3.9 by Robert Collins Review feedback and fix VFat emulated transports to not claim to have unix permissions.	1491	def test_get_with_open_write_stream_sees_all_content(self):
2671.3.5 by Robert Collins * New methods on ``bzrlib.transport.Transport`` ``open_file_stream`` and	1492	t = self.get_transport()
	1493	if t.is_readonly():
	1494	return
2671.3.9 by Robert Collins Review feedback and fix VFat emulated transports to not claim to have unix permissions.	1495	handle = t.open_write_stream('foo')
2671.3.5 by Robert Collins * New methods on ``bzrlib.transport.Transport`` ``open_file_stream`` and	1496	try:
2671.3.6 by Robert Collins Review feedback.	1497	handle.write('bcd')
2671.3.5 by Robert Collins * New methods on ``bzrlib.transport.Transport`` ``open_file_stream`` and	1498	self.assertEqual([(0, 'b'), (2, 'd')], list(t.readv('foo', ((0,1), (2,1)))))
	1499	finally:
2671.3.6 by Robert Collins Review feedback.	1500	handle.close()
2671.3.5 by Robert Collins * New methods on ``bzrlib.transport.Transport`` ``open_file_stream`` and	1501
2018.2.3 by Andrew Bennetts Starting factoring out the smart server client "medium" from the protocol.	1502	def test_get_smart_medium(self):
	1503	"""All transports must either give a smart medium, or know they can't.
	1504	"""
	1505	transport = self.get_transport()
	1506	try:
2018.5.2 by Andrew Bennetts Start splitting bzrlib/transport/smart.py into a package.	1507	client_medium = transport.get_smart_medium()
	1508	self.assertIsInstance(client_medium, medium.SmartClientMedium)
2018.2.3 by Andrew Bennetts Starting factoring out the smart server client "medium" from the protocol.	1509	except errors.NoSmartMedium:
	1510	# as long as we got it we're fine
	1511	pass
	1512
2001.3.2 by John Arbash Meinel Force all transports to raise ShortReadvError if they can	1513	def test_readv_short_read(self):
	1514	transport = self.get_transport()
	1515	if transport.is_readonly():
	1516	file('a', 'w').write('0123456789')
	1517	else:
	1518	transport.put_bytes('a', '01234567890')
	1519
	1520	# This is intentionally reading off the end of the file
	1521	# since we are sure that it cannot get there
2000.3.9 by v.ladeuil+lp at free The tests that would have help avoid bug #73948 and all that mess :)	1522	self.assertListRaises((errors.ShortReadvError, errors.InvalidRange,
	1523	# Can be raised by paramiko
	1524	AssertionError),
2001.3.2 by John Arbash Meinel Force all transports to raise ShortReadvError if they can	1525	transport.readv, 'a', [(1,1), (8,10)])
	1526
	1527	# This is trying to seek past the end of the file, it should
	1528	# also raise a special error
2000.3.9 by v.ladeuil+lp at free The tests that would have help avoid bug #73948 and all that mess :)	1529	self.assertListRaises((errors.ShortReadvError, errors.InvalidRange),
2001.3.2 by John Arbash Meinel Force all transports to raise ShortReadvError if they can	1530	transport.readv, 'a', [(12,2)])