X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=planetstack%2Fobserver%2F__init__.py;h=0d6c550ac0b47680784bc2134da6d5b282c4ebd5;hb=6ecd42600aa29e2ccaf0a59db03210d032d8d30d;hp=e69de29bb2d1d6434b8b29ae775ad8c2e48c5391;hpb=2d95e48d394480aa22596105c9ca469fb5c4c923;p=plstackapi.git

diff --git a/planetstack/observer/__init__.py b/planetstack/observer/__init__.py
index e69de29..0d6c550 100644
--- a/planetstack/observer/__init__.py
+++ b/planetstack/observer/__init__.py
@@ -0,0 +1,31 @@
+from planetstack.config import Config
+
+try:
+    observer_disabled = Config().observer_disabled
+except:
+    observer_disabled = False
+
+print_once = True
+
+if (not observer_disabled):
+    from .event_manager import EventSender
+
+    def notify_observer(model=None, delete=False, pk=None, model_dict={}):
+        try:
+            if (model and delete):
+                if hasattr(model,"__name__"):
+                    modelName = model.__name__
+                else:
+                    modelName = model.__class__.__name__
+                EventSender().fire(delete_flag = delete, model = modelName, pk = pk, model_dict=model_dict)
+            else:
+                EventSender().fire()
+        except Exception,e:
+            print "Exception in Observer. This should not disrupt the front end. %s"%str(e)
+
+else:
+    def notify_observer(model=None, delete=False):
+#        if (print_once):
+#            print "The observer is disabled"
+#            print_once = False
+        return