src/cm/denorm_engine.py
author raph
Wed, 24 Mar 2010 16:14:19 +0100
changeset 228 3a0f8b54a151
parent 0 40c8f766c9b8
child 278 3d25afbd78ff
permissions -rw-r--r--
add tracking HTML from configuration
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:
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    21
        logging.warning('No text found for text_version: %i' %text_version.id)
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    22
        
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    23
        
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    24
def connect_all():
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    25
    # text updated by text_version
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    26
    signals.post_save.connect(update_text_from_last_version, sender=TextVersion)
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    27
    signals.post_delete.connect(update_text_from_last_version, sender=TextVersion)
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    28
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    29
40c8f766c9b8 import from internal svn r 4007
raph
parents:
diff changeset
    30
connect_all()