126 lines
4.8 KiB
Python
126 lines
4.8 KiB
Python
# -*- coding: utf-8 -*-
|
|
# Copyright (C) 2014-2016 Andrey Antukh <niwi@niwi.nz>
|
|
# Copyright (C) 2014-2016 Jesús Espino <jespinog@gmail.com>
|
|
# Copyright (C) 2014-2016 David Barragán <bameda@dbarragan.com>
|
|
# Copyright (C) 2014-2016 Alejandro Alonso <alejandro.alonso@kaleidos.net>
|
|
# This program is free software: you can redistribute it and/or modify
|
|
# it under the terms of the GNU Affero General Public License as
|
|
# published by the Free Software Foundation, either version 3 of the
|
|
# License, or (at your option) any later version.
|
|
#
|
|
# This program is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU Affero General Public License for more details.
|
|
#
|
|
# You should have received a copy of the GNU Affero General Public License
|
|
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
from django.db import models
|
|
from django.utils import timezone
|
|
from django.contrib.contenttypes.models import ContentType
|
|
from django.contrib.contenttypes.fields import GenericForeignKey
|
|
|
|
from taiga.projects.models import Project
|
|
from taiga.projects.epics.models import Epic
|
|
from taiga.projects.userstories.models import UserStory
|
|
from taiga.projects.tasks.models import Task
|
|
from taiga.projects.issues.models import Issue
|
|
|
|
from . import sequences as seq
|
|
|
|
|
|
class Reference(models.Model):
|
|
content_type = models.ForeignKey(ContentType, related_name="+")
|
|
object_id = models.PositiveIntegerField()
|
|
ref = models.BigIntegerField()
|
|
content_object = GenericForeignKey("content_type", "object_id")
|
|
created_at = models.DateTimeField(default=timezone.now)
|
|
project = models.ForeignKey("projects.Project", null=False,
|
|
blank=False, related_name="references")
|
|
|
|
class Meta:
|
|
ordering = ["created_at"]
|
|
unique_together = ["project", "ref"]
|
|
|
|
def __str__(self):
|
|
return "Reference {}".format(self.object_id)
|
|
|
|
|
|
def make_sequence_name(project) -> str:
|
|
return "references_project{0}".format(project.pk)
|
|
|
|
|
|
def make_unique_reference_id(project, *, create=False):
|
|
seqname = make_sequence_name(project)
|
|
if create and not seq.exists(seqname):
|
|
seq.create(seqname)
|
|
return seq.next_value(seqname)
|
|
|
|
|
|
def make_reference(instance, project, create=False):
|
|
refval = make_unique_reference_id(project, create=create)
|
|
ct = ContentType.objects.get_for_model(instance.__class__)
|
|
refinstance = Reference.objects.create(content_type=ct,
|
|
object_id=instance.pk,
|
|
ref=refval,
|
|
project=project)
|
|
return refval, refinstance
|
|
|
|
|
|
def create_sequence(sender, instance, created, **kwargs):
|
|
if not created:
|
|
return
|
|
|
|
seqname = make_sequence_name(instance)
|
|
if not seq.exists(seqname):
|
|
seq.create(seqname)
|
|
|
|
|
|
def delete_sequence(sender, instance, **kwargs):
|
|
seqname = make_sequence_name(instance)
|
|
if seq.exists(seqname):
|
|
seq.delete(seqname)
|
|
|
|
|
|
def store_previous_project(sender, instance, **kwargs):
|
|
try:
|
|
prev_instance = sender.objects.get(pk=instance.pk)
|
|
instance.prev_project = prev_instance.project
|
|
except sender.DoesNotExist:
|
|
instance.prev_project = None
|
|
|
|
|
|
def attach_sequence(sender, instance, created, **kwargs):
|
|
if not instance._importing:
|
|
if created or instance.prev_project != instance.project:
|
|
# Create a reference object. This operation should be
|
|
# used in transaction context, otherwise it can
|
|
# create a lot of phantom reference objects.
|
|
refval, _ = make_reference(instance, instance.project)
|
|
|
|
# Additionally, attach sequence number to instance as ref
|
|
instance.ref = refval
|
|
instance.save(update_fields=['ref'])
|
|
|
|
|
|
# Project
|
|
models.signals.post_save.connect(create_sequence, sender=Project, dispatch_uid="refproj")
|
|
models.signals.post_delete.connect(delete_sequence, sender=Project, dispatch_uid="refprojdel")
|
|
|
|
# Epic
|
|
models.signals.pre_save.connect(store_previous_project, sender=Epic, dispatch_uid="refepic")
|
|
models.signals.post_save.connect(attach_sequence, sender=Epic, dispatch_uid="refepic")
|
|
|
|
# User Story
|
|
models.signals.pre_save.connect(store_previous_project, sender=UserStory, dispatch_uid="refus")
|
|
models.signals.post_save.connect(attach_sequence, sender=UserStory, dispatch_uid="refus")
|
|
|
|
# Task
|
|
models.signals.pre_save.connect(store_previous_project, sender=Task, dispatch_uid="reftask")
|
|
models.signals.post_save.connect(attach_sequence, sender=Task, dispatch_uid="reftask")
|
|
|
|
# Issue
|
|
models.signals.pre_save.connect(store_previous_project, sender=Issue, dispatch_uid="refissue")
|
|
models.signals.post_save.connect(attach_sequence, sender=Issue, dispatch_uid="refissue")
|