Merge lp:~dobey/ubuntuone-dev-tools/update-4-2 into lp:ubuntuone-dev-tools/stable-4-2

Proposed by dobey
Status: Merged
Merged at revision: 99
Proposed branch: lp:~dobey/ubuntuone-dev-tools/update-4-2
Merge into: lp:ubuntuone-dev-tools/stable-4-2
Diff against target: 723 lines (+121/-111)
19 files modified
bin/u1lint (+9/-11)
setup.py (+3/-4)
ubuntuone/devtools/handlers.py (+3/-3)
ubuntuone/devtools/runners/__init__.py (+1/-1)
ubuntuone/devtools/services/__init__.py (+3/-3)
ubuntuone/devtools/services/dbus.py (+1/-1)
ubuntuone/devtools/services/squid.py (+10/-9)
ubuntuone/devtools/services/tests/test_dbus.py (+5/-5)
ubuntuone/devtools/services/tests/test_squid.py (+9/-8)
ubuntuone/devtools/testcases/__init__.py (+3/-3)
ubuntuone/devtools/testcases/dbus.py (+2/-2)
ubuntuone/devtools/testcases/tests/test_squid_testcase.py (+19/-13)
ubuntuone/devtools/testcases/tests/test_txsocketserver.py (+14/-14)
ubuntuone/devtools/testcases/txsocketserver.py (+17/-15)
ubuntuone/devtools/testing/tests/test_txwebserver.py (+6/-4)
ubuntuone/devtools/testing/txcheck.py (+6/-6)
ubuntuone/devtools/testing/txwebserver.py (+6/-5)
ubuntuone/devtools/tests/test_decorators.py (+1/-1)
ubuntuone/devtools/tests/test_txcheck.py (+3/-3)
To merge this branch: bzr merge lp:~dobey/ubuntuone-dev-tools/update-4-2
Reviewer Review Type Date Requested Status
Roberto Alsina (community) Approve
Review via email: mp+137057@code.launchpad.net

Commit message

Fix pep8 warnings that are newly presented in pep8 1.3

To post a comment you must log in.
Revision history for this message
Roberto Alsina (ralsina) :
review: Approve
Revision history for this message
Ubuntu One Auto Pilot (otto-pilot) wrote :
Download full text (24.8 KiB)

The attempt to merge lp:~dobey/ubuntuone-dev-tools/update-4-2 into lp:ubuntuone-dev-tools/stable-4-2 failed. Below is the output from the failed tests.

Starting squid version...
Waiting for squid to start....
Waiting for squid to start.....
ubuntuone.devtools.testing.tests.test_txwebserver
  MultipleWebServersTestCase
    test_multiple_requests ... [OK]
    test_single_request ... [OK]
twisted.trial.unittest
  TestCase
    runTest ... [OK]
ubuntuone.devtools.testing.tests.test_txwebserver
  WebServerTestCase
    test_get_iri ... [OK]
    test_get_port ... [OK]
    test_multiple_requests ... [OK]
    test_single_request ... [OK]
ubuntuone.devtools.testcases
  BaseTestCase
    runTest ... [OK]
ubuntuone.devtools.tests.test_decorators
  TestSkipBasicDecorators
    test_skip_class ... [OK]
    test_skip_decorators ... [OK]
ubuntuone.devtools.tests.test_txcheck
  TestCheckTwistedTestClass
    test_bad_mixin_order ... [OK]
    test_bare_super ... [OK]
    test_inline_callbacks ... [OK]
    test_inline_callbacks_missing ... [OK]
    test_missing_return ... [OK]
    test_no_problems ... [OK]
    test_not_twisted ... [OK]
    test_ok_mixin_order ... [OK]
    test_super_not_called ... [OK]
  TestTwistedCheckSuite
    test_suite_catches_problems ... [OK]
    test_suite_runs_tests ... [OK]
twisted.trial.unittest
  TestCase
    runTest ... [OK]
ubuntuone.devtools.testcases
  BaseTestCase
    runTest ... [OK]
ubuntuone.devtools.tests.test_utils
  OptionParserTestCase
    test_get_flags_long_arg ... [OK]
    test_get_flags_short_arg ... [OK]
    test_get_params_combined_arg ... [OK]
    test_get_params_missing_arg ... [OK]
    test_get_params_short_arg ... [OK]
    test_get_params_split_arg ... [OK]
    test_unknown_option ... [OK]
ubuntuone.devtools.testcases.tests.te...

99. By dobey

Fix pep8 warnings that are newly presented in pep8 1.3

Preview Diff

[H/L] Next/Prev Comment, [J/K] Next/Prev File, [N/P] Next/Prev Hunk
=== modified file 'bin/u1lint'
--- bin/u1lint 2012-10-18 21:17:22 +0000
+++ bin/u1lint 2012-11-29 21:41:22 +0000
@@ -162,7 +162,7 @@
162162
163 # pylint: disable=E1103163 # pylint: disable=E1103
164 return [os.path.join(SRCDIR, item) for item in164 return [os.path.join(SRCDIR, item) for item in
165 config.get("MASTER", "ignore").split(",")]165 config.get("MASTER", "ignore").split(",")]
166 except (TypeError, configparser.NoOptionError):166 except (TypeError, configparser.NoOptionError):
167 return []167 return []
168 # pylint: enable=E1103168 # pylint: enable=E1103
@@ -210,15 +210,13 @@
210 continue210 continue
211211
212 # Skip protobuf-generated and backup files212 # Skip protobuf-generated and backup files
213 if (filename.endswith("_pb2.py")213 if filename.endswith("_pb2.py") \
214 or filename.endswith("~")214 or filename.endswith("~") \
215 or filename.endswith(".bat")215 or filename.endswith(".bat"):
216 ):
217 continue216 continue
218217
219 if (filename.endswith(".py")218 if filename.endswith(".py") \
220 or filepath.endswith("bin" + os.path.sep)219 or filepath.endswith("bin" + os.path.sep):
221 ):
222 pyfiles.append(os.path.join(root, filename))220 pyfiles.append(os.path.join(root, filename))
223221
224 pyfiles.sort()222 pyfiles.sort()
@@ -231,14 +229,14 @@
231 usage = '%prog [options]'229 usage = '%prog [options]'
232 parser = OptionParser(usage=usage)230 parser = OptionParser(usage=usage)
233 parser.add_option('-i', '--ignore', dest='ignored', default=None,231 parser.add_option('-i', '--ignore', dest='ignored', default=None,
234 help='comma-separated paths or files, to ignore')232 help='comma-separated paths or files, to ignore')
235 (options, args) = parser.parse_args()233 (options, args) = parser.parse_args()
236234
237 failed = False235 failed = False
238 ignored = _read_pylintrc_ignored()236 ignored = _read_pylintrc_ignored()
239 if options.ignored:237 if options.ignored:
240 ignored.extend([os.path.join(SRCDIR, item) for item in238 ignored.extend([os.path.join(SRCDIR, item) for item in
241 map(str.strip, options.ignored.split(','))])239 map(str.strip, options.ignored.split(','))])
242240
243 if os.environ.get('USE_PYFLAKES'):241 if os.environ.get('USE_PYFLAKES'):
244 pylint_args = get_subprocess_start_info('pyflakes')242 pylint_args = get_subprocess_start_info('pyflakes')
@@ -246,7 +244,7 @@
246 pylint_args = get_subprocess_start_info('pylint')244 pylint_args = get_subprocess_start_info('pylint')
247 # append the extra args to the start info245 # append the extra args to the start info
248 pylint_args.extend(['--output-format=parseable',246 pylint_args.extend(['--output-format=parseable',
249 '--include-ids=yes'])247 '--include-ids=yes'])
250 if PYLINTRC:248 if PYLINTRC:
251 pylint_args.append("--rcfile=" + PYLINTRC)249 pylint_args.append("--rcfile=" + PYLINTRC)
252250
253251
=== modified file 'setup.py'
--- setup.py 2012-07-26 21:13:55 +0000
+++ setup.py 2012-11-29 21:41:22 +0000
@@ -80,7 +80,7 @@
80 ('share/man/man1',80 ('share/man/man1',
81 ['man/u1lint.1',81 ['man/u1lint.1',
82 'man/u1trial.1']),82 'man/u1trial.1']),
83 ]83 ]
8484
85setup(name=PACKAGE,85setup(name=PACKAGE,
86 version=VERSION,86 version=VERSION,
@@ -96,7 +96,6 @@
96 extra_path='ubuntuone-dev-tools',96 extra_path='ubuntuone-dev-tools',
97 scripts=scripts,97 scripts=scripts,
98 data_files=DATA_FILES,98 data_files=DATA_FILES,
99 cmdclass={99 cmdclass={'lint': Lint,
100 'lint': Lint,100 },
101 },
102 )101 )
103102
=== modified file 'ubuntuone/devtools/handlers.py'
--- ubuntuone/devtools/handlers.py 2012-08-20 22:15:07 +0000
+++ ubuntuone/devtools/handlers.py 2012-11-29 21:41:22 +0000
@@ -90,8 +90,8 @@
90 def check_exception(self, exception_info, *msgs):90 def check_exception(self, exception_info, *msgs):
91 """Shortcut for checking exceptions."""91 """Shortcut for checking exceptions."""
92 for rec in self.records:92 for rec in self.records:
93 if (rec.levelno == logging.ERROR and93 if rec.levelno == logging.ERROR and \
94 all(m in rec.exc_text + rec.message for m in msgs) and94 all(m in rec.exc_text + rec.message for m in msgs) and \
95 exception_info in rec.exc_info):95 exception_info in rec.exc_info:
96 return True96 return True
97 return False97 return False
9898
=== modified file 'ubuntuone/devtools/runners/__init__.py'
--- ubuntuone/devtools/runners/__init__.py 2012-09-28 13:58:23 +0000
+++ ubuntuone/devtools/runners/__init__.py 2012-11-29 21:41:22 +0000
@@ -151,7 +151,7 @@
151 for test in files:151 for test in files:
152 filepath = os.path.join(root, test)152 filepath = os.path.join(root, test)
153 if test.endswith(".py") and test not in ignored_modules and \153 if test.endswith(".py") and test not in ignored_modules and \
154 not _is_in_ignored_path(filepath, ignored_paths):154 not _is_in_ignored_path(filepath, ignored_paths):
155 self.source_files.append(filepath)155 self.source_files.append(filepath)
156 if test.startswith("test_"):156 if test.startswith("test_"):
157 module_suite = self._load_unittest(filepath)157 module_suite = self._load_unittest(filepath)
158158
=== modified file 'ubuntuone/devtools/services/__init__.py'
--- ubuntuone/devtools/services/__init__.py 2012-04-25 10:27:12 +0000
+++ ubuntuone/devtools/services/__init__.py 2012-11-29 21:41:22 +0000
@@ -37,9 +37,9 @@
37 """Find the first appropriate conf to use."""37 """Find the first appropriate conf to use."""
38 # In case we're running from within the source tree38 # In case we're running from within the source tree
39 path = os.path.abspath(os.path.join(os.path.dirname(__file__),39 path = os.path.abspath(os.path.join(os.path.dirname(__file__),
40 os.path.pardir, os.path.pardir,40 os.path.pardir, os.path.pardir,
41 os.path.pardir,41 os.path.pardir,
42 "data", in_config_file))42 "data", in_config_file))
43 if not os.path.exists(path):43 if not os.path.exists(path):
44 # Use the installed file in $pkgdatadir as source44 # Use the installed file in $pkgdatadir as source
45 for path in load_data_paths("ubuntuone-dev-tools",45 for path in load_data_paths("ubuntuone-dev-tools",
4646
=== modified file 'ubuntuone/devtools/services/dbus.py'
--- ubuntuone/devtools/services/dbus.py 2012-08-28 21:28:15 +0000
+++ ubuntuone/devtools/services/dbus.py 2012-11-29 21:41:22 +0000
@@ -103,7 +103,7 @@
103103
104 if self.dbus_address != "":104 if self.dbus_address != "":
105 os.environ["DBUS_SESSION_BUS_ADDRESS"] = \105 os.environ["DBUS_SESSION_BUS_ADDRESS"] = \
106 self.dbus_address.decode("utf8")106 self.dbus_address.decode("utf8")
107 else:107 else:
108 os.kill(self.dbus_pid, signal.SIGKILL)108 os.kill(self.dbus_pid, signal.SIGKILL)
109 raise DBusLaunchError("There was a problem launching dbus-daemon.")109 raise DBusLaunchError("There was a problem launching dbus-daemon.")
110110
=== modified file 'ubuntuone/devtools/services/squid.py'
--- ubuntuone/devtools/services/squid.py 2012-08-20 21:20:50 +0000
+++ ubuntuone/devtools/services/squid.py 2012-11-29 21:41:22 +0000
@@ -225,13 +225,14 @@
225 spool_path = _get_spool_temp_path(tempdir)225 spool_path = _get_spool_temp_path(tempdir)
226 squid_path = _get_squid_temp_path(tempdir)226 squid_path = _get_squid_temp_path(tempdir)
227 with open(self.config_file, 'w') as out_file:227 with open(self.config_file, 'w') as out_file:
228 out_file.write(template.safe_substitute(228 out_file.write(
229 auth_file=self.auth_file,229 template.safe_substitute(
230 auth_process=self.auth_process,230 auth_file=self.auth_file,
231 noauth_port_number=self.settings['noauth_port'],231 auth_process=self.auth_process,
232 auth_port_number=self.settings['auth_port'],232 noauth_port_number=self.settings['noauth_port'],
233 spool_temp=spool_path,233 auth_port_number=self.settings['auth_port'],
234 squid_temp=squid_path))234 spool_temp=spool_path,
235 squid_temp=squid_path))
235236
236 def _generate_swap(self, config_file):237 def _generate_swap(self, config_file):
237 """Generate the squid swap files."""238 """Generate the squid swap files."""
@@ -271,8 +272,8 @@
271 try:272 try:
272 # Do not use stdout=PIPE or stderr=PIPE with this function.273 # Do not use stdout=PIPE or stderr=PIPE with this function.
273 subprocess.check_call([self.squid] + squid_args,274 subprocess.check_call([self.squid] + squid_args,
274 stdout=subprocess.PIPE,275 stdout=subprocess.PIPE,
275 stderr=subprocess.PIPE)276 stderr=subprocess.PIPE)
276 return True277 return True
277 except subprocess.CalledProcessError:278 except subprocess.CalledProcessError:
278 message += '.'279 message += '.'
279280
=== modified file 'ubuntuone/devtools/services/tests/test_dbus.py'
--- ubuntuone/devtools/services/tests/test_dbus.py 2012-08-20 22:10:29 +0000
+++ ubuntuone/devtools/services/tests/test_dbus.py 2012-11-29 21:41:22 +0000
@@ -47,14 +47,14 @@
47 def test_dbus_session_is_running(self):47 def test_dbus_session_is_running(self):
48 """Test that dbus session is the private one we started."""48 """Test that dbus session is the private one we started."""
49 bus_address = os.environ.get('DBUS_SESSION_BUS_ADDRESS', None)49 bus_address = os.environ.get('DBUS_SESSION_BUS_ADDRESS', None)
50 self.assertEqual(os.path.dirname(50 self.assertEqual(
51 unquote(bus_address.split(',')[0].split('=')[1])),51 os.path.dirname(unquote(bus_address.split(',')[0].split('=')[1])),
52 os.path.dirname(os.getcwd()))52 os.path.dirname(os.getcwd()))
5353
54 def test_config_file_path(self):54 def test_config_file_path(self):
55 """Test that we loaded the config file from the local tree."""55 """Test that we loaded the config file from the local tree."""
56 expected = os.path.abspath(os.path.join(56 expected = os.path.abspath(
57 self.tmpdir, 'dbus-session.conf'))57 os.path.join(self.tmpdir, 'dbus-session.conf'))
58 runner = DBusRunner()58 runner = DBusRunner()
59 # pylint: disable=W021259 # pylint: disable=W0212
60 os.makedirs(self.tmpdir)60 os.makedirs(self.tmpdir)
6161
=== modified file 'ubuntuone/devtools/services/tests/test_squid.py'
--- ubuntuone/devtools/services/tests/test_squid.py 2012-09-06 19:02:51 +0000
+++ ubuntuone/devtools/services/tests/test_squid.py 2012-11-29 21:41:22 +0000
@@ -187,7 +187,7 @@
187 squid.store_proxy_settings(self.settings)187 squid.store_proxy_settings(self.settings)
188 self.assertTrue(('dumps', self.settings) in self.called)188 self.assertTrue(('dumps', self.settings) in self.called)
189 self.assertEqual(self.env[squid.PROXY_ENV_VAR],189 self.assertEqual(self.env[squid.PROXY_ENV_VAR],
190 json.dumps(self.settings))190 json.dumps(self.settings))
191191
192 def test_retrieve_proxy_settings(self):192 def test_retrieve_proxy_settings(self):
193 """Test reading the settings."""193 """Test reading the settings."""
@@ -223,7 +223,7 @@
223 """Perform the assertion when a bin is missing."""223 """Perform the assertion when a bin is missing."""
224 self.assertRaises(squid.SquidLaunchError, squid.SquidRunner)224 self.assertRaises(squid.SquidLaunchError, squid.SquidRunner)
225 self.assertTrue(('fake_find_executable', binary) in self.called,225 self.assertTrue(('fake_find_executable', binary) in self.called,
226 self.called)226 self.called)
227227
228 def test_squid_missing(self):228 def test_squid_missing(self):
229 """Test when squid is missing."""229 """Test when squid is missing."""
@@ -352,12 +352,13 @@
352 self.runner._generate_config_file(self.tmpdir)352 self.runner._generate_config_file(self.tmpdir)
353 # remove the generated file353 # remove the generated file
354 self.addCleanup(os.unlink, self.runner.config_file)354 self.addCleanup(os.unlink, self.runner.config_file)
355 expected_parameters = ('safe_substitute', (),355 expected_parameters = \
356 dict(auth_file=self.runner.auth_file,356 ('safe_substitute', (),
357 noauth_port_number=self.port,357 dict(auth_file=self.runner.auth_file,
358 auth_port_number=self.port,358 noauth_port_number=self.port,
359 spool_temp=squid._get_spool_temp_path(self.tmpdir),359 auth_port_number=self.port,
360 squid_temp=squid._get_squid_temp_path(self.tmpdir)))360 spool_temp=squid._get_spool_temp_path(self.tmpdir),
361 squid_temp=squid._get_squid_temp_path(self.tmpdir)))
361 self.assertTrue(expected_parameters, self.template.called[0])362 self.assertTrue(expected_parameters, self.template.called[0])
362 self.assertEqual(2, self.called.count(('fake_get_port',)))363 self.assertEqual(2, self.called.count(('fake_get_port',)))
363364
364365
=== modified file 'ubuntuone/devtools/testcases/__init__.py'
--- ubuntuone/devtools/testcases/__init__.py 2012-08-21 21:19:41 +0000
+++ ubuntuone/devtools/testcases/__init__.py 2012-11-29 21:41:22 +0000
@@ -64,7 +64,7 @@
64 def decorator(test_item):64 def decorator(test_item):
65 """Decorate the test so that it is skipped."""65 """Decorate the test so that it is skipped."""
66 if not (isinstance(test_item, type) and66 if not (isinstance(test_item, type) and
67 issubclass(test_item, TestCase)):67 issubclass(test_item, TestCase)):
6868
69 @wraps(test_item)69 @wraps(test_item)
70 def skip_wrapper(*args, **kwargs):70 def skip_wrapper(*args, **kwargs):
@@ -106,8 +106,8 @@
106def skipIfNotOS(current_os, reason):106def skipIfNotOS(current_os, reason):
107 """Skip test we are not in a particular os."""107 """Skip test we are not in a particular os."""
108 if os:108 if os:
109 if sys.platform not in current_os or\109 if sys.platform not in current_os or \
110 sys.platform != current_os:110 sys.platform != current_os:
111 return skipTest(reason)111 return skipTest(reason)
112 return _id112 return _id
113 return _id113 return _id
114114
=== modified file 'ubuntuone/devtools/testcases/dbus.py'
--- ubuntuone/devtools/testcases/dbus.py 2012-10-18 21:17:22 +0000
+++ ubuntuone/devtools/testcases/dbus.py 2012-11-29 21:41:22 +0000
@@ -71,7 +71,7 @@
7171
7272
73@skipIf(dbus is None or service is None or DBusGMainLoop is None,73@skipIf(dbus is None or service is None or DBusGMainLoop is None,
74 "The test requires dbus.")74 "The test requires dbus.")
75class DBusTestCase(BaseTestCase):75class DBusTestCase(BaseTestCase):
76 """Test the DBus event handling."""76 """Test the DBus event handling."""
7777
@@ -110,7 +110,7 @@
110 # str instead of anything from ubuntuone.devtools.compat. dbus110 # str instead of anything from ubuntuone.devtools.compat. dbus
111 # expects this to be str regardless of version.111 # expects this to be str regardless of version.
112 self.bus = dbus.bus.BusConnection(address_or_type=str(bus_address),112 self.bus = dbus.bus.BusConnection(address_or_type=str(bus_address),
113 mainloop=self.loop)113 mainloop=self.loop)
114114
115 # Monkeypatch the dbus.SessionBus/SystemBus methods, to ensure we115 # Monkeypatch the dbus.SessionBus/SystemBus methods, to ensure we
116 # always point at our own private bus instance.116 # always point at our own private bus instance.
117117
=== modified file 'ubuntuone/devtools/testcases/tests/test_squid_testcase.py'
--- ubuntuone/devtools/testcases/tests/test_squid_testcase.py 2012-04-24 17:58:16 +0000
+++ ubuntuone/devtools/testcases/tests/test_squid_testcase.py 2012-11-29 21:41:22 +0000
@@ -71,7 +71,7 @@
71 """Provide useful web methods with proxy."""71 """Provide useful web methods with proxy."""
7272
73 def __init__(self, proxy_url=None, proxy_port=None, username=None,73 def __init__(self, proxy_url=None, proxy_port=None, username=None,
74 password=None):74 password=None):
75 """Create a new instance with the proxy settings."""75 """Create a new instance with the proxy settings."""
76 self.proxy_url = proxy_url76 self.proxy_url = proxy_url
77 self.proxy_port = proxy_port77 self.proxy_port = proxy_port
@@ -105,8 +105,9 @@
105 # we try to get the page using the basic auth105 # we try to get the page using the basic auth
106 auth = base64.b64encode('%s:%s' % (self.username, self.password))106 auth = base64.b64encode('%s:%s' % (self.username, self.password))
107 auth_header = 'Basic ' + auth.strip()107 auth_header = 'Basic ' + auth.strip()
108 self.factory = ProxyClientFactory(self.proxy_url, self.proxy_port,108 self.factory = ProxyClientFactory(
109 url, headers={'Proxy-Authorization': auth_header})109 self.proxy_url, self.proxy_port,
110 url, headers={'Proxy-Authorization': auth_header})
110 self._connect(url, contextFactory)111 self._connect(url, contextFactory)
111 return self.factory.deferred112 return self.factory.deferred
112 else:113 else:
@@ -123,7 +124,7 @@
123 headers={'Connection': 'close'})124 headers={'Connection': 'close'})
124 self._connect(url, contextFactory)125 self._connect(url, contextFactory)
125 self.factory.deferred.addErrback(self._process_auth_error, url,126 self.factory.deferred.addErrback(self._process_auth_error, url,
126 contextFactory)127 contextFactory)
127 return self.factory.deferred128 return self.factory.deferred
128129
129 @defer.inlineCallbacks130 @defer.inlineCallbacks
@@ -177,7 +178,8 @@
177 root.putChild(THROWERROR, resource.NoResource())178 root.putChild(THROWERROR, resource.NoResource())
178179
179 unauthorized_resource = resource.ErrorPage(resource.http.UNAUTHORIZED,180 unauthorized_resource = resource.ErrorPage(resource.http.UNAUTHORIZED,
180 "Unauthorized", "Unauthorized")181 "Unauthorized",
182 "Unauthorized")
181 root.putChild(UNAUTHORIZED, unauthorized_resource)183 root.putChild(UNAUTHORIZED, unauthorized_resource)
182184
183 self.site = SaveSite(root)185 self.site = SaveSite(root)
@@ -221,9 +223,10 @@
221 """Clean resources."""223 """Clean resources."""
222 if self.proxy_client is not None:224 if self.proxy_client is not None:
223 self.proxy_client.shutdown()225 self.proxy_client.shutdown()
224 return defer.gatherResults([self.ws.stop(),226 return defer.gatherResults(
225 self.proxy_client.shutdown(),227 [self.ws.stop(),
226 self.proxy_client.factory.disconnected_d])228 self.proxy_client.shutdown(),
229 self.proxy_client.factory.disconnected_d])
227 else:230 else:
228 return self.ws.stop()231 return self.ws.stop()
229232
@@ -234,8 +237,10 @@
234237
235 def access_auth_url(self, address, port, username, password):238 def access_auth_url(self, address, port, username, password):
236 """Access a url throught the proxy."""239 """Access a url throught the proxy."""
237 self.proxy_client = ProxyWebClient(proxy_url=address, proxy_port=port,240 self.proxy_client = ProxyWebClient(proxy_url=address,
238 username=username, password=password)241 proxy_port=port,
242 username=username,
243 password=password)
239 return self.proxy_client.get_page(self.url)244 return self.proxy_client.get_page(self.url)
240245
241 @defer.inlineCallbacks246 @defer.inlineCallbacks
@@ -262,9 +267,10 @@
262 """Test failing accessing the url."""267 """Test failing accessing the url."""
263 settings = self.get_auth_proxy_settings()268 settings = self.get_auth_proxy_settings()
264 # swap password for username to fail269 # swap password for username to fail
265 d = self.failUnlessFailure(self.access_auth_url(settings['host'],270 d = self.failUnlessFailure(
266 settings['port'], settings['password'],271 self.access_auth_url(settings['host'],
267 settings['username']), error.Error)272 settings['port'], settings['password'],
273 settings['username']), error.Error)
268 return d274 return d
269275
270 def test_auth_url_407(self):276 def test_auth_url_407(self):
271277
=== modified file 'ubuntuone/devtools/testcases/tests/test_txsocketserver.py'
--- ubuntuone/devtools/testcases/tests/test_txsocketserver.py 2012-06-08 11:55:53 +0000
+++ ubuntuone/devtools/testcases/tests/test_txsocketserver.py 2012-11-29 21:41:22 +0000
@@ -139,9 +139,9 @@
139 prot.factory._disconnecting = disconnecting139 prot.factory._disconnecting = disconnecting
140 prot.connectionLost()140 prot.connectionLost()
141 self.assertIn('connectionLost', self.called,141 self.assertIn('connectionLost', self.called,
142 'Super connectionLost most be called')142 'Super connectionLost most be called')
143 self.assertEqual(disconnecting,143 self.assertEqual(disconnecting,
144 prot.factory.testserver_on_connection_lost.called)144 prot.factory.testserver_on_connection_lost.called)
145145
146 def test_connection_lost_disconnecting(self):146 def test_connection_lost_disconnecting(self):
147 """Test the connectionLost method."""147 """Test the connectionLost method."""
@@ -163,7 +163,7 @@
163 prot.factory.testserver_on_connection_lost.callback(True)163 prot.factory.testserver_on_connection_lost.callback(True)
164 prot.connectionLost()164 prot.connectionLost()
165 self.assertIn('connectionLost', self.called,165 self.assertIn('connectionLost', self.called,
166 'Super connectionLost must be called')166 'Super connectionLost must be called')
167# pylint: enable=E1102167# pylint: enable=E1102
168168
169169
@@ -187,7 +187,7 @@
187 protocol_instance = protocol_cls()187 protocol_instance = protocol_cls()
188 protocol_instance.connectionMade()188 protocol_instance.connectionMade()
189 self.assertIn('connectionMade', self.called,189 self.assertIn('connectionMade', self.called,
190 'Super connectionMade must be called')190 'Super connectionMade must be called')
191191
192 # factory outside init192 # factory outside init
193 def test_connection_made_called(self):193 def test_connection_made_called(self):
@@ -203,7 +203,7 @@
203 protocol_instance.factory.testserver_on_connection_made.callback(True)203 protocol_instance.factory.testserver_on_connection_made.callback(True)
204 protocol_instance.connectionMade()204 protocol_instance.connectionMade()
205 self.assertIn('connectionMade', self.called,205 self.assertIn('connectionMade', self.called,
206 'Super connectionMade must be called')206 'Super connectionMade must be called')
207# pylint: enable=E1101207# pylint: enable=E1101
208208
209209
@@ -283,8 +283,8 @@
283 calculator = yield self.client_factory.getRootObject()283 calculator = yield self.client_factory.getRootObject()
284 adder = yield calculator.callRemote('get_adder')284 adder = yield calculator.callRemote('get_adder')
285 self.setup_result = yield adder.callRemote('add',285 self.setup_result = yield adder.callRemote('add',
286 self.first_number,286 self.first_number,
287 self.second_number)287 self.second_number)
288288
289 def test_deferreds(self):289 def test_deferreds(self):
290 """Test that the deferreds are not broken."""290 """Test that the deferreds are not broken."""
@@ -391,10 +391,10 @@
391 first_number = 1391 first_number = 1
392 second_number = 2392 second_number = 2
393 yield self.first_tcp_server.listen_server(pb.PBServerFactory,393 yield self.first_tcp_server.listen_server(pb.PBServerFactory,
394 self.calculator)394 self.calculator)
395 self.addCleanup(self.first_tcp_server.clean_up)395 self.addCleanup(self.first_tcp_server.clean_up)
396 calculator_c = yield self.first_tcp_server.connect_client(396 calculator_c = yield self.first_tcp_server.connect_client(
397 pb.PBClientFactory)397 pb.PBClientFactory)
398 calculator = yield calculator_c.getRootObject()398 calculator = yield calculator_c.getRootObject()
399 adder = yield calculator.callRemote('get_adder')399 adder = yield calculator.callRemote('get_adder')
400 result = yield adder.callRemote('add', first_number, second_number)400 result = yield adder.callRemote('add', first_number, second_number)
@@ -407,7 +407,7 @@
407 second_number = 2407 second_number = 2
408 # first server408 # first server
409 yield self.first_tcp_server.listen_server(pb.PBServerFactory,409 yield self.first_tcp_server.listen_server(pb.PBServerFactory,
410 self.calculator)410 self.calculator)
411 self.addCleanup(self.first_tcp_server.clean_up)411 self.addCleanup(self.first_tcp_server.clean_up)
412412
413 # second server413 # second server
@@ -417,9 +417,9 @@
417417
418 # connect the diff clients418 # connect the diff clients
419 calculator_c = yield self.first_tcp_server.connect_client(419 calculator_c = yield self.first_tcp_server.connect_client(
420 pb.PBClientFactory)420 pb.PBClientFactory)
421 echoer_c = yield self.second_tcp_server.connect_client(421 echoer_c = yield self.second_tcp_server.connect_client(
422 pb.PBClientFactory)422 pb.PBClientFactory)
423423
424 calculator = yield calculator_c.getRootObject()424 calculator = yield calculator_c.getRootObject()
425 adder = yield calculator.callRemote('get_adder')425 adder = yield calculator.callRemote('get_adder')
@@ -434,7 +434,7 @@
434 """Test setting a single server no client."""434 """Test setting a single server no client."""
435 # start server but do not connect a client435 # start server but do not connect a client
436 yield self.first_tcp_server.listen_server(pb.PBServerFactory,436 yield self.first_tcp_server.listen_server(pb.PBServerFactory,
437 self.calculator)437 self.calculator)
438 self.addCleanup(self.first_tcp_server.clean_up)438 self.addCleanup(self.first_tcp_server.clean_up)
439439
440 @defer.inlineCallbacks440 @defer.inlineCallbacks
@@ -442,7 +442,7 @@
442 """Test setting multiple servers no clients."""442 """Test setting multiple servers no clients."""
443 # first server443 # first server
444 yield self.first_tcp_server.listen_server(pb.PBServerFactory,444 yield self.first_tcp_server.listen_server(pb.PBServerFactory,
445 self.calculator)445 self.calculator)
446 self.addCleanup(self.first_tcp_server.clean_up)446 self.addCleanup(self.first_tcp_server.clean_up)
447447
448 # second server448 # second server
449449
=== modified file 'ubuntuone/devtools/testcases/txsocketserver.py'
--- ubuntuone/devtools/testcases/txsocketserver.py 2012-06-08 14:16:29 +0000
+++ ubuntuone/devtools/testcases/txsocketserver.py 2012-11-29 21:41:22 +0000
@@ -143,7 +143,7 @@
143 self.server_factory = tidy_class(*args, **kwargs)143 self.server_factory = tidy_class(*args, **kwargs)
144 self.server_factory._disconnecting = False144 self.server_factory._disconnecting = False
145 self.server_factory.protocol = server_protocol_factory(145 self.server_factory.protocol = server_protocol_factory(
146 self.server_factory.protocol)146 self.server_factory.protocol)
147 endpoint = endpoints.serverFromString(reactor,147 endpoint = endpoints.serverFromString(reactor,
148 self.get_server_endpoint())148 self.get_server_endpoint())
149 self.listener = yield endpoint.listen(self.server_factory)149 self.listener = yield endpoint.listen(self.server_factory)
@@ -163,10 +163,10 @@
163 self.client_factory = client_class(*args, **kwargs)163 self.client_factory = client_class(*args, **kwargs)
164 self.client_factory._disconnecting = False164 self.client_factory._disconnecting = False
165 self.client_factory.protocol = client_protocol_factory(165 self.client_factory.protocol = client_protocol_factory(
166 self.client_factory.protocol)166 self.client_factory.protocol)
167 self.client_factory.testserver_on_connection_lost = defer.Deferred()167 self.client_factory.testserver_on_connection_lost = defer.Deferred()
168 endpoint = endpoints.clientFromString(reactor,168 endpoint = endpoints.clientFromString(reactor,
169 self.get_client_endpoint())169 self.get_client_endpoint())
170 self.connector = yield endpoint.connect(self.client_factory)170 self.connector = yield endpoint.connect(self.client_factory)
171 defer.returnValue(self.client_factory)171 defer.returnValue(self.client_factory)
172172
@@ -183,12 +183,14 @@
183 d = defer.maybeDeferred(self.listener.stopListening)183 d = defer.maybeDeferred(self.listener.stopListening)
184 self.connector.transport.loseConnection()184 self.connector.transport.loseConnection()
185 if self.server_factory.testserver_on_connection_lost:185 if self.server_factory.testserver_on_connection_lost:
186 return defer.gatherResults([d,186 return defer.gatherResults(
187 self.client_factory.testserver_on_connection_lost,187 [d,
188 self.server_factory.testserver_on_connection_lost])188 self.client_factory.testserver_on_connection_lost,
189 self.server_factory.testserver_on_connection_lost])
189 else:190 else:
190 return defer.gatherResults([d,191 return defer.gatherResults(
191 self.client_factory.testserver_on_connection_lost])192 [d,
193 self.client_factory.testserver_on_connection_lost])
192 if self.listener:194 if self.listener:
193 # just clean the server since there is no client195 # just clean the server since there is no client
194 # pylint: disable=W0201196 # pylint: disable=W0201
@@ -213,7 +215,7 @@
213 raise ValueError('Server Factory was not provided.')215 raise ValueError('Server Factory was not provided.')
214 if self.listener is None:216 if self.listener is None:
215 raise ValueError('%s has not started listening.',217 raise ValueError('%s has not started listening.',
216 self.server_factory)218 self.server_factory)
217 return self.client_endpoint_pattern % self.listener.getHost().port219 return self.client_endpoint_pattern % self.listener.getHost().port
218220
219221
@@ -279,9 +281,9 @@
279 passed to the server constructor.281 passed to the server constructor.
280 """282 """
281 self.server_factory = yield self.server_runner.listen_server(283 self.server_factory = yield self.server_runner.listen_server(
282 server_class, *args, **kwargs)284 server_class, *args, **kwargs)
283 self.server_disconnected = \285 self.server_disconnected = \
284 self.server_factory.testserver_on_connection_lost286 self.server_factory.testserver_on_connection_lost
285 self.listener = self.server_runner.listener287 self.listener = self.server_runner.listener
286288
287 @defer.inlineCallbacks289 @defer.inlineCallbacks
@@ -292,9 +294,9 @@
292 should be passed to the client constructor.294 should be passed to the client constructor.
293 """295 """
294 self.client_factory = yield self.server_runner.connect_client(296 self.client_factory = yield self.server_runner.connect_client(
295 client_class, *args, **kwargs)297 client_class, *args, **kwargs)
296 self.client_disconnected = \298 self.client_disconnected = \
297 self.client_factory.testserver_on_connection_lost299 self.client_factory.testserver_on_connection_lost
298 self.connector = self.server_runner.connector300 self.connector = self.server_runner.connector
299301
300 def tear_down_server_client(self):302 def tear_down_server_client(self):
@@ -330,13 +332,13 @@
330 def listen_server(self, *args, **kwargs):332 def listen_server(self, *args, **kwargs):
331 """Listen a pb server."""333 """Listen a pb server."""
332 yield super(PbServerTestCase, self).listen_server(pb.PBServerFactory,334 yield super(PbServerTestCase, self).listen_server(pb.PBServerFactory,
333 *args, **kwargs)335 *args, **kwargs)
334336
335 @defer.inlineCallbacks337 @defer.inlineCallbacks
336 def connect_client(self, *args, **kwargs):338 def connect_client(self, *args, **kwargs):
337 """Connect a pb client."""339 """Connect a pb client."""
338 yield super(PbServerTestCase, self).connect_client(pb.PBClientFactory,340 yield super(PbServerTestCase, self).connect_client(pb.PBClientFactory,
339 *args, **kwargs)341 *args, **kwargs)
340342
341343
342class TCPPbServerTestCase(PbServerTestCase):344class TCPPbServerTestCase(PbServerTestCase):
343345
=== modified file 'ubuntuone/devtools/testing/tests/test_txwebserver.py'
--- ubuntuone/devtools/testing/tests/test_txwebserver.py 2012-08-28 20:28:43 +0000
+++ ubuntuone/devtools/testing/tests/test_txwebserver.py 2012-11-29 21:41:22 +0000
@@ -40,7 +40,7 @@
40SAMPLE_KEY = b"result"40SAMPLE_KEY = b"result"
41SAMPLE_VALUE = b"sample result"41SAMPLE_VALUE = b"sample result"
42SAMPLE_RESOURCE = '{{"{0}": "{1}"}}'.format(42SAMPLE_RESOURCE = '{{"{0}": "{1}"}}'.format(
43 SAMPLE_KEY, SAMPLE_VALUE).encode("utf8")43 SAMPLE_KEY, SAMPLE_VALUE).encode("utf8")
44SIMPLERESOURCE = b"simpleresource"44SIMPLERESOURCE = b"simpleresource"
45OTHER_SIMPLERESOURCE = b"othersimpleresource"45OTHER_SIMPLERESOURCE = b"othersimpleresource"
46THROWERROR = b"throwerror"46THROWERROR = b"throwerror"
@@ -74,12 +74,13 @@
74 root.putChild(THROWERROR, resource.NoResource())74 root.putChild(THROWERROR, resource.NoResource())
7575
76 unauthorized_resource = resource.ErrorPage(resource.http.UNAUTHORIZED,76 unauthorized_resource = resource.ErrorPage(resource.http.UNAUTHORIZED,
77 "Unauthorized", "Unauthorized")77 "Unauthorized",
78 "Unauthorized")
78 root.putChild(UNAUTHORIZED, unauthorized_resource)79 root.putChild(UNAUTHORIZED, unauthorized_resource)
79 self.server = HTTPWebServer(root)80 self.server = HTTPWebServer(root)
80 self.server.start()81 self.server.start()
81 self.uri = "http://127.0.0.1:{port}/".format(82 self.uri = "http://127.0.0.1:{port}/".format(
82 port=self.server.get_port()).encode("utf8")83 port=self.server.get_port()).encode("utf8")
83 self.addCleanup(self.server.stop)84 self.addCleanup(self.server.stop)
8485
85 @defer.inlineCallbacks86 @defer.inlineCallbacks
@@ -130,7 +131,8 @@
130 self.root.putChild(THROWERROR, resource.NoResource())131 self.root.putChild(THROWERROR, resource.NoResource())
131132
132 unauthorized_resource = resource.ErrorPage(resource.http.UNAUTHORIZED,133 unauthorized_resource = resource.ErrorPage(resource.http.UNAUTHORIZED,
133 "Unauthorized", "Unauthorized")134 "Unauthorized",
135 "Unauthorized")
134 self.root.putChild(UNAUTHORIZED, unauthorized_resource)136 self.root.putChild(UNAUTHORIZED, unauthorized_resource)
135137
136 def get_uri(self, server):138 def get_uri(self, server):
137139
=== modified file 'ubuntuone/devtools/testing/txcheck.py'
--- ubuntuone/devtools/testing/txcheck.py 2012-08-20 22:39:50 +0000
+++ ubuntuone/devtools/testing/txcheck.py 2012-11-29 21:41:22 +0000
@@ -303,17 +303,17 @@
303 if not any_matches(decorators, INLINE_CALLBACKS_DECORATOR):303 if not any_matches(decorators, INLINE_CALLBACKS_DECORATOR):
304 # ...but the inlineCallbacks decorator is missing304 # ...but the inlineCallbacks decorator is missing
305 problem = MissingInlineCallbacks(305 problem = MissingInlineCallbacks(
306 method=def_node.name,306 method=def_node.name,
307 test_class=class_to_check,307 test_class=class_to_check,
308 ancestor_class=ancestor_class)308 ancestor_class=ancestor_class)
309 problems.add(problem)309 problems.add(problem)
310 else:310 else:
311 if not matches(def_node, match_descendant(RETURN_VALUE, DEFS)):311 if not matches(def_node, match_descendant(RETURN_VALUE, DEFS)):
312 # The function fails to return a deferred312 # The function fails to return a deferred
313 problem = MissingReturnValue(313 problem = MissingReturnValue(
314 method=def_node.name,314 method=def_node.name,
315 test_class=class_to_check,315 test_class=class_to_check,
316 ancestor_class=ancestor_class)316 ancestor_class=ancestor_class)
317 problems.add(problem)317 problems.add(problem)
318318
319 return problems319 return problems
320320
=== modified file 'ubuntuone/devtools/testing/txwebserver.py'
--- ubuntuone/devtools/testing/txwebserver.py 2012-08-21 21:36:20 +0000
+++ ubuntuone/devtools/testing/txwebserver.py 2012-11-29 21:41:22 +0000
@@ -68,7 +68,7 @@
68 def get_iri(self):68 def get_iri(self):
69 """Build the iri for this mock server."""69 """Build the iri for this mock server."""
70 return "{scheme}://127.0.0.1:{port}/".format(scheme=self.scheme,70 return "{scheme}://127.0.0.1:{port}/".format(scheme=self.scheme,
71 port=self.get_port())71 port=self.get_port())
7272
73 def get_port(self):73 def get_port(self):
74 """Return the port where we are listening."""74 """Return the port where we are listening."""
@@ -88,10 +88,11 @@
88 con.transport.loseConnection()88 con.transport.loseConnection()
89 else:89 else:
90 self.wrapper.testserver_on_connection_lost = \90 self.wrapper.testserver_on_connection_lost = \
91 defer.succeed(None)91 defer.succeed(None)
92 d = defer.maybeDeferred(self.port.stopListening)92 d = defer.maybeDeferred(self.port.stopListening)
93 return defer.gatherResults([d,93 return defer.gatherResults(
94 self.wrapper.testserver_on_connection_lost])94 [d,
95 self.wrapper.testserver_on_connection_lost])
95 return defer.succeed(None)96 return defer.succeed(None)
9697
9798
@@ -118,6 +119,6 @@
118 def listen(self, site):119 def listen(self, site):
119 """Listen a port to allow the tests."""120 """Listen a port to allow the tests."""
120 ssl_context = ssl.DefaultOpenSSLContextFactory(121 ssl_context = ssl.DefaultOpenSSLContextFactory(
121 self.ssl_settings['key'], self.ssl_settings['cert'])122 self.ssl_settings['key'], self.ssl_settings['cert'])
122123
123 return reactor.listenSSL(0, site, ssl_context)124 return reactor.listenSSL(0, site, ssl_context)
124125
=== modified file 'ubuntuone/devtools/tests/test_decorators.py'
--- ubuntuone/devtools/tests/test_decorators.py 2012-10-18 21:17:22 +0000
+++ ubuntuone/devtools/tests/test_decorators.py 2012-11-29 21:41:22 +0000
@@ -90,7 +90,7 @@
90 self.assertEqual(len(result.skips), 1)90 self.assertEqual(len(result.skips), 1)
91 self.assertEqual(result.successes, 1)91 self.assertEqual(result.successes, 1)
92 self.assertEqual(result.skips,92 self.assertEqual(result.skips,
93 [(test_do_skip, do_skip[1])])93 [(test_do_skip, do_skip[1])])
9494
95 def test_skip_class(self):95 def test_skip_class(self):
96 """Test skipping a full test class."""96 """Test skipping a full test class."""
9797
=== modified file 'ubuntuone/devtools/tests/test_txcheck.py'
--- ubuntuone/devtools/tests/test_txcheck.py 2012-03-30 17:44:03 +0000
+++ ubuntuone/devtools/tests/test_txcheck.py 2012-11-29 21:41:22 +0000
@@ -110,7 +110,7 @@
110 problems = find_problems(MissingReturnCase)110 problems = find_problems(MissingReturnCase)
111 self.assertEqual(problems, set([111 self.assertEqual(problems, set([
112 MissingReturnValue(method=m, test_class=MissingReturnCase,112 MissingReturnValue(method=m, test_class=MissingReturnCase,
113 ancestor_class=MissingReturnCase)113 ancestor_class=MissingReturnCase)
114 for m in ('setUp', 'tearDown')]))114 for m in ('setUp', 'tearDown')]))
115115
116 def test_super_not_called(self):116 def test_super_not_called(self):
@@ -130,7 +130,7 @@
130 problems = find_problems(NoSuperCase)130 problems = find_problems(NoSuperCase)
131 self.assertEqual(problems, set([131 self.assertEqual(problems, set([
132 SuperNotCalled(method=m, test_class=NoSuperCase,132 SuperNotCalled(method=m, test_class=NoSuperCase,
133 ancestor_class=NoSuperCase)133 ancestor_class=NoSuperCase)
134 for m in ('setUp', 'tearDown')]))134 for m in ('setUp', 'tearDown')]))
135135
136 def test_bare_super(self):136 def test_bare_super(self):
@@ -152,7 +152,7 @@
152 problems = find_problems(BareSuperCase)152 problems = find_problems(BareSuperCase)
153 self.assertEqual(problems, set([153 self.assertEqual(problems, set([
154 SuperResultDiscarded(method=m, test_class=BareSuperCase,154 SuperResultDiscarded(method=m, test_class=BareSuperCase,
155 ancestor_class=BareSuperCase)155 ancestor_class=BareSuperCase)
156 for m in ('setUp', 'tearDown')]))156 for m in ('setUp', 'tearDown')]))
157157
158 def test_inline_callbacks_missing(self):158 def test_inline_callbacks_missing(self):

Subscribers

People subscribed via source and target branches

to all changes: