2 % Ce module gére les différents messages envoyés par le client (javascript) via AJAX.
3 % Les messages donnés ainsi que les réponses sont au format JSON.
6 -module(euphorik_protocole
).
18 -include_lib("xmerl/include/xmerl.hrl").
19 -include("../include/euphorik_bd.hrl").
20 -include("../include/euphorik_defines.hrl").
23 % Une utilisateur s'enregistre avec un tuple {Login, Password}.
24 register([{login
, Login
}, {password
, Password
}], IP
) ->
25 Can_register
= euphorik_bd:can_register(IP
),
27 case euphorik_bd:user_by_login(Login
) of
29 erreur("Login déjà existant");
31 User
= euphorik_bd:nouveau_user(Login
, Password
, generer_cookie()),
32 euphorik_bd:update_ip(User#user
.id
, IP
),
33 json_reponse_login_ok(User
)
36 erreur_register_flood()
38 % Enregistrement sans {Login, Password}
40 Can_register
= euphorik_bd:can_register(IP
),
42 User
= euphorik_bd:nouveau_user("<nick>", generer_cookie()),
43 euphorik_bd:update_ip(User#user
.id
, IP
),
44 json_reponse_login_ok(User
);
46 erreur_register_flood()
49 erreur_register_flood() ->
50 erreur("Trop de register (flood)").
53 % Un utilisateur se logge (avec un couple {login, mot de passe})
54 login([{login
, Login
}, {password
, Password
}], IP
) ->
55 loginUser(euphorik_bd:user_by_login_password(Login
, Password
), IP
);
56 % Un utilisateur se logge (avec un cookie)
57 login([{cookie
, Cookie
}], IP
) ->
58 loginUser(euphorik_bd:user_by_cookie(Cookie
), IP
).
60 loginUser({ok
, User
}, IP
) ->
61 euphorik_bd:update_ip(User#user
.id
, IP
),
62 euphorik_bd:update_date_derniere_connexion(User#user
.id
),
63 json_reponse_login_ok(User
);
65 % ajoute un délais d'attente (TODO : un autre moyen plus élégant ?)
67 erreur("Erreur login")
71 % Renvoie un string() représentant un cookie en base 36. Il y a 10^32 possibillités.
74 random:seed(A1
, A2
, A3
),
75 erlang:integer_to_list(random:uniform(math:pow(10, 32)), 36).
78 % Un utilisateur se délogge.
83 % Modification du profile.
92 {nick_format
, Nick_format_str
},
93 {main_page
, Main_page
},
94 {conversations
, {array
, Conversations_json
}}
97 % est-ce que les messages auquel on répond existent ?
98 Conversations
= lists:foldr(
99 fun({struct
, [{root
, Root
}, {page
, Page
}]}, Acc
) ->
100 Message_existe
= euphorik_bd:message_existe(Root
),
102 [{Root
, Page
} | Acc
];
110 case euphorik_bd:set_profile(Cookie
, Login
, Password
, Pseudo
, Email
, Css
, list_to_atom(Nick_format_str
), Main_page
, Conversations
) of
114 erreur("Login déjà pris");
116 erreur("Impossible de mettre à jour le profile")
120 % Renvoie les messages appropriés.
121 % last_message id et cookie sont facultatifs
123 Cookie
= case lists:keysearch(cookie
, 1, Data
) of {value
, {_
, C
}} -> C
; _
-> inconnu
end,
124 Last_message_id
= case lists:keysearch(last_message_id
, 1, Data
) of {value
, {_
, Id
}} -> Id
; _
-> 0 end,
125 {value
, {_
, Message_count
}} = lists:keysearch(message_count
, 1, Data
),
126 Main_page
= case lists:keysearch(main_page
, 1, Data
) of {value
, {_
, P
}} -> P
; _
-> 1 end,
127 {value
, {_
, {array
, Conversations_json
}}} = lists:keysearch(conversations
, 1, Data
),
128 Conversations
= lists:map(
129 fun({struct
, [{root
, Racine
}, {page
, Page
} | Reste
]}) ->
130 Last_mess_conv
= case Reste
of [{last_message_id
, L
}] -> L
; _
-> 0 end,
131 {Racine
, Page
, Last_mess_conv
}
135 User
= case euphorik_bd:user_by_cookie(Cookie
) of
140 {reply
, "new_message"},
141 {conversations
, {array
,
142 % accrochez-vous ca va siouxer ;)
146 {last_page
, not Plus
},
149 fun({Mess
, Repond_a
}) ->
150 Est_proprietaire
= User
=/= inconnu andalso User#user
.id
=:= Mess#minichat
.auteur_id
,
151 A_repondu_a_message
= User
=/= inconnu andalso
euphorik_bd:a_repondu_a_message(User#user
.id
, Mess#minichat
.id
),
152 Est_une_reponse_a_user
= User
=/= inconnu andalso
euphorik_bd:est_une_reponse_a_user(User#user
.id
, Mess#minichat
.id
),
154 if Mess#minichat
.auteur_id
=:= 0 ->
157 {ok
, U2
} = euphorik_bd:user_by_id(Mess#minichat
.auteur_id
),
161 {id
, Mess#minichat
.id
},
162 {date, format_date(Mess#minichat
.date)},
163 {system
, Mess#minichat
.auteur_id
=:= 0},
164 {owner
, Est_proprietaire
},
165 {answered
, A_repondu_a_message
},
166 {is_a_reply
, Est_une_reponse_a_user
},
167 {nick
, Mess#minichat
.pseudo
},
168 {login
, if User_mess
=:= inconnu
-> Mess#minichat
.pseudo
; true
-> User_mess#user
.login
end},
169 {content
, Mess#minichat
.contenu
},
170 {answer_to
, {array
, lists:map(
172 {ok
, M
} = euphorik_bd:message_by_id(Id_mess
),
173 {ok
, User_reponse
} = euphorik_bd:user_by_mess(M#minichat
.id
),
174 {struct
, [{id
, M#minichat
.id
}, {nick
, M#minichat
.pseudo
}, {login
, User_reponse#user
.login
}]}
178 {ek_master
, User_mess#user
.ek_master
}
186 euphorik_minichat_conversation:conversations(
197 % Un utilisateur envoie un message
203 {answer_to
, {array
, Answer_to
}}
206 case euphorik_bd:user_by_cookie(Cookie
) of
208 Strip_content
= string:strip(Content
),
209 if (Strip_content
=:= []) ->
210 erreur("Message vide");
212 % TODO : non-atomique (update_pseudo+nouveau_message)
213 euphorik_bd:update_pseudo_user(User#user
.id
, Nick
),
214 case euphorik_bd:nouveau_message(Strip_content
, User#user
.id
, Answer_to
) of
215 erreur
-> erreur("Impossible d'ajouter un nouveau message");
221 erreur("Utilisateur inconnu")
225 % bannissement d'un utilisateur (son ip est bannie)
229 {duration
, Duration
},
232 % controle que l'utilisateur est un admin
233 case euphorik_bd:user_by_cookie(Cookie
) of
234 {ok
, User
= #user
{ek_master
= true
}} ->
235 case euphorik_bd:user_by_id(User_id
) of
237 euphorik_bd:ban(User#user
.last_ip
, Duration
);
239 erreur("Utilisateur à bannir inconnu")
242 erreur("Utilisateur inconnu ou non ek master")
246 % Construit une erreur
251 {error_message
, Message
}
256 % Formatage d'une heure
257 % local_time() -> string
259 DateLocal
= calendar:now_to_local_time(Date
),
260 DateNowLocal
= calendar:local_time(),
261 {{Annee
, Mois
, Jour
}, {Heure
, Minute
, Seconde
}} = DateLocal
,
262 {{AnneeNow
, _
, _
}, {_
, _
, _
}} = DateNowLocal
,
263 Hier
= calendar:date_to_gregorian_days(element(1, DateLocal
)) =:= calendar:date_to_gregorian_days(element(1, DateNowLocal
)) - 1,
265 if element(1, DateLocal
) =:= element(1, DateNowLocal
) ->
269 Annee
=:= AnneeNow
->
270 io_lib:format("~2.10.0B/~2.10.0B ", [Jour
, Mois
]);
272 io_lib:format("~2.10.0B/~2.10.0B/~B ", [Jour
, Mois
, Annee
])
274 io_lib:format("~2.10.0B:~2.10.0B:~2.10.0B", [Heure
, Minute
, Seconde
])
279 {struct
, [{reply
, "ok"}]}.
282 json_reponse_login_ok(User
) ->
286 {status
, if (User#user
.password
=/= []) and (User#user
.login
=/= []) -> "auth_registered"; true
-> "auth_not_registered" end},
287 {cookie
, User#user
.cookie
},
289 {nick
, User#user
.pseudo
},
290 {login
, User#user
.login
},
291 {email
, User#user
.email
},
292 {css
, User#user
.css
},
293 {nick_format
, atom_to_list(User#user
.nick_format
)},
294 {main_page
, User#user
.page_principale
},
301 {root
, element(1, C
)},
302 {page
, element(2, C
)}
306 User#user
.conversations
310 {ek_master
, User#user
.ek_master
}