-refreshMessage(Action) ->\r
- simple_xml_to_string(
- case {
- xmerl_xpath:string("nombreMessage", Action), % le nombre de message qu'affiche le client
- xmerl_xpath:string("page", Action) % la page désiré, la première (les derniers messages) étant la 1
- } of
- {
- [#xmlElement{content = [#xmlText{value = Nb_message_str}]}],
- [#xmlElement{content = [#xmlText{value = Page_str}]}]
- } ->
- Nb_message = list_to_integer(Nb_message_str),
- Page = list_to_integer(Page_str),
- Dernier_id = case xmerl_xpath:string("dernierMessageId", Action) of % l'id du dernier message que connait le client
- [#xmlElement{content = [#xmlText{value = D}]}] -> erlang:list_to_integer(D, 36);
- _ -> 0
- end,
- User = case xmerl_xpath:string("cookie", Action) of
- [#xmlElement{content = [#xmlText{value = Cookie}]}] ->
- case euphorik_minichat:user_by_cookie(Cookie) of
- {ok, U} -> U;
- _ -> inconnu
- end;
- _ -> inconnu
- end,
- % extraction des conversations en [{id, page}, ..]
- Conversations = lists:map(
- fun(Conv) ->
- [#xmlElement{content = [#xmlText{value = Id_racine_str}]}] = xmerl_xpath:string("racine", Conv),
- [#xmlElement{content = [#xmlText{value = Page_conv_str}]}] = xmerl_xpath:string("page", Conv),
- {erlang:list_to_integer(Id_racine_str, 36), erlang:list_to_integer(Page_conv_str)}
- end,
- xmerl_xpath:string("conversation", Action)
- ),\r
- % accrochez-vous ca va siouxer ;)
- [{reponse, [{name, "refreshMessages"}],\r
- lists:map(\r
+% last_message id et cookie sont facultatifs
+wait_event([{page, "chat"} | Data]) ->
+ % traitement des inputs
+ Cookie = case lists:keysearch(cookie, 1, Data) of {value, {_, C}} -> C; _ -> inconnu end,
+ Last_message_id = case lists:keysearch(last_message_id, 1, Data) of {value, {_, Id}} -> Id; _ -> 0 end,
+ {value, {_, Message_count}} = lists:keysearch(message_count, 1, Data),
+ Main_page = case lists:keysearch(main_page, 1, Data) of {value, {_, P}} -> P; _ -> 1 end,
+ Troll_id = case lists:keysearch(troll_id, 1, Data) of {value, {_, T}} -> T; _ -> 0 end,
+ {value, {_, {array, Conversations_json}}} = lists:keysearch(conversations, 1, Data),
+ Racines_conversations = lists:map(
+ fun({struct, [{root, Racine}, {page, Page} | Reste]}) ->
+ Last_mess_conv = case Reste of [{last_message_id, L}] -> L; _ -> 0 end,
+ {Racine, Page, Last_mess_conv}
+ end,
+ Conversations_json
+ ),
+ User = case euphorik_bd:user_by_cookie(Cookie) of\r
+ {ok, U} -> U;\r
+ _ -> inconnu\r
+ end,
+ case {mnesia:subscribe({table, minichat, detailed}), mnesia:subscribe({table, troll, detailed})} of
+ {{error, E}, _} -> E;
+ {_, {error, E}} -> E;
+ _ ->
+ % attente d'événements
+ R = wait_event_page_chat(User, Racines_conversations, Message_count, Last_message_id, Main_page, Troll_id),
+ mnesia:unsubscribe({table, minichat, detailed}),
+ mnesia:unsubscribe({table, troll, detailed}),
+ R
+ end;
+wait_event([{page, "admin"}, {last_troll, Last_troll}]) ->
+ case euphorik_bd:trolls_attente(Last_troll) of
+ {mod, Troll} ->
+ {struct,
+ [
+ {reply, "troll_modified"},
+ {troll_id, Troll#troll.id},
+ {content, Troll#troll.content}
+ ]
+ };
+ {add, Trolls} ->
+ {struct,
+ [
+ {reply, "troll_added"},
+ {trolls, {array,
+ lists:map(
+ fun(T) ->
+ {ok, User} = euphorik_bd:user_by_id(T#troll.id_user),
+ {struct,
+ [
+ {troll_id, T#troll.id},
+ {content, T#troll.content},
+ {author, User#user.pseudo},
+ {author_id, User#user.id}
+ ]
+ }
+ end,
+ Trolls
+ )
+ }}
+ ]
+ };
+ {del, Troll_id} ->
+ {struct,
+ [
+ {reply, "troll_deleted"},
+ {troll_id, Troll_id}
+ ]
+ };
+ _ ->
+ erreur("timeout")
+ end;
+wait_event(_) ->
+ erreur("Page inconnue").
+
+
+wait_event_page_chat(User, Racines_conversations, Message_count, Last_message_id, Main_page, Troll_id) ->
+ % est-ce qu'il y a des nouveaux messages ?
+ case euphorik_minichat_conversation:conversations(Racines_conversations, Message_count, Last_message_id, Main_page) of
+ vide ->
+ % est-ce que le troll est à jour ?
+ case euphorik_bd:current_troll() of
+ Current when is_record(Current, troll), Current#troll.id =/= Troll_id ->
+ {struct, [
+ {reply, "new_troll"},
+ {troll_id, Current#troll.id},
+ {content, Current#troll.content}
+ ]};
+ _ ->
+ wait_event_bd_page_chat(),
+ % TODO : l'appel est-il bien tail-recursive ?
+ wait_event_page_chat(User, Racines_conversations, Message_count, Last_message_id, Main_page, Troll_id)
+ end;
+ Conversations ->
+ % accrochez-vous ca va siouxer ;)
+ {struct, [
+ {reply, "new_messages"},
+ {conversations, {array,
+ lists:map(