| author | gibus |
| Thu, 03 Jan 2013 11:04:39 +0100 | |
| changeset 478 | b9772b94b624 |
| parent 460 | 2fdb7d095d5c |
| child 504 | b2e0186daa5b |
| permissions | -rw-r--r-- |
|
156
6d447220fd1e
bug fix: removed \r in textversion's content because of a comment position bug in pre_edit. Added a save function to TextVersion to do so.
rbernard
parents:
155
diff
changeset
|
1 |
import re |
| 0 | 2 |
from cm.converters.pandoc_converters import \ |
3 |
CHOICES_INPUT_FORMATS as CHOICES_INPUT_FORMATS_PANDOC, \ |
|
4 |
DEFAULT_INPUT_FORMAT as DEFAULT_INPUT_FORMAT_PANDOC, pandoc_convert |
|
5 |
from cm.models_base import PermanentModel, KeyManager, Manager, KeyModel, AuthorModel |
|
6 |
from cm.models_utils import * |
|
7 |
from cm.utils.dj import absolute_reverse |
|
8 |
from cm.utils.date import datetime_to_user_str |
|
| 175 | 9 |
from cm.utils.html import on_content_receive |
| 0 | 10 |
from cm.utils.comment_positioning import compute_new_comment_positions |
11 |
from django import forms |
|
12 |
from django.db.models import Q |
|
13 |
from django.template.loader import render_to_string |
|
14 |
from django.conf import settings |
|
15 |
from django.template import RequestContext |
|
16 |
from django.contrib.auth.models import Permission |
|
17 |
from django.contrib.contenttypes import generic |
|
18 |
from django.contrib.contenttypes.models import ContentType |
|
19 |
from django.core.files.base import ContentFile |
|
20 |
from django.core.urlresolvers import reverse |
|
21 |
from django.template.defaultfilters import timesince |
|
22 |
from django.db import models |
|
23 |
from django.utils.translation import ugettext as _, ugettext_lazy, ugettext_noop |
|
24 |
from tagging.fields import TagField |
|
25 |
import pickle |
|
26 |
from django.db import connection |
|
|
72
b0c777412d0a
keep comment dates (created / modified) when duplicating (fixes #12)
raph
parents:
38
diff
changeset
|
27 |
from datetime import datetime |
| 0 | 28 |
|
29 |
class TextManager(Manager): |
|
30 |
def create_text(self, title, format, content, note, name, email, tags, user=None, state='approved', **kwargs): |
|
| 175 | 31 |
content = on_content_receive(content, format) |
| 0 | 32 |
text = self.create(name=name, email=email, user=user, state=state) |
33 |
text_version = TextVersion.objects.create(title=title, format=format, content=content, text=text, note=note, name=name, email=email, tags=tags, user=user) |
|
34 |
return text |
|
35 |
||
36 |
def create_new_version(self, text, title, format, content, note, name, email, tags, user=None, **kwargs): |
|
37 |
text_version = TextVersion.objects.create(title=title, format=format, content=content, text=text, note=note, name=name, email=email, tags=tags, user=user) |
|
38 |
return text_version |
|
39 |
||
40 |
class Text(PermanentModel, AuthorModel): |
|
41 |
modified = models.DateTimeField(auto_now=True) |
|
42 |
created = models.DateTimeField(auto_now_add=True) |
|
43 |
||
44 |
private_feed_key = models.CharField(max_length=20, db_index=True, unique=True, blank=True, null=True, default=None) |
|
45 |
||
46 |
# denormalized fields |
|
|
407
2d14a80716e2
When last_version is deleted, do not delete text and previous versions in cascade, but really delete text only when there is no previous version, otherwise update text.last_version with previous version.
gibus
parents:
347
diff
changeset
|
47 |
last_text_version = models.ForeignKey("TextVersion", related_name='related_text', null=True, blank=True, on_delete=models.SET_NULL) |
| 0 | 48 |
title = models.TextField() |
49 |
||
50 |
objects = TextManager() |
|
51 |
||
52 |
def get_latest_version(self): |
|
53 |
return self.last_text_version |
|
54 |
||
55 |
def fetch_latest_version(self): |
|
56 |
versions = self.get_versions() |
|
57 |
if versions: |
|
58 |
return versions[0] |
|
59 |
else: |
|
60 |
return None |
|
61 |
||
62 |
def update_denorm_fields(self): |
|
63 |
real_last_text_version = self.fetch_latest_version() |
|
64 |
||
| 289 | 65 |
try: |
66 |
last_text_version = self.last_text_version |
|
67 |
except TextVersion.DoesNotExist: |
|
68 |
# the text version has just been deleted |
|
69 |
last_text_version = None |
|
70 |
||
| 0 | 71 |
modif = False |
| 289 | 72 |
if real_last_text_version and real_last_text_version != last_text_version: |
| 0 | 73 |
self.last_text_version = real_last_text_version |
74 |
modif = True |
|
75 |
||
76 |
if real_last_text_version and real_last_text_version.title and real_last_text_version.title != self.title: |
|
77 |
self.title = real_last_text_version.title |
|
78 |
modif = True |
|
79 |
||
80 |
if real_last_text_version and real_last_text_version.modified != self.modified: |
|
81 |
self.modified = real_last_text_version.modified |
|
82 |
modif = True |
|
83 |
||
84 |
if modif: |
|
85 |
self.save() |
|
86 |
||
|
407
2d14a80716e2
When last_version is deleted, do not delete text and previous versions in cascade, but really delete text only when there is no previous version, otherwise update text.last_version with previous version.
gibus
parents:
347
diff
changeset
|
87 |
# GIB: there is no more version for this text => delete it |
|
2d14a80716e2
When last_version is deleted, do not delete text and previous versions in cascade, but really delete text only when there is no previous version, otherwise update text.last_version with previous version.
gibus
parents:
347
diff
changeset
|
88 |
if real_last_text_version == None and last_text_version == None: |
|
2d14a80716e2
When last_version is deleted, do not delete text and previous versions in cascade, but really delete text only when there is no previous version, otherwise update text.last_version with previous version.
gibus
parents:
347
diff
changeset
|
89 |
self.real_delete() |
| 0 | 90 |
|
91 |
def get_title(self): |
|
92 |
return self.get_latest_version().title |
|
93 |
||
94 |
def get_versions(self): |
|
95 |
""" |
|
96 |
Versions with most recent first |
|
97 |
""" |
|
98 |
versions = TextVersion.objects.filter(text__exact=self).order_by('-created') |
|
99 |
# TODO: use new postgresql 8.4 row_number as extra select to do that |
|
| 145 | 100 |
#for index in xrange(len(versions)): |
101 |
# v = versions[index] |
|
102 |
# # version_number is 1-based |
|
103 |
# setattr(v, 'version_number', len(versions) - index) |
|
| 0 | 104 |
return versions |
105 |
||
106 |
def get_version(self, version_number): |
|
107 |
""" |
|
108 |
Get version number 'version_number' (1-based) |
|
109 |
""" |
|
110 |
version = TextVersion.objects.filter(text__exact=self).order_by('created')[version_number - 1:version_number][0] |
|
111 |
return version |
|
112 |
||
113 |
def get_inversed_versions(self): |
|
114 |
versions = TextVersion.objects.filter(text__exact=self).order_by('created') |
|
115 |
# TODO: use new postgresql 8.4 row_number as extra select to do that |
|
| 145 | 116 |
#for index in xrange(len(versions)): |
117 |
# v = versions[index] |
|
118 |
# # version_number is 1-based |
|
119 |
# setattr(v, 'version_number', index + 1) |
|
| 0 | 120 |
return versions |
121 |
||
122 |
def get_versions_number(self): |
|
123 |
return self.get_versions().count() |
|
124 |
||
125 |
def is_admin(self, adminkey=None): |
|
126 |
if adminkey and self.adminkey == adminkey: |
|
127 |
return True |
|
128 |
else: |
|
129 |
return False |
|
130 |
||
| 145 | 131 |
def revert_to_version(self, text_version_key): |
132 |
text_version = TextVersion.objects.get(key=text_version_key) |
|
133 |
if text_version.text != self: |
|
134 |
raise Exception('Invalid revert attempt') |
|
| 0 | 135 |
new_text_version = TextVersion.objects.duplicate(text_version, True) |
136 |
return new_text_version |
|
137 |
||
| 103 | 138 |
def edit(self, new_title, new_format, new_content, new_tags=None, new_note=None, keep_comments=True, cancel_modified_scopes=True, new_version=True): |
| 0 | 139 |
text_version = self.get_latest_version() |
140 |
||
141 |
if new_version: |
|
142 |
text_version = TextVersion.objects.duplicate(text_version, keep_comments) |
|
| 103 | 143 |
text_version.edit(new_title, new_format, new_content, new_tags, new_note, keep_comments, cancel_modified_scopes) |
| 0 | 144 |
return text_version |
145 |
||
146 |
def __unicode__(self): |
|
147 |
return self.title |
|
148 |
||
149 |
DEFAULT_INPUT_FORMAT = getattr(settings, 'DEFAULT_INPUT_FORMAT', DEFAULT_INPUT_FORMAT_PANDOC) |
|
150 |
CHOICES_INPUT_FORMATS = getattr(settings, 'CHOICES_INPUT_FORMATS', CHOICES_INPUT_FORMATS_PANDOC) |
|
151 |
||
| 24 | 152 |
class TextVersionManager(KeyManager): |
| 0 | 153 |
|
154 |
def duplicate(self, text_version, duplicate_comments=True): |
|
155 |
old_comment_set = set(text_version.comment_set.all()) |
|
156 |
text_version.id = None |
|
| 24 | 157 |
|
158 |
# generate new key |
|
159 |
text_version.key = self._gen_key() |
|
160 |
text_version.adminkey = self._gen_adminkey() |
|
161 |
||
| 0 | 162 |
text_version.save() |
163 |
||
164 |
duplicate_text_version = text_version |
|
165 |
||
166 |
if duplicate_comments: |
|
167 |
old_comment_map = {} |
|
168 |
while len(old_comment_set): |
|
169 |
for c in old_comment_set: |
|
170 |
if not c.reply_to or c.reply_to.id in old_comment_map: |
|
171 |
old_id = c.id |
|
172 |
old_comment_set.remove(c) |
|
173 |
reply_to = None |
|
174 |
if c.reply_to: |
|
175 |
reply_to = old_comment_map[c.reply_to.id] |
|
|
72
b0c777412d0a
keep comment dates (created / modified) when duplicating (fixes #12)
raph
parents:
38
diff
changeset
|
176 |
c2 = Comment.objects.duplicate(c, duplicate_text_version, reply_to, keep_dates=True) |
| 0 | 177 |
old_comment_map[old_id] = c2 |
178 |
break |
|
179 |
||
180 |
return duplicate_text_version |
|
181 |
||
| 24 | 182 |
class TextVersion(AuthorModel, KeyModel): |
| 0 | 183 |
modified = models.DateTimeField(auto_now=True) |
184 |
created = models.DateTimeField(auto_now_add=True) |
|
185 |
||
186 |
title = models.TextField(ugettext_lazy("Title")) |
|
187 |
format = models.CharField(ugettext_lazy("Format"), max_length=20, blank=False, default=DEFAULT_INPUT_FORMAT, choices=CHOICES_INPUT_FORMATS) |
|
188 |
content = models.TextField(ugettext_lazy("Content")) |
|
189 |
tags = TagField(ugettext_lazy("Tags"), max_length=1000) |
|
190 |
||
191 |
note = models.CharField(ugettext_lazy("Note"), max_length=100, null=True, blank=True) |
|
192 |
||
193 |
mod_posteriori = models.BooleanField(ugettext_lazy('Moderation a posteriori?'), default=True) |
|
194 |
||
195 |
text = models.ForeignKey("Text") |
|
196 |
||
197 |
objects = TextVersionManager() |
|
198 |
||
199 |
def get_content(self, format='html'): |
|
|
259
0371caf8bcc6
always use pandoc but in raw mode for html->html convert
raph
parents:
252
diff
changeset
|
200 |
return pandoc_convert(self.content, self.format, format) |
| 478 | 201 |
|
| 0 | 202 |
def get_comments(self): |
203 |
"Warning: data access without security" |
|
204 |
return self.comment_set.filter(reply_to=None, deleted=False) |
|
205 |
||
206 |
def get_replies(self): |
|
207 |
"Warning: data access without security" |
|
208 |
return self.comment_set.filter(~Q(reply_to == None), Q(deleted=False)) |
|
209 |
||
210 |
def __unicode__(self): |
|
211 |
return '<%d> %s' % (self.id, self.title) |
|
212 |
||
| 175 | 213 |
def edit(self, new_title, new_format, new_content, new_tags=None, new_note=None, keep_comments=True, cancel_modified_scopes=True): |
214 |
new_content = on_content_receive(new_content, new_format) |
|
| 0 | 215 |
if not keep_comments : |
216 |
self.comment_set.all().delete() |
|
217 |
elif self.content != new_content or new_format != self.format: |
|
218 |
comments = self.get_comments() ; |
|
219 |
tomodify_comments, toremove_comments = compute_new_comment_positions(self.content, self.format, new_content, new_format, comments) |
|
|
72
b0c777412d0a
keep comment dates (created / modified) when duplicating (fixes #12)
raph
parents:
38
diff
changeset
|
220 |
[comment.save(keep_dates=True) for comment in tomodify_comments] |
| 103 | 221 |
if cancel_modified_scopes : |
222 |
[comment.remove_scope() for comment in toremove_comments] |
|
223 |
else : |
|
224 |
[comment.delete() for comment in toremove_comments] |
|
225 |
||
| 0 | 226 |
self.title = new_title |
227 |
if new_tags: |
|
228 |
self.tags = new_tags |
|
229 |
if new_note: |
|
230 |
self.note = new_note |
|
231 |
self.content = new_content |
|
232 |
self.format = new_format |
|
233 |
self.save() |
|
| 145 | 234 |
|
235 |
def get_next_version(self): |
|
236 |
other_versions = TextVersion.objects.filter(text__exact=self.text).order_by('created').filter(created__gt=self.created) |
|
237 |
return other_versions[0] if other_versions else None |
|
238 |
if other_versions: |
|
239 |
return |
|
240 |
else: |
|
241 |
return None |
|
242 |
||
243 |
def get_previous_version(self): |
|
244 |
other_versions = TextVersion.objects.filter(text__exact=self.text).order_by('-created').filter(created__lt=self.created) |
|
245 |
return other_versions[0] if other_versions else None |
|
246 |
||
247 |
def get_version_number(self): |
|
248 |
return TextVersion.objects.filter(text__exact=self.text).order_by('created').filter(created__lte=self.created).count() |
|
|
156
6d447220fd1e
bug fix: removed \r in textversion's content because of a comment position bug in pre_edit. Added a save function to TextVersion to do so.
rbernard
parents:
155
diff
changeset
|
249 |
|
| 0 | 250 |
class CommentManager(Manager): |
251 |
||
|
72
b0c777412d0a
keep comment dates (created / modified) when duplicating (fixes #12)
raph
parents:
38
diff
changeset
|
252 |
def duplicate(self, comment, text_version, reply_to=None, keep_dates=False): |
| 0 | 253 |
comment.id = None |
254 |
comment.text_version = text_version |
|
255 |
if reply_to: |
|
256 |
comment.reply_to = reply_to |
|
257 |
self.update_keys(comment) |
|
|
72
b0c777412d0a
keep comment dates (created / modified) when duplicating (fixes #12)
raph
parents:
38
diff
changeset
|
258 |
comment.save(keep_dates=keep_dates) |
| 0 | 259 |
return comment |
260 |
||
|
130
f257ad33bed5
model change+migration (add id_key to comment): run ./bin/django migrate
raph
parents:
103
diff
changeset
|
261 |
from cm.models_base import KEY_MAX_SIZE, generate_key |
|
f257ad33bed5
model change+migration (add id_key to comment): run ./bin/django migrate
raph
parents:
103
diff
changeset
|
262 |
|
| 0 | 263 |
class Comment(PermanentModel, AuthorModel): |
|
72
b0c777412d0a
keep comment dates (created / modified) when duplicating (fixes #12)
raph
parents:
38
diff
changeset
|
264 |
modified = models.DateTimeField() |
|
b0c777412d0a
keep comment dates (created / modified) when duplicating (fixes #12)
raph
parents:
38
diff
changeset
|
265 |
created = models.DateTimeField() |
| 0 | 266 |
|
|
130
f257ad33bed5
model change+migration (add id_key to comment): run ./bin/django migrate
raph
parents:
103
diff
changeset
|
267 |
# key to identify same comments across versions |
|
f257ad33bed5
model change+migration (add id_key to comment): run ./bin/django migrate
raph
parents:
103
diff
changeset
|
268 |
id_key = models.CharField(max_length=KEY_MAX_SIZE, db_index=True, default=generate_key) |
|
f257ad33bed5
model change+migration (add id_key to comment): run ./bin/django migrate
raph
parents:
103
diff
changeset
|
269 |
|
| 0 | 270 |
text_version = models.ForeignKey("TextVersion") |
271 |
||
272 |
# comment_set will be replies |
|
273 |
reply_to = models.ForeignKey("Comment", null=True, blank=True) |
|
274 |
||
275 |
title = models.TextField() |
|
276 |
content = models.TextField() |
|
277 |
content_html = models.TextField() |
|
278 |
||
279 |
format = models.CharField(_("Format:"), max_length=20, blank=False, default=DEFAULT_INPUT_FORMAT, choices=CHOICES_INPUT_FORMATS) |
|
280 |
||
281 |
tags = TagField() |
|
282 |
||
283 |
start_wrapper = models.IntegerField(null=True, blank=True) |
|
284 |
end_wrapper = models.IntegerField(null=True, blank=True) |
|
285 |
start_offset = models.IntegerField(null=True, blank=True) |
|
286 |
end_offset = models.IntegerField(null=True, blank=True) |
|
287 |
||
288 |
objects = CommentManager() |
|
289 |
||
| 327 | 290 |
def save(self, keep_dates=False, **kwargs): |
|
72
b0c777412d0a
keep comment dates (created / modified) when duplicating (fixes #12)
raph
parents:
38
diff
changeset
|
291 |
if not keep_dates: |
|
b0c777412d0a
keep comment dates (created / modified) when duplicating (fixes #12)
raph
parents:
38
diff
changeset
|
292 |
now = datetime.now() |
|
b0c777412d0a
keep comment dates (created / modified) when duplicating (fixes #12)
raph
parents:
38
diff
changeset
|
293 |
if not self.id: |
|
b0c777412d0a
keep comment dates (created / modified) when duplicating (fixes #12)
raph
parents:
38
diff
changeset
|
294 |
self.created = now |
|
b0c777412d0a
keep comment dates (created / modified) when duplicating (fixes #12)
raph
parents:
38
diff
changeset
|
295 |
self.modified = now |
| 327 | 296 |
super(PermanentModel, self).save(**kwargs) |
|
72
b0c777412d0a
keep comment dates (created / modified) when duplicating (fixes #12)
raph
parents:
38
diff
changeset
|
297 |
|
| 0 | 298 |
def __unicode__(self): |
| 262 | 299 |
return '<%d> %s [st_wrp:%s, st_ofs:%s, e_wrp:%s, e_ofs:%s]' % (self.id, self.title, self.start_wrapper , self.start_offset, self.end_wrapper, self.end_offset, ) |
| 0 | 300 |
|
301 |
def is_reply(self): |
|
302 |
return self.reply_to != None |
|
303 |
||
| 16 | 304 |
def is_thread_full_visible(self, own_user=None): |
305 |
""" |
|
306 |
own_user: comment belonging to this user are also visible |
|
307 |
""" |
|
308 |
if self.state == 'approved' or (own_user and self.user == own_user): |
|
309 |
if self.reply_to==None: |
|
310 |
return True |
|
311 |
else: |
|
312 |
return self.reply_to.is_thread_full_visible(own_user) |
|
313 |
return False |
|
314 |
||
| 103 | 315 |
def is_scope_removed(self): |
316 |
#when scope is "removed" we will have |
|
317 |
#self.start_wrapper == self.end_wrapper == self.start_offset == self.end_offset == -1 |
|
318 |
return (self.start_wrapper == -1) |
|
319 |
||
| 0 | 320 |
def top_comment(self): |
321 |
if self.reply_to == None : |
|
322 |
return self |
|
323 |
else : |
|
324 |
return self.reply_to.top_comment() |
|
325 |
||
326 |
def depth(self): |
|
327 |
if self.reply_to == None : |
|
328 |
return 0 |
|
329 |
else : |
|
330 |
return 1 + self.reply_to.depth() |
|
331 |
||
332 |
def delete(self): |
|
333 |
PermanentModel.delete(self) |
|
334 |
# delete replies |
|
335 |
[c.delete() for c in self.comment_set.all()] |
|
| 103 | 336 |
|
337 |
def remove_scope(self): |
|
338 |
self.start_wrapper = self.end_wrapper = self.start_offset = self.end_offset = -1 |
|
339 |
self.save() |
|
340 |
||
| 0 | 341 |
# http://docs.djangoproject.com/en/dev/topics/files/#topics-files |
342 |
||
343 |
# default conf values |
|
344 |
DEFAULT_CONF = { |
|
345 |
'workspace_name' : 'Workspace', |
|
346 |
'site_url' : settings.SITE_URL, |
|
347 |
'email_from' : settings.DEFAULT_FROM_EMAIL, |
|
348 |
} |
|
349 |
||
350 |
from cm.role_models import change_role_model |
|
351 |
||
352 |
class ConfigurationManager(models.Manager): |
|
353 |
def set_workspace_name(self, workspace_name): |
|
| 140 | 354 |
if workspace_name: |
355 |
self.set_key('workspace_name', workspace_name) |
|
| 0 | 356 |
|
357 |
def get_key(self, key, default_value=None): |
|
358 |
try: |
|
359 |
return self.get(key=key).value |
|
360 |
except Configuration.DoesNotExist: |
|
361 |
return DEFAULT_CONF.get(key, default_value) |
|
| 160 | 362 |
|
363 |
def del_key(self, key): |
|
364 |
try: |
|
365 |
self.get(key=key).delete() |
|
366 |
except Configuration.DoesNotExist: |
|
367 |
return None |
|
| 0 | 368 |
|
369 |
def set_key(self, key, value): |
|
370 |
conf, created = self.get_or_create(key=key) |
|
371 |
if created or conf.value != value: |
|
372 |
conf.value = value |
|
373 |
conf.save() |
|
374 |
if key == 'workspace_role_model': |
|
375 |
change_role_model(value) |
|
376 |
||
377 |
def __getitem__(self, key): |
|
| 160 | 378 |
if not key.startswith('f_'): |
379 |
return self.get_key(key, None) |
|
380 |
else: |
|
381 |
return getattr(self,key)() |
|
382 |
||
383 |
def f_get_logo_url(self): |
|
384 |
key = self.get_key('workspace_logo_file_key', None) |
|
385 |
if key: |
|
386 |
attach = Attachment.objects.get(key=key) |
|
387 |
return attach.data.url |
|
388 |
else: |
|
389 |
return None |
|
| 0 | 390 |
|
391 |
import base64 |
|
392 |
||
393 |
class Configuration(models.Model): |
|
394 |
key = models.TextField(blank=False) # , unique=True cannot be added: creates error on mysql (?) |
|
395 |
raw_value = models.TextField(blank=False) |
|
396 |
||
397 |
def get_value(self): |
|
398 |
return pickle.loads(base64.b64decode(self.raw_value.encode('utf8'))) |
|
399 |
||
400 |
def set_value(self, value): |
|
401 |
self.raw_value = base64.b64encode(pickle.dumps(value, 0)).encode('utf8') |
|
402 |
||
403 |
value = property(get_value, set_value) |
|
404 |
||
405 |
objects = ConfigurationManager() |
|
406 |
||
407 |
def __unicode__(self): |
|
408 |
return '%s: %s' % (self.key, self.value) |
|
409 |
||
410 |
ApplicationConfiguration = Configuration.objects |
|
411 |
||
412 |
class AttachmentManager(KeyManager): |
|
413 |
def create_attachment(self, text_version, filename, data): |
|
414 |
attach = self.create(text_version=text_version) |
|
415 |
ff = ContentFile(data) |
|
416 |
attach.data.save(filename, ff) |
|
417 |
return attach |
|
418 |
||
419 |
class Attachment(KeyModel): |
|
420 |
data = models.FileField(upload_to="attachments/%Y/%m/%d/", max_length=1000) |
|
| 160 | 421 |
text_version = models.ForeignKey(TextVersion, null=True) |
| 0 | 422 |
|
423 |
objects = AttachmentManager() |
|
424 |
||
425 |
class NotificationManager(KeyManager): |
|
| 12 | 426 |
def create_notification(self, text, type, active, email_or_user): |
427 |
notification = self.create(text=text, type=type, active=active) |
|
428 |
notification.set_email_or_user(email_or_user) |
|
429 |
return notification |
|
| 0 | 430 |
|
| 12 | 431 |
def get_notifications(self, text, type, email_or_user): |
| 0 | 432 |
if isinstance(email_or_user,unicode): |
433 |
prev_notifications = Notification.objects.filter(text=text, type=type, email=email_or_user) |
|
434 |
else: |
|
435 |
prev_notifications = Notification.objects.filter(text=text, type=type, user=email_or_user) |
|
| 12 | 436 |
|
| 0 | 437 |
if prev_notifications: |
438 |
return prev_notifications[0] |
|
439 |
else: |
|
440 |
return None |
|
441 |
||
| 12 | 442 |
def set_notification(self, text, type, active, email_or_user): |
443 |
notification = self.get_notifications(text, type, email_or_user) |
|
444 |
if notification == None : |
|
445 |
self.create_notification(text, type, active, email_or_user) |
|
446 |
else : |
|
447 |
notification.active = active |
|
| 0 | 448 |
notification.save() |
449 |
||
450 |
class Notification(KeyModel, AuthorModel): |
|
451 |
text = models.ForeignKey(Text, null=True, blank=True) |
|
452 |
type = models.CharField(max_length=30, null=True, blank=True) |
|
453 |
active = models.BooleanField(default=True) # active = False means user desactivation |
|
454 |
||
455 |
objects = NotificationManager() |
|
456 |
||
457 |
def desactivate_notification_url(self): |
|
458 |
return reverse('desactivate-notification', args=[self.adminkey]) |
|
459 |
||
460 |
def desactivate(self): |
|
461 |
if self.type=='own': |
|
462 |
self.active = False |
|
463 |
self.save() |
|
464 |
else: |
|
465 |
self.delete() |
|
466 |
||
| 266 | 467 |
def __unicode__(self): |
468 |
return u"%s: %s %s %s %s" % (self.__class__.__name__, self.user, self.text, self.type, self.active ) |
|
469 |
||
| 0 | 470 |
# right management |
471 |
class UserRoleManager(models.Manager): |
|
472 |
def create_userroles_text(self, text): |
|
473 |
# make sure every user has a userrole on this text |
|
474 |
for user in User.objects.all(): |
|
475 |
userrole, _ = self.get_or_create(user=user, text=text) |
|
476 |
# anon user |
|
477 |
userrole, _ = self.get_or_create(user=None, text=text) |
|
478 |
# anon global user |
|
479 |
global_userrole, _ = self.get_or_create(user=None, text=None) |
|
480 |
||
481 |
class UserRole(models.Model): |
|
482 |
role = models.ForeignKey("Role", null=True, blank=True) |
|
483 |
||
484 |
# user == null => anyone |
|
485 |
user = models.ForeignKey(User, null=True, blank=True) |
|
486 |
||
487 |
# text == null => any text (workspace role) |
|
488 |
text = models.ForeignKey(Text, null=True, blank=True) |
|
489 |
||
490 |
objects = UserRoleManager() |
|
491 |
||
492 |
class Meta: |
|
493 |
unique_together = (('role', 'user', 'text',)) |
|
494 |
||
495 |
def __unicode__(self): |
|
496 |
if self.role: |
|
497 |
rolename = _(self.role.name) |
|
498 |
else: |
|
499 |
rolename = '' |
|
500 |
||
501 |
if self.user: |
|
502 |
return u"%s: %s %s %s" % (self.__class__.__name__, self.user.username, self.text, rolename) |
|
503 |
else: |
|
504 |
return u"%s: *ALL* %s %s" % (self.__class__.__name__, self.text, rolename) |
|
505 |
||
506 |
def __repr__(self): |
|
507 |
return self.__unicode__() |
|
508 |
||
509 |
from cm.models_base import generate_key |
|
510 |
from cm.utils.misc import update |
|
511 |
||
512 |
class Role(models.Model): |
|
513 |
""" |
|
514 |
'Static' application roles |
|
515 |
""" |
|
516 |
name = models.CharField(ugettext_lazy('name'), max_length=50, unique=True) |
|
517 |
description = models.TextField(ugettext_lazy('description')) |
|
518 |
permissions = models.ManyToManyField(Permission, related_name="roles") |
|
519 |
||
520 |
global_scope = models.BooleanField('global scope', default=False) # applies to global scope only |
|
521 |
anon = models.BooleanField('anonymous', default=False) # role possible for anonymous users? |
|
522 |
||
523 |
def __unicode__(self): |
|
524 |
return _(self.name) |
|
525 |
||
526 |
def __hash__(self): |
|
527 |
return self.id |
|
528 |
||
529 |
def name_i18n(self): |
|
530 |
return _(self.name) |
|
531 |
||
532 |
from django.utils.safestring import mark_safe |
|
533 |
||
534 |
class RegistrationManager(KeyManager): |
|
535 |
def activate_user(self, activation_key): |
|
536 |
""" |
|
537 |
Validates an activation key and activates the corresponding |
|
538 |
``User`` if valid. |
|
539 |
If the key is valid , returns the ``User`` as second arg |
|
540 |
First is boolean indicating if user has just been activated |
|
541 |
""" |
|
542 |
# Make sure the key we're trying conforms to the pattern of a |
|
543 |
# SHA1 hash; if it doesn't, no point trying to look it up in |
|
544 |
# the database. |
|
545 |
try: |
|
546 |
profile = self.get(admin_key=activation_key) |
|
547 |
except self.model.DoesNotExist: |
|
548 |
return False, False |
|
549 |
user = profile.user |
|
550 |
activated = False |
|
551 |
if not user.is_active: |
|
552 |
user.is_active = True |
|
553 |
user.save() |
|
554 |
activated = True |
|
555 |
return (activated, user) |
|
556 |
||
557 |
def _create_manager(self, email, username, password, first_name, last_name): |
|
558 |
if username and email and password and len(User.objects.filter(username=username)) == 0: |
|
559 |
user = User.objects.create(username=username, email=email, first_name=first_name, last_name=last_name, is_active=True) |
|
560 |
user.set_password(password) |
|
561 |
user.save() |
|
562 |
||
563 |
profile = UserProfile.objects.create(user=user) |
|
564 |
||
565 |
manager = Role.objects.get(name='Manager') |
|
566 |
UserRole.objects.create(text=None, user=user, role=manager) |
|
567 |
return user |
|
568 |
else: |
|
569 |
return None |
|
570 |
||
571 |
||
572 |
def create_inactive_user(self, email, send_invitation, **kwargs): |
|
|
448
054d572a3db4
Avoid warnings for deprecated instructions in djan 1.3
gibus
parents:
407
diff
changeset
|
573 |
if 'postgresql' in settings.DATABASES['default']['ENGINE']: |
|
305
df2c3202fd8e
do not lock table with backends other than postgresql (postgresql specific syntax) (fixes #52)
raph
parents:
289
diff
changeset
|
574 |
#prevent concurrent access |
|
df2c3202fd8e
do not lock table with backends other than postgresql (postgresql specific syntax) (fixes #52)
raph
parents:
289
diff
changeset
|
575 |
cursor = connection.cursor() |
|
df2c3202fd8e
do not lock table with backends other than postgresql (postgresql specific syntax) (fixes #52)
raph
parents:
289
diff
changeset
|
576 |
sql = "LOCK TABLE auth_user IN EXCLUSIVE MODE" |
|
df2c3202fd8e
do not lock table with backends other than postgresql (postgresql specific syntax) (fixes #52)
raph
parents:
289
diff
changeset
|
577 |
cursor.execute(sql) |
| 0 | 578 |
|
579 |
try: |
|
580 |
user_with_email = User.objects.get(email__iexact=email) |
|
581 |
except User.DoesNotExist: |
|
582 |
user = User.objects.create(username=email, email=email) |
|
583 |
profile = UserProfile.objects.create(user=user) |
|
584 |
update(user, kwargs) |
|
585 |
update(profile, kwargs) |
|
586 |
||
587 |
user.is_active = False |
|
588 |
user.save() |
|
589 |
profile.save() |
|
590 |
||
591 |
note = kwargs.get('note', None) |
|
592 |
if send_invitation: |
|
593 |
profile.send_activation_email(note) |
|
594 |
return user |
|
595 |
else: |
|
596 |
return user_with_email |
|
597 |
||
598 |
||
599 |
from cm.utils.mail import send_mail |
|
600 |
||
601 |
class UserProfile(KeyModel): |
|
602 |
modified = models.DateTimeField(auto_now=True) |
|
603 |
created = models.DateTimeField(auto_now_add=True) |
|
604 |
||
605 |
user = models.ForeignKey(User, unique=True) |
|
606 |
||
607 |
allow_contact = models.BooleanField(ugettext_lazy(u'Allow contact'), default=True, help_text=ugettext_lazy(u"Allow email messages from other users")) |
|
608 |
preferred_language = models.CharField(ugettext_lazy(u'Preferred language'), max_length=2, default="en") |
|
609 |
is_temp = models.BooleanField(default=False) |
|
610 |
is_email_error = models.BooleanField(default=False) |
|
611 |
is_suspended = models.BooleanField(ugettext_lazy(u'Suspended access'), default=False) # used to disable access or to wait for approval when registering |
|
612 |
||
| 38 | 613 |
tags = TagField(ugettext_lazy("Tags"), max_length=1000) |
614 |
||
| 0 | 615 |
objects = RegistrationManager() |
616 |
||
617 |
class Meta: |
|
618 |
permissions = ( |
|
619 |
("can_create_user", "Can create user"), |
|
620 |
("can_delete_user", "Can delete user"), |
|
621 |
) |
|
622 |
||
623 |
def __unicode__(self): |
|
624 |
return unicode(self.user) |
|
625 |
||
626 |
def global_userrole(self): |
|
627 |
try: |
|
628 |
return UserRole.objects.get(user=self.user, text=None) |
|
629 |
except UserRole.DoesNotExist: |
|
630 |
return None |
|
631 |
||
632 |
def admin_print(self): |
|
633 |
if self.is_suspended: |
|
634 |
if self.user.is_active: |
|
635 |
return mark_safe('%s (%s)' % (self.user.username, _(u'suspended'),)) |
|
636 |
else: |
|
637 |
return mark_safe('%s (%s)' % (self.user.username, _(u'waiting approval'),)) |
|
638 |
else: |
|
639 |
if self.user.is_active: |
|
640 |
return mark_safe('%s' % self.user.username) |
|
641 |
else: |
|
642 |
email_username = self.user.email.split('@')[0] |
|
643 |
return mark_safe('%s (%s)' % (self.user.username, _(u'pending'),)) |
|
644 |
||
645 |
def simple_print(self): |
|
646 |
if self.user.is_active: |
|
647 |
return self.user.username |
|
648 |
else: |
|
649 |
return self.user.email |
|
650 |
||
651 |
def send_activation_email(self, note=None): |
|
652 |
self._send_act_invit_email(note=note, template='email/activation_email.txt') |
|
653 |
||
654 |
def send_invitation_email(self, note=None): |
|
655 |
self._send_act_invit_email(note=note, template='email/invitation_email.txt') |
|
656 |
||
657 |
def _send_act_invit_email(self, template, note=None): |
|
658 |
subject = _(u'Invitation') |
|
659 |
||
660 |
activate_url = reverse('user-activate', args=[self.adminkey]) |
|
661 |
message = render_to_string(template, |
|
662 |
{ |
|
663 |
'activate_url' : activate_url, |
|
664 |
'note' : note, |
|
665 |
'CONF': ApplicationConfiguration |
|
666 |
}) |
|
667 |
||
668 |
send_mail(subject, message, ApplicationConfiguration['email_from'], [self.user.email]) |
|
669 |
||
670 |
from django.db.models import signals |
|
671 |
||
672 |
def delete_profile(sender, **kwargs): |
|
673 |
user_profile = kwargs['instance'] |
|
674 |
user = user_profile.user |
|
675 |
user.delete() |
|
676 |
||
677 |
signals.post_delete.connect(delete_profile, sender=UserProfile) |
|
678 |
||
679 |
class ActivityManager(models.Manager): |
|
680 |
pass |
|
681 |
||
682 |
class Activity(models.Model): |
|
683 |
created = models.DateTimeField(auto_now_add=True) |
|
684 |
originator_user = models.ForeignKey(User, related_name='originator_activity', null=True, blank=True, default=None) |
|
685 |
text = models.ForeignKey(Text, null=True, blank=True, default=None) |
|
686 |
text_version = models.ForeignKey(TextVersion, null=True, blank=True, default=None) |
|
687 |
comment = models.ForeignKey(Comment, null=True, blank=True, default=None) |
|
688 |
user = models.ForeignKey(User, null=True, blank=True, default=None) |
|
689 |
type = models.CharField(max_length=30) |
|
690 |
ip = models.IPAddressField(null=True, blank=True, default=None) |
|
691 |
||
692 |
objects = ActivityManager() |
|
693 |
||
694 |
# viewable activities (i.e. now 'text-view') |
|
695 |
VIEWABLE_ACTIVITIES = { |
|
696 |
'view_comments' : ['comment_created', 'comment_removed'], |
|
697 |
'view_users' : ['user_created', 'user_activated', 'user_refused', 'user_enabled', 'user_approved', 'user_suspended'], |
|
|
460
2fdb7d095d5c
Added import from XML file, including text, comments and attachments.
gibus
parents:
448
diff
changeset
|
698 |
'view_texts' : ['text_created', 'text_imported', 'text_removed', 'text_edited', 'text_edited_new_version'], |
| 0 | 699 |
} |
700 |
ACTIVITIES_TYPES = reduce(list.__add__, VIEWABLE_ACTIVITIES.values()) |
|
701 |
||
702 |
IMGS = { |
|
703 |
'text_created' : u'page_add_small.png', |
|
|
460
2fdb7d095d5c
Added import from XML file, including text, comments and attachments.
gibus
parents:
448
diff
changeset
|
704 |
'text_imported' : u'sop_import_small.png', |
| 0 | 705 |
'text_removed' : u'page_delete_small.png', |
706 |
'text_edited' : u'page_save_small.png', |
|
707 |
'text_edited_new_version' : u'page_save_small.png', |
|
708 |
'user_created' : u'user_add_small.png', |
|
709 |
'user_enabled' : u'user_add_small.png', |
|
710 |
'user_refused': u'user_delete_small.png', |
|
711 |
'user_suspended': u'user_delete_small.png', |
|
712 |
'user_approved': u'user_add_small.png', |
|
713 |
'user_activated' : u'user_go.png', |
|
714 |
'comment_created' : u'note_add_small.png', |
|
715 |
'comment_removed' : u'note_delete_small.png', |
|
716 |
} |
|
717 |
||
718 |
#type/msg |
|
719 |
MSGS = { |
|
| 227 | 720 |
'text_edited' : ugettext_lazy(u'Text %(link_to_text)s edited by %(creator)s'), |
721 |
'text_edited_new_version' : ugettext_lazy(u'Text %(link_to_text)s edited (new version created) by %(creator)s'), |
|
722 |
'text_created' : ugettext_lazy(u'Text %(link_to_text)s added by %(creator)s'), |
|
|
460
2fdb7d095d5c
Added import from XML file, including text, comments and attachments.
gibus
parents:
448
diff
changeset
|
723 |
'text_imported' : ugettext_lazy(u'Text %(link_to_text)s imported by %(creator)s'), |
| 5 | 724 |
'text_removed' : ugettext_lazy(u'Text %(link_to_text)s removed'), |
| 227 | 725 |
'comment_created' : ugettext_lazy(u'Comment %(link_to_comment)s added on text %(link_to_text)s by %(creator)s'), |
| 5 | 726 |
'comment_removed' : ugettext_lazy(u'Comment %(link_to_comment)s removed from text %(link_to_text)s'), |
727 |
'user_created' : ugettext_lazy(u'User %(username)s added'), |
|
728 |
'user_enabled' : ugettext_lazy(u'User %(username)s access to workspace enabled'), |
|
729 |
'user_refused' : ugettext_lazy(u'User %(username)s access to workspace refused'), |
|
730 |
'user_suspended' : ugettext_lazy(u'User %(username)s access to workspace suspended'), |
|
731 |
'user_activated' : ugettext_lazy(u'User %(username)s access to workspace activated'), |
|
732 |
'user_approved' : ugettext_lazy(u'User %(username)s has activated his account'), |
|
| 0 | 733 |
} |
734 |
||
735 |
def is_same_user(self, other_activity): |
|
736 |
if (self.originator_user != None or other_activity.originator_user != None) and self.originator_user != other_activity.originator_user: |
|
737 |
return False |
|
738 |
else: |
|
739 |
return self.ip != None and self.ip == other_activity.ip |
|
740 |
||
741 |
def linkable_text_title(self, html=True, link=True): |
|
742 |
# html: whether or not output sould be html |
|
743 |
format_args = {'link':absolute_reverse('text-view', args=[self.text.key]), 'title':self.text.title} |
|
744 |
if html and not self.text.deleted : |
|
745 |
return mark_safe(u'<a href="%(link)s">%(title)s</a>' % format_args) |
|
746 |
else: |
|
747 |
if link and not self.text.deleted: |
|
748 |
return u'%(title)s (%(link)s)' % format_args |
|
749 |
else: |
|
750 |
return self.text.title ; |
|
751 |
||
752 |
def linkable_comment_title(self, html=True, link=True): |
|
753 |
if self.comment: |
|
| 144 | 754 |
format_args = {'link':absolute_reverse('text-view-show-comment', args=[self.text.key, self.comment.id_key]), 'title':self.comment.title} |
| 0 | 755 |
if html and not self.comment.deleted and not self.text.deleted: |
756 |
return mark_safe(u'<a href="%(link)s">%(title)s</a>' % format_args) |
|
757 |
else : |
|
758 |
if link and not self.comment.deleted and not self.text.deleted: |
|
759 |
return u'%(title)s (%(link)s)' % format_args |
|
760 |
else: |
|
761 |
return self.comment.title ; |
|
762 |
else: |
|
763 |
return u'' |
|
764 |
||
765 |
def __unicode__(self): |
|
766 |
return u"%s %s %s %s %s" % (self.type, self.originator_user, self.text, self.comment, self.user) |
|
767 |
||
768 |
def img_name(self): |
|
769 |
return self.IMGS.get(self.type) |
|
770 |
||
771 |
def printable_data_nohtml_link(self): |
|
772 |
return self.printable_data(html=False, link=True) |
|
773 |
||
774 |
def printable_data(self, html=True, link=True): |
|
775 |
msg = self.MSGS.get(self.type, None) |
|
776 |
if msg: |
|
777 |
return mark_safe(msg % { |
|
778 |
'link_to_text' : self.linkable_text_title(html=html, link=link) if self.text else None, |
|
779 |
'link_to_comment' : self.linkable_comment_title(html=html, link=link) if self.comment else None, |
|
780 |
'username' : self.user.username if self.user else None, |
|
| 227 | 781 |
'creator' : self.originator_user.username if self.originator_user else ugettext_lazy(u'anonymous'), |
| 0 | 782 |
}) |
783 |
return '' |
|
784 |
||
785 |
def printable_metadata(self, html=True): |
|
786 |
ret = [] |
|
787 |
if self.type == 'user_activated': |
|
788 |
ret.append(_(u'by "%(username)s"') % {'username' : self.originator_user.username}) |
|
789 |
ret.append(' ') |
|
790 |
ret.append(_(u"%(time_since)s ago") % {'time_since':timesince(self.created)}) |
|
791 |
return ''.join(ret) |
|
792 |
||
793 |
def printable_metadata_absolute(self, html=True): |
|
794 |
ret = [] |
|
795 |
if self.type == 'user_activated': |
|
796 |
ret.append(_(u'by "%(username)s"') % {'username' : self.originator_user.username}) |
|
797 |
ret.append(u' ') |
|
798 |
ret.append(datetime_to_user_str(self.created)) |
|
799 |
return u''.join(ret) |
|
800 |
||
801 |
import cm.denorm_engine |
|
802 |
import cm.admin |
|
803 |
import cm.main |
|
804 |
import cm.activity |
|
805 |
import cm.notifications |
|
806 |
||
807 |
# we fill username with email so we need a bigger value |
|
808 |
User._meta.get_field('username').max_length = 75 |
|
|
347
0a359382701b
prevent uno custom __import__ from messing with south import machinery (to discover south enabled dj apps)
Production Moz <dev@sopinspace.com>
parents:
327
diff
changeset
|
809 |
|
|
0a359382701b
prevent uno custom __import__ from messing with south import machinery (to discover south enabled dj apps)
Production Moz <dev@sopinspace.com>
parents:
327
diff
changeset
|
810 |
import monkey_patches |