1 # Copyright 2011 GRNET S.A. All rights reserved.
3 # Redistribution and use in source and binary forms, with or
4 # without modification, are permitted provided that the following
7 # 1. Redistributions of source code must retain the above
8 # copyright notice, this list of conditions and the following
11 # 2. Redistributions in binary form must reproduce the above
12 # copyright notice, this list of conditions and the following
13 # disclaimer in the documentation and/or other materials
14 # provided with the distribution.
16 # THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS
17 # OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
18 # WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
19 # PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR
20 # CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
21 # SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
22 # LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
23 # USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
24 # AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
25 # LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
26 # ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
27 # POSSIBILITY OF SUCH DAMAGE.
29 # The views and conclusions contained in the software and
30 # documentation are those of the authors and should not be
31 # interpreted as representing official policies, either expressed
32 # or implied, of GRNET S.A.
36 from django.http import HttpResponse
38 from pithos.api.faults import (Fault, BadRequest, ItemNotFound)
39 from pithos.api.util import (put_object_meta, update_manifest_meta,
40 validate_modification_preconditions, validate_matching_preconditions,
41 object_data_response, api_method)
42 from pithos.backends import backend
45 logger = logging.getLogger(__name__)
48 def object_demux(request, v_account, v_container, v_object):
49 if request.method == 'HEAD':
50 return object_meta(request, v_account, v_container, v_object)
51 elif request.method == 'GET':
52 return object_read(request, v_account, v_container, v_object)
54 return method_not_allowed(request)
56 # TODO: Use a version of api_method that does not check for a token.
59 def object_meta(request, v_account, v_container, v_object):
60 # Normal Response Codes: 204
61 # Error Response Codes: serviceUnavailable (503),
67 meta = backend.get_object_meta(request.user, v_account, v_container, v_object)
69 raise ItemNotFound('Object does not exist')
71 if 'X-Object-Public' not in meta:
72 raise ItemNotFound('Object does not exist')
73 update_manifest_meta(request, v_account, meta)
75 response = HttpResponse(status=204)
76 put_object_meta(response, meta, True)
80 def object_read(request, v_account, v_container, v_object):
81 # Normal Response Codes: 200, 206
82 # Error Response Codes: serviceUnavailable (503),
83 # rangeNotSatisfiable (416),
84 # preconditionFailed (412),
91 meta = backend.get_object_meta(request.user, v_account, v_container, v_object)
93 raise ItemNotFound('Object does not exist')
95 if 'X-Object-Public' not in meta:
96 raise ItemNotFound('Object does not exist')
97 update_manifest_meta(request, v_account, meta)
99 # Evaluate conditions.
100 validate_modification_preconditions(request, meta)
102 validate_matching_preconditions(request, meta)
104 response = HttpResponse(status=304)
105 response['ETag'] = meta['hash']
110 if 'X-Object-Manifest' in meta:
112 src_container, src_name = split_container_object_string('/' + meta['X-Object-Manifest'])
113 objects = backend.list_objects(request.user, v_account, src_container, prefix=src_name, virtual=False)
115 raise ItemNotFound('Object does not exist')
117 raise ItemNotFound('Object does not exist')
121 s, h = backend.get_object_hashmap(request.user, v_account, src_container, x[0], x[1])
125 raise ItemNotFound('Object does not exist')
128 s, h = backend.get_object_hashmap(request.user, v_account, v_container, v_object, version)
132 raise ItemNotFound('Object does not exist')
134 return object_data_response(request, sizes, hashmaps, meta, True)
137 def method_not_allowed(request):
138 raise ItemNotFound('Object does not exist')