forked from webmachine/webmachine
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathwebmachine_error_log_handler.erl
More file actions
112 lines (95 loc) · 3.62 KB
/
webmachine_error_log_handler.erl
File metadata and controls
112 lines (95 loc) · 3.62 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
%% Copyright (c) 2011-2013 Basho Technologies, Inc. All Rights Reserved.
%%
%% This file is provided to you under the Apache License,
%% Version 2.0 (the "License"); you may not use this file
%% except in compliance with the License. You may obtain
%% a copy of the License at
%%
%% http://www.apache.org/licenses/LICENSE-2.0
%%
%% Unless required by applicable law or agreed to in writing,
%% software distributed under the License is distributed on an
%% "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
%% KIND, either express or implied. See the License for the
%% specific language governing permissions and limitations
%% under the License.
%% @doc Default log handler for webmachine
-module(webmachine_error_log_handler).
-behaviour(gen_event).
%% gen_event callbacks
-export([init/1,
handle_call/2,
handle_event/2,
handle_info/2,
terminate/2,
code_change/3]).
-include("webmachine_logger.hrl").
-ifdef(TEST).
-include_lib("eunit/include/eunit.hrl").
-endif.
-record(state, {hourstamp, filename, handle}).
-define(FILENAME, "wm_error.log").
%% ===================================================================
%% gen_event callbacks
%% ===================================================================
%% @private
init([BaseDir]) ->
webmachine_log:defer_refresh(?MODULE),
FileName = filename:join(BaseDir, ?FILENAME),
{Handle, DateHour} = webmachine_log:log_open(FileName),
{ok, #state{filename=FileName, handle=Handle, hourstamp=DateHour}}.
%% @private
handle_call({_Label, MRef, get_modules}, State) ->
{ok, {MRef, [?MODULE]}, State};
handle_call({refresh, Time}, State) ->
{ok, ok, webmachine_log:maybe_rotate(?MODULE, Time, State)};
handle_call(_Request, State) ->
{ok, ok, State}.
%% @private
handle_event({log_error, Msg}, State) ->
NewState = webmachine_log:maybe_rotate(?MODULE, os:timestamp(), State),
FormattedMsg = format_req(error, undefined, undefined, Msg),
webmachine_log:log_write(NewState#state.handle, FormattedMsg),
{ok, NewState};
handle_event({log_error, Code, _Req, _Reason}, State) when Code < 500 ->
{ok, State};
handle_event({log_error, Code, Req, Reason}, State) ->
NewState = webmachine_log:maybe_rotate(?MODULE, os:timestamp(), State),
Msg = format_req(error, Code, Req, Reason),
webmachine_log:log_write(NewState#state.handle, Msg),
{ok, NewState};
handle_event({log_info, Msg}, State) ->
NewState = webmachine_log:maybe_rotate(?MODULE, os:timestamp(), State),
FormattedMsg = format_req(info, undefined, undefined, Msg),
webmachine_log:log_write(NewState#state.handle, FormattedMsg),
{ok, NewState};
handle_event(_Event, State) ->
{ok, State}.
%% @private
handle_info(_Info, State) ->
{ok, State}.
%% @private
terminate(_Reason, _State) ->
ok.
%% @private
code_change(_OldVsn, State, _Extra) ->
{ok, State}.
%% ===================================================================
%% Internal functions
%% ===================================================================
format_req(info, undefined, _, Msg) ->
["[info] ", Msg];
format_req(error, undefined, _, Msg) ->
["[error] ", Msg];
format_req(error, 501, Req, _) ->
{Path, _} = Req:path(),
{Method, _} = Req:method(),
Reason = "Webmachine does not support method ",
["[error] ", Reason, Method, ": path=", Path, $\n];
format_req(error, 503, Req, _) ->
{Path, _} = Req:path(),
Reason = "Webmachine cannot fulfill the request at this time",
["[error] ", Reason, ": path=", Path, $\n];
format_req(error, _Code, Req, Reason) ->
{Path, _} = Req:path(),
["[error] path=", Path, $\x20, Reason, $\n].