server/sources/pyrorql.py
changeset 8675 b60329e40e26
parent 8545 eb7a171cec72
child 8695 358d8bed9626
--- a/server/sources/pyrorql.py	Fri Jan 04 15:18:44 2013 +0100
+++ b/server/sources/pyrorql.py	Fri Jan 04 15:39:52 2013 +0100
@@ -23,9 +23,6 @@
 import threading
 from Pyro.errors import PyroError, ConnectionClosedError
 
-from logilab.common.configuration import REQUIRED
-
-from cubicweb import dbapi
 from cubicweb import ConnectionError
 from cubicweb.server.sources import ConnectionWrapper
 
@@ -34,44 +31,6 @@
 class PyroRQLSource(RemoteSource):
     """External repository source, using Pyro connection"""
 
-    CNX_TYPE = 'pyro'
-
-    options = RemoteSource.options + (
-        # XXX pyro-ns host/port
-        ('pyro-ns-id',
-         {'type' : 'string',
-          'default': REQUIRED,
-          'help': 'identifier of the repository in the pyro name server',
-          'group': 'remote-source', 'level': 0,
-          }),
-        ('pyro-ns-host',
-         {'type' : 'string',
-          'default': None,
-          'help': 'Pyro name server\'s host. If not set, default to the value \
-from all_in_one.conf. It may contains port information using <host>:<port> notation.',
-          'group': 'remote-source', 'level': 1,
-          }),
-        ('pyro-ns-group',
-         {'type' : 'string',
-          'default': None,
-          'help': 'Pyro name server\'s group where the repository will be \
-registered. If not set, default to the value from all_in_one.conf.',
-          'group': 'remote-source', 'level': 2,
-          }),
-    )
-
-    def _get_connection(self):
-        """open and return a connection to the source"""
-        nshost = self.config.get('pyro-ns-host') or self.repo.config['pyro-ns-host']
-        nsgroup = self.config.get('pyro-ns-group') or self.repo.config['pyro-ns-group']
-        self.info('connecting to instance :%s.%s for user %s',
-                  nsgroup, self.config['pyro-ns-id'], self.config['cubicweb-user'])
-        return dbapi.connect(database=self.config['pyro-ns-id'],
-                             login=self.config['cubicweb-user'],
-                             password=self.config['cubicweb-password'],
-                             host=nshost, group=nsgroup,
-                             setvreg=False)
-
     def get_connection(self):
         try:
             return self._get_connection()