[feature] send tag header from server

1 files changed, 16 insertions, 0 deletions

diff --git a/server/src/leap/soledad/server/_blobs.py b/server/src/leap/soledad/server/_blobs.py
index 3b840391..454ff5fe 100644
--- a/server/src/leap/soledad/server/_blobs.py
+++ b/server/src/leap/soledad/server/_blobs.py
@@ -26,6 +26,7 @@ environments.
 """
 import commands
 import os
+import base64
 
 from twisted.web import static
 from twisted.web import resource
@@ -66,6 +67,14 @@ class IBlobsBackend(Interface):
         :returns: a deferred that fires upon finishing.
         """
 
+    def tag_header(user, blob_id, request):
+        """
+        Adds a header 'Tag' with the last 20 bytes of the encoded file,
+        which contains the tag.
+
+        :returns: a deferred that fires upon finishing.
+        """
+
     def write_blob(user, blob_id, request):
         """
         Write blob to the storage, reading it from the passed request.
@@ -91,6 +100,12 @@ class FilesystemBlobsBackend(object):
     path = '/tmp/blobs/'
     quota = 200 * 1024  # in KB
 
+    def tag_header(self, user, blob_id, request):
+        with open(self._get_path(user, blob_id)) as doc_file:
+                doc_file.seek(-16, 2)
+                tag = base64.urlsafe_b64encode(doc_file.read())
+                request.responseHeaders.setRawHeaders('Tag', [tag])
+
     def read_blob(self, user, blob_id, request):
         print "USER", user
         print "BLOB_ID", blob_id
@@ -168,6 +183,7 @@ class BlobsResource(resource.Resource):
     def render_GET(self, request):
         print "GETTING", request.path
         user, blob_id = self._split_path(request.path)
+        self._handler.tag_header(user, blob_id, request)
         return self._handler.read_blob(user, blob_id, request)
 
     def render_PUT(self, request):