mirror of
https://github.com/tahoe-lafs/tahoe-lafs.git
synced 2025-04-08 19:34:18 +00:00
A little closer to passing tests on Python 3.
This commit is contained in:
parent
83e16d40a4
commit
5e59b9d8d6
src/allmydata
@ -6,7 +6,7 @@ from allmydata.scripts.common import get_alias, DEFAULT_ALIAS, escape_path, \
|
||||
from allmydata.scripts.common_http import do_http, format_http_error
|
||||
from allmydata.util import base32
|
||||
from allmydata.util.encodingutil import quote_output, is_printable_ascii
|
||||
import urllib
|
||||
from urllib.parse import quote as url_quote
|
||||
import json
|
||||
|
||||
class SlowOperationRunner(object):
|
||||
@ -27,7 +27,7 @@ class SlowOperationRunner(object):
|
||||
return 1
|
||||
if path == '/':
|
||||
path = ''
|
||||
url = nodeurl + "uri/%s" % urllib.quote(rootcap)
|
||||
url = nodeurl + "uri/%s" % url_quote(rootcap)
|
||||
if path:
|
||||
url += "/" + escape_path(path)
|
||||
# todo: should it end with a slash?
|
||||
|
@ -4,7 +4,7 @@ from urllib.parse import quote as url_quote
|
||||
import json
|
||||
|
||||
# Python 2 compatibility
|
||||
from future.utils import PY2
|
||||
from future.utils import PY2, PY3
|
||||
if PY2:
|
||||
from future.builtins import str # noqa: F401
|
||||
|
||||
@ -54,8 +54,12 @@ def check_location(options, where):
|
||||
return 1
|
||||
jdata = resp.read()
|
||||
if options.get("raw"):
|
||||
stdout.write(jdata)
|
||||
stdout.write("\n")
|
||||
if PY3:
|
||||
stdoutb = stdout.buffer
|
||||
else:
|
||||
stdoutb = stdout
|
||||
stdoutb.write(jdata)
|
||||
stdoutb.write(b"\n")
|
||||
return 0
|
||||
data = json.loads(jdata)
|
||||
|
||||
|
@ -1,3 +1,4 @@
|
||||
from past.builtins import unicode
|
||||
import os.path
|
||||
import json
|
||||
from twisted.trial import unittest
|
||||
@ -41,7 +42,7 @@ class Check(GridTestMixin, CLITestMixin, unittest.TestCase):
|
||||
self.failUnlessReallyEqual(err, "")
|
||||
self.failUnlessReallyEqual(rc, 0)
|
||||
data = json.loads(out)
|
||||
self.failUnlessReallyEqual(to_bytes(data["summary"]), "Healthy")
|
||||
self.failUnlessReallyEqual(to_bytes(data["summary"]), b"Healthy")
|
||||
self.failUnlessReallyEqual(data["results"]["healthy"], True)
|
||||
d.addCallback(_check2)
|
||||
|
||||
@ -68,7 +69,7 @@ class Check(GridTestMixin, CLITestMixin, unittest.TestCase):
|
||||
self.failUnlessReallyEqual(data["results"]["healthy"], True)
|
||||
d.addCallback(_check_lit_raw)
|
||||
|
||||
d.addCallback(lambda ign: c0.create_immutable_dirnode({}, convergence=""))
|
||||
d.addCallback(lambda ign: c0.create_immutable_dirnode({}, convergence=b""))
|
||||
def _stash_lit_dir_uri(n):
|
||||
self.lit_dir_uri = n.get_uri()
|
||||
d.addCallback(_stash_lit_dir_uri)
|
||||
@ -89,9 +90,9 @@ class Check(GridTestMixin, CLITestMixin, unittest.TestCase):
|
||||
cso.parseOptions([shares[1][2]])
|
||||
storage_index = uri.from_string(self.uri).get_storage_index()
|
||||
self._corrupt_share_line = " server %s, SI %s, shnum %d" % \
|
||||
(base32.b2a(shares[1][1]),
|
||||
base32.b2a(storage_index),
|
||||
shares[1][0])
|
||||
(unicode(base32.b2a(shares[1][1]), "ascii"),
|
||||
unicode(base32.b2a(storage_index), "ascii"),
|
||||
shares[1][0])
|
||||
debug.corrupt_share(cso)
|
||||
d.addCallback(_clobber_shares)
|
||||
|
||||
@ -418,8 +419,8 @@ class Check(GridTestMixin, CLITestMixin, unittest.TestCase):
|
||||
self.failUnlessReallyEqual(rc, 0)
|
||||
self.failUnlessReallyEqual(err, "")
|
||||
#Ensure healthy appears for each uri
|
||||
self.failUnlessIn("Healthy", out[:len(out)/2])
|
||||
self.failUnlessIn("Healthy", out[len(out)/2:])
|
||||
self.failUnlessIn("Healthy", out[:len(out)//2])
|
||||
self.failUnlessIn("Healthy", out[len(out)//2:])
|
||||
d.addCallback(_check)
|
||||
|
||||
d.addCallback(lambda ign: self.do_cli("check", self.uriList[0], "nonexistent:"))
|
||||
|
Loading…
x
Reference in New Issue
Block a user