4698755488

Committed 14 Apr 2023 10:23AM UTC coverage: 81.909% (+0.4%) from 81.533%

Build Type

push

github

Committed by GitHub

Commit Message

Merge pull request #4002 from esl/measured-sql-requests

Run Details

9 of 9 new or added lines in 1 file covered. (100.0%)

27696 of 33813 relevant lines covered (81.91%)

27956.57 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

62.83

/src/mod_muc_log.erl

%%%----------------------------------------------------------------------
%%% File    : mod_muc_log.erl
%%% Author  : Badlop@process-one.net
%%% Purpose : MUC room logging
%%% Created : 12 Mar 2006 by Alexey Shchepin <alexey@process-one.net>
%%%
%%%
%%% ejabberd, Copyright (C) 2002-2011   ProcessOne
%%%
%%% This program is free software; you can redistribute it and/or
%%% modify it under the terms of the GNU General Public License as
%%% published by the Free Software Foundation; either version 2 of the
%%% License, or (at your option) any later version.
%%%
%%% This program is distributed in the hope that it will be useful,
%%% but WITHOUT ANY WARRANTY; without even the implied warranty of
%%% MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
%%% General Public License for more details.
%%%
%%% You should have received a copy of the GNU General Public License
%%% along with this program; if not, write to the Free Software
%%% Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
%%%
%%%----------------------------------------------------------------------

-module(mod_muc_log).
-author('badlop@process-one.net').

-behaviour(gen_server).
-behaviour(gen_mod).
-behaviour(mongoose_module_metrics).

%% API
-export([start_link/2,
         start/2,
         stop/1,
         supported_features/0,
         check_access_log/3,
         add_to_log/5,
         set_room_occupants/4]).

%% Config callbacks
-export([config_spec/0,
         process_top_link/1]).

%% gen_server callbacks
-export([init/1, handle_call/3, handle_cast/2, handle_info/2,
         terminate/2, code_change/3]).

-ignore_xref([start_link/2]).

-include("mongoose.hrl").
-include("jlib.hrl").
-include("mod_muc_room.hrl").
-include("mongoose_config_spec.hrl").

-define(T(Text), translate:translate(Lang, Text)).
-define(PROCNAME, ejabberd_mod_muc_log).

-record(room, {jid, title, subject, subject_author, config}).
-type room() :: #room{}.

-type command() :: 'join'
                 | 'kickban'
                 | 'leave'
                 | 'nickchange'
                 | 'room_existence'
                 | 'roomconfig_change'
                 | 'roomconfig_change_enabledlogging'
                 | 'text'.

-type jid_nick_role() :: {jid:jid(), mod_muc:nick(), mod_muc:role()}.
-type jid_nick() :: {jid:jid(), mod_muc:nick()}.
-type dir_type() :: 'plain' | 'subdirs'.
-type dir_name() :: 'room_jid' | 'room_name'.
-type file_format() :: 'html' | 'plaintext'.

-record(logstate, {host_type    :: mongooseim:host_type(),
                   out_dir      :: binary(),
                   dir_type     :: dir_type(),
                   dir_name     :: dir_name(),
                   file_format  :: file_format(),
                   css_file     :: binary() | false,
                   access,
                   lang         :: ejabberd:lang(),
                   timezone,
                   spam_prevention,
                   top_link,
                   occupants = #{} :: #{RoomJID :: binary() => [jid_nick_role()]},
                   room_monitors = #{} :: #{reference() => RoomJID :: binary()}
                }).
-type logstate() :: #logstate{}.

%%====================================================================
%% API
%%====================================================================

%% @doc Starts the server
-spec start_link(mongooseim:host_type(), _) -> 'ignore' | {'error', _} | {'ok', pid()}.
start_link(Host, Opts) ->
    Proc = gen_mod:get_module_proc(Host, ?PROCNAME),
    gen_server:start_link({local, Proc}, ?MODULE, {Host, Opts}, []).

-spec start(mongooseim:host_type(), map()) -> {'error', _}
                                  | {'ok', 'undefined' | pid()}
                                  | {'ok', 'undefined' | pid(), _}.
start(Host, Opts) ->
    Proc = gen_mod:get_module_proc(Host, ?PROCNAME),
    ChildSpec =
        {Proc,
         {?MODULE, start_link, [Host, Opts]},
         temporary,
         1000,
         worker,
         [?MODULE]},
    ejabberd_sup:start_child(ChildSpec).

-spec stop(jid:server()) -> 'ok'
    | {'error', 'not_found' | 'restarting' | 'running' | 'simple_one_for_one'}.
stop(Host) ->
    Proc = gen_mod:get_module_proc(Host, ?PROCNAME),
    gen_server:call(Proc, stop),
    ejabberd_sup:stop_child(Proc).

-spec supported_features() -> [atom()].
supported_features() ->
    [dynamic_domains].

-spec config_spec() -> mongoose_config_spec:config_section().
config_spec() ->
    #section{
       items = #{<<"outdir">> => #option{type = string,
                                         validate = dirname},
                 <<"access_log">> => #option{type = atom,
                                             validate = access_rule},
                 <<"dirtype">> => #option{type = atom,
                                          validate = {enum, [subdirs, plain]}},
                 <<"dirname">> => #option{type = atom,
                                          validate = {enum, [room_jid, room_name]}},
                 <<"file_format">> => #option{type = atom,
                                              validate = {enum, [html, plaintext]}},
                 <<"css_file">> => #option{type = binary,
                                           validate = non_empty},
                 <<"timezone">> => #option{type = atom,
                                           validate = {enum, [local, universal]}},
                 <<"top_link">> => top_link_config_spec(),
                 <<"spam_prevention">> => #option{type = boolean}
                },
          defaults = defaults()
      }.

defaults() ->
    #{<<"outdir">> => "www/muc",
      <<"access_log">> => muc_admin,
      <<"dirtype">> => subdirs,
      <<"dirname">> => room_jid,
      <<"file_format">> => html,
      <<"css_file">> => false,
      <<"timezone">> => local,
      <<"top_link">> => {"/", "Home"},
      <<"spam_prevention">> => true}.

top_link_config_spec() ->
    #section{
       items = #{<<"target">> => #option{type = string,
                                         validate = url},
                 <<"text">> => #option{type = string,
                                       validate = non_empty}},
       required = all,
       process = fun ?MODULE:process_top_link/1
      }.

process_top_link(#{target := Target, text := Text}) ->
    {Target, Text}.

-spec add_to_log(mongooseim:host_type(), Type :: any(), Data :: any(), mod_muc:room(),
                 list()) -> 'ok'.
add_to_log(HostType, Type, Data, Room, Opts) ->
    gen_server:cast(get_proc_name(HostType),
                    {add_to_log, Type, Data, Room, Opts}).


-spec check_access_log(mongooseim:host_type(), jid:lserver(), jid:jid()) -> any().
check_access_log(HostType, ServerHost, From) ->
    case catch gen_server:call(get_proc_name(HostType),
                               {check_access_log, HostType, ServerHost, From}) of
        {'EXIT', _Error} ->
            deny;
        Res ->
            Res
    end.

-spec set_room_occupants(mongooseim:host_type(), RoomPID :: pid(), RoomJID :: jid:jid(),
                         Occupants :: [mod_muc_room:user()]) -> ok.
set_room_occupants(HostType, RoomPID, RoomJID, Occupants) ->
    gen_server:cast(get_proc_name(HostType), {set_room_occupants, RoomPID, RoomJID, Occupants}).

%%====================================================================
%% gen_server callbacks
%%====================================================================

%%--------------------------------------------------------------------
%% Function: init(Args) -> {ok, State} |
%%                         {ok, State, Timeout} |
%%                         ignore               |
%%                         {stop, Reason}
%% Description: Initiates the server
%%--------------------------------------------------------------------
-spec init({HostType :: mongooseim:host_type(), map()}) -> {ok, logstate()}.
init({HostType, Opts}) ->
    #{
        access_log := AccessLog,
        css_file := CSSFile,
        dirname := DirName,
        dirtype := DirType,
        file_format := FileFormat,
        outdir := OutDir,
        spam_prevention := NoFollow,
        timezone := Timezone,
        top_link := TopLink
     } = Opts,
    {ok, #logstate{host_type = HostType,
                out_dir = OutDir,
                dir_type = DirType,
                dir_name = DirName,
                file_format = FileFormat,
                css_file = CSSFile,
                access = AccessLog,
                lang = ?MYLANG,
                timezone = Timezone,
                spam_prevention = NoFollow,
                top_link = TopLink}}.

%%--------------------------------------------------------------------
%% Function: %% handle_call(Request, From, State) -> {reply, Reply, State} |
%%                                      {reply, Reply, State, Timeout} |
%%                                      {noreply, State} |
%%                                      {noreply, State, Timeout} |
%%                                      {stop, Reason, Reply, State} |
%%                                      {stop, Reason, State}
%% Description: Handling call messages
%%--------------------------------------------------------------------
-spec handle_call('stop'
            | {'check_access_log', mongooseim:host_type(), 'global' | jid:server(), jid:jid()},
        From :: any(), logstate()) -> {'reply', 'allow' | 'deny', logstate()}
                                    | {'stop', 'normal', 'ok', _}.
handle_call({check_access_log, HostType, ServerHost, FromJID}, _From, State) ->
    Reply = acl:match_rule(HostType, ServerHost, State#logstate.access, FromJID),
    {reply, Reply, State};
handle_call(stop, _From, State) ->
    {stop, normal, ok, State}.

%%--------------------------------------------------------------------
%% Function: handle_cast(Msg, State) -> {noreply, State} |
%%                                      {noreply, State, Timeout} |
%%                                      {stop, Reason, State}
%% Description: Handling cast messages
%%--------------------------------------------------------------------
-spec handle_cast
    ({add_to_log, any(), any(), mod_muc:room(), list()}, logstate()) -> {'noreply', logstate()};
    ({set_room_occupants, pid(), jid:jid(), [mod_muc_room:user()]}, logstate()) ->
        {noreply, logstate()}.
handle_cast({add_to_log, Type, Data, Room, Opts}, State) ->
    try
        add_to_log2(Type, Data, Room, Opts, State)
    catch Class:Reason:Stacktrace ->
              ?LOG_ERROR(#{what => muc_add_to_log_failed, room => Room,
                           class => Class, reason => Reason, stacktrace => Stacktrace,
                           log_type => Type, log_data => Data})
    end,
    {noreply, State};
handle_cast({set_room_occupants, RoomPID, RoomJID, Users}, State) ->
    #logstate{occupants = OldOccupantsMap, room_monitors = OldMonitors} = State,
    RoomJIDBin = jid:to_binary(RoomJID),
    Monitors =
        case maps:is_key(RoomJIDBin, OldOccupantsMap) of
            true -> OldMonitors;
            false ->
                MonitorRef = monitor(process, RoomPID),
                maps:put(MonitorRef, RoomJIDBin, OldMonitors)
        end,
    Occupants = [{U#user.jid, U#user.nick, U#user.role} || U <- Users],
    OccupantsMap = maps:put(RoomJIDBin, Occupants, OldOccupantsMap),
    {noreply, State#logstate{occupants = OccupantsMap, room_monitors = Monitors}};
handle_cast(_Msg, State) ->
    {noreply, State}.

%%--------------------------------------------------------------------
%% Function: handle_info(Info, State) -> {noreply, State} |
%%                                       {noreply, State, Timeout} |
%%                                       {stop, Reason, State}
%% Description: Handling all non call/cast messages
%%--------------------------------------------------------------------
handle_info({'DOWN', MonitorRef, process, Pid, Info}, State) ->
    #logstate{occupants = OldOccupantsMap, room_monitors = OldMonitors} = State,
    case maps:find(MonitorRef, OldMonitors) of
        error ->
            ?LOG_WARNING(#{what => muc_unknown_monitor,
                           text => <<"Unknown monitored process is now down">>,
                           monitor_ref => MonitorRef, monitor_pid => Pid, reason => Info}),
            {noreply, State};
        {ok, RoomJID} ->
            Monitors = maps:remove(MonitorRef, OldMonitors),
            OccupantsMap = maps:remove(RoomJID, OldOccupantsMap),
            {noreply, State#logstate{occupants = OccupantsMap, room_monitors = Monitors}}
    end;
handle_info(_Info, State) ->
    {noreply, State}.

%%--------------------------------------------------------------------
%% Function: terminate(Reason, State) -> void()
%% Description: This function is called by a gen_server when it is about to
%% terminate. It should be the opposite of Module:init/1 and do any necessary
%% cleaning up. When it returns, the gen_server terminates with Reason.
%% The return value is ignored.
%%--------------------------------------------------------------------
terminate(_Reason, _State) ->
    ok.

%%--------------------------------------------------------------------
%% Func: code_change(OldVsn, State, Extra) -> {ok, NewState}
%% Description: Convert process state when code is changed
%%--------------------------------------------------------------------
code_change(_OldVsn, State, _Extra) ->
    {ok, State}.

%%--------------------------------------------------------------------
%%% Internal functions
%%--------------------------------------------------------------------
-spec add_to_log2(command(), {mod_muc:nick(), mod_muc:packet()}, mod_muc:room(),
        list(), logstate()) -> 'ok'.
add_to_log2(text, {Nick, Packet}, Room, Opts, State) ->
    case {xml:get_subtag(Packet, <<"subject">>), xml:get_subtag(Packet, <<"body">>)} of
        {false, false} ->
            ok;
        {false, SubEl} ->
            Message = {body, xml:get_tag_cdata(SubEl)},
            add_message_to_log(Nick, Message, Room, Opts, State);
        {SubEl, _} ->
            Message = {subject, xml:get_tag_cdata(SubEl)},
            add_message_to_log(Nick, Message, Room, Opts, State)
    end;
add_to_log2(roomconfig_change, _Occupants, Room, Opts, State) ->
    add_message_to_log(<<"">>, roomconfig_change, Room, Opts, State);
add_to_log2(roomconfig_change_enabledlogging, Occupants, Room, Opts, State) ->
    add_message_to_log(<<"">>, {roomconfig_change, Occupants}, Room, Opts, State);
add_to_log2(room_existence, NewStatus, Room, Opts, State) ->
    add_message_to_log(<<"">>, {room_existence, NewStatus}, Room, Opts, State);
add_to_log2(nickchange, {OldNick, NewNick}, Room, Opts, State) ->
    add_message_to_log(NewNick, {nickchange, OldNick}, Room, Opts, State);
add_to_log2(join, Nick, Room, Opts, State) ->
    add_message_to_log(Nick, join, Room, Opts, State);
add_to_log2(leave, {Nick, Reason}, Room, Opts, State) ->
    case Reason of
        <<"">> -> add_message_to_log(Nick, leave, Room, Opts, State);
        _ -> add_message_to_log(Nick, {leave, Reason}, Room, Opts, State)
    end;
add_to_log2(kickban, {Nick, Reason, Code}, Room, Opts, State) ->
    add_message_to_log(Nick, {kickban, Code, Reason}, Room, Opts, State).


%%----------------------------------------------------------------------
%% Core

-spec build_filename_string(calendar:datetime(), OutDir :: binary(),
        RoomJID :: jid:literal_jid(), dir_type(), dir_name(), file_format())
            -> {binary(), binary(), binary()}.
build_filename_string(TimeStamp, OutDir, RoomJID, DirType, DirName, FileFormat) ->
    {{Year, Month, Day}, _Time} = TimeStamp,

    %% Directory and file names
    {Dir, Filename, Rel} =
        case DirType of
            subdirs ->
                    SYear = list_to_binary(lists:flatten(io_lib:format("~4..0w", [Year]))),
                    SMonth = list_to_binary(lists:flatten(io_lib:format("~2..0w", [Month]))),
                    SDay = list_to_binary(lists:flatten(io_lib:format("~2..0w", [Day]))),
                {filename:join(SYear, SMonth), SDay, <<"../..">>};
            plain ->
                    Date = list_to_binary(lists:flatten(
                             io_lib:format("~4..0w-~2..0w-~2..0w",
                                           [Year, Month, Day]))),
                    {<<"">>, Date, <<".">>}
        end,

    RoomString = case DirName of
                     room_jid -> RoomJID;
                     room_name -> get_room_name(RoomJID)
                 end,
    Extension = case FileFormat of
                    html -> <<".html">>;
                    plaintext -> <<".txt">>
                end,
    Fd = filename:join([OutDir, RoomString, Dir]),
    Fn = filename:join([Fd, <<Filename/binary, Extension/binary>>]),
    Fnrel = filename:join([Rel, Dir, <<Filename/binary, Extension/binary>>]),
    {Fd, Fn, Fnrel}.


-spec get_room_name(jid:literal_jid()) -> mod_muc:room().
get_room_name(RoomJID) ->
    JID = jid:from_binary(RoomJID),
    JID#jid.luser.


%% @doc calculate day before
-spec get_timestamp_daydiff(calendar:datetime(), integer()) -> calendar:datetime().
get_timestamp_daydiff(TimeStamp, Daydiff) ->
    {Date1, HMS} = TimeStamp,
    Date2 = calendar:gregorian_days_to_date(
              calendar:date_to_gregorian_days(Date1) + Daydiff),
    {Date2, HMS}.


%% @doc Try to close the previous day log, if it exists
-spec close_previous_log(binary(), any(), file_format()) -> 'ok' | {'error', atom()}.
close_previous_log(Fn, ImagesDir, FileFormat) ->
    case file:read_file_info(Fn) of
        {ok, _} ->
            {ok, F} = file:open(Fn, [append]),
            write_last_lines(F, ImagesDir, FileFormat),
            file:close(F);
        _ -> ok
    end.


-spec write_last_lines(file:io_device(), binary(), file_format()) -> 'ok'.
write_last_lines(_, _, plaintext) ->
    ok;
write_last_lines(F, ImagesDir, _FileFormat) ->
    fw(F, <<"<div class=\"legend\">">>),
    fw(F, <<"  <a href=\"http://www.ejabberd.im\"><img style=\"border:0\" src=\"", ImagesDir/binary,
            "/powered-by-ejabberd.png\" alt=\"Powered by ejabberd\"/></a>">>),
    fw(F, <<"  <a href=\"http://www.erlang.org/\"><img style=\"border:0\" src=\"", ImagesDir/binary,
            "/powered-by-erlang.png\" alt=\"Powered by Erlang\"/></a>">>),
    fw(F, <<"<span class=\"w3c\">">>),
    fw(F, <<"  <a href=\"http://validator.w3.org/check?uri=referer\">"
            "<img style=\"border:0;width:88px;height:31px\" src=\"", ImagesDir/binary,
            "/valid-xhtml10.png\" alt=\"Valid XHTML 1.0 Transitional\" /></a>">>),
    fw(F, <<"  <a href=\"http://jigsaw.w3.org/css-validator/\">"
            "<img style=\"border:0;width:88px;height:31px\" src=\"", ImagesDir/binary,
            "/vcss.png\" alt=\"Valid CSS!\"/></a>">>),
    fw(F, <<"</span></div></body></html>">>).


-spec add_message_to_log(mod_muc:nick(), Message :: atom() | tuple(),
    RoomJID :: jid:simple_jid() | jid:jid(), Opts :: list(), State :: logstate()) -> ok.
add_message_to_log(Nick1, Message, RoomJID, Opts, State) ->
    #logstate{out_dir = OutDir,
           dir_type = DirType,
           dir_name = DirName,
           file_format = FileFormat,
           css_file = CSSFile,
           lang = Lang,
           timezone = Timezone,
           spam_prevention = NoFollow,
           top_link = TopLink,
           occupants = OccupantsMap} = State,
    Room = get_room_info(RoomJID, Opts),
    Nick = htmlize(Nick1, FileFormat),
    Nick2 = htmlize(<<"<", Nick1/binary, ">">>, FileFormat),
    Now = erlang:timestamp(),
    TimeStamp = case Timezone of
                    local -> calendar:now_to_local_time(Now);
                    universal -> calendar:now_to_universal_time(Now)
                end,
    {Fd, Fn, _Dir} = build_filename_string(TimeStamp, OutDir, Room#room.jid,
                                           DirType, DirName, FileFormat),
    {Date, Time} = TimeStamp,

    %% Open file, create if it does not exist, create parent dirs if needed
    case file:read_file_info(Fn) of
        {ok, _} ->
            {ok, F} = file:open(Fn, [append]);
        {error, enoent} ->
            make_dir_rec(Fd),
            {ok, F} = file:open(Fn, [append]),
            Datestring = get_dateweek(Date, Lang),

            TimeStampYesterday = get_timestamp_daydiff(TimeStamp, -1),
            {_FdYesterday, FnYesterday, DatePrev} =
                build_filename_string(
                  TimeStampYesterday, OutDir, Room#room.jid, DirType, DirName, FileFormat),

            TimeStampTomorrow = get_timestamp_daydiff(TimeStamp, 1),
            {_FdTomorrow, _FnTomorrow, DateNext} =
                build_filename_string(
                  TimeStampTomorrow, OutDir, Room#room.jid, DirType, DirName, FileFormat),

            HourOffset = calc_hour_offset(TimeStamp),
            put_header(F, Room, Datestring, CSSFile, Lang,
                       HourOffset, DatePrev, DateNext, TopLink, FileFormat, OccupantsMap),

            ImagesDir = <<OutDir/binary, "images">>,
            file:make_dir(ImagesDir),
            create_image_files(ImagesDir),
            ImagesUrl = case DirType of
                             subdirs -> <<"../../../images">>;
                             plain -> <<"../images">>
                         end,
            close_previous_log(FnYesterday, ImagesUrl, FileFormat)
    end,

    %% Build message
    Text
    = case Message of
          roomconfig_change ->
              RoomConfig = roomconfig_to_binary(Room#room.config, Lang, FileFormat),
              put_room_config(F, RoomConfig, Lang, FileFormat),
              <<"<font class=\"mrcm\">", (?T(<<"Chatroom configuration modified">>))/binary,
                "</font><br/>">>;
          {roomconfig_change, Occupants} ->
              RoomConfig = roomconfig_to_binary(Room#room.config, Lang, FileFormat),
              put_room_config(F, RoomConfig, Lang, FileFormat),
              RoomOccupants = roomoccupants_to_binary(Occupants, FileFormat),
              put_room_occupants(F, RoomOccupants, Lang, FileFormat),
              <<"<font class=\"mrcm\">", (?T(<<"Chatroom configuration modified">>))/binary,
                "</font><br/>">>;
          join ->
              <<"<font class=\"mj\">", Nick/binary, " ", (?T(<<"joins the room">>))/binary,
                "</font><br/>">>;
          leave ->
              <<"<font class=\"mj\">", Nick/binary, " ", (?T(<<"leaves the room">>))/binary,
                "</font><br/>">>;
          {leave, Reason} ->
              <<"<font class=\"ml\">", Nick/binary, " ", (?T(<<"leaves the room">>))/binary, ": ",
                (htmlize(Reason, NoFollow, FileFormat))/binary, ": ~s</font><br/>">>;
          {kickban, "301", ""} ->
              <<"<font class=\"mb\">", Nick/binary, " ", (?T(<<"has been banned">>))/binary,
                "</font><br/>">>;
          {kickban, "301", Reason} ->
              <<"<font class=\"mb\">", Nick/binary, " ", (?T(<<"has been banned">>))/binary, ": ",
                (htmlize(Reason, FileFormat))/binary, "</font><br/>">>;
          {kickban, "307", ""} ->
              <<"<font class=\"mk\">", Nick/binary, " ", (?T(<<"has been kicked">>))/binary,
                "</font><br/>">>;
          {kickban, "307", Reason} ->
              <<"<font class=\"mk\">", Nick/binary, " ", (?T(<<"has been kicked">>))/binary, ": ",
                (htmlize(Reason, FileFormat))/binary, "</font><br/>">>;
          {kickban, "321", ""} ->
              <<"<font class=\"mk\">", Nick/binary, " ",
                (?T(<<"has been kicked because of an affiliation change">>))/binary,
                "</font><br/>">>;
          {kickban, "322", ""} ->
              <<"<font class=\"mk\">", Nick/binary, " ",
                (?T(<<"has been kicked because the room has been changed to"
                      " members-only">>))/binary, "</font><br/>">>;
          {kickban, "332", ""} ->
              <<"<font class=\"mk\">", Nick/binary, " ",
                (?T(<<"has been kicked because of a system shutdown">>))/binary, "</font><br/>">>;
          {nickchange, OldNick} ->
              <<"<font class=\"mnc\">", (htmlize(OldNick, FileFormat))/binary, " ",
                (?T(<<"is now known as">>))/binary, " ", Nick/binary, "</font><br/>">>;
          {subject, T} ->
              <<"<font class=\"msc\">", Nick/binary, (?T(<<" has set the subject to: ">>))/binary,
                (htmlize(T, NoFollow, FileFormat))/binary, "</font><br/>">>;
          {body, T} ->
              case {re:run(T, <<"^/me\s">>, [{capture, none}]), Nick} of
                  {_, ""} ->
                      <<"<font class=\"msm\">", (htmlize(T, NoFollow, FileFormat))/binary,
                        "</font><br/>">>;
                  {match, _} ->
                      %% Delete "/me " from the beginning.
                      <<_Pref:32, SubStr/binary>> = htmlize(T, FileFormat),
                      <<"<font class=\"mne\">", Nick/binary, " ", SubStr/binary, "</font><br/>">>;
                  {nomatch, _} ->
                      <<"<font class=\"mn\">", Nick2/binary, "</font> ",
                        (htmlize(T, NoFollow, FileFormat))/binary, "<br/>">>
              end;
          {room_existence, RoomNewExistence} ->
              <<"<font class=\"mrcm\">", (get_room_existence_string(RoomNewExistence, Lang))/binary,
                "</font><br/>">>
      end,
    {Hour, Minute, Second} = Time,
    STime = lists:flatten(
              io_lib:format("~2..0w:~2..0w:~2..0w", [Hour, Minute, Second])),
    {_, _, Microsecs} = Now,
    STimeUnique = list_to_binary(lists:flatten(io_lib:format("~s.~w", [STime, Microsecs]))),

    %% Write message
    fw(F, <<"<a id=\"", STimeUnique/binary, "\" name=\"", STimeUnique/binary,
        "\" href=\"#", STimeUnique/binary, "\" class=\"ts\">[",
        (list_to_binary(STime))/binary, "]</a> ", Text/binary>>, FileFormat),

    %% Close file
    file:close(F),
    ok.


%%----------------------------------------------------------------------
%% Utilities

-spec get_room_existence_string('created' | 'destroyed' | 'started' | 'stopped',
        binary()) -> binary().
get_room_existence_string(created, Lang) -> ?T(<<"Chatroom is created">>);
get_room_existence_string(destroyed, Lang) -> ?T(<<"Chatroom is destroyed">>);
get_room_existence_string(started, Lang) -> ?T(<<"Chatroom is started">>);
get_room_existence_string(stopped, Lang) -> ?T(<<"Chatroom is stopped">>).


-spec get_dateweek(calendar:date(), binary()) -> binary().
get_dateweek(Date, Lang) ->
    Weekday = case calendar:day_of_the_week(Date) of
                  1 -> ?T(<<"Monday">>);
                  2 -> ?T(<<"Tuesday">>);
                  3 -> ?T(<<"Wednesday">>);
                  4 -> ?T(<<"Thursday">>);
                  5 -> ?T(<<"Friday">>);
                  6 -> ?T(<<"Saturday">>);
                  7 -> ?T(<<"Sunday">>)
              end,
    {Y, M, D} = Date,
    Month = case M of
                1 -> ?T(<<"January">>);
                2 -> ?T(<<"February">>);
                3 -> ?T(<<"March">>);
                4 -> ?T(<<"April">>);
                5 -> ?T(<<"May">>);
                6 -> ?T(<<"June">>);
                7 -> ?T(<<"July">>);
                8 -> ?T(<<"August">>);
                9 -> ?T(<<"September">>);
                10 -> ?T(<<"October">>);
                11 -> ?T(<<"November">>);
                12 -> ?T(<<"December">>)
            end,
    case Lang of
        <<"en">> -> list_to_binary(
            lists:flatten(io_lib:format("~s, ~s ~w, ~w", [Weekday, Month, D, Y])));
        <<"es">> -> list_to_binary(
            lists:flatten(io_lib:format("~s ~w de ~s de ~w", [Weekday, D, Month, Y])));
        _    -> list_to_binary(
            lists:flatten(io_lib:format("~s, ~w ~s ~w", [Weekday, D, Month, Y])))
    end.


-spec make_dir_rec(binary()) -> 'ok' | {'error', atom()}.
make_dir_rec(Dir) ->
    case file:read_file_info(Dir) of
        {ok, _} ->
            ok;
        {error, enoent} ->
            DirS = filename:split(Dir),
            DirR = lists:sublist(DirS, length(DirS)-1),
            make_dir_rec(filename:join(DirR)),
            file:make_dir(Dir)
    end.


%% {ok, F1}=file:open("valid-xhtml10.png", [read]).
%% {ok, F1b}=file:read(F1, 1000000).
%% c("../../ejabberd/src/jlib.erl").
%% jlib:encode_base64(F1b).

image_base64(<<"powered-by-erlang.png">>) ->
    <<"iVBORw0KGgoAAAANSUhEUgAAAGUAAAAfCAYAAAD+xQNoAAADN0lEQVRo3u1a"
        "P0waURz+rjGRRQ+nUyRCYmJyDPTapDARaSIbTUjt1gVSh8ZW69aBAR0cWLSx"
        "CXWp59LR1jbdqKnGxoQuRZZrSYyHEVM6iZMbHewROA7u3fHvkr5vOn737vcu"
        "33ffu9/vcQz+gef5Cij6CkmSGABgFEH29r5SVvqIsTEOHo8HkiQxDBXEOjg9"
        "PcHc3BxuUSqsI8jR0REAUFGsCCoKFYWCBAN6AxyO0Z7cyMXFb6oGqSgAsIrJ"
        "ut9hMQlvdNbUhKWshLd3HtTF4jihShgVpRaBxKKmIGX5HL920/hz/BM2+zAm"
        "pn2YioQaxnECj0BiEYcrG0Tzzc8/rfudSm02jaVSm9Vr1MdG8rSKKXlJ7lHr"
        "fjouCut2IrC82BDPbe/gc+xlXez7KxEz63H4lmIN473Rh8Si1BKhRY6aEJI8"
        "pLmbjSPN0xOnBBILmg5RC6Lg28preKOzsNmHG8R1Bf0o7GdMucUslDy1pJLG"
        "2sndVVG0lq3c9vum4zmBR1kuwiYMN5ybmCYXxQg57ThFOTYznzpPO+IQi+IK"
        "+jXjg/YhuIJ+cIIHg+wQJoJ+2N3jYN3Olvk4ge/IU98spne+FfGtlslm16nn"
        "a8fduntfDscoVjGJqUgIjz686ViFUdjP4N39x9Xq638viZVtlq2tLXKncLf5"
        "ticuZSWU5XOUshJKxxKtfdtdvs4OyNb/68urKvlluYizgwwu5SLK8jllu1t9"
        "ihYOlzdwdpBBKSvh+vKKzHkCj1JW3y1m+hSj13WjqOiJKK0qpXKhSFxJAYBv"
        "KYaZ9TjWRu4SiWi2LyDtb6wghGmn5HfTml16ILGA/G5al2DW7URYTFYrOU7g"
        "icQ020sYqYDM9CbdgqFd4vzHL03JfvLjk6ZgADAVCSEsJvHsdL+utNYrm2uf"
        "ZDVZSkzPKaQkW8kthpyS297BvRdRzR6DdTurJbPy9Ov1K6xr3HBPQuIMowR3"
        "asegUyDuU9SuUG+dmIGyZ0b7FBN9St3WunyC5yMsrVv7uXzRP58s/qKn6C4q"
        "lQoVxVIvd4YBwzBUFKs6ZaD27U9hEdcAN98Sx2IxykafIYrizbfESoB+dd9/"
        "KF/d/wX3cJvREzl1vAAAAABJRU5ErkJggg==">>;
image_base64(<<"valid-xhtml10.png">>) ->
    <<"iVBORw0KGgoAAAANSUhEUgAAAFgAAAAfCAMAAAEjEcpEAAACiFBMVEUAAADe"
        "5+fOezmtra3ejEKlhELvvWO9WlrehELOe3vepaWclHvetVLGc3PerVKcCAj3"
        "vVqUjHOUe1JjlL0xOUpjjL2UAAC91ueMrc7vrVKlvdbW3u+EpcbO3ufO1ucY"
        "WpSMKQi9SiF7e3taWkoQEAiMczkQSoxaUkpzc3O1lEoICACEazEhGAgIAACE"
        "YzFra2utjELWcznGnEr/7+9jY2POazHOYzGta2NShLVrlL05OUqctdacCADG"
        "a2ucAADGpVqUtc61ORg5OTmlUikYGAiUezl7YzEYEAiUczkxMTG9nEqtIRDe"
        "3t4AMXu9lEoQCACMazEAKXspKSmljFrW1ta1jELOzs7n7/fGxsa9pVqEOSkp"
        "Y5xznL29tZxahLXOpVr/99ZrY1L/79ZjUiljSikAOYTvxmMAMYScezmchFqU"
        "czGtlFp7c2utjFqUlJStxt73///39/9Ce61CSkq9xsZznMbW5+9Cc62MjIxC"
        "Qkrv9/fv7/fOzsbnlErWjIz/3mtCORhza1IpIRBzWjH/1mtCMRhzY1L/zmvn"
        "vVpSQiHOpVJrUinntVr3zmOEc1L3xmNaWlq1nFo5QkrGWim1lFoISpRSUlK1"
        "zt4hWpwASoz///////8xa6WUaykAQoxKe61KSkp7nMbWtWPe5+9jWlL39/f3"
        "9/fWrWNCQkLera3nvWPv7+85MRjntWPetVp7c1IxKRCUlHtKORh7a1IxIRCU"
        "jHtaSiHWrVIpIQhzWinvvVpaQiH/1mPWpVKMe1L/zmP/xmNrUiGErc4YGBj/"
        "73PG1ucQWpT/53O9nFoQUpS1SiEQEBC9zt69vb05c6UISoxSUko5a6UICAhS"
        "SkohUpS1tbXetWMAQoSUgD+kAAAA2HRSTlP/////////iP9sSf//dP//////"
        "//////////////////////////////////////////8M////////////ef//"
        "////////////////////////////////////////////////////////////"
        "//////////////////////9d////////////////////////////////////"
        "AP//////////////CP//RP//////////////////////////////////////"
        "//////////////////////9xPp1gAAAFvUlEQVR42pVWi18URRwfy7vsYUba"
        "iqBRBFmICUQGVKcZckQeaRJQUCLeycMSfKGH0uo5NELpIvGQGzokvTTA85VH"
        "KTpbRoeJnPno/p1+M7t3txj20e/Nzu7Ofve7v/k9Zg4Vc+wRQMW0eyLx1ZSA"
        "NeBDxVmxZZSwEUYkGAewm1eIBOMRvhv1UA+q8KXIVuxGdCelFYwxAnxOrxgb"
        "Y8Ti1t4VA0QHYz4x3FnVC8OVLXv9fkKGSWDoW/4lG6VbdtBblesOs+MjmEmz"
        "JKNIJWFEfEQTCWNPFKvcKEymjLO1b8bwYQd1hCiiDCl5KsrDCIlhj4fSuvcp"
        "fSpgJmyv6dzeZv+nMPx3dhbt94II07/JZliEtm1N2RIYPkTYshwYm245a/zk"
        "WjJwcyFh6ZIcYxxmqiaDSYxhOhFUsqngi3Fzcj3ljdYDNE9uzA1YD/5MhnzW"
        "1KRqF7mYG8jFYXLcfLpjOe2LA0fuGqQrQHl10sdK0sFcFSOSlzF0BgXQH9h3"
        "QZDBI0ccNEhftjXuippBDD2/eMRiETmwwNEYHyqhdDyo22w+3QHuNbdve5a7"
        "eOkHmDVJ0ixNmfbz1h0qo/Q6GuSB2wQJQbpOjOQAl7woWSRJ0m2ewhvAOUiY"
        "YtZtaZL0CZZmtmVOQttLfr/dbveLZodrfrL7W75wG/JjqkQxoNTtNsTKELQp"
        "QL6/D5loaSmyTT8TUhsmi8iFA0hZiyltf7OiNKdarRm5w2So2lTNdPLuIzR+"
        "AiLj8VTRJaj0LmX4VhJ27f/VJV/yycilWPOrk8NkXi7Qqmj5bHqVZlJKZIRk"
        "1wFzKrt0WUbnXMPJ1fk4TJ5oWBA61p1V76DeIs0MX+s3GxRlA1vtw83KhgNp"
        "hc1nyErLO5zcvbOsrq+scbZnpzc6QVFPenLwGxmC+BOfYI+DN55QYddh4Q/N"
        "E/yGYYj4TOGNngQavAZnzzTovEA+kcMJ+247uYexNA+4Fsvjmuv662jsWxPZ"
        "x2xg890bYMYnTgya7bjmCiEY0qgJ0vMF3c+NoFdPyzxz6V3Uxs3AOWCDchRv"
        "OsQtBrbFsrT2fhHEc7ByGzu/dA4IO0A3HdfeP9yMqAwP6NPEb6cbwn0PWVU1"
        "7/FDBQh/CPIrbfcg027IZrsAT/Bf3FNWyn9RSR4cvvwn3e4HFmYPDl/thYcR"
        "Vi8qPEoXVUWBl6FTBFTtnqmKKg5wnlF4wZ1yeLv7TiwXKektE+iDBNicWEyL"
        "pnFhfDkpJc3q2khSPyQBbE0dMJnOoDzTwGsI7cdyMkL5gWqUjCF6Txst/twx"
        "Cv1WzzHoy21ZDQ1xnuDzdPDWR4knr14v0tYn3IxaMFFdiMOlEOJHw1jOQ4sW"
        "t5rQopRkXZhMEi7pmeDCVWBlfUKwhMZ7rsF6elKsvbwiKxgxIdewa3ErsaYo"
        "mCVZFYJb0GUu3JqGUNoplBxYiYby8vLBFWef+Cri4/I1sbQ/1OtYTrNtdXS+"
        "rSe7kQ52eSObL99/iErCWUjCy5W4JLygmCouGfG9x9fmx17XhBuDCaOerbt5"
        "38erta7TFktLvdHghZcCbcPQO33zIJG9kxF5hoVXnzTzRz0r5js8oTj6uyPk"
        "GRf346HOLcasgFexueNUWFPtuFKzjoSFYYedhwVlhsRVYWWJpltv1XPQT1Rl"
        "0bjZIBlb1XujVDzY/Kj4k6Ku3+Z0jo1owjVzDpFTXe1juvBSWNFmNWGZy8Lv"
        "zUl5PN4JCwyNDzbQ0aAj4Zrjz0FatGJJYhvq4j7mGSpvytGFlZtHf2C4o/28"
        "Zu8z7wo7eYPfXysnF0i9NnPh1t1zR7VBb9GqaOXhtTmHQdgMFXE+Z608cnpO"
        "DdZdjL+TuDY44Q38kJXHhccWLoOd9uv1AwwvO+48uu+faCSJPJ1bmy6Thyvp"
        "ivBmYWgjxPDPAp7JTemY/yGKFEiRt/jG/2P79s8KCwoLCgoLC/khUBA5F0Sf"
        "QZ+RYfpNE/4Xosmq7jsZAJsAAAAASUVORK5CYII=">>;
image_base64(<<"vcss.png">>) ->
    <<"iVBORw0KGgoAAAANSUhEUgAAAFgAAAAfCAMAAABUFvrSAAABKVBMVEUAAAAj"
        "Ix8MR51ZVUqAdlmdnZ3ejEWLDAuNjY1kiMG0n2d9fX19Ghfrp1FtbW3y39+3"
        "Ph6lIRNdXV2qJBFcVUhcVUhPT0/dsmpUfLr57+/u7u4/PDWZAACZAADOp1Gd"
        "GxG+SyTgvnNdSySzk16+mkuxw+BOS0BOS0DOzs7MzMy4T09RRDwsJBG+vr73"
        "wV6fkG6eCQRFcLSurq6/X1+ht9nXfz5sepHuwV59ZTHetFjQ2+wMCQQ2ZK5t"
        "WCsmWajsz8+Sq9NMPh4hVaY8MRj///////////////////////9MTEyOp9Lu"
        "8vhXU1A8PDyjOSTBz+YLRJ2rLy8sLCwXTaKujEUcHByDn82dfz7/zGafDw+f"
        "Dw+zRSlzlMcMDAyNcji1tbXf5vIcFgvATJOjAAAAY3RSTlP/8///////////"
        "//////8A//////P/////ov//8//////////////z///T//////////+i////"
        "//////////8w/////6IA/xAgMP//////////8/////////8w0/////////+z"
        "ehebAAACkUlEQVR42u2VfVPTQBDG19VqC6LY+lKrRIxFQaFSBPuSvhBPF8SI"
        "UZK2J5Yav/+HcO8uZdLqTCsU/nKnyWwvk1/unnt2D9ZmH+8/cMAaTRFy+ng6"
        "9/yiwC/+gy8R3McGv5zHvGJEGAdR4eBgi1IbZwevIEZE24pFtBtzG1Q4AoD5"
        "zvw5pEDcJvIQV/TE3/l+H9GnNJwcdABS5wAbFQLMqI98/UReoAaOTlaJsp0z"
        "aHx7LwZvY0BUR2xpWTzqam0gzY8KGzG4MhBCNGucha4QbpETy+Yk/BP85nt7"
        "34AjpQLTsE4ZFpf/dnkUCglXVNYB+OfUZJHvAqAoa45OeuPgm4+Xjtv7xm4N"
        "7PMV4C61+Mrz3H2WImm3ATiWrAiwZRWcUA5Ej4dgIEMxDv6yxHHcNuAutnjv"
        "2HZ1NeuycoVPh0mwC834zZC9Ao5dkZZKwLVGwT+WdLw0YOZ1saEkUDoT+QGW"
        "KZ0E2xpcrPakVW2KXwyUtYEtlEAj3GXD/fYwrryAdeiyGqidQSw1eqtJcA8c"
        "Zq4zXqhPuCBYE1fKJjh/5X6MwRm9c2xf7WVdLf5oSdt64esVIwVAKC1HJ2ol"
        "i8vj3L0YzC4zjkMagt+arDAs6bApbL1RVlWIqrJbreqKZmh4y6VR7rAJeUYD"
        "VRj9VqRXkErpJ9lbEwtE83KlIfeG4p52t7zWIMO1XcaGz54uUyet+hBM7BXX"
        "DS8Xc5+8Gmmbu1xwSoGIokA3oTptQecQ4Iimm/Ew7jwbPfMi3TM91T9XVIGo"
        "+W9xC8oWpugVCXLuwXijjxJ3r/6PjX7nlFua8QmyM+TO/Gja2TTc2Z95C5ua"
        "ewGH6cJi6bJO6Z+TY276eH3tbgy+/3ly3Js+rj66osG/AV5htgaQ9SeRAAAA"
        "AElFTkSuQmCC">>;
image_base64(<<"powered-by-ejabberd.png">>) ->
    <<"iVBORw0KGgoAAAANSUhEUgAAAGUAAAAfCAMAAADJG/NaAAAAw1BMVEUAAAAj"
        "BgYtBAM5AwFCAAAYGAJNAABcAABIDQ5qAAAoJRV7AACFAAAoKSdJHByLAAAw"
        "Lwk1NQA1MzFJKyo4NxtDQQBEQT5KSCxSTgBSUBlgQ0JYSEpZWQJPUU5hYABb"
        "W0ZiYClcW1poaCVwbQRpaDhzYWNsakhuZ2VrbFZ8dwCEgAB3dnd4d2+OjACD"
        "hYKcmACJi4iQkpWspgCYmJm5swCmqazEwACwsbS4ub3X0QLExsPLyszW1Nnc"
        "3ODm5ugMBwAWAwPHm1IFAAAAAXRSTlMAQObYZgAAAAFiS0dEAIgFHUgAAAAJ"
        "cEhZcwAACxMAAAsTAQCanBgAAAAHdElNRQfVCRQOBA7VBkCMAAACcElEQVRI"
        "x72WjXKiMBSFQalIFbNiy1pdrJZaRVYR5deGwPs/VRNBSBB2OjvQO0oYjPfj"
        "5J6bCcdx8i2UldxKcDhk1HbIPwFBF/kHKJfjPSVAyIRHF9rRZ4sUX3EDdWOv"
        "1+u2tESaavpnYTbv9zvd0WwDy3/QcGQXlH5uTxB1l07MJlRpsUei0JF6Qi+O"
        "HyGK7ijXxPklHe/umIllim3iUBMJDIEULxxPP0TVWhhKJoN9fUpdmQLteV8a"
        "DgEAg9gIcTjL4F4L+r4WVKEF+rbJdwYYAoQHY+oQjnGootyKwxapoi73WkyF"
        "FySQBv988naEEp4+YMMec5VUCQDJTscEy7Kc0HsLmqNE7rovDjMpIHHGYeid"
        "Xn4TQcaxMYqP3RV3C8oCl2WvrlSPaNpGZadRnmPGCk8ylM2okAJ4i9TEe1Ke"
        "rsXxSl6jUt5uayiIodirtcKLOaWblj50wiyMv1F9lm9TUDArGAD0FmEpvCUs"
        "VoZy6dW81Fg0aDaHogQa36ekAPG5DDGsbdZrGsrzZUnzvBo1I2tLmuL69kSi"
        "tAweyHKN9b3leDfQMnu3nIIKWfmXnqGVKedJT6QpICbJvf2f8aOsvn68v+k7"
        "/cwUQdPoxaMoRTnKFHNlKsKQphCTOa84u64vpi8bH31CqsbF6lSONRTkTyQG"
        "Arq49/fEvjBwz4eDS2/JpaXRNOoXRD/VmOrDVTJJRIZCTLav3VrqbPvP3vdd"
        "uGEhQJzilncbpSA4F3vsihErO+dayv/sY5/yRE0GDEXCu2VoNiMlo5i+P2Kl"
        "gMEvTNk2eYa5XEyh12Ex17Z8vzQUR3KEPbYd6XG87eC4Ly75RneS5ZYHAAAA"
        "AElFTkSuQmCC">>.


-spec create_image_files(<<_:8, _:_*8>>) -> 'ok'.
create_image_files(ImagesDir) ->
    Filenames = [<<"powered-by-ejabberd.png">>,
                 <<"powered-by-erlang.png">>,
                 <<"valid-xhtml10.png">>,
                 <<"vcss.png">>
                ],
    lists:foreach(
      fun(Filename) ->
              FilenameFull = filename:join([ImagesDir, Filename]),
              {ok, F} = file:open(FilenameFull, [write]),
              Image = jlib:decode_base64(image_base64(Filename)),
              io:format(F, "~s", [Image]),
              file:close(F)
      end,
      Filenames),
    ok.


-spec fw(file:io_device(), binary()) -> 'ok'.
fw(F, S) -> fw(F, S, html).


-spec fw(file:io_device(), binary(), file_format()) -> 'ok'.
fw(F, S, FileFormat) ->
    S1 = <<S/binary, "~n">>,
    S2 = case FileFormat of
             html ->
                    S1;
             plaintext ->
            re:replace(S1, <<"<[^>]*>">>, <<"">>, [global, {return, binary}])
         end,
    io:format(F, S2, []).


-spec put_header(file:io_device(), Room :: room(), Date :: binary(),
        CSSFile :: false | binary(), Lang :: ejabberd:lang(), HourOffset :: integer(),
        DatePrev :: binary(), DateNext :: binary(), TopLink :: tuple(),
        file_format(), OccupantsMap :: #{binary() => [jid_nick_role()]}) -> 'ok'.
put_header(_, _, _, _, _, _, _, _, _, plaintext, _) ->
    ok;
put_header(F, Room, Date, CSSFile, Lang, HourOffset, DatePrev, DateNext, TopLink, FileFormat,
           OccupantsMap) ->
    fw(F, <<"<!DOCTYPE html PUBLIC \"-//W3C//DTD XHTML 1.0 Transitional//EN\""
            " \"http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd\">">>),
    fw(F, <<"<html xmlns=\"http://www.w3.org/1999/xhtml\" xml:lang=\"",
            Lang/binary, "\" lang=\"", Lang/binary, "\">">>),
    fw(F, <<"<head>">>),
    fw(F, <<"<meta http-equiv=\"Content-Type\" content=\"text/html; charset=utf-8\" />">>),
    fw(F, <<"<title>", (htmlize(Room#room.title))/binary, " - ", Date/binary, "</title>">>),
    put_header_css(F, CSSFile),
    put_header_script(F),
    fw(F, <<"</head>">>),
    fw(F, <<"<body>">>),
    {TopUrl, TopText} = TopLink,
    fw(F, <<"<div style=\"text-align: right;\"><a style=\"color: #AAAAAA; font-family: monospace;"
            " text-decoration: none; font-weight: bold;\" href=\"", TopUrl/binary, "\">",
            TopText/binary, "</a></div>">>),
    fw(F, <<"<div class=\"roomtitle\">", (htmlize(Room#room.title))/binary, "</div>">>),
    fw(F, <<"<a class=\"roomjid\" href=\"xmpp:", (Room#room.jid)/binary, "?join\">",
            (Room#room.jid)/binary, "</a>">>),
    fw(F, <<"<div class=\"logdate\">", Date/binary, "<span class=\"w3c\"><a class=\"nav\" href=\"",
            DatePrev/binary, "\">&lt;</a> <a class=\"nav\" href=\".\/\">^</a>"
            " <a class=\"nav\" href=\"", DateNext/binary, "\">&gt;</a></span></div>">>),
    case {htmlize(Room#room.subject_author), htmlize(Room#room.subject)} of
        {<<"">>, <<"">>} ->
            ok;
        {SuA, Su} -> fw(F, <<"<div class=\"roomsubject\">", SuA/binary,
                             (?T(<<" has set the subject to: ">>))/binary, Su/binary, "</div>">>)
    end,
    RoomConfig = roomconfig_to_binary(Room#room.config, Lang, FileFormat),
    put_room_config(F, RoomConfig, Lang, FileFormat),
    Occupants = maps:get(Room#room.jid, OccupantsMap, []),
    RoomOccupants = roomoccupants_to_binary(Occupants, FileFormat),
    put_room_occupants(F, RoomOccupants, Lang, FileFormat),
    TimeOffsetBin = case HourOffset<0 of
                          true -> list_to_binary(lists:flatten(io_lib:format("~p", [HourOffset])));
                          false -> list_to_binary(lists:flatten(io_lib:format("+~p", [HourOffset])))
        end,
    fw(F, <<"<br/><a class=\"ts\">GMT", TimeOffsetBin/binary, "</a><br/>">>).


-spec put_header_css(file:io_device(), 'false' | binary()) -> 'ok'.
put_header_css(F, false) ->
    fw(F, <<"<style type=\"text/css\">">>),
    fw(F, <<"<!--">>),
    fw(F, <<".ts {color: #AAAAAA; text-decoration: none;}">>),
    fw(F, <<".mrcm {color: #009900; font-style: italic; font-weight: bold;}">>),
    fw(F, <<".msc {color: #009900; font-style: italic; font-weight: bold;}">>),
    fw(F, <<".msm {color: #000099; font-style: italic; font-weight: bold;}">>),
    fw(F, <<".mj {color: #009900; font-style: italic;}">>),
    fw(F, <<".ml {color: #009900; font-style: italic;}">>),
    fw(F, <<".mk {color: #009900; font-style: italic;}">>),
    fw(F, <<".mb {color: #009900; font-style: italic;}">>),
    fw(F, <<".mnc {color: #009900; font-style: italic;}">>),
    fw(F, <<".mn {color: #0000AA;}">>),
    fw(F, <<".mne {color: #AA0099;}">>),
    fw(F, <<"a.nav {color: #AAAAAA; font-family: monospace; letter-spacing: 3px;"
            " text-decoration: none;}">>),
    fw(F, <<"div.roomtitle {border-bottom: #224466 solid 3pt; margin-left: 20pt;}">>),
    fw(F, <<"div.roomtitle {color: #336699; font-size: 24px; font-weight: bold;"
            " font-family: sans-serif; letter-spacing: 3px; text-decoration: none;}">>),
    fw(F, <<"a.roomjid {color: #336699; font-size: 24px; font-weight: bold;"
            " font-family: sans-serif; letter-spacing: 3px; margin-left: 20pt;"
            " text-decoration: none;}">>),
    fw(F, <<"div.logdate {color: #663399; font-size: 20px; font-weight: bold;"
            " font-family: sans-serif; letter-spacing: 2px; border-bottom: #224466 solid 1pt;"
            " margin-left:80pt; margin-top:20px;}">>),
    fw(F, <<"div.roomsubject {color: #336699; font-size: 18px; font-family: sans-serif;"
            " margin-left: 80pt; margin-bottom: 10px;}">>),
    fw(F, <<"div.rc {color: #336699; font-size: 12px; font-family: sans-serif; margin-left: 50%;"
            " text-align: right; background: #f3f6f9; border-bottom: 1px solid #336699;"
            " border-right: 4px solid #336699;}">>),
    fw(F, <<"div.rct {font-weight: bold; background: #e3e6e9; padding-right: 10px;}">>),
    fw(F, <<"div.rcos {padding-right: 10px;}">>),
    fw(F, <<"div.rcoe {color: green;}">>),
    fw(F, <<"div.rcod {color: red;}">>),
    fw(F, <<"div.rcoe:after {content: \": v\";}">>),
    fw(F, <<"div.rcod:after {content: \": x\";}">>),
    fw(F, <<"div.rcot:after {}">>),
    fw(F, <<".legend {width: 100%; margin-top: 30px; border-top: #224466 solid 1pt;"
            " padding: 10px 0px 10px 0px; text-align: left;"
            " font-family: monospace; letter-spacing: 2px;}">>),
    fw(F, <<".w3c {position: absolute; right: 10px; width: 60%; text-align: right;"
            " font-family: monospace; letter-spacing: 1px;}">>),
    fw(F, <<"//-->">>),
    fw(F, <<"</style>">>);
put_header_css(F, CSSFile) ->
    fw(F, <<"<link rel=\"stylesheet\" type=\"text/css\" href=\"",
            CSSFile/binary, "\" media=\"all\">">>).

put_header_script(F) ->
    fw(F, <<"<script type=\"text/javascript\">">>),
    fw(F, <<"function sh(e) // Show/Hide an element">>),
    fw(F, <<"{if(document.getElementById(e).style.display=='none')">>),
    fw(F, <<"{document.getElementById(e).style.display='block';}">>),
    fw(F, <<"else {document.getElementById(e).style.display='none';}}">>),
    fw(F, <<"</script>">>).


-spec put_room_config(file:io_device(), any(), ejabberd:lang(),
                      file_format()) -> 'ok'.
put_room_config(_F, _RoomConfig, _Lang, plaintext) ->
    ok;
put_room_config(F, RoomConfig, Lang, _FileFormat) ->
    {Now1, Now2, Now3} = erlang:timestamp(),
    NowBin = list_to_binary(lists:flatten(io_lib:format("~p~p~p", [Now1, Now2, Now3]))),
    fw(F, <<"<div class=\"rc\">">>),
    fw(F, <<"<div class=\"rct\" onclick=\"sh('a", NowBin/binary, "');return false;\">",
            (?T(<<"Room Configuration">>))/binary, "</div>">>),
    fw(F, <<"<div class=\"rcos\" id=\"a", NowBin/binary, "\" style=\"display: none;\" ><br/>",
            RoomConfig/binary, "</div>">>),
    fw(F, <<"</div>">>).


-spec put_room_occupants(file:io_device(), any(), ejabberd:lang(),
                         file_format()) -> 'ok'.
put_room_occupants(_F, _RoomOccupants, _Lang, plaintext) ->
    ok;
put_room_occupants(F, RoomOccupants, Lang, _FileFormat) ->
    {Now1, Now2, Now3} = erlang:timestamp(),
    NowBin = list_to_binary(lists:flatten(io_lib:format("~p~p~p", [Now1, Now2, Now3]))),
    fw(F, <<"<div class=\"rc\">">>),
    fw(F, <<"<div class=\"rct\" onclick=\"sh('o", NowBin/binary, "');return false;\">",
            (?T(<<"Room Occupants">>))/binary, "</div>">>),
    fw(F, <<"<div class=\"rcos\" id=\"o", NowBin/binary, "\" style=\"display: none;\" ><br/>",
            RoomOccupants/binary, "</div>">>),
    fw(F, <<"</div>">>).


%% @doc htmlize
%% The default behaviour is to ignore the nofollow spam prevention on links
%% (NoFollow=false)
htmlize(S1) ->
    htmlize(S1, html).

htmlize(S1, FileFormat) ->
    htmlize(S1, false, FileFormat).


%% @doc The NoFollow parameter tell if the spam prevention should be applied to
%% the link found. true means 'apply nofollow on links'.
htmlize(S1, _NoFollow, plaintext) ->
    ReplacementRules =
        [{<<"<">>, <<"[">>},
         {<<">">>, <<"]">>}],
    lists:foldl(fun({RegExp, Replace}, Acc) ->
                        re:replace(Acc, RegExp, Replace, [global, {return, binary}])
                end, S1, ReplacementRules);
htmlize(S1, NoFollow, _FileFormat) ->
    S2List = binary:split(S1, <<"\n">>, [global]),
    lists:foldl(
      fun(Si, Res) ->
              Si2 = htmlize2(Si, NoFollow),
              case Res of
                      <<"">> -> Si2;
                      _ -> <<Res/binary, "<br/>", Si2/binary>>
              end
      end,
      <<"">>,
      S2List).

htmlize2(S1, NoFollow) ->
    ReplacementRules =
        [{<<"\\&">>, <<"\\&amp;">>},
         {<<"<">>, <<"\\&lt;">>},
         {<<">">>, <<"\\&gt;">>},
         {<<"((http|https|ftp)://|(mailto|xmpp):)[^] )\'\"}]+">>, link_regexp(NoFollow)},
         {<<"  ">>, <<"\\&nbsp;\\&nbsp;">>},
         {<<"\\t">>, <<"\\&nbsp;\\&nbsp;\\&nbsp;\\&nbsp;">>},
         {<<226, 128, 174>>, <<"[RLO]">>}],
    lists:foldl(fun({RegExp, Replace}, Acc) ->
                        re:replace(Acc, RegExp, Replace, [global, {return, binary}])
                end, S1, ReplacementRules).

%% @doc Regexp link. Add the nofollow rel attribute when required
link_regexp(false) ->
    <<"<a href=\"&\">&</a>">>;
link_regexp(true) ->
    <<"<a href=\"&\" rel=\"nofollow\">&</a>">>.


get_room_info(RoomJID, Opts) ->
    Title =
        case lists:keysearch(title, 1, Opts) of
            {value, {_, T}} -> T;
            false -> <<"">>
        end,
    Subject =
        case lists:keysearch(subject, 1, Opts) of
            {value, {_, S}} -> S;
            false -> <<"">>
        end,
    SubjectAuthor =
        case lists:keysearch(subject_author, 1, Opts) of
            {value, {_, SA}} -> SA;
            false -> <<"">>
        end,
    #room{jid = RoomJID,
          title = Title,
          subject = Subject,
          subject_author = SubjectAuthor,
          config = Opts
         }.


-spec roomconfig_to_binary(list(), ejabberd:lang(), file_format()) -> binary().
roomconfig_to_binary(Options, Lang, FileFormat) ->
    %% Get title, if available
    Title = case lists:keysearch(title, 1, Options) of
                {value, Tuple} -> [Tuple];
                false -> []
            end,

    %% Remove title from list
    Os1 = lists:keydelete(title, 1, Options),

    %% Order list
    Os2 = lists:sort(Os1),

    %% Add title to ordered list
    Options2 = Title ++ Os2,

    lists:foldl(
      fun({Opt, Val}, R) ->
              case get_roomconfig_text(Opt) of
                  undefined ->
                      R;
                  OptT ->
                      OptText = ?T(OptT),
                      R2 = render_config_value(Opt, Val, OptText, FileFormat),
                      <<R/binary, R2/binary>>
              end
      end,
      <<"">>,
      Options2).

-spec render_config_value(Opt :: atom(),
                          Val :: boolean() | string() | binary(),
                          OptText :: binary(),
                          FileFormat :: file_format()) -> binary().
render_config_value(_Opt, false, OptText, _FileFormat) ->
    <<"<div class=\"rcod\">", OptText/binary, "</div>">>;
render_config_value(_Opt, true, OptText, _FileFormat) ->
    <<"<div class=\"rcoe\">", OptText/binary, "</div>">>;
render_config_value(_Opt, "", OptText, _FileFormat) ->
    <<"<div class=\"rcod\">", OptText/binary, "</div>">>;
render_config_value(password, _T, OptText, _FileFormat) ->
    <<"<div class=\"rcoe\">", OptText/binary, "</div>">>;
render_config_value(max_users, T, OptText, FileFormat) ->
    HtmlizedBin = htmlize(list_to_binary(lists:flatten(io_lib:format("~p", [T]))), FileFormat),
    <<"<div class=\"rcot\">", OptText/binary, ": \"", HtmlizedBin/binary, "\"</div>">>;
render_config_value(title, T, OptText, FileFormat) ->
    <<"<div class=\"rcot\">", OptText/binary, ": \"", (htmlize(T, FileFormat))/binary, "\"</div>">>;
render_config_value(description, T, OptText, FileFormat) ->
    <<"<div class=\"rcot\">", OptText/binary, ": \"", (htmlize(T, FileFormat))/binary, "\"</div>">>;
render_config_value(_, T, _OptText, _FileFormat) -> <<"\"", T/binary, "\"">>.

-spec get_roomconfig_text(atom()) -> 'undefined' | binary().
get_roomconfig_text(title) -> <<"Room title">>;
get_roomconfig_text(persistent) -> <<"Make room persistent">>;
get_roomconfig_text(public) -> <<"Make room public searchable">>;
get_roomconfig_text(public_list) -> <<"Make participants list public">>;
get_roomconfig_text(password_protected) -> <<"Make room password protected">>;
get_roomconfig_text(password) -> <<"Password">>;
get_roomconfig_text(anonymous) -> <<"This room is not anonymous">>;
get_roomconfig_text(members_only) -> <<"Make room members-only">>;
get_roomconfig_text(moderated) -> <<"Make room moderated">>;
get_roomconfig_text(members_by_default) -> <<"Default users as participants">>;
get_roomconfig_text(allow_change_subj) -> <<"Allow users to change the subject">>;
get_roomconfig_text(allow_private_messages) -> <<"Allow users to send private messages">>;
get_roomconfig_text(allow_query_users) -> <<"Allow users to query other users">>;
get_roomconfig_text(allow_user_invites) -> <<"Allow users to send invites">>;
get_roomconfig_text(logging) ->  <<"Enable logging">>;
get_roomconfig_text(allow_visitor_nickchange) ->  <<"Allow visitors to change nickname">>;
get_roomconfig_text(allow_visitor_status) ->
    <<"Allow visitors to send status text in presence updates">>;
get_roomconfig_text(description) ->  <<"Room description">>;
get_roomconfig_text(max_users) -> <<"Maximum Number of Occupants">>;
get_roomconfig_text(_) -> undefined.


%% @doc Users = [{JID, Nick, Role}]
-spec roomoccupants_to_binary([jid_nick_role()], file_format()) -> binary().
roomoccupants_to_binary(Users, _FileFormat) ->
    Res = [role_users_to_string(RoleS, Users1)
           || {RoleS, Users1} <- group_by_role(Users), Users1 /= []],
    list_to_binary(lists:flatten(["<div class=\"rcot\">", Res, "</div>"])).


%% @doc Users = [{JID, Nick, Role}]
-spec group_by_role([{jid_nick_role()}]) -> [{string(), string()}].
group_by_role(Users) ->
    {Ms, Ps, Vs, Ns} =
        lists:foldl(
          fun({JID, Nick, moderator}, {Mod, Par, Vis, Non}) ->
                  {[{JID, Nick}] ++ Mod, Par, Vis, Non};
             ({JID, Nick, participant}, {Mod, Par, Vis, Non}) ->
                  {Mod, [{JID, Nick}] ++ Par, Vis, Non};
             ({JID, Nick, visitor}, {Mod, Par, Vis, Non}) ->
                  {Mod, Par, [{JID, Nick}] ++ Vis, Non};
             ({JID, Nick, none}, {Mod, Par, Vis, Non}) ->
                  {Mod, Par, Vis, [{JID, Nick}] ++ Non}
          end,
          {[], [], [], []},
          Users),
    case Ms of [] -> []; _ -> [{"Moderator", Ms}] end
        ++ case Ps of [] -> []; _ -> [{"Participant", Ps}] end
        ++ case Vs of [] -> []; _ -> [{"Visitor", Vs}] end
        ++ case Ns of [] -> []; _ -> [{"None", Ns}] end.


%% Users = [{JID, Nick}]
-spec role_users_to_string(string(), [jid_nick()]) -> [string(), ...].
role_users_to_string(RoleS, Users) ->
    SortedUsers = lists:keysort(2, Users),
    UsersString = [[Nick, "<br/>"] || {_JID, Nick} <- SortedUsers],
    [RoleS, ": ", UsersString].


get_proc_name(Host) -> gen_mod:get_module_proc(Host, ?PROCNAME).


-spec calc_hour_offset(calendar:datetime()) -> integer().
calc_hour_offset(TimeHere) ->
    TimeZero = calendar:now_to_universal_time(erlang:timestamp()),
    TimeHereHour = calendar:datetime_to_gregorian_seconds(TimeHere) div 3600,
    TimeZeroHour = calendar:datetime_to_gregorian_seconds(TimeZero) div 3600,
    TimeHereHour - TimeZeroHour.

esl / MongooseIM / 4698755488

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous