Still wip, but connections are ok

Mirantis · Sep 18, 2015 · ce45875 · ce45875
1 parent 43b0131
commit ce45875
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 13 deletions.
diff --git a/resources/ro_node/meta.yaml b/resources/ro_node/meta.yaml
@@ -18,4 +18,4 @@ input:
     location_id:
       schema: str!
       value: $uuid
-        
+      reverse: True
diff --git a/solar/solar/core/signals.py b/solar/solar/core/signals.py
@@ -64,23 +64,16 @@ def _single(single):
         print emitter_single, receiver_single
         # connect in other direction
         if emitter_single_reverse:
+            if receiver_single_reverse:
+                connect_single(receiver, single, emitter, single)
+                _remove_from_mapping(single)
+                return
+        if receiver_single_reverse:
             connect_single(receiver, single, emitter, single)
             _remove_from_mapping(single)
             return
         if isinstance(orig_mapping, dict):
             orig_mapping[single] = single
-        # if we have reverse then do it in reverse way
-        # if emitter_single.get('reverse'):
-        #     connect_single(receiver, single, emitter, single)
-        #     # maybe already connected somewhere, then don't create this relation
-        #     if not emitter.resource_inputs()[single].backtrack_value():
-        #         connect_single(receiver, single, emitter, single)
-        # elif not receiver_single.get('reverse', False):
-        #     # maybe already connected somewhere, then don't create this relation
-        #     if not receiver.resource_inputs()[single].backtrack_value():
-        #         if isinstance(orig_mapping, dict):
-        #             orig_mapping[single] = single
-
     for single in ('transports_id', 'location_id'):
         _single(single)
     return