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

Using transaction hooks to emit to taiga-events only after database commit

remotes/origin/enhancement/email-actions
Jesús Espino 2015-02-16 14:49:59 +01:00 committed by David Barragán Merino
parent 4660ee9ad0
commit 7f26677c07
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)