server/python/django2/renkanmanager/api/views.py
changeset 589 0ae11aa255a3
parent 588 95536fa18d0d
child 596 58bcb390c9e2
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/server/python/django2/renkanmanager/api/views.py	Tue Feb 02 16:21:20 2016 +0100
@@ -0,0 +1,270 @@
+# -*- coding: utf-8 -*-
+'''
+Created on Jul 01, 2014
+
+@author: tc
+'''
+from datetime import datetime
+import json
+import logging
+import uuid
+
+from django.core.urlresolvers import reverse
+from django.http import Http404
+from django.http.response import HttpResponse, HttpResponseBadRequest
+from django.shortcuts import get_object_or_404, redirect
+from django.views.decorators.csrf import csrf_exempt
+from django.views.generic import View
+from renkanmanager.models import Renkan, Revision, Workspace
+from renkanmanager.permissions import CanEditRenkan, CanDeleteRenkan, CanCreateRenkan, \
+                                      CanEditWorkspace, CanDeleteWorkspace, CanCreateWorkspace, \
+                                      CanDeleteRevision
+from renkanmanager.serializers import RenkanSerializer, RevisionSerializer, WorkspaceSerializer
+from renkanmanager.auth import CsrfExemptSessionAuthentication
+from rest_framework import permissions, status
+from rest_framework.response import Response
+from rest_framework.views import APIView
+
+
+logger = logging.getLogger(__name__)
+            
+class RenkanList(APIView):
+    """
+        View for listing renkans or posting new renkan
+    """
+    permission_classes = (
+        permissions.IsAuthenticatedOrReadOnly,
+        CanCreateRenkan,
+    )
+    
+    def get(self, request, workspace_guid='', format=None):
+        if workspace_guid == '':
+            renkans = Renkan.objects.all()
+        else:
+            renkans = Renkan.objects.filter(workspace_guid=workspace_guid)
+        serializer = RenkanSerializer(renkans, many=True)
+        return Response(serializer.data, status=status.HTTP_200_OK, content_type='application/json')    
+    
+    def post(self, request, workspace_guid='', format=None):
+        create_data = request.data
+        source_renkan_guid = request.GET.get("source_renkan_id", request.data.get("source_renkan_id", None))
+        source_revision_guid = request.GET.get("source_revision_id", request.data.get("source_revision_id", None))
+        if source_renkan_guid is not None:
+            try:
+                source_renkan=Renkan.objects.get(renkan_guid=source_renkan_guid)
+            except Renkan.DoesNotExist:
+                return Response({'detail': 'Source renkan '+source_renkan_guid+' does not exist'}, status=status.HTTP_404_NOT_FOUND)
+            source_revision_guid = source_renkan.current_revision_guid
+        if source_revision_guid is not None:
+            try:
+                source_revision=Revision.objects.get(revision_guid=source_revision_guid)
+            except Revision.DoesNotExist:
+                return Response({'detail': 'Source revision '+source_revision_guid+' does not exist'}, status=status.HTTP_404_NOT_FOUND)
+            create_data["source_revision_id"] = source_revision.revision_guid
+            create_data["title"] = request.data.get("title", source_revision.title)
+            create_data["content"] = source_revision.content
+        if workspace_guid:
+            try:
+                workspace = Workspace.objects.get(workspace_guid=workspace_guid)
+            except Workspace.DoesNotExist:
+                return Response({'detail': 'Workspace '+workspace_guid+' does not exist'}, status=status.HTTP_404_NOT_FOUND)
+            create_data["workspace_id"] = workspace_guid
+        
+        serializer = RenkanSerializer(data=create_data)
+        if serializer.is_valid():
+            serializer.save(creator=request.user)       
+            return Response(serializer.data, status=status.HTTP_201_CREATED, content_type='application/json')
+        return Response(serializer.errors, status=status.HTTP_400_BAD_REQUEST)
+        
+
+class RenkanDetail(APIView):
+    """
+        View for retrieving, updating or deleting a single renkan
+    """
+    lookup_field = "renkan_guid"
+    permission_classes = (
+        permissions.IsAuthenticatedOrReadOnly, 
+        CanEditRenkan,
+        CanDeleteRenkan,
+    )
+    authentication_classes = (
+        CsrfExemptSessionAuthentication,
+    )
+    @csrf_exempt
+    def dispatch(self, *args, **kwargs):
+        return super(RenkanDetail, self).dispatch(*args, **kwargs)
+    
+    def get_object(self, renkan_guid):
+        return Renkan.objects.get(renkan_guid=renkan_guid)
+    
+    def get(self, request, renkan_guid, format=None):
+        try:
+            renkan = self.get_object(renkan_guid=renkan_guid)
+        except Renkan.DoesNotExist:
+            return Response({'detail': 'Renkan project '+renkan_guid+' does not exist'}, status=status.HTTP_404_NOT_FOUND)
+        self.check_object_permissions(request, renkan)
+        serializer = RenkanSerializer(renkan)
+        if {'true': True, 'false': False, "0": False, "1": True}.get(request.GET.get("content_only", "false").lower()):
+            return Response(json.loads(serializer.data["content"]), status=status.HTTP_200_OK, content_type='application/json')
+        return Response(serializer.data, status=status.HTTP_200_OK, content_type='application/json')
+    
+    def put(self, request, renkan_guid, format=None):
+        try:
+            renkan = self.get_object(renkan_guid=renkan_guid)
+        except Renkan.DoesNotExist:
+            return Response({'detail': 'Renkan project '+renkan_guid+' does not exist'}, status=status.HTTP_404_NOT_FOUND)
+        self.check_object_permissions(request, renkan)
+        if {'true': True, 'false': False, "0": False, "1": True}.get(request.GET.get("content_only", "false").lower()):
+            put_data = {}
+            put_data["content"] = json.dumps(request.data)
+            put_data["title"] = request.data.get("title", "")
+        else: 
+            put_data = request.data
+        serializer = RenkanSerializer(renkan, data=put_data)
+        if serializer.is_valid():
+            serializer.save(updator=request.user)
+            return Response(serializer.data, status=status.HTTP_200_OK, content_type='application/json')
+        return Response(serializer.errors, status=status.HTTP_400_BAD_REQUEST)
+    
+    def delete(self, request, renkan_guid, format=None):
+        try:
+            to_delete_renkan = self.get_object(renkan_guid=renkan_guid)
+        except Renkan.DoesNotExist:
+            return Response({'detail': 'Renkan project '+renkan_guid+' does not exist'}, status=status.HTTP_404_NOT_FOUND)
+        self.check_object_permissions(request, to_delete_renkan)
+        renkan_revisions = Revision.objects.filter(parent_renkan_guid = to_delete_renkan.renkan_guid)
+        for child_revision in renkan_revisions:
+            # Deleting reference to revision in renkans copied from this revision
+            for related_renkan in Renkan.objects.filter(source_revision_guid=child_revision.revision_guid):
+                related_renkan.source_revision_guid = ''
+                related_renkan.save()
+            child_revision.delete()
+        to_delete_renkan.delete()
+        return Response(status=status.HTTP_204_NO_CONTENT)
+
+class WorkspaceList(APIView):
+    """
+        View for listing workspaces or creating new workspace
+    """
+    permission_classes = (
+        permissions.IsAuthenticatedOrReadOnly,
+        CanCreateWorkspace,
+    )
+    
+    def get(self, request, format=None):
+        workspaces = Workspace.objects.all()
+        serializer = WorkspaceSerializer(workspaces, many=True)
+        return Response(serializer.data)
+    
+    def post(self, request, format=None):
+        serializer = WorkspaceSerializer(data=request.data)
+        if serializer.is_valid():
+            serializer.save(creator=request.user)       
+            return Response(serializer.data, status=status.HTTP_201_CREATED, content_type='application/json')
+        return Response(serializer.errors, status=status.HTTP_400_BAD_REQUEST)
+    
+class WorkspaceDetail(APIView):
+    """
+        View for retrieving, updating or deleting a single workspace
+    """
+    permission_classes = (
+        permissions.IsAuthenticatedOrReadOnly,
+        CanEditWorkspace,
+        CanDeleteWorkspace,
+    )
+    
+    def get_object(self, workspace_guid):
+        return Workspace.objects.get(workspace_guid=workspace_guid)
+    
+    def get(self, request, workspace_guid, format=None):
+        try:
+            workspace = Workspace.objects.get(workspace_guid=workspace_guid)
+        except Workspace.DoesNotExist:
+            return Response({'detail': 'Workspace '+workspace_guid+' does not exist.'}, status=status.HTTP_404_NOT_FOUND)
+        self.check_object_permissions(request, workspace)
+        serializer = WorkspaceSerializer(workspace)
+        return Response(serializer.data, status=status.HTTP_200_OK, content_type='application/json')
+    
+    def put(self, request, workspace_guid, format=None):
+        try:
+            workspace = Workspace.objects.get(workspace_guid=workspace_guid)
+        except Workspace.DoesNotExist:
+            return Response({'detail': 'Workspace '+workspace_guid+' does not exist.'}, status=status.HTTP_404_NOT_FOUND)
+        self.check_object_permissions(request, workspace)
+        serializer = WorkspaceSerializer(workspace, data=request.data)
+        if serializer.is_valid():
+            serializer.save()       
+            return Response(serializer.data, status=status.HTTP_200_OK, content_type='application/json')
+        return Response(serializer.errors, status=status.HTTP_400_BAD_REQUEST)
+    
+    def delete(self, request, workspace_guid, format=None):
+        try:
+            to_delete_workspace = self.get_object(workspace_guid=workspace_guid)
+        except Workspace.DoesNotExist:
+            return Response({'detail': 'Workspace '+workspace_guid+' does not exist'}, status=status.HTTP_404_NOT_FOUND)
+        self.check_object_permissions(request, to_delete_workspace)
+        if to_delete_workspace.renkan_count != 0:
+            return Response({'detail': 'Workspace '+workspace_guid+' cannot be deleted because it is not empty'}, status=status.HTTP_400_BAD_REQUEST)
+        to_delete_workspace.delete()
+        return Response(status=status.HTTP_204_NO_CONTENT)
+
+class RevisionList(APIView):
+    """
+        View for listing revisions from a given renkan
+    """
+    permission_classes = (permissions.IsAuthenticatedOrReadOnly,)
+    
+    def get_queryset(self, renkan_guid):
+        return Revision.objects.filter(parent_renkan_guid=renkan_guid)
+    
+    def get(self, request, renkan_guid, format=None):
+        revisions = self.get_queryset(renkan_guid)
+        if not revisions:
+            return Response({'detail': 'Renkan project '+renkan_guid+' does not exist'}, status=status.HTTP_404_NOT_FOUND)
+        serializer = RevisionSerializer(revisions.all(), many=True)
+        return Response(serializer.data, status=status.HTTP_200_OK, content_type='application/json')
+
+class RevisionDetail(APIView):
+    """
+        View for retrieving or deleting a single revision from a given renkan
+    """
+    permission_classes = (
+        permissions.IsAuthenticatedOrReadOnly,
+        CanDeleteRevision,
+    )
+    
+    def get_queryset(self, renkan_guid):
+        return Revision.objects.filter(parent_renkan_guid=renkan_guid)
+    
+    def get(self, request, renkan_guid, revision_guid, format=None):
+        revisions = self.get_queryset(renkan_guid)
+        if not revisions:
+            return Response({'detail': 'Renkan project '+renkan_guid+' does not exist'}, status=status.HTTP_404_NOT_FOUND)
+        try:
+            revision = revisions.get(revision_guid=revision_guid)
+        except Revision.DoesNotExist:
+            return Response({'detail': 'Revision '+revision_guid+' does not exist'}, status=status.HTTP_404_NOT_FOUND)
+        self.check_object_permissions(request, revision)
+        serializer = RevisionSerializer(revision)
+        return Response(serializer.data, status=status.HTTP_200_OK, content_type='application/json')
+    
+    def delete(self, request, renkan_guid, revision_guid, format=None):
+        revisions = self.get_queryset(renkan_guid)
+        if not revisions:
+            return Response({'detail': 'Renkan project '+renkan_guid+' does not exist'}, status=status.HTTP_404_NOT_FOUND)
+        try:
+            revision = revisions.get(revision_guid=revision_guid)
+        except Revision.DoesNotExist:
+            return Response({'detail': 'Revision '+revision_guid+' does not exist'}, status=status.HTTP_404_NOT_FOUND)
+        self.check_object_permissions(request, revision)
+        if revisions.count() == 1:
+            return Response({'detail': 'You cannot delete the last remaining revision of a renkan from the Revision API. Try deleting the parent Renkan with the Renkan API'}, status=status.HTTP_400_BAD_REQUEST)
+        if revision.is_current_revision:
+            return Response({'detail': 'You cannot delete the current revision of a renkan from the Revision API.'}, status=status.HTTP_400_BAD_REQUEST)
+        
+        # Deleting reference to revision in renkans copied from this revision
+        for related_renkan in Renkan.objects.filter(source_revision_guid=revision_guid):
+            related_renkan.source_revision_guid = ''
+            related_renkan.save()
+        revision.delete()
+        return Response(status=status.HTTP_204_NO_CONTENT)
\ No newline at end of file