chat

-module(chat_message).
-include_lib("chat/include/roster.hrl").
-include_lib("n2o/include/n2o.hrl").
-include_lib("kvs/include/kvs.hrl").
-export([start/0,info/3]).

-define(MSG_EDIT_ACTION, <<"message_edit">>).
-define(MSG_DELETE_ACTION, <<"message_delete">>).

start() -> n2o_pi:start(#pi{module = ?MODULE, table = system, sup = roster, name = "Message Service", state = []}).

info(#'Typing'{phone_id = Phone, comments = Comments}, Req, #cx{} = State) -> {reply, {bert, <<>>}, Req, State};
info(#'Message'{msg_id=MsgID, status=Status} = M, Req, #cx{state=[]}=State) when MsgID /= [], Status/=update-> {reply, {bert, #'Ack'{id=MsgID}}, Req, State};
info(#'Message'{status = [], id = [], feed_id = F, from=From0, to = To, type = Type, files = [#'Desc'{payload = Payload} | _] = Descs} = Msg, Req, #cx{client_pid = C, params = ClientId, state=ack} = State) -> {reply, {bert, #io{}}, Req, State};
info(#'Message'{status = edit, id = Id, msg_id = ClMID, feed_id = Feed, from = From, to = To, mentioned = Mentioned, files = [#'Desc'{payload = Payload} | _] = Descs}, Req, #cx{params = ClientId, client_pid = C, state=ack} = State) -> {reply, {bert, #io{}}, Req, State};
info(#'Message'{id = Id, msg_id = ClMID, feed_id = Feed, from = From0, seenby = Seen, status = delete}, Req, #cx{params = ClientId, client_pid = C, state=ack} = State) when is_integer(Id) -> {reply, {bert,#io{}}, Req, State};
info(#'Message'{from = From, to = To} = ReqData, Req, State) -> {reply, {bert, #io{code = #error{code = invalid_data}}}, Req, State}.