Added handle_resource_conflict_response feature to handle 409 reponse,

Cosmetic.
This commit is contained in:
jvelilla
2011-10-13 09:07:37 -03:00
parent 4c36d75ef3
commit 8255dfd996
3 changed files with 104 additions and 35 deletions

View File

@@ -50,7 +50,6 @@ feature -- Access
end end
end end
note note
copyright: "2011-2011, Javier Velilla and others" copyright: "2011-2011, Javier Velilla and others"
license: "Eiffel Forum License v2 (see http://www.eiffel.com/licensing/forum.txt)" license: "Eiffel Forum License v2 (see http://www.eiffel.com/licensing/forum.txt)"

View File

@@ -1,5 +1,5 @@
note note
description: "Summary description for {ORDER_HANDLER}." description: "{ORDER_HANDLER} handle the resources that we want to expose"
author: "" author: ""
date: "$Date$" date: "$Date$"
revision: "$Revision$" revision: "$Revision$"
@@ -74,66 +74,95 @@ feature -- HTTP Methods
end end
do_put (ctx: C; req: WGI_REQUEST; res: WGI_RESPONSE_BUFFER) do_put (ctx: C; req: WGI_REQUEST; res: WGI_RESPONSE_BUFFER)
-- Updating a resource with PUT
-- A successful PUT request will not create a new resource, instead it will
-- change the state of the resource identified by the current uri.
-- If success we response with 200 and the updated order.
-- 404 if the order is not found
-- 400 in case of a bad request
-- 500 internal server error
local local
l_post: STRING l_post: STRING
l_location : STRING
l_order : detachable ORDER l_order : detachable ORDER
h : EWF_HEADER
do do
fixme ("TODO handle an Internal Server Error")
fixme ("Refactor the code, create new abstractions")
fixme ("Add Header Date to the response")
fixme ("Put implementation is wrong!!!!")
req.input.read_stream (req.content_length_value.as_integer_32) req.input.read_stream (req.content_length_value.as_integer_32)
l_post := req.input.last_string l_post := req.input.last_string
l_order := extract_order_request(l_post) l_order := extract_order_request(l_post)
fixme ("TODO move to a service method")
if l_order /= Void and then db_access.orders.has_key (l_order.id) then if l_order /= Void and then db_access.orders.has_key (l_order.id) then
if is_valid_to_update(l_order) then
update_order( l_order) update_order( l_order)
compute_response_put (ctx, req, res, l_order)
else
--| FIXME: Here we need to define the Allow methods
handle_resource_conflict_response (l_post +"%N There is conflict while trying to update the order, the order could not be update in the current state", ctx, req, res)
end
else
handle_bad_request_response (l_post +"%N is not a valid ORDER, maybe the order does not exist in the system", ctx, req, res)
end
end
compute_response_put (ctx: C; req: WGI_REQUEST; res: WGI_RESPONSE_BUFFER; l_order : ORDER)
local
h: EWF_HEADER
joc : JSON_ORDER_CONVERTER
do
create h.make
create joc.make
json.add_converter(joc)
create h.make create h.make
h.put_status ({HTTP_STATUS_CODE}.ok) h.put_status ({HTTP_STATUS_CODE}.ok)
h.put_content_type ("application/json") h.put_content_type_application_json
if attached req.request_time as time then if attached req.request_time as time then
h.add_header ("Date:" +time.formatted_out ("ddd,[0]dd mmm yyyy [0]hh:[0]mi:[0]ss.ff2") + " GMT") h.add_header ("Date:" +time.formatted_out ("ddd,[0]dd mmm yyyy [0]hh:[0]mi:[0]ss.ff2") + " GMT")
end end
if attached req.http_host as host then
l_location := "http://"+host +req.request_uri+"/" + l_order.id
h.add_header ("Location:"+ l_location)
end
if attached {JSON_VALUE} json.value (l_order) as jv then if attached {JSON_VALUE} json.value (l_order) as jv then
h.put_content_length (jv.representation.count) h.put_content_length (jv.representation.count)
res.set_status_code ({HTTP_STATUS_CODE}.ok) res.set_status_code ({HTTP_STATUS_CODE}.ok)
res.write_headers_string (h.string) res.write_headers_string (h.string)
res.write_string (jv.representation) res.write_string (jv.representation)
end end
else
handle_bad_request_response (l_post +"%N is not a valid ORDER, maybe the order does not exist in the system", ctx, req, res)
end
end end
do_delete (ctx: C; req: WGI_REQUEST; res: WGI_RESPONSE_BUFFER) do_delete (ctx: C; req: WGI_REQUEST; res: WGI_RESPONSE_BUFFER)
-- Here we use DELETE to cancel an order, if that order is in state where
-- it can still be canceled.
-- 200 if is ok
-- 409 if consumer and service's view of the resouce state is inconsisent
-- 500 if we have an internal server error
local local
id: STRING id: STRING
h : EWF_HEADER h : EWF_HEADER
do do
fixme ("TODO handle an Internal Server Error")
fixme ("Refactor the code, create new abstractions")
if attached req.orig_path_info as orig_path then if attached req.orig_path_info as orig_path then
id := get_order_id_from_path (orig_path) id := get_order_id_from_path (orig_path)
if db_access.orders.has_key (id) then if db_access.orders.has_key (id) then
if is_valid_to_delete (id) then
delete_order( id) delete_order( id)
compute_response_delete (ctx, req, res)
else
--| FIXME: Here we need to define the Allow methods
handle_resource_conflict_response (orig_path + "%N There is conflict while trying to delete the order, the order could not be deleted in the current state", ctx, req, res)
end
else
handle_resource_not_found_response (orig_path + " not found in this server", ctx, req, res)
end
end
end
compute_response_delete (ctx: C; req: WGI_REQUEST; res: WGI_RESPONSE_BUFFER)
local
h: EWF_HEADER
do
create h.make create h.make
h.put_status ({HTTP_STATUS_CODE}.no_content) h.put_status ({HTTP_STATUS_CODE}.no_content)
h.put_content_type ("application/json") h.put_content_type_application_json
if attached req.request_time as time then if attached req.request_time as time then
h.put_utc_date (time) h.put_utc_date (time)
end end
res.set_status_code ({HTTP_STATUS_CODE}.no_content) res.set_status_code ({HTTP_STATUS_CODE}.no_content)
res.write_headers_string (h.string) res.write_headers_string (h.string)
else
handle_resource_not_found_response (orig_path + " not found in this server", ctx, req, res)
end
end
end end
do_post (ctx: C; req: WGI_REQUEST; res: WGI_RESPONSE_BUFFER) do_post (ctx: C; req: WGI_REQUEST; res: WGI_RESPONSE_BUFFER)
@@ -221,6 +250,28 @@ feature {NONE} -- Implementation Repository Layer
db_access.orders.force (an_order, an_order.id) db_access.orders.force (an_order, an_order.id)
end end
is_valid_to_delete ( an_id : STRING) : BOOLEAN
-- Is the order identified by `an_id' in a state whre it can still be deleted?
do
if attached retrieve_order (an_id) as l_order then
if order_validation.is_state_valid_to_update (l_order.status) then
Result := True
end
end
end
is_valid_to_update (an_order: ORDER) : BOOLEAN
-- Check if there is a conflict while trying to update the order
do
if attached retrieve_order (an_order.id) as l_order then
if order_validation.is_state_valid_to_update (l_order.status) and then order_validation.is_valid_status_state (an_order.status) and then
order_validation.is_valid_transition (l_order, an_order.status) then
Result := True
end
end
end
update_order (an_order: ORDER) update_order (an_order: ORDER)
-- update the order to the repository -- update the order to the repository
do do

View File

@@ -238,6 +238,25 @@ feature -- Handle responses
res.write_string (a_description) res.write_string (a_description)
end end
handle_resource_conflict_response (a_description:STRING; ctx: C; req: WGI_REQUEST; res: WGI_RESPONSE_BUFFER)
local
h : EWF_HEADER
do
create h.make
h.put_status ({HTTP_STATUS_CODE}.conflict)
if attached ctx.request_content_type (supported_content_types) as l_content_type then
h.put_content_type (l_content_type)
else
h.put_content_type ("*/*")
end
h.put_content_length (a_description.count)
h.put_current_date
res.set_status_code ({HTTP_STATUS_CODE}.conflict)
res.write_headers_string (h.string)
res.write_string (a_description)
end
note note
copyright: "2011-2011, Eiffel Software and others" copyright: "2011-2011, Eiffel Software and others"
license: "Eiffel Forum License v2 (see http://www.eiffel.com/licensing/forum.txt)" license: "Eiffel Forum License v2 (see http://www.eiffel.com/licensing/forum.txt)"