1

#!/usr/bin/env python

     2

# -*- coding: utf-8 -*-

     3

#

     4

# Copyright (C) 2007: Edouard TISSERANT and Laurent BESSARD

     5

#

     6

# See COPYING file for copyrights details.

     7

#

     8

# This library is free software; you can redistribute it and/or

     9

# modify it under the terms of the GNU General Public

    10

# License as published by the Free Software Foundation; either

    11

# version 2.1 of the License, or (at your option) any later version.

    12

#

    13

# This library is distributed in the hope that it will be useful,

    14

# but WITHOUT ANY WARRANTY; without even the implied warranty of

    15

# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU

    16

# General Public License for more details.

    17

#

    18

# You should have received a copy of the GNU General Public

    19

# License along with this library; if not, write to the Free Software

    20

# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

    21

    22

# Package initialisation

    23

    24

from os import listdir, path

    25

    26

    27

_base_path = path.split(__file__)[0]

    28

    29

    30

def _GetLocalConnectorClassFactory(name):

    31

    return lambda: getattr(__import__(name, globals(), locals()), name + "_connector_factory")

    32

    33

connectors = {name:_GetLocalConnectorClassFactory(name)

    34

                  for name in listdir(_base_path)

    35

                      if path.isdir(path.join(_base_path, name))

    36

                          and not name.startswith("__")}

    37

    38

    39

def ConnectorFactory(uri, confnodesroot):

    40

    """

    41

    Return a connector corresponding to the URI

    42

    or None if cannot connect to URI

    43

    """

    44

    servicetype = uri.split("://")[0].upper()

    45

    if servicetype == "LOCAL":

    46

        # Local is special case

    47

        # pyro connection to local runtime

    48

        # started on demand, listening on random port

    49

        servicetype = "PYRO"

    50

        runtime_port = confnodesroot.AppFrame.StartLocalRuntime(

    51

            taskbaricon=True)

    52

        uri = "PYROLOC://127.0.0.1:" + str(runtime_port)

    53

    elif servicetype in connectors:

    54

        pass

    55

    elif servicetype[-1] == 'S' and servicetype[:-1] in connectors:

    56

        servicetype = servicetype[:-1]

    57

    else:

    58

        return None

    59

    60

    # import module according to uri type

    61

    connectorclass = connectors[servicetype]()

    62

    return connectorclass(uri, confnodesroot)