resources should not return complex responses, also sendfile needs request which is only available in view

Author: Tobias Zanke

djangodav/fs/resources.py

@@ -18,21 +18,13 @@
 #
 # You should have received a copy of the GNU Affero General Public License
 # along with DjangoDav.  If not, see <http://www.gnu.org/licenses/>.
-import hashlib
-import mimetypes
-from sys import getfilesystemencoding
-import os
 import datetime
+import os
 import shutil
-import urllib
-
-from django.http import HttpResponse
-from django.utils.http import http_date
+from sys import getfilesystemencoding
 
 from djangodav.base.resources import BaseDavResource
-from djangodav.responses import ResponseException
-from djangodav.utils import safe_join, url_join
-
+from djangodav.utils import url_join
 
 fs_encoding = getfilesystemencoding()
 
@@ -43,6 +35,8 @@ class BaseFSDavResource(BaseDavResource):
     python's os library to do most of the work."""
 
     root = None
+    quote = False
+    prefix = "/"
 
     def get_abs_path(self):
         """Return the absolute path of the resource. Used internally to interface with
@@ -129,33 +123,3 @@ def write(self, request):
 
 class DummyFSDAVResource(DummyReadFSDavResource, DummyWriteFSDavResource, BaseFSDavResource):
     pass
-
-
-class SendFileFSDavResource(BaseFSDavResource):
-    quote = False
-
-    def read(self):
-        response = HttpResponse()
-        full_path = self.get_abs_path().encode('utf-8')
-        if self.quote:
-            full_path = urllib.quote(full_path)
-        response['X-SendFile'] = full_path
-        response['Content-Type'] = mimetypes.guess_type(self.displayname)
-        response['Content-Length'] = self.getcontentlength
-        response['Last-Modified'] = http_date(self.getlastmodified)
-        response['ETag'] = self.getetag
-        raise ResponseException(response)
-
-
-class RedirectFSDavResource(BaseFSDavResource):
-    prefix = "/"
-
-    def read(self):
-        response = HttpResponse()
-        response['X-Accel-Redirect'] = url_join(self.prefix, self.get_path().encode('utf-8'))
-        response['X-Accel-Charset'] = 'utf-8'
-        response['Content-Type'] = mimetypes.guess_type(self.displayname)
-        response['Content-Length'] = self.getcontentlength
-        response['Last-Modified'] = http_date(self.getlastmodified)
-        response['ETag'] = self.getetag
-        raise ResponseException(response)

djangodav/responses.py

@@ -41,6 +41,14 @@ def __init__(self, response, *args, **kwargs):
         self.response = response
 
 
+class AsSendFileFS(Exception):
+    pass
+
+
+class RedirectFSException(Exception):
+    pass
+
+
 class HttpResponsePreconditionFailed(HttpResponse):
     status_code = httplib.PRECONDITION_FAILED
 

djangodav/views/views.py

@@ -6,26 +6,30 @@
 from sys import version_info as python_version
 from django.utils.timezone import now
 from lxml import etree
+import mimetypes
+import urllib
 
 from django.http import HttpResponseForbidden, HttpResponseNotAllowed, HttpResponseBadRequest, \
-    HttpResponseNotModified, HttpResponseRedirect, Http404
+    HttpResponseNotModified, HttpResponseRedirect, Http404, HttpResponse
 from django.utils.decorators import method_decorator
 from django.utils.functional import cached_property
-from django.utils.http import parse_etags
-from django.shortcuts import render_to_response
+from django.utils.http import parse_etags, http_date
 from django.views.decorators.csrf import csrf_exempt
-from django.views.generic import View
+from django.views.generic import TemplateView
 
-from djangodav.responses import ResponseException, HttpResponsePreconditionFailed, HttpResponseCreated, HttpResponseNoContent, \
+from djangodav.responses import HttpResponsePreconditionFailed, HttpResponseCreated, HttpResponseNoContent, \
     HttpResponseConflict, HttpResponseMediatypeNotSupported, HttpResponseBadGateway, \
-    HttpResponseMultiStatus, HttpResponseLocked, HttpResponse
-from djangodav.utils import WEBDAV_NSMAP, D, url_join, get_property_tag_list, rfc1123_date
+    HttpResponseMultiStatus, HttpResponseLocked, RedirectFSException, ResponseException, AsSendFileFS
+from djangodav.utils import WEBDAV_NSMAP, D, get_property_tag_list, rfc1123_date
 from djangodav import VERSION as djangodav_version
 from django import VERSION as django_version, get_version
 
+from sendfile import sendfile
+
 PATTERN_IF_DELIMITER = re.compile(r'(<([^>]+)>)|(\(([^\)]+)\))')
 
-class DavView(View):
+
+class DavView(TemplateView):
     resource_class = None
     lock_class = None
     acl_class = None
@@ -173,6 +177,12 @@ def evaluate_conditions(self, res):
                 cond_if = '<*>' + cond_if
             #for (tmpurl, url, tmpcontent, content) in PATTERN_IF_DELIMITER.findall(cond_if):
 
+    def get_context_data(self, **kwargs):
+        context = super(DavView, self).get_context_data(**kwargs)
+        context['resource'] = self.resource
+        context['base_url'] = self.base_url
+        return context
+
     def get(self, request, path, head=False, *args, **kwargs):
         if not self.resource.exists:
             raise Http404("Resource doesn't exists")
@@ -190,9 +200,26 @@ def get(self, request, path, head=False, *args, **kwargs):
             response['ETag'] = self.resource.getetag
             if not head:
                 response['Content-Length'] = self.resource.getcontentlength
-                response.content = self.resource.read()
+                try:
+                    response.content = self.resource.read()
+                except AsSendFileFS:
+                    assert sendfile is not None, "django-sendfile is not installed."
+                    full_path = self.resource.get_abs_path().encode('utf-8')
+                    if self.resource.quote:
+                        full_path = urllib.quote(full_path)
+                    response = sendfile(request, full_path)
+                    return response
+                except RedirectFSException:
+                    response = HttpResponse()
+                    response['X-Accel-Redirect'] = url_join(self.resource.prefix, self.resource.get_path().encode('utf-8'))
+                    response['X-Accel-Charset'] = 'utf-8'
+                    response['Content-Type'] = mimetypes.guess_type(self.resource.displayname)
+                    response['Content-Length'] = self.resource.getcontentlength
+                    response['Last-Modified'] = http_date(self.resource.getlastmodified)
+                    response['ETag'] = self.resource.getetag
+                    raise ResponseException(response)
         elif not head:
-            response = render_to_response(self.template_name, dict(resource=self.resource, base_url=self.base_url))
+            response = super(DavView, self).get(request, *args, **kwargs)
         response['Last-Modified'] = self.resource.getlastmodified
         return response