Changeset 1181:f768c6025b94

Timestamp:

06/10/08 01:10:03 (6 months ago)

Author:

Ali Afshar <aafshar@…>

Message:

Support http proxy. Fixes lp:120543

Files:

• pida/services/plugins/plugins.py (modified) (5 diffs)

pida/services/plugins/plugins.py

@@ -29 +29 @@
 import base64
 import shutil
+import httplib
 
 from kiwi.ui.objectlist import Column
@@ -61 +62 @@
     return tab[key]
 
+# http://docs.python.org/lib/xmlrpc-client-example.html
+class ProxiedTransport(xmlrpclib.Transport):
+
+    def set_proxy(self, proxy):
+        self.proxy = proxy
+
+    def make_connection(self, host):
+        self.realhost = host
+        h = httplib.HTTP(self.proxy)
+        return h
+
+    def send_request(self, connection, handler, request_body):
+        connection.putrequest("POST", 'http://%s%s' % (self.realhost, handler))
+
+    def send_host(self, connection, host):
+        connection.putheader('Host', self.realhost)
+
+def create_transport():
+    if 'http_proxy' in os.environ:
+        host = os.environ['http_proxy']
+        t = ProxiedTransport()
+        t.set_proxy(host)
+        return t
+    else:
+        return xmlrpclib.Transport()
 
 class PluginsItem(object):
@@ -185 +211 @@
             if self.first_start:
                 self.first_start = False
-                gcall(self.svc.fetch_available_plugins)
+                def _fetch():
+                    gcall(self.svc.fetch_available_plugins)
+                gobject.idle_add(_fetch)
         else:
             self.svc.update_installed_plugins()
@@ -490 +518 @@
         self._view.start_pulse(_('Download available plugins'))
         try:
-            proxy = xmlrpclib.ServerProxy(self.rpc_url)
+            proxy = xmlrpclib.ServerProxy(self.rpc_url,
+                                          transport=create_transport())
             plist = proxy.plugins.list({'version': PIDA_VERSION})
             for k in plist:
@@ -597 +626 @@
                     data = file.read()
                     file.close()
-                    proxy = xmlrpclib.ServerProxy(self.rpc_url)
+                    proxy = xmlrpclib.ServerProxy(self.rpc_url,
+                                                  transport=create_transport())
                     code = proxy.plugins.push(login, password,
                             plugin, base64.b64encode(data))