export router function in ::Logging; add time of log event to metadata and render...
[scpubgit/Object-Remote.git] / lib / Object / Remote / Logging / Logger.pm
CommitLineData
21988035 1package Object::Remote::Logging::Logger;
2
3use Moo;
4use Scalar::Util qw(weaken);
5
6has level_names => ( is => 'ro', required => 1 );
7has min_level => ( is => 'ro', required => 1 );
8has max_level => ( is => 'ro' );
9has _level_active => ( is => 'lazy' );
10
11sub BUILD {
7d063a6a 12 my ($self) = @_;
13 our $METHODS_INSTALLED;
14 $self->_install_methods unless $METHODS_INSTALLED;
21988035 15}
16
17sub _build__level_active {
7d063a6a 18 my ($self) = @_;
19 my $should_log = 0;
20 my $min_level = $self->min_level;
21 my $max_level = $self->max_level;
22 my %active;
21988035 23
7d063a6a 24 foreach my $level (@{$self->level_names}) {
25 if($level eq $min_level) {
26 $should_log = 1;
27 }
28
29 $active{$level} = $should_log;
21988035 30
7d063a6a 31 if (defined $max_level && $level eq $max_level) {
32 $should_log = 0;
21988035 33 }
7d063a6a 34 }
35
36 return \%active;
21988035 37}
38
39sub _install_methods {
7d063a6a 40 my ($self) = @_;
41 my $should_log = 0;
42 our $METHODS_INSTALLED = 1;
21988035 43
7d063a6a 44 no strict 'refs';
21988035 45
7d063a6a 46 foreach my $level (@{$self->level_names}) {
47 *{"is_$level"} = sub { shift(@_)->_level_active->{$level} };
48 *{$level} = sub { shift(@_)->_log($level, @_) };
49 }
21988035 50}
51
52sub _log {
7d063a6a 53 my ($self, $level, $content, $metadata_in) = @_;
7d063a6a 54 my %metadata = %$metadata_in;
55 my $rendered = $self->_render($level, \%metadata, @$content);
56 $self->_output($rendered);
21988035 57}
58
59sub _render {
7d063a6a 60 my ($self, $level, $metadata, @content) = @_;
7d063a6a 61 my $remote_info = $metadata->{object_remote};
c3d5ef8a 62 my $when = $metadata->{timestamp};
63 my $rendered;
7d063a6a 64
c3d5ef8a 65 if (defined($when)) {
66 $when = localtime($when);
67 } else {
68 $when = 'no time data';
69 }
70
7d063a6a 71 if ($remote_info) {
c3d5ef8a 72 $rendered .= "[$level connection #$remote_info->{connection_id}] [$when] ";
7d063a6a 73 } else {
c3d5ef8a 74 $rendered .= "[$level local] [$when] ";
7d063a6a 75 }
c3d5ef8a 76
21988035 77
7d063a6a 78 $rendered .= join('', @content);
c3d5ef8a 79 chomp($rendered);
80 $rendered =~ s/\n/\n /g;
81 $rendered .= "\n";
7d063a6a 82 return $rendered;
21988035 83}
84
85sub _output {
7d063a6a 86 my ($self, $content) = @_;
87 print STDERR $content;
21988035 88}
89
90
911;
92