diff options
Diffstat (limited to 'lib/polyjuice/client/endpoint')
-rw-r--r-- | lib/polyjuice/client/endpoint/get_rooms_messages.ex | 10 | ||||
-rw-r--r-- | lib/polyjuice/client/endpoint/get_sync.ex | 10 | ||||
-rw-r--r-- | lib/polyjuice/client/endpoint/post_join.ex | 14 | ||||
-rw-r--r-- | lib/polyjuice/client/endpoint/post_login.ex | 10 | ||||
-rw-r--r-- | lib/polyjuice/client/endpoint/post_logout.ex | 14 | ||||
-rw-r--r-- | lib/polyjuice/client/endpoint/post_rooms_receipt.ex | 14 | ||||
-rw-r--r-- | lib/polyjuice/client/endpoint/post_user_filter.ex | 14 | ||||
-rw-r--r-- | lib/polyjuice/client/endpoint/put_rooms_send.ex | 14 | ||||
-rw-r--r-- | lib/polyjuice/client/endpoint/put_rooms_state.ex | 14 |
9 files changed, 48 insertions, 66 deletions
diff --git a/lib/polyjuice/client/endpoint/get_rooms_messages.ex b/lib/polyjuice/client/endpoint/get_rooms_messages.ex index bceea3f..3a5d2df 100644 --- a/lib/polyjuice/client/endpoint/get_rooms_messages.ex +++ b/lib/polyjuice/client/endpoint/get_rooms_messages.ex @@ -78,14 +78,8 @@ defmodule Polyjuice.Client.Endpoint.GetRoomsMessages do } end - def transform_http_result(_req, status_code, _resp_headers, body) do - case status_code do - 200 -> - {:ok, Poison.decode!(body)} - - _ -> - {:error, status_code, body} - end + def transform_http_result(req, status_code, resp_headers, body) do + Polyjuice.Client.Endpoint.parse_response(req, status_code, resp_headers, body) end end end diff --git a/lib/polyjuice/client/endpoint/get_sync.ex b/lib/polyjuice/client/endpoint/get_sync.ex index c30e680..511fb21 100644 --- a/lib/polyjuice/client/endpoint/get_sync.ex +++ b/lib/polyjuice/client/endpoint/get_sync.ex @@ -84,14 +84,8 @@ defmodule Polyjuice.Client.Endpoint.GetSync do } end - def transform_http_result(_req, status_code, _resp_headers, body) do - case status_code do - 200 -> - {:ok, Poison.decode!(body)} - - _ -> - {:error, status_code, body} - end + def transform_http_result(req, status_code, resp_headers, body) do + Polyjuice.Client.Endpoint.parse_response(req, status_code, resp_headers, body) end end end diff --git a/lib/polyjuice/client/endpoint/post_join.ex b/lib/polyjuice/client/endpoint/post_join.ex index bdc8c0a..6689f59 100644 --- a/lib/polyjuice/client/endpoint/post_join.ex +++ b/lib/polyjuice/client/endpoint/post_join.ex @@ -76,14 +76,14 @@ defmodule Polyjuice.Client.Endpoint.PostJoin do } end - def transform_http_result(_req, status_code, _resp_headers, body) do - case status_code do - 200 -> - {:ok, body |> Poison.decode!() |> Map.get("room_id")} + def transform_http_result(req, status_code, resp_headers, body) do + Polyjuice.Client.Endpoint.parse_response(req, status_code, resp_headers, body) + end + end - _ -> - {:error, status_code, body} - end + defimpl Polyjuice.Client.Endpoint.BodyParser do + def parse(_req, parsed) do + {:ok, Map.get(parsed, "room_id")} end end end diff --git a/lib/polyjuice/client/endpoint/post_login.ex b/lib/polyjuice/client/endpoint/post_login.ex index e374b41..23fa5c3 100644 --- a/lib/polyjuice/client/endpoint/post_login.ex +++ b/lib/polyjuice/client/endpoint/post_login.ex @@ -84,14 +84,8 @@ defmodule Polyjuice.Client.Endpoint.PostLogin do } end - def transform_http_result(_req, status_code, _resp_headers, body) do - case status_code do - 200 -> - {:ok, Poison.decode!(body)} - - _ -> - {:error, status_code, body} - end + def transform_http_result(req, status_code, resp_headers, body) do + Polyjuice.Client.Endpoint.parse_response(req, status_code, resp_headers, body) end end end diff --git a/lib/polyjuice/client/endpoint/post_logout.ex b/lib/polyjuice/client/endpoint/post_logout.ex index e29c28b..d0e4e1a 100644 --- a/lib/polyjuice/client/endpoint/post_logout.ex +++ b/lib/polyjuice/client/endpoint/post_logout.ex @@ -45,14 +45,14 @@ defmodule Polyjuice.Client.Endpoint.PostLogout do } end - def transform_http_result(_req, status_code, _resp_headers, body) do - case status_code do - 200 -> - {:ok} + def transform_http_result(req, status_code, resp_headers, body) do + Polyjuice.Client.Endpoint.parse_response(req, status_code, resp_headers, body) + end + end - _ -> - {:error, status_code, body} - end + defimpl Polyjuice.Client.Endpoint.BodyParser do + def parse(_req, _body) do + {:ok} end end end diff --git a/lib/polyjuice/client/endpoint/post_rooms_receipt.ex b/lib/polyjuice/client/endpoint/post_rooms_receipt.ex index 45cff8e..5b92803 100644 --- a/lib/polyjuice/client/endpoint/post_rooms_receipt.ex +++ b/lib/polyjuice/client/endpoint/post_rooms_receipt.ex @@ -63,14 +63,14 @@ defmodule Polyjuice.Client.Endpoint.PostRoomsReceipt do } end - def transform_http_result(_req, status_code, _resp_headers, body) do - case status_code do - 200 -> - {:ok} + def transform_http_result(req, status_code, resp_headers, body) do + Polyjuice.Client.Endpoint.parse_response(req, status_code, resp_headers, body) + end + end - _ -> - {:error, status_code, body} - end + defimpl Polyjuice.Client.Endpoint.BodyParser do + def parse(_req, _body) do + {:ok} end end end diff --git a/lib/polyjuice/client/endpoint/post_user_filter.ex b/lib/polyjuice/client/endpoint/post_user_filter.ex index 39b0f4a..cf57437 100644 --- a/lib/polyjuice/client/endpoint/post_user_filter.ex +++ b/lib/polyjuice/client/endpoint/post_user_filter.ex @@ -57,14 +57,14 @@ defmodule Polyjuice.Client.Endpoint.PostUserFilter do } end - def transform_http_result(_req, status_code, _resp_headers, body) do - case status_code do - 200 -> - {:ok, body |> Poison.decode!() |> Map.get("filter_id")} + def transform_http_result(req, status_code, resp_headers, body) do + Polyjuice.Client.Endpoint.parse_response(req, status_code, resp_headers, body) + end + end - _ -> - {:error, status_code, body} - end + defimpl Polyjuice.Client.Endpoint.BodyParser do + def parse(_req, parsed) do + {:ok, Map.get(parsed, "filter_id")} end end end diff --git a/lib/polyjuice/client/endpoint/put_rooms_send.ex b/lib/polyjuice/client/endpoint/put_rooms_send.ex index 717624d..549bc2b 100644 --- a/lib/polyjuice/client/endpoint/put_rooms_send.ex +++ b/lib/polyjuice/client/endpoint/put_rooms_send.ex @@ -65,14 +65,14 @@ defmodule Polyjuice.Client.Endpoint.PutRoomsSend do } end - def transform_http_result(_req, status_code, _resp_headers, body) do - case status_code do - 200 -> - {:ok, body |> Poison.decode!() |> Map.get("event_id")} + def transform_http_result(req, status_code, resp_headers, body) do + Polyjuice.Client.Endpoint.parse_response(req, status_code, resp_headers, body) + end + end - _ -> - {:error, status_code, body} - end + defimpl Polyjuice.Client.Endpoint.BodyParser do + def parse(_req, parsed) do + {:ok, Map.get(parsed, "event_id")} end end end diff --git a/lib/polyjuice/client/endpoint/put_rooms_state.ex b/lib/polyjuice/client/endpoint/put_rooms_state.ex index 98481ed..51e9d64 100644 --- a/lib/polyjuice/client/endpoint/put_rooms_state.ex +++ b/lib/polyjuice/client/endpoint/put_rooms_state.ex @@ -65,14 +65,14 @@ defmodule Polyjuice.Client.Endpoint.PutRoomsState do } end - def transform_http_result(_req, status_code, _resp_headers, body) do - case status_code do - 200 -> - {:ok, body |> Poison.decode!() |> Map.get("event_id")} + def transform_http_result(req, status_code, resp_headers, body) do + Polyjuice.Client.Endpoint.parse_response(req, status_code, resp_headers, body) + end + end - _ -> - {:error, status_code, body} - end + defimpl Polyjuice.Client.Endpoint.BodyParser do + def parse(_req, parsed) do + {:ok, Map.get(parsed, "event_id")} end end end |