--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/cm/activity.py	Mon Nov 23 15:14:29 2009 +0100
@@ -0,0 +1,100 @@
+from cm.models import Activity, Text
+from django.contrib.auth.models import User
+from django.db.models import signals
+from datetime import datetime, timedelta
+from time import mktime
+import django.dispatch
+import logging
+
+def register_activity(request, type, text=None, comment=None, user=None, text_version=None):
+    signal_activity.send(sender=text, request=request, type=type, comment=comment, user=user, text_version=text_version)
+    
+# activity signal
+
+signal_activity = django.dispatch.Signal(providing_args=["request", "type", "comment"])
+
+def _save_activity(sender, **kwargs):
+    request = kwargs['request']
+    type = kwargs['type']
+    comment = kwargs['comment']
+    user = kwargs['user']
+    
+    text = sender
+    text_version = kwargs.get('text_version', None)
+    if not text_version and text:
+    	text_version = text.last_text_version
+        
+    if request.user.is_anonymous():
+        originator_user = None
+    else:
+        originator_user = request.user
+    ip = request.META['REMOTE_ADDR']
+    Activity.objects.create(text=text, user=user, text_version=text_version, comment=comment, type=type, ip=ip, originator_user=originator_user)
+    
+def connect_all():
+    signal_activity.connect(_save_activity)
+
+connect_all()
+
+# activity processing
+
+def seconds(t_delta):
+    return abs(t_delta.seconds + t_delta.days * 86400)
+
+VISIT_DURATION = timedelta(seconds=30 * 60) # 30 minutes
+
+def get_activity(text='all', user='all', reference_date=None, nb_slots=31, slot_timedelta=timedelta(days=1), action="all", kind=''):
+    """
+    text : text: specific text
+           'all': all texts
+    user : user: specific user
+           None: anonymous users
+           'all': all users
+    """
+    # calc activities used    
+    if not reference_date:
+        reference_date = datetime.now()
+    from_date = reference_date - slot_timedelta * nb_slots
+    activities = Activity.objects.filter(created__gt=from_date)
+    if action != 'all':
+        activities = activities.filter(type=action)
+    if text != 'all':
+        activities = activities.filter(text=text)
+    if user != 'all':
+        activities = activities.filter(originator_user=user)
+    activities = activities.order_by('created').only('created', 'originator_user', 'text')
+    #print 'got %d activities' % len(activities), [a.created for a in activities]
+    
+    if kind == 'raw':
+        visits = activities
+    else:
+        # calc visits
+        visits = []
+        if activities:
+            for i in range(len(activities)):
+                activity = activities[i]
+                found = False
+                for j in range(i - 1, -1, -1):
+                    prev_act = activities[j]                
+                    if activity.created > prev_act.created + VISIT_DURATION: # out of session bounds: add act
+                        visits.append(activity)
+                        found = True
+                        break
+                    else:
+                        if not activity.is_same_user(prev_act): # another user: just ignore prev_act
+                            continue
+                        else: # in session: do not count act
+                            found = True
+                            break
+                if not found:                    
+                    visits.append(activity)
+        #print 'got %d visits' % len(visits), [(v.created, v.user) for v in visits]
+    
+    # hist by slot_timedelta
+    slots = [seconds(from_date - v.created) // seconds(slot_timedelta) for v in visits]
+    
+    # TODO: could be more efficient...
+    res = [slots.count(index) for index in range(nb_slots)]
+    return res
+        
+