Packages

diint_utilites_common_app

1.4.7
1.4.23 1.4.22 1.4.21 1.4.20 1.4.19 1.4.18 1.4.17 1.4.16 1.4.15 1.4.14 1.4.12 1.4.11 1.4.10 1.4.9 1.4.8 1.4.7 1.4.6 1.4.5 1.4.4 1.4.3 1.4.2 1.4.1 1.4.0 1.3.9 1.3.8 1.3.7 1.3.6 1.3.5 1.3.4 1.3.3 1.3.2 1.3.1 1.3.0 1.2.101 1.2.11 1.2.10 1.2.9 1.2.8 1.2.7 1.2.6 1.2.5 1.2.4 1.2.3 1.2.2 1.2.1 1.2.0 1.1.7 1.1.6 1.1.5 1.1.4 1.1.3 1.1.2 1.1.1 1.1.0 1.0.13 1.0.12 1.0.11 1.0.10 1.0.9 1.0.8 1.0.7 1.0.6 1.0.5 1.0.4 1.0.3 1.0.2 1.0.1

библиотеки для работы с ребитом и протоколы

HexDocs

Current section

Files

Jump to
Readme
67 Versions
4 Dependencies
Dependants
Files
Activity
diint_utilites_common_app src log file_logger_handler.erl
Raw

src/log/file_logger_handler.erl 

-module(file_logger_handler).

-include("include/types_rabbit.hrl").

-include_lib("kernel/include/logger.hrl").



-export([adding_handler/1, removing_handler/1, log/2]).

-export([init/1, handle_call/3, handle_cast/2, terminate/2]).







adding_handler(Config) ->

    MyConfig = maps:get(config,Config),

    {ok, Pid} = gen_server:start(?MODULE, MyConfig, []),

    {ok, Config#{config => MyConfig#{pid => Pid}}}.



init(#{logFolder := LogFolder}) ->

{ok,#{fileD => [], logFolder => LogFolder}}.



removing_handler(#{config := #{pid := Pid}}) ->

    gen_server:stop(Pid).



terminate(_Reason, #{fileD := FileDescriptors}) ->

    _ = closeFD(FileDescriptors),

    ok.



log(LogEvent,#{config := #{pid := Pid}} = Config) ->

    gen_server:cast(Pid, {log, LogEvent, Config}).



handle_cast({log, LogEvent = #{meta := #{mfa := {MODULE, _FUNCTION_NAME, _FUNCTION_ARITY}}}, Config}, #{logFolder := LogFolder, fileD := FileDescriptors} = State) ->

    FilePath = string:join([LogFolder,MODULE],"/"),

    case find_fd(FileDescriptors,FilePath) of

        none -> NewFD = open_new_fd(FilePath),

        NewFDL = lists:append(FileDescriptors,[{FilePath,NewFD}]),

        do_log(NewFD,LogEvent,Config),

        {noreply, State#{fileD => NewFDL}};

        Fd -> 

            do_log(Fd,LogEvent,Config),

            {noreply, State}

    end.



handle_call(_, _, State) ->

    {reply, {error, bad_request}, State}.



find_fd([], _Name) -> none;

find_fd([{Name,Fd}|_FileDescriptors], Name) ->

    Fd;

find_fd([_|FileDescriptors], Name) ->

find_fd(FileDescriptors,Name).





open_new_fd(File) ->

    {ok, Fd} = file:open(File, [append, {encoding, utf8}]),

    Fd.





do_log(Fd, LogEvent, #{formatter := {FModule, FConfig}}) ->

    String = FModule:format(LogEvent, FConfig),

    io:put_chars(Fd, String).



closeFD([]) -> ok;

closeFD([{_Name,Fd}|FileDescriptors]) ->

    file:close(Fd),

    closeFD(FileDescriptors).