|
3732
|
1 local pack = require "util.table".pack;
|
|
|
2 local json = require "util.json";
|
|
|
3 local array = require "util.array";
|
|
|
4 local datetime = require "util.datetime".datetime;
|
|
|
5
|
|
|
6 module:set_global();
|
|
|
7
|
|
|
8 local function sink_maker(config)
|
|
|
9 local logfile = io.open("blah.json", "a");
|
|
|
10 logfile:setvbuf("no");
|
|
|
11 return function (source, level, message, ...)
|
|
|
12 local args = pack(...);
|
|
|
13 for i = 1, args.n do
|
|
|
14 if args[i] == nil then
|
|
|
15 args[i] = json.null;
|
|
|
16 elseif type(args[i]) ~= "string" or type(args[i]) ~= "number" then
|
|
|
17 args[i] = tostring(args[i]);
|
|
|
18 end
|
|
|
19 end
|
|
|
20 args.n = nil;
|
|
|
21 local payload = {
|
|
|
22 datetime = datetime(),
|
|
|
23 source = source,
|
|
|
24 level = level,
|
|
|
25 message = message,
|
|
|
26 args = array(args);
|
|
|
27 };
|
|
|
28 logfile:write(json.encode(payload), "\n");
|
|
|
29 end
|
|
|
30 end
|
|
|
31
|
|
|
32 require"core.loggingmanager".register_sink_type("json", sink_maker);
|
