aboutsummaryrefslogtreecommitdiffstats
path: root/python/Pubnub.py
diff options
context:
space:
mode:
authorDevendra2014-03-25 10:50:39 +0530
committerDevendra2014-03-25 10:50:39 +0530
commitb8d1dd86a0d8c4261d4f3765f3ca227d7b555c84 (patch)
treed5cd2e092f44ff36e739fd029afc7b028c8c087f /python/Pubnub.py
parent80edcffbfe140a6d19c65deca24e1ba1c0f49b99 (diff)
downloadpubnub-python-b8d1dd86a0d8c4261d4f3765f3ca227d7b555c84.tar.bz2
fixing encryption, and changing from urllib3 to urllib
Diffstat (limited to 'python/Pubnub.py')
-rw-r--r--python/Pubnub.py21
1 files changed, 10 insertions, 11 deletions
diff --git a/python/Pubnub.py b/python/Pubnub.py
index 5dd4c7d..aa7068b 100644
--- a/python/Pubnub.py
+++ b/python/Pubnub.py
@@ -40,7 +40,7 @@ class PubnubCrypto() :
#**
"""
padding = block_size - (len(msg) % block_size)
- return msg + chr(padding)*padding
+ return msg + (chr(padding)*padding).encode('utf-8')
def depad( self, msg ):
"""
@@ -62,7 +62,7 @@ class PubnubCrypto() :
#* @return key in MD5 format
#**
"""
- return hashlib.sha256(key).hexdigest()
+ return hashlib.sha256(key.encode("utf-8")).hexdigest()
def encrypt( self, key, msg ):
"""
@@ -76,8 +76,7 @@ class PubnubCrypto() :
secret = self.getSecret(key)
Initial16bytes='0123456789012345'
cipher = AES.new(secret[0:32],AES.MODE_CBC,Initial16bytes)
- enc = encodestring(cipher.encrypt(self.pad(msg)))
- return enc
+ return encodestring(cipher.encrypt(self.pad(msg.encode('utf-8')))).decode('utf-8')
def decrypt( self, key, msg ):
"""
#**
@@ -90,7 +89,7 @@ class PubnubCrypto() :
secret = self.getSecret(key)
Initial16bytes='0123456789012345'
cipher = AES.new(secret[0:32],AES.MODE_CBC,Initial16bytes)
- return self.depad((cipher.decrypt(decodestring(msg))))
+ return (cipher.decrypt(decodestring(msg.encode('utf-8')))).decode('utf-8')
try: import json
@@ -575,7 +574,8 @@ class PubnubCore(PubnubBase):
return True
-import urllib3
+
+import urllib.request
class Pubnub(PubnubCore):
def __init__(
@@ -597,17 +597,16 @@ class Pubnub(PubnubCore):
origin = origin,
uuid = pres_uuid
)
- self.http = urllib3.PoolManager(timeout=310)
def _request( self, request, callback = None ) :
## Build URL
url = self.getUrl(request)
-
+ print(url)
## Send Request Expecting JSONP Response
try:
- response = self.http.request('GET', url)
- resp_json = json.loads(response.data.decode("utf-8"))
- except:
+ response = urllib.request.urlopen(url,timeout=310)
+ resp_json = json.loads(response.read().decode("utf-8"))
+ except Exception as e:
return None
if (callback):