Packages

chat

6.7.14
9.4.14 9.4.13 9.2.28 9.1.4 9.1.2 9.1.1 6.8.2 6.7.14 5.11.1 5.11.0 3.9.0 3.8.1 3.7.5 3.7.4 3.7.3 3.7.2 3.7.1 3.7.0 3.6.0

CHAT CXC 138 25 X.509 CMS Instant Messenger

HexDocs

Current section

Files

Jump to
Readme
19 Versions
9 Dependencies
Dependants
Files
Activity
chat src services chat_room.erl
Raw

src/services/chat_room.erl 

-module(chat_room).

-include_lib("chat/include/roster.hrl").

-include_lib("n2o/include/n2o.hrl").

-export([start/0, info/3, proc/2]).



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



info(#'Member'{status = patch, id = Id}, Req, #cx{params = _ClientId, from = _From} = State) -> {reply, {bert, #io{}}, Req, State#cx{from = []}};

info(#'Member'{}, Req, #cx{params = ClientId} = State) -> {reply, {bert, #io{}}, Req, State#cx{from = []}};



info(#'Room'{status = create, id = Room, admins = [Admin|_], type=Type}, Req, #cx{state = verified} = State) -> {reply, {bert, #io{}}, Req, State#cx{from = []}};

info(#'Room'{status = patch, id = Room, name = _Name, data = _Avatar}, Req, #cx{params = _ClientId, client_pid = _PID} = State) when Room /= [] -> {reply, {bert, #io{}}, Req, State#cx{from = []}};

info(#'Room'{status = remove, members = _Members, admins = _Admins, id = _Room}, Req, #cx{params = ClientId, client_pid = C} = State) -> {reply, {bert, #io{}}, Req, State#cx{from = []}};

info(#'Room'{status = delete, members = [], admins = [], id = Room} = R, Req, #cx{params = <<"sys_", _/binary>> = ClientId, client_pid = C} = State) -> {reply, {bert, #io{}}, Req, State#cx{from = []}};

info(#'Room'{status = leave, id = Room}, Req, #cx{params = ClientId, client_pid = C} = State) -> {reply, {bert, #io{}}, Req, State#cx{from = []}};

info(#'Room'{status = get, id = Room}, Req, #cx{params = ClientId} = State) -> {reply, {bert, #io{}}, Req, State#cx{from = []}};

info(#'Room'{status = MuteUnmute, id = Room}, Req, #cx{params = ClientId, client_pid = C} = State) when MuteUnmute == mute;MuteUnmute == unmute -> {reply, {bert, #io{}}, Req, State#cx{from = []}};

info(#'Room'{status = AddJoin, id=R, members=M, admins=A}, Req, #cx{params=C, client_pid=C, state=RS} = State) when (AddJoin==add orelse(AddJoin==join andalso RS/=create))andalso(M/=[]orelse A/=[]) -> {reply, {bert, #io{}}, Req, State#cx{from = []}};

info(#'Room'{} = Room, Req, #cx{params = ClientId} = State) -> {reply, {bert, #io{}}, Req, State#cx{from = []}}.



proc(init, #pi{name = roster_room} = Async) -> {ok, Async};

proc({send_push, NewMembers, Msg, Type}, #pi{} = H) -> {reply, [], H}.