taiga
/
taiga-back
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Merge pull request #255 from taigaio/events-after-commit 

Using transaction hooks to emit to taiga-events only after database comm...
remotes/origin/enhancement/email-actions
David Barragán Merino 2015-02-19 16:05:07 +01:00
parent 4660ee9ad0 7f26677c07
commit e81f2b36ae
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
taiga/events/signal_handlers.py
View File

@ -15,6 +15,8 @@
# along with this program. If not, see <http://www.gnu.org/licenses/>. # along with this program. If not, see <http://www.gnu.org/licenses/>.
from django.db.models import signals from django.db.models import signals
from django.db import connection
from django.dispatch import receiver from django.dispatch import receiver
from taiga.base.utils.db import get_typename_for_model_instance from taiga.base.utils.db import get_typename_for_model_instance
@ -33,10 +35,12 @@ def on_save_any_model(sender, instance, created, **kwargs):
sesionid = mw.get_current_session_id() sesionid = mw.get_current_session_id()
type = "change"
if created: if created:
events.emit_event_for_model(instance, sessionid=sesionid, type="create") type = "created"
else:
events.emit_event_for_model(instance, sessionid=sesionid, type="change") emit_event = lambda: events.emit_event_for_model(instance, sessionid=sesionid, type=type)
connection.on_commit(emit_event)
def on_delete_any_model(sender, instance, **kwargs): def on_delete_any_model(sender, instance, **kwargs):
@ -48,4 +52,5 @@ def on_delete_any_model(sender, instance, **kwargs):
return return
sesionid = mw.get_current_session_id() sesionid = mw.get_current_session_id()
events.emit_event_for_model(instance, sessionid=sesionid, type="delete") emit_event = lambda: events.emit_event_for_model(instance, sessionid=sesionid, type="delete")
connection.on_commit(emit_event)