forum/models/node.py

   1 from base import *
   2 import re
   3 from tag import Tag
   4
   5 import markdown
   6 from django.utils.translation import ugettext as _
   7 from django.utils.safestring import mark_safe
   8 from django.utils.html import strip_tags
   9 from forum.utils.html import sanitize_html
  10
  11 class NodeContent(models.Model):
  12     title      = models.CharField(max_length=300)
  13     tagnames   = models.CharField(max_length=125)
  14     author     = models.ForeignKey(User, related_name='%(class)ss')
  15     body       = models.TextField()
  16
  17     @property
  18     def user(self):
  19         return self.author
  20
  21     @property
  22     def html(self):
  23         return self.as_markdown()
  24
  25     def as_markdown(self, *extensions):
  26         return mark_safe(sanitize_html(markdown.markdown(self.body, extensions=extensions)))
  27
  28     @property
  29     def headline(self):
  30         return self.title
  31
  32     def tagname_list(self):
  33         if self.tagnames:
  34             t = [name.strip() for name in self.tagnames.split(u' ') if name]
  35             return [name.strip() for name in self.tagnames.split(u' ') if name]
  36         else:
  37             return []
  38
  39     def tagname_meta_generator(self):
  40         return u','.join([tag for tag in self.tagname_list()])
  41
  42     class Meta:
  43         abstract = True
  44         app_label = 'forum'
  45
  46 class NodeMetaClass(BaseMetaClass):
  47     types = {}
  48
  49     def __new__(cls, *args, **kwargs):
  50         new_cls = super(NodeMetaClass, cls).__new__(cls, *args, **kwargs)
  51
  52         if not new_cls._meta.abstract and new_cls.__name__ is not 'Node':
  53             NodeMetaClass.types[new_cls.get_type()] = new_cls
  54
  55         return new_cls
  56
  57     @classmethod
  58     def setup_relations(cls):
  59         for node_cls in NodeMetaClass.types.values():
  60             NodeMetaClass.setup_relation(node_cls)
  61
  62     @classmethod
  63     def setup_relation(cls, node_cls):
  64         name = node_cls.__name__.lower()
  65
  66         def children(self):
  67             return node_cls.objects.filter(parent=self)
  68
  69         def parent(self):
  70             p = self.__dict__.get('_%s_cache' % name, None)
  71
  72             if p is None and (self.parent is not None) and self.parent.node_type == name:
  73                 p = self.parent.leaf
  74                 self.__dict__['_%s_cache' % name] = p
  75
  76             return p
  77
  78         Node.add_to_class(name + 's', property(children))
  79         Node.add_to_class(name, property(parent))
  80
  81
  82 class NodeQuerySet(CachedQuerySet):
  83     def obj_from_datadict(self, datadict):
  84         cls = NodeMetaClass.types.get(datadict.get("node_type", ""), None)
  85         if cls:
  86             obj = cls()
  87             obj.__dict__.update(datadict)
  88             return obj
  89         else:
  90             return super(NodeQuerySet, self).obj_from_datadict(datadict)
  91
  92     def get(self, *args, **kwargs):
  93         return super(NodeQuerySet, self).get(*args, **kwargs).leaf
  94
  95     def filter_state(self, **kwargs):
  96         apply_bool = lambda q, b: b and q or ~q
  97         return self.filter(*[apply_bool(models.Q(state_string__contains="(%s)" % s), b) for s, b in kwargs.items()])
  98
  99
 100 class NodeManager(CachedManager):
 101     use_for_related_fields = True
 102
 103     def get_query_set(self):
 104         qs = NodeQuerySet(self.model)
 105
 106         if self.model is not Node:
 107             return qs.filter(node_type=self.model.get_type())
 108         else:
 109             return qs
 110
 111     def get_for_types(self, types, *args, **kwargs):
 112         kwargs['node_type__in'] = [t.get_type() for t in types]
 113         return self.get(*args, **kwargs)
 114
 115     def filter_state(self, **kwargs):
 116         return self.all().filter_state(**kwargs)
 117
 118
 119 class NodeStateDict(object):
 120     def __init__(self, node):
 121         self.__dict__['_node'] = node
 122
 123     def __getattr__(self, name):
 124         if self.__dict__.get(name, None):
 125             return self.__dict__[name]
 126
 127         try:
 128             node = self.__dict__['_node']
 129             action = NodeState.objects.get(node=node, state_type=name).action
 130             self.__dict__[name] = action
 131             return action
 132         except:
 133             return None
 134
 135     def __setattr__(self, name, value):
 136         current = self.__getattr__(name)
 137
 138         if value:
 139             if current:
 140                 current.action = value
 141                 current.save()
 142             else:
 143                 node = self.__dict__['_node']
 144                 state = NodeState(node=node, action=value, state_type=name)
 145                 state.save()
 146                 self.__dict__[name] = value
 147
 148                 if not "(%s)" % name in node.state_string:
 149                     node.state_string = "%s(%s)" % (node.state_string, name)
 150                     node.save()
 151         else:
 152             if current:
 153                 node = self.__dict__['_node']
 154                 node.state_string = "".join("(%s)" % s for s in re.findall('\w+', node.state_string) if s != name)
 155                 node.save()
 156                 current.node_state.delete()
 157                 del self.__dict__[name]
 158
 159
 160 class NodeStateQuery(object):
 161     def __init__(self, node):
 162         self.__dict__['_node'] = node
 163
 164     def __getattr__(self, name):
 165         node = self.__dict__['_node']
 166         return "(%s)" % name in node.state_string
 167
 168
 169
 170 class Node(BaseModel, NodeContent):
 171     __metaclass__ = NodeMetaClass
 172
 173     node_type            = models.CharField(max_length=16, default='node')
 174     parent               = models.ForeignKey('Node', related_name='children', null=True)
 175     abs_parent           = models.ForeignKey('Node', related_name='all_children', null=True)
 176
 177     added_at             = models.DateTimeField(default=datetime.datetime.now)
 178     score                 = models.IntegerField(default=0)
 179
 180     state_string          = models.TextField(default='')
 181     last_edited           = models.ForeignKey('Action', null=True, unique=True, related_name="edited_node")
 182
 183     last_activity_by       = models.ForeignKey(User, null=True)
 184     last_activity_at       = models.DateTimeField(null=True, blank=True)
 185
 186     tags                 = models.ManyToManyField('Tag', related_name='%(class)ss')
 187     active_revision       = models.OneToOneField('NodeRevision', related_name='active', null=True)
 188
 189     extra_ref = models.ForeignKey('Node', null=True)
 190     extra_count = models.IntegerField(default=0)
 191
 192     marked = models.BooleanField(default=False)
 193
 194     comment_count = DenormalizedField("children", node_type="comment", canceled=False)
 195     flag_count = DenormalizedField("flags")
 196
 197     friendly_name = _("post")
 198
 199     objects = NodeManager()
 200
 201     def __unicode__(self):
 202         return self.headline
 203
 204     @classmethod
 205     def cache_key(cls, pk):
 206         return '%s:node:%s' % (settings.APP_URL, pk)
 207
 208     @classmethod
 209     def get_type(cls):
 210         return cls.__name__.lower()
 211
 212     @property
 213     def leaf(self):
 214         leaf_cls = NodeMetaClass.types.get(self.node_type, None)
 215
 216         if leaf_cls is None:
 217             return self
 218
 219         leaf = leaf_cls()
 220         leaf.__dict__ = self.__dict__
 221         return leaf
 222
 223     @property
 224     def nstate(self):
 225         state = self.__dict__.get('_nstate', None)
 226
 227         if state is None:
 228             state = NodeStateDict(self)
 229             self._nstate = state
 230
 231         return state
 232
 233     @property
 234     def nis(self):
 235         nis = self.__dict__.get('_nis', None)
 236
 237         if nis is None:
 238             nis = NodeStateQuery(self)
 239             self._nis = nis
 240
 241         return nis
 242
 243     @property
 244     def deleted(self):
 245         return self.nis.deleted
 246
 247     @property
 248     def absolute_parent(self):
 249         if not self.abs_parent_id:
 250             return self
 251
 252         return self.abs_parent
 253
 254     @property
 255     def summary(self):
 256         return strip_tags(self.html)[:300]
 257
 258     @models.permalink
 259     def get_revisions_url(self):
 260         return ('revisions', (), {'id': self.id})
 261
 262     def update_last_activity(self, user, save=False):
 263         self.last_activity_by = user
 264         self.last_activity_at = datetime.datetime.now()
 265
 266         if self.parent:
 267             self.parent.update_last_activity(user, save=True)
 268
 269         if save:
 270             self.save()
 271
 272     def _create_revision(self, user, number, **kwargs):
 273         revision = NodeRevision(author=user, revision=number, node=self, **kwargs)
 274         revision.save()
 275         return revision
 276
 277     def create_revision(self, user, **kwargs):
 278         number = self.revisions.aggregate(last=models.Max('revision'))['last'] + 1
 279         revision = self._create_revision(user, number, **kwargs)
 280         self.activate_revision(user, revision)
 281         return revision
 282
 283     def activate_revision(self, user, revision):
 284         self.title = revision.title
 285         self.tagnames = revision.tagnames
 286         self.body = revision.body
 287
 288         self.active_revision = revision
 289         self.update_last_activity(user)
 290
 291         self.save()
 292
 293     def _list_changes_in_tags(self):
 294         dirty = self.get_dirty_fields()
 295
 296         if not 'tagnames' in dirty:
 297             return None
 298         else:
 299             if self._original_state['tagnames']:
 300                 old_tags = set(name for name in self._original_state['tagnames'].split(u' '))
 301             else:
 302                 old_tags = set()
 303             new_tags = set(name for name in self.tagnames.split(u' ') if name)
 304
 305             return dict(
 306                 current=list(new_tags),
 307                 added=list(new_tags - old_tags),
 308                 removed=list(old_tags - new_tags)
 309             )
 310
 311     def _last_active_user(self):
 312         return self.last_edited and self.last_edited.by or self.author
 313
 314     def _process_changes_in_tags(self):
 315         tag_changes = self._list_changes_in_tags()
 316
 317         if tag_changes is not None:
 318             for name in tag_changes['added']:
 319                 try:
 320                     tag = Tag.objects.get(name=name)
 321                 except:
 322                     tag = Tag.objects.create(name=name, created_by=self._last_active_user())
 323
 324                 if not self.nis.deleted:
 325                     tag.used_count = models.F('used_count') + 1
 326                     tag.save()
 327
 328             if not self.nis.deleted:
 329                 for name in tag_changes['removed']:
 330                     try:
 331                         tag = Tag.objects.get(name=name)
 332                         tag.used_count = models.F('used_count') - 1
 333                         tag.save()
 334                     except:
 335                         pass
 336
 337             return True
 338
 339         return False
 340
 341     def mark_deleted(self, action):
 342         self.nstate.deleted = action
 343         self.save()
 344
 345         if action:
 346             for tag in self.tags.all():
 347                 tag.used_count = models.F('used_count') - 1
 348                 tag.save()
 349         else:
 350             for tag in Tag.objects.filter(name__in=self.tagname_list()):
 351                 tag.used_count = models.F('used_count') + 1
 352                 tag.save()
 353
 354     def save(self, *args, **kwargs):
 355         tags_changed = self._process_changes_in_tags()
 356
 357         if not self.id:
 358             self.node_type = self.get_type()
 359             super(BaseModel, self).save(*args, **kwargs)
 360             self.active_revision = self._create_revision(self.author, 1, title=self.title, tagnames=self.tagnames, body=self.body)
 361             self.update_last_activity(self.author)
 362
 363         if self.parent_id and not self.abs_parent_id:
 364             self.abs_parent = self.parent.absolute_parent
 365
 366         super(Node, self).save(*args, **kwargs)
 367         if tags_changed: self.tags = list(Tag.objects.filter(name__in=self.tagname_list()))
 368
 369     class Meta:
 370         app_label = 'forum'
 371
 372
 373 class NodeRevision(BaseModel, NodeContent):
 374     node       = models.ForeignKey(Node, related_name='revisions')
 375     summary    = models.CharField(max_length=300)
 376     revision   = models.PositiveIntegerField()
 377     revised_at = models.DateTimeField(default=datetime.datetime.now)
 378
 379     class Meta:
 380         unique_together = ('node', 'revision')
 381         app_label = 'forum'
 382
 383
 384 class NodeState(models.Model):
 385     node       = models.ForeignKey(Node, related_name='states')
 386     state_type = models.CharField(max_length=16)
 387     action     = models.OneToOneField('Action', related_name="node_state")
 388
 389     class Meta:
 390         unique_together = ('node', 'state_type')
 391         app_label = 'forum'
 392
 393