1

#!/usr/bin/env python

     2

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

     3

#

     5

#

     7

#

    12

#

    17

#

    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):

    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

    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)

    53

    elif servicetype in connectors:

    54

        pass

    56

        servicetype = servicetype[:-1]

    58

        return None

    59

    60

    # import module according to uri type

    61

    connectorclass = connectors[servicetype]()

    62

    return connectorclass(uri, confnodesroot)