Commit f3835955 authored by Kazuhiko Shiozaki's avatar Kazuhiko Shiozaki

py2/py3: use six.moves.urllib for compatibility.

parent e21d6451
...@@ -26,7 +26,7 @@ ...@@ -26,7 +26,7 @@
############################################################################## ##############################################################################
import os import os
from urllib import urlencode from six.moves.urllib.parse import urlencode
import tempfile import tempfile
from DateTime import DateTime from DateTime import DateTime
from zLOG import LOG from zLOG import LOG
......
from Products.ERP5Type.UnrestrictedMethod import UnrestrictedMethod from Products.ERP5Type.UnrestrictedMethod import UnrestrictedMethod
import urllib from six.moves.urllib.parse import urlencode
import mechanize import mechanize
def getProductPrice(product): def getProductPrice(product):
...@@ -9,7 +9,7 @@ def getProductPrice(product): ...@@ -9,7 +9,7 @@ def getProductPrice(product):
def submitPaypalNVPRequest(parameter_dict, nvp_url): def submitPaypalNVPRequest(parameter_dict, nvp_url):
request = mechanize.Request(nvp_url) request = mechanize.Request(nvp_url)
params = urllib.urlencode(parameter_dict) params = urlencode(parameter_dict)
try: try:
response = mechanize.urlopen(request, data=params) response = mechanize.urlopen(request, data=params)
except: except:
......
import feedparser, urllib2, socket import feedparser, six.moves.urllib.request, six.moves.urllib.error, socket
from hashlib import md5 from hashlib import md5
def getRssDataAsDict(context, url, username=None, password=None): def getRssDataAsDict(context, url, username=None, password=None):
...@@ -11,9 +11,9 @@ def getRssDataAsDict(context, url, username=None, password=None): ...@@ -11,9 +11,9 @@ def getRssDataAsDict(context, url, username=None, password=None):
# use authentication or not? # use authentication or not?
handlers = [] handlers = []
if username is not None and password is not None: if username is not None and password is not None:
passman = urllib2.HTTPPasswordMgrWithDefaultRealm() passman = six.moves.urllib.request.HTTPPasswordMgrWithDefaultRealm()
passman.add_password(None, url, username, password) passman.add_password(None, url, username, password)
auth_handler = urllib2.HTTPBasicAuthHandler(passman) auth_handler = six.moves.urllib.request.HTTPBasicAuthHandler(passman)
handlers.append(auth_handler) handlers.append(auth_handler)
# set shorter timeouts and revert default at enf of read # set shorter timeouts and revert default at enf of read
...@@ -24,7 +24,7 @@ def getRssDataAsDict(context, url, username=None, password=None): ...@@ -24,7 +24,7 @@ def getRssDataAsDict(context, url, username=None, password=None):
finally: finally:
socket.setdefaulttimeout(default_timeout) socket.setdefaulttimeout(default_timeout)
if d.bozo and isinstance(d.bozo_exception, urllib2.URLError): if d.bozo and isinstance(d.bozo_exception, six.moves.urllib.error.URLError):
# we have an URL error # we have an URL error
return {'status':-2} return {'status':-2}
elif d.bozo: elif d.bozo:
......
...@@ -26,7 +26,7 @@ ...@@ -26,7 +26,7 @@
############################################################################## ##############################################################################
import suds import suds
import urllib2 import six.moves.urllib.request
import ssl import ssl
import lxml.etree import lxml.etree
...@@ -39,7 +39,7 @@ from suds.transport.https import HttpAuthenticated ...@@ -39,7 +39,7 @@ from suds.transport.https import HttpAuthenticated
class HTTPAuthenticatedUnverifiedSSL(HttpAuthenticated): class HTTPAuthenticatedUnverifiedSSL(HttpAuthenticated):
def u2handlers(self): def u2handlers(self):
handlers = [ urllib2.HTTPSHandler(context=ssl._create_unverified_context()) ] handlers = [ six.moves.urllib.request.HTTPSHandler(context=ssl._create_unverified_context()) ]
handlers.extend(HttpAuthenticated.u2handlers(self)) handlers.extend(HttpAuthenticated.u2handlers(self))
return handlers return handlers
......
...@@ -27,8 +27,8 @@ ...@@ -27,8 +27,8 @@
# #
############################################################################## ##############################################################################
import zope import zope
from urllib import urlencode from six.moves.urllib.parse import urlencode
from urllib2 import urlopen, Request from six.moves.urllib.request import urlopen, Request
from zLOG import LOG, DEBUG from zLOG import LOG, DEBUG
from AccessControl import ClassSecurityInfo from AccessControl import ClassSecurityInfo
from Products.ERP5Type import Permissions, PropertySheet from Products.ERP5Type import Permissions, PropertySheet
......
...@@ -57,8 +57,8 @@ def parseTestReport(text): ...@@ -57,8 +57,8 @@ def parseTestReport(text):
Return the content of a web page Return the content of a web page
""" """
def urlread(url): def urlread(url):
import urllib from six.moves.urllib.request import urlopen
return urllib.urlopen(url).read() return urlopen(url).read()
""" """
Remove everything but the test in a webpage Remove everything but the test in a webpage
......
...@@ -29,7 +29,8 @@ ...@@ -29,7 +29,8 @@
"""Receive or send SMS""" """Receive or send SMS"""
#Import python module #Import python module
import urllib from six.moves.urllib.parse import urlencode, unquote
from six.moves.urllib.request import urlopen
from lxml import etree from lxml import etree
from DateTime import DateTime from DateTime import DateTime
...@@ -91,14 +92,14 @@ class EssendexGateway(XMLObject): ...@@ -91,14 +92,14 @@ class EssendexGateway(XMLObject):
if len(parts) == 1: if len(parts) == 1:
data = parts[0].split('=') data = parts[0].split('=')
#Remove \n et \r from value #Remove \n et \r from value
result[data[0]] = urllib.unquote(data[1].replace('\r','').replace('\n','')) result[data[0]] = unquote(data[1].replace('\r','').replace('\n',''))
else: else:
#Mutil values #Mutil values
subresult = {} subresult = {}
for part in parts: for part in parts:
data = part.split('=') data = part.split('=')
subresult[data[0]] = urllib.unquote(data[1].replace('\r','').replace('\n','')) subresult[data[0]] = unquote(data[1].replace('\r','').replace('\n',''))
result[index] = subresult result[index] = subresult
#Increment index for next #Increment index for next
index += 1 index += 1
...@@ -161,8 +162,8 @@ class EssendexGateway(XMLObject): ...@@ -161,8 +162,8 @@ class EssendexGateway(XMLObject):
params['Test'] = 1 params['Test'] = 1
LOG("EssendexGateway", INFO, params) LOG("EssendexGateway", INFO, params)
params = urllib.urlencode(params) params = urlencode(params)
page = urllib.urlopen(base_url, params) page = urlopen(base_url, params)
result = self._fetchPageAsDict(page) result = self._fetchPageAsDict(page)
if result['Result'] == "OK": if result['Result'] == "OK":
message_ids = result.get('MessageIDs', "") message_ids = result.get('MessageIDs', "")
...@@ -171,7 +172,7 @@ class EssendexGateway(XMLObject): ...@@ -171,7 +172,7 @@ class EssendexGateway(XMLObject):
return message_ids.split(",") return message_ids.split(",")
elif result['Result'] == "Error": elif result['Result'] == "Error":
#we get an error when call the gateway #we get an error when call the gateway
raise SMSGatewayError(urllib.unquote(result.get('Message', "Impossible to send the SMS"))) raise SMSGatewayError(unquote(result.get('Message', "Impossible to send the SMS")))
elif result['Result'] == "Test": elif result['Result'] == "Test":
#just a test, no message id #just a test, no message id
return None return None
...@@ -190,15 +191,15 @@ class EssendexGateway(XMLObject): ...@@ -190,15 +191,15 @@ class EssendexGateway(XMLObject):
'MessageID': message_id, 'MessageID': message_id,
} }
params = urllib.urlencode(params) params = urlencode(params)
page = urllib.urlopen(base_url, params) page = urlopen(base_url, params)
result = self._fetchPageAsDict(page) result = self._fetchPageAsDict(page)
if result['Result'] == "OK": if result['Result'] == "OK":
return result.get('MessageStatus').lower() return result.get('MessageStatus').lower()
elif result['Result'] == "Error": elif result['Result'] == "Error":
#we get an error when call the gateway #we get an error when call the gateway
raise SMSGatewayError(urllib.unquote(result.get('Message', "Impossible to get the message status"))) raise SMSGatewayError(unquote(result.get('Message', "Impossible to get the message status")))
security.declarePublic('receive') security.declarePublic('receive')
def receive(self, REQUEST, **kw): def receive(self, REQUEST, **kw):
...@@ -319,8 +320,8 @@ class EssendexGateway(XMLObject): ...@@ -319,8 +320,8 @@ class EssendexGateway(XMLObject):
params['Test'] = 1 params['Test'] = 1
LOG("EssendexGateway", INFO, params) LOG("EssendexGateway", INFO, params)
params = urllib.urlencode(params) params = urlencode(params)
page = urllib.urlopen(base_url, params) page = urlopen(base_url, params)
result = self._fetchPageAsDict(page) result = self._fetchPageAsDict(page)
if result['Result'] == "OK": if result['Result'] == "OK":
...@@ -344,6 +345,6 @@ class EssendexGateway(XMLObject): ...@@ -344,6 +345,6 @@ class EssendexGateway(XMLObject):
LOG("EssendexGateway", INFO, result) LOG("EssendexGateway", INFO, result)
elif result['Result'] == "Error": elif result['Result'] == "Error":
#we get an error when call the gateway #we get an error when call the gateway
raise SMSGatewayError(urllib.unquote(result.get('Message', "Impossible to get last message list"))) raise SMSGatewayError(unquote(result.get('Message', "Impossible to get last message list")))
...@@ -29,7 +29,8 @@ ...@@ -29,7 +29,8 @@
"""Receive or send SMS""" """Receive or send SMS"""
#Import python module #Import python module
import urllib from six.moves.urllib.parse import urlencode, unquote
from six.moves.urllib.request import urlopen
from DateTime import DateTime from DateTime import DateTime
#Import Zope module #Import Zope module
...@@ -179,8 +180,8 @@ class MobytGateway(XMLObject): ...@@ -179,8 +180,8 @@ class MobytGateway(XMLObject):
LOG("MobytGateway", INFO, params) LOG("MobytGateway", INFO, params)
result = {'status': "Test"} result = {'status': "Test"}
else: else:
params = urllib.urlencode(params) params = urlencode(params)
page = urllib.urlopen(base_url, params) page = urlopen(base_url, params)
result = self._fetchSendResponseAsDict(page) result = self._fetchSendResponseAsDict(page)
#Check result and return #Check result and return
...@@ -188,7 +189,7 @@ class MobytGateway(XMLObject): ...@@ -188,7 +189,7 @@ class MobytGateway(XMLObject):
return [result.get('status_info', "")] #return message id (gateway side) return [result.get('status_info', "")] #return message id (gateway side)
elif result['status'] == "KO": elif result['status'] == "KO":
#we get an error when call the gateway #we get an error when call the gateway
raise SMSGatewayError(urllib.unquote(result.get('status_info', "Impossible to send the SMS"))) raise SMSGatewayError(unquote(result.get('status_info', "Impossible to send the SMS")))
elif result['status'] == "Test": elif result['status'] == "Test":
#just a test, no message id #just a test, no message id
return None return None
...@@ -206,8 +207,8 @@ class MobytGateway(XMLObject): ...@@ -206,8 +207,8 @@ class MobytGateway(XMLObject):
"type" : 'notify', "type" : 'notify',
"schema" : 1 } "schema" : 1 }
params = urllib.urlencode(params) params = urlencode(params)
page = urllib.urlopen(base_url, params) page = urlopen(base_url, params)
result = self._fetchStatusResponseAsDict(page) result = self._fetchStatusResponseAsDict(page)
if result['status'] == "OK": if result['status'] == "OK":
...@@ -223,7 +224,7 @@ class MobytGateway(XMLObject): ...@@ -223,7 +224,7 @@ class MobytGateway(XMLObject):
elif result['status'] == "KO": elif result['status'] == "KO":
#we get an error when call the gateway #we get an error when call the gateway
raise SMSGatewayError(urllib.unquote(result.get('status_info', "Impossible to get the message status"))) raise SMSGatewayError(unquote(result.get('status_info', "Impossible to get the message status")))
security.declarePublic('receive') security.declarePublic('receive')
def receive(self,REQUEST): def receive(self,REQUEST):
......
...@@ -25,8 +25,8 @@ ...@@ -25,8 +25,8 @@
# #
############################################################################## ##############################################################################
from urllib import urlencode from six.moves.urllib.parse import urlencode
from urllib2 import urlopen from six.moves.urllib.request import urlopen
def OpenAMLogout(self, url, token): def OpenAMLogout(self, url, token):
code = urlopen(url, urlencode({'subjectid':token})).getcode() code = urlopen(url, urlencode({'subjectid':token})).getcode()
......
...@@ -27,7 +27,7 @@ ...@@ -27,7 +27,7 @@
############################################################################## ##############################################################################
from urllib import quote_plus from six.moves.urllib.parse import quote_plus
from six.moves.urllib.parse import urlparse from six.moves.urllib.parse import urlparse
from six.moves.urllib.parse import urljoin from six.moves.urllib.parse import urljoin
import logging import logging
......
...@@ -41,9 +41,9 @@ def UpdateImage(image): ...@@ -41,9 +41,9 @@ def UpdateImage(image):
image._update_image_info() image._update_image_info()
def urlread(url, safe_return=0): def urlread(url, safe_return=0):
import urllib from six.moves.urllib.request import urlopen
try: try:
return urllib.urlopen(url).read() return urlopen(url).read()
except IOError as e: except IOError as e:
if safe_return: if safe_return:
# Return an Selenium test code that will obviously fail. This # Return an Selenium test code that will obviously fail. This
......
...@@ -37,7 +37,7 @@ from Products.ERP5Type import Permissions ...@@ -37,7 +37,7 @@ from Products.ERP5Type import Permissions
from webdav.NullResource import NullResource from webdav.NullResource import NullResource
import urllib from six.moves.urllib.parse import unquote
MARKER = [] MARKER = []
...@@ -69,7 +69,7 @@ class StaticWebSection(WebSection): ...@@ -69,7 +69,7 @@ class StaticWebSection(WebSection):
# Drop the automatically added VirtualHostMonster object ID # Drop the automatically added VirtualHostMonster object ID
virtual_url_part_tuple = request.get('VIRTUAL_URL_PARTS', None) virtual_url_part_tuple = request.get('VIRTUAL_URL_PARTS', None)
if (virtual_url_part_tuple is not None) and \ if (virtual_url_part_tuple is not None) and \
(not urllib.unquote(virtual_url_part_tuple[-1]).endswith("/".join(url_list))): (not unquote(virtual_url_part_tuple[-1]).endswith("/".join(url_list))):
url_list.pop(0) url_list.pop(0)
if request.get('ACTUAL_URL', '').endswith("/"): # or len(url_list) == 0: if request.get('ACTUAL_URL', '').endswith("/"): # or len(url_list) == 0:
......
...@@ -3,7 +3,8 @@ from AccessControl import ClassSecurityInfo ...@@ -3,7 +3,8 @@ from AccessControl import ClassSecurityInfo
from Products.ERP5Type import Permissions, PropertySheet from Products.ERP5Type import Permissions, PropertySheet
from Products.ERP5Type.XMLObject import XMLObject from Products.ERP5Type.XMLObject import XMLObject
from zLOG import LOG, WARNING from zLOG import LOG, WARNING
import random, string, hashlib, urllib2, socket import random, string, hashlib, socket
from six.moves.urllib.request import Request, urlopen
from six.moves.urllib.parse import urlparse from six.moves.urllib.parse import urlparse
from six import string_types as basestring from six import string_types as basestring
try: try:
...@@ -103,8 +104,8 @@ class WechatService(XMLObject): ...@@ -103,8 +104,8 @@ class WechatService(XMLObject):
params['sign'] = self.calculateSign(params, self.getServiceApiKey()) params['sign'] = self.calculateSign(params, self.getServiceApiKey())
LOG('WechatService', WARNING, LOG('WechatService', WARNING,
"getSandboxKey : data = %s SANDBOX_KEY_URL = %s" % (self.convert_dict_to_xml(params), SANDBOX_KEY_URL), error=False) "getSandboxKey : data = %s SANDBOX_KEY_URL = %s" % (self.convert_dict_to_xml(params), SANDBOX_KEY_URL), error=False)
result = urllib2.Request(SANDBOX_KEY_URL, data=self.convert_dict_to_xml(params)) result = Request(SANDBOX_KEY_URL, data=self.convert_dict_to_xml(params))
result_data = urllib2.urlopen(result) result_data = urlopen(result)
result_read = result_data.read() result_read = result_data.read()
result_dict_content = self.convert_xml_to_dict(result_read) result_dict_content = self.convert_xml_to_dict(result_read)
return_code = result_dict_content.get('return_code', '') return_code = result_dict_content.get('return_code', '')
...@@ -151,8 +152,8 @@ class WechatService(XMLObject): ...@@ -151,8 +152,8 @@ class WechatService(XMLObject):
LOG('callWechatApi', WARNING, LOG('callWechatApi', WARNING,
"data = %s URL = %s" % (self.convert_dict_to_xml(wechat_dict), wechat_url + URL), error=False) "data = %s URL = %s" % (self.convert_dict_to_xml(wechat_dict), wechat_url + URL), error=False)
# send data # send data
result = urllib2.Request(wechat_url + URL, data=self.convert_dict_to_xml(wechat_dict)) result = Request(wechat_url + URL, data=self.convert_dict_to_xml(wechat_dict))
result_data = urllib2.urlopen(result) result_data = urlopen(result)
result_read = result_data.read() result_read = result_data.read()
result_dict_content = self.convert_xml_to_dict(result_read) result_dict_content = self.convert_xml_to_dict(result_read)
return_code = result_dict_content['return_code'] return_code = result_dict_content['return_code']
......
...@@ -36,7 +36,7 @@ import os ...@@ -36,7 +36,7 @@ import os
import dircache import dircache
import mimetypes, mimetools import mimetypes, mimetools
from email.utils import formatdate from email.utils import formatdate
class DirectoryFileHandler(urllib2.FileHandler): class DirectoryFileHandler(six.moves.urllib.request.FileHandler):
""" """
Extends the file handler to provide an HTML Extends the file handler to provide an HTML
representation of local directories. representation of local directories.
...@@ -55,7 +55,7 @@ class DirectoryFileHandler(urllib2.FileHandler): ...@@ -55,7 +55,7 @@ class DirectoryFileHandler(urllib2.FileHandler):
def open_local_file(self, req): def open_local_file(self, req):
host = req.get_host() host = req.get_host()
file = req.get_selector() file = req.get_selector()
localfile = urllib2.url2pathname(file) localfile = six.moves.urllib.request.url2pathname(file)
stats = os.stat(localfile) stats = os.stat(localfile)
size = stats.st_size size = stats.st_size
modified = formatdate(stats.st_mtime, usegmt=True) modified = formatdate(stats.st_mtime, usegmt=True)
...@@ -64,7 +64,7 @@ class DirectoryFileHandler(urllib2.FileHandler): ...@@ -64,7 +64,7 @@ class DirectoryFileHandler(urllib2.FileHandler):
'Content-type: %s\nContent-length: %d\nLast-modified: %s\n' % 'Content-type: %s\nContent-length: %d\nLast-modified: %s\n' %
(mtype or 'text/plain', size, modified))) (mtype or 'text/plain', size, modified)))
if host: if host:
host, port = urllib.splitport(host) host, port = six.moves.urllib.parse.splitport(host)
if not host or \ if not host or \
(not port and socket.gethostbyname(host) in self.get_names()): (not port and socket.gethostbyname(host) in self.get_names()):
try: try:
...@@ -73,16 +73,16 @@ class DirectoryFileHandler(urllib2.FileHandler): ...@@ -73,16 +73,16 @@ class DirectoryFileHandler(urllib2.FileHandler):
s.write('<html><head><base href="%s"/></head><body>' % ('file:' + file)) s.write('<html><head><base href="%s"/></head><body>' % ('file:' + file))
s.write('<p>Directory Content:</p>') s.write('<p>Directory Content:</p>')
for f in file_list: for f in file_list:
s.write('<p><a href="%s">%s</a></p>\n' % (urllib.quote(f), f)) s.write('<p><a href="%s">%s</a></p>\n' % (six.moves.urllib.parse.quote(f), f))
s.write('</body></html>') s.write('</body></html>')
s.seek(0) s.seek(0)
headers = mimetools.Message(StringIO( headers = mimetools.Message(StringIO(
'Content-type: %s\nContent-length: %d\nLast-modified: %s\n' % 'Content-type: %s\nContent-length: %d\nLast-modified: %s\n' %
('text/html', size, modified))) ('text/html', size, modified)))
return urllib2.addinfourl(s, headers, 'file:' + file) return six.moves.urllib.response.addinfourl(s, headers, 'file:' + file)
except OSError: except OSError:
return urllib2.addinfourl(open(localfile, 'rb'), return six.moves.urllib.response.addinfourl(open(localfile, 'rb'),
headers, 'file:'+file) headers, 'file:'+file)
raise urllib2.URLError('file not on local host') raise six.moves.urllib.error.URLError('file not on local host')
opener = urllib2.build_opener(DirectoryFileHandler) opener = six.moves.urllib.request.build_opener(DirectoryFileHandler)
urllib2.install_opener(opener) six.moves.urllib.request.install_opener(opener)
...@@ -18,7 +18,6 @@ import string ...@@ -18,7 +18,6 @@ import string
import sys import sys
import time import time
import traceback import traceback
import urllib
from six.moves import configparser from six.moves import configparser
from contextlib import contextmanager from contextlib import contextmanager
from io import BytesIO from io import BytesIO
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment