DRAFT: Feat/journal logging

Kernel/System/Log/Journal.pm

@@ -0,0 +1,68 @@
+# --
+# Copyright (C) 2021 Znuny GmbH, https://znuny.org/
+# --
+# This software comes with ABSOLUTELY NO WARRANTY. For details, see
+# the enclosed file COPYING for license information (AGPL). If you
+# did not receive this file, see http://www.gnu.org/licenses/agpl.txt.
+# --
+## nofilter(TidyAll::Plugin::Znuny::CodeStyle::STDERRCheck)
+
+package Kernel::System::Log::Journal;
+
+use utf8;
+use strict;
+use warnings;
+use IO::Socket::UNIX;
+
+our @ObjectDependencies = (
+    'Kernel::Config',
+);
+
+# see man:systemd.journal-fields(7) for default fields
+my %KeyTranslate = (
+    "Line"   => "CODE_LINE",
+    "Module" => "CODE_FUNC",
+);
+
+sub new {
+    my ( $Type, %Param ) = @_;
+
+    # allocate new hash for object
+    my $Self = {};
+    bless( $Self, $Type );
+
+    # get logfile location
+    $Self->{LogSockPath}
+        = $Kernel::OM->Get('Kernel::Config')->Get('LogModule::Journal::SocketPath') || '/run/systemd/journal/socket';
+
+    return $Self;
+}
+
+sub Serialize {
+    my ( $k, $v ) = @_;
+    return uc($k) . "\n" . pack( "Q<", length($v) ) . $v . "\n";
+}
+
+sub Log {
+    my ( $Self, %Param ) = @_;
+
+    my $LogSocket = IO::Socket::UNIX->new(
+        Type => SOCK_DGRAM(),
+        Peer => $Self->{LogSockPath},
+    );
+
+    my $LogMessage = "";
+    keys(%Param);
+    while ( my ( $Key, $Value ) = each(%Param) ) {
+        $Key = $KeyTranslate{$Key} || $Key;
+        $LogMessage .= Serialize( $Key, $Value );
+    }
+
+    print $LogSocket $LogMessage;
+
+    close($LogSocket);
+
+    return;
+}
+
+1;