added unit conversion as plugin

istsos/actions/action.py

@@ -240,6 +240,9 @@ def __get_proxy(istsos_package, action_module, **kwargs):
         state.config["loader"]["type"],
         fileName
     )
+    print('GET_Proxy')
+    print(istsos_package)
+    print(action_module)
 
     istsos.debug("Importing %s.%s" % (module, action_module))
     try:
@@ -256,36 +259,11 @@ def __get_proxy(istsos_package, action_module, **kwargs):
         return m(**kwargs)
     return m()
 
-@asyncio.coroutine
-def __get_plugin_proxy(istsos_package, action_module, **kwargs):
-    from istsos import setting
-    import importlib
-    state = yield from setting.get_state()
-    fileName = action_module[0].lower() + action_module[1:]
-    module = 'istsos.%s.%s.%s' % (
-        istsos_package,
-        state.config["loader"]["type"],
-        fileName
-    )
-
-    istsos.debug("Importing %s.%s" % (module, action_module))
-    try:
-        m = importlib.import_module(module)
-    except Exception:
-        module = 'istsos.%s.%s' % (
-            istsos_package,
-            fileName
-        )
-        m = importlib.import_module(module)
-
-    m = getattr(m, action_module)
-    if kwargs is not None:
-        return m(**kwargs)
-    return m()
-
-
 @asyncio.coroutine
 def get_plugin(plugin, name, **kwargs):
+    print('GET_PLUGIN')
+    print(plugin)
+    print(name)
     import importlib
     fileName = name[0].lower() + name[1:]
     module = 'istsos.plugins.%s.%s.%s' % (
@@ -304,6 +282,7 @@ def get_plugin(plugin, name, **kwargs):
         m = importlib.import_module(module)
 
     m = getattr(m, name)
+    print(m)
     if kwargs is not None:
         return m(**kwargs)
     return m()

istsos/plugins/unit_con_post/retrievers/README.md

@@ -0,0 +1,4 @@
+# istSOS3 - Retrievers
+
+In this folder contains all the actions capable of storing the entities into
+a database.

istsos/plugins/unit_con_post/retrievers/aiopg/featureOfInterest.py

@@ -0,0 +1,46 @@
+# -*- coding: utf-8 -*-
+# istSOS. See https://istsos.org/
+# License: https://github.com/istSOS/istsos3/master/LICENSE.md
+# Version: v3.0.0
+
+import asyncio
+from istsos.actions.retrievers.featureOfInterest import (
+    FeatureOfInterest
+)
+
+
+class FeatureOfInterest(FeatureOfInterest):
+    """Return a single Feature of Interest based on identifier filter
+    """
+
+    @asyncio.coroutine
+    def process(self, request):
+        """Load all the featureOfInterest
+        """
+        dbmanager = yield from self.init_connection()
+        cur = dbmanager.cur
+        identifier = request.get_filter(self._IDENTIFIER)
+
+        if identifier is not None:
+            yield from cur.execute("""
+                SELECT
+                    row_to_json(t)
+                FROM (
+                    SELECT
+                        id,
+                        description,
+                        identifier,
+                        foi_name as name,
+                        foi_type as type,
+                        (
+                            ST_AsGeoJSON(ST_Force2D(geom))
+                        )::json as shape
+                    FROM
+                        public.fois
+                    WHERE
+                        fois.identifier = %s
+                ) t;
+            """, (identifier,))
+            rec = yield from cur.fetchone()
+            if rec is not None:
+                request['featureOfInterest'] = rec[0]