src/cm/denorm_engine.py
author Production Moz <dev@sopinspace.com>
Tue, 31 May 2011 17:52:28 +0200
changeset 344 9787360440db
parent 278 3d25afbd78ff
child 407 2d14a80716e2
permissions -rw-r--r--
memoize get_activity
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
0
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
     1
# This is the denormalisation engine
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
     2
# his goal is to leverage on django's signal to update
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
     3
# denormalized fields
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
     4
# this should be used with beanstalk or starling
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
     5
# python client (there is 2) http://github.com/earl/beanstalkc/tree/master
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
     6
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
     7
import logging
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
     8
from django.db.models import signals
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
     9
from cm.models import TextVersion, Text
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    10
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    11
# Text denormalisation
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    12
def update_text_from_last_version(sender, **kwargs):
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    13
    """
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    14
    Update text's last version
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    15
    """
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    16
    text_version = kwargs['instance']
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    17
    try:
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    18
        text = text_version.text
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    19
        text.update_denorm_fields()
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    20
    except Text.DoesNotExist:
278
3d25afbd78ff fix unit tests
raph
parents: 0
diff changeset
    21
        pass
3d25afbd78ff fix unit tests
raph
parents: 0
diff changeset
    22
        #logging.warning('No text found for text_version: %i' %text_version.id)
0
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    23
        
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    24
        
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    25
def connect_all():
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    26
    # text updated by text_version
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    27
    signals.post_save.connect(update_text_from_last_version, sender=TextVersion)
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    28
    signals.post_delete.connect(update_text_from_last_version, sender=TextVersion)
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    29
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    30
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    31
connect_all()