tremove old http interface code, not used - electrum - Electrum Bitcoin wallet
HTML git clone https://git.parazyd.org/electrum
DIR Log
DIR Files
DIR Refs
DIR Submodules
---
DIR commit ae7405a10f94c8ae2555439f20b2e8b2d5bde612
DIR parent 92987d90193dc8c15f3e1b9455941681ed770099
HTML Author: ThomasV <thomasv@gitorious>
Date: Thu, 12 Mar 2015 11:55:10 +0100
remove old http interface code, not used
Diffstat:
M lib/interface.py | 119 -------------------------------
1 file changed, 0 insertions(+), 119 deletions(-)
---
DIR diff --git a/lib/interface.py b/lib/interface.py
t@@ -69,8 +69,6 @@ def Interface(server, config = None):
port = int(port)
if protocol in 'st':
return TcpInterface(server, config)
- elif protocol in 'hg':
- return HttpInterface(server, config)
else:
raise Exception('Unknown protocol: %s'%protocol)
t@@ -350,123 +348,6 @@ class TcpInterface(threading.Thread):
-class HttpInterface(TcpInterface):
-
- def run(self):
- self.start_http()
- if self.is_connected:
- self.send_request({'method':'server.version', 'params':[ELECTRUM_VERSION, PROTOCOL_VERSION]})
- self.change_status()
- self.run_http()
- self.change_status()
-
- def send_request(self, request, queue=None):
- import urllib2, json, time, cookielib
- print_error( "send_http", messages )
-
- if self.proxy:
- socks.setdefaultproxy(self.proxy_mode, self.proxy["host"], int(self.proxy["port"]) )
- socks.wrapmodule(urllib2)
-
- cj = cookielib.CookieJar()
- opener = urllib2.build_opener(urllib2.HTTPCookieProcessor(cj))
- urllib2.install_opener(opener)
-
- t1 = time.time()
-
- data = []
- ids = []
- for m in messages:
- method, params = m
- if type(params) != type([]): params = [params]
- data.append( { 'method':method, 'id':self.message_id, 'params':params } )
- self.unanswered_requests[self.message_id] = method, params, callback
- ids.append(self.message_id)
- self.message_id += 1
-
- if data:
- data_json = json.dumps(data)
- else:
- # poll with GET
- data_json = None
-
-
- headers = {'content-type': 'application/json'}
- if self.session_id:
- headers['cookie'] = 'SESSION=%s'%self.session_id
-
- try:
- req = urllib2.Request(self.connection_msg, data_json, headers)
- response_stream = urllib2.urlopen(req, timeout=DEFAULT_TIMEOUT)
- except Exception:
- return
-
- for index, cookie in enumerate(cj):
- if cookie.name=='SESSION':
- self.session_id = cookie.value
-
- response = response_stream.read()
- self.bytes_received += len(response)
- if response:
- response = json.loads( response )
- if type(response) is not type([]):
- self.process_response(response)
- else:
- for item in response:
- self.process_response(item)
- if response:
- self.poll_interval = 1
- else:
- if self.poll_interval < 15:
- self.poll_interval += 1
- #print self.poll_interval, response
- self.rtime = time.time() - t1
- self.is_connected = True
- return ids
-
- def poll(self):
- self.send([], None)
-
- def start_http(self):
- self.rtime = 0
- self.bytes_received = 0
- self.poll_interval = 1
-
- self.session_id = None
- self.is_connected = True
- self.connection_msg = ('https' if self.use_ssl else 'http') + '://%s:%d'%( self.host, self.port )
- try:
- self.poll()
- except Exception:
- print_error("http init session failed")
- self.is_connected = False
- return
-
- if self.session_id:
- print_error('http session:',self.session_id)
- self.is_connected = True
- else:
- self.is_connected = False
-
- def run_http(self):
- self.is_connected = True
- while self.is_connected:
- try:
- if self.session_id:
- self.poll()
- time.sleep(self.poll_interval)
- except socket.gaierror:
- break
- except socket.error:
- break
- except Exception:
- traceback.print_exc(file=sys.stdout)
- break
-
- self.is_connected = False
-
-
-