Make it possible to attach items to a given plugin

bin/smarthome.py

@@ -426,6 +426,12 @@ def return_plugins(self):
         for plugin in self._plugins:
             yield plugin
 
+    def return_plugin(self, name):
+        return self._plugins.get_plugin(name)
+
+    def get_plugin_ident(self, plugin):
+        return self._plugins.get_plugin_ident(plugin)
+
     #################################################################
     # Logic Methods
     #################################################################

lib/item.py

@@ -264,7 +264,31 @@ def __init__(self, smarthome, parent, path, config):
         #############################################################
         # Plugins
         #############################################################
+        confPlugins = []
+        if 'plugin' in self.conf:
+            for pluginName in self.conf['plugin'] if type(self.conf['plugin']) is list else [self.conf['plugin']]:
+                plugin = self._sh.return_plugin(pluginName)
+                if plugin is None:
+                   logger.error("Item {}: attached plugin {} not found.".format(self.id(), pluginName))
+                else:
+                   confPlugins.append(plugin)
+
         for plugin in self._sh.return_plugins():
+
+            # Check if plugin is explicitely configured in item or not
+            if len(confPlugins) and plugin not in confPlugins:
+                configurePlugin = True
+                for confPlugin in confPlugins:
+
+                    # Skip plugin if plugin was not configured explictely, but another instance
+                    # of the same class
+                    if plugin != confPlugin and issubclass(type(plugin), type(confPlugin)):
+                       configurePlugin = False
+                       break
+
+                if configurePlugin == False:
+                   continue
+
             if hasattr(plugin, 'parse_item'):
                 update = plugin.parse_item(self)
                 if update:

lib/plugin.py

@@ -61,6 +61,18 @@ def __iter__(self):
         for plugin in self._plugins:
             yield plugin
 
+    def get_plugin(self, name):
+        for thread in self._threads:
+            if thread.name == name:
+               return thread.plugin
+        return None
+
+    def get_plugin_ident(self, plugin):
+        for thread in self._threads:
+            if thread.plugin == plugin:
+               return thread.ident
+        return None
+
     def start(self):
         logger.info('Start Plugins')
         for plugin in self._threads:

plugins/sml/__init__.py

@@ -21,6 +21,7 @@
 
 import logging
 import time
+import socket
 import re
 import serial
 import threading