Add src/hk_api_messages_h.erl

src/hk_api_messages_h.erl

@@ -0,0 +1,40 @@
+%%%-------------------------------------------------------------------
+%%% @doc `/messages' API domain.
+%%%
+%%%   POST /api/messages?conversation_id=...   send a message
+%%%   GET  /api/messages?conversation_id=...   list that conversation's history
+%%% @end
+%%%-------------------------------------------------------------------
+-module(hk_api_messages_h).
+
+-export([init/2]).
+
+init(Req0 = #{method := <<"POST">>}, State) ->
+    RequestId = hk_api_util:request_id(Req0),
+    {ok, Body, Req1} = hk_api_util:read_json_body(Req0),
+    Sender = maps:get(<<"sender">>, Body, <<"unknown">>),
+    Recipient = maps:get(<<"recipient">>, Body, <<"unknown">>),
+    ConversationId = maps:get(<<"conversation_id">>, Body, hk_id:new(<<"conv">>)),
+    MessageType = binary_to_atom(maps:get(<<"message_type">>, Body, <<"user_to_agent">>), utf8),
+    Payload = maps:get(<<"payload">>, Body, #{}),
+    Req = hk_api_util:run_operation(message_send, RequestId, fun() ->
+        {ok, MessageId} = hk_messaging_portal:send(Sender, Recipient, ConversationId,
+                                                     MessageType, Payload),
+        {ok, {message, MessageId}, #{message_id => MessageId, conversation_id => ConversationId}}
+    end, Req1),
+    {ok, Req, State};
+
+init(Req0 = #{method := <<"GET">>}, State) ->
+    Qs = cowboy_req:parse_qs(Req0),
+    Req = case lists:keyfind(<<"conversation_id">>, 1, Qs) of
+              {<<"conversation_id">>, ConversationId} ->
+                  Messages = hk_messaging_portal:list_conversation(ConversationId),
+                  hk_api_util:reply_json(200, #{messages => Messages}, Req0);
+              false ->
+                  hk_api_util:reply_error(400, missing_conversation_id, Req0)
+          end,
+    {ok, Req, State};
+
+init(Req0, State) ->
+    Req = hk_api_util:reply_error(405, method_not_allowed, Req0),
+    {ok, Req, State}.