Web-GUI die eine Liste der ausgehenden Mails aus Postfix anzeigt gesucht

#!/usr/bin/env php
<?php
/**
 * parse_postfix_log.php
 *
 * Reads Postfix log lines in ISO-8601 format, aggregates the relevant data
 * by queue ID, and outputs a JSON file "postfix_mails.json" containing 
 * details about each processed email.
 *
 * Usage:
 *   php parse_postfix_log.php /path/to/mail.log /path/to/mail.log.1 [...]
 */
 
 
 // ---------------------------------------------------------------------
// 1) Helper function: Convert ISO-8601 date string to Unix timestamp
// ---------------------------------------------------------------------
function isoToTimestamp($isoString) {
    // If the string is empty or null, return null
    if (!$isoString) {
        return null;
    }

    try {
        $dt = new DateTime($isoString);
        // getTimestamp() returns the integer seconds since epoch
        return $dt->getTimestamp();
    } catch (Exception $e) {
        // On parsing error, return null or handle as needed
        return null;
    }
}

// Check if log files are provided
if ($argc < 2) {
    fwrite(STDERR, "Usage: php parse_postfix_log.php /path/to/mail.log [...]\n");  
    exit(1);
}

// Prepare a regular expression to match ISO-8601 timestamps and Postfix queue lines.
//
// Example line:
// 2025-02-09T19:45:01.585459+00:00 serverXYZ postfix/qmgr[17934]: 5B2423E652: removed
//
// Explanation of the pattern:
// ^(?<timestamp>...)         -> Matches the full date/time with microseconds and timezone
// \s+(?<host>\S+)            -> Captures the hostname
// \s+postfix\/(?<process>...) -> Matches "postfix/<something>[PID]:"  
// \[(?<pid>\d+)\]:\s+        -> Captures the PID, then a colon
// (?<queueid>[A-Za-z0-9]+):\s+ -> Captures the queue ID (up to next colon)
// (?<msg>.*)$                -> The rest of the line ("from=..., to=..., status=..., etc.")  
$logLineRegex = '/^'  
    . '(?<timestamp>\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}\.\d+(?:[+\-]\d{2}:\d{2}|Z))'  
    . '\s+(?<host>\S+)'  
    . '\s+postfix\/(?<process>\S+)\[(?<pid>\d+)\]:'  
    . '\s+(?<queueid>[A-Za-z0-9]+):'  
    . '\s+(?<msg>.*)'  
    . '$/';  

// This array will map queue IDs to their collected information
// Example structure:
// $messages['QUEUEID'] = [  
//   'queue_id'      => 'QUEUEID',  
//   'time_received' => '2025-02-09T19:44:59.390574+00:00',  
//   'time_removed'  => null,  
//   'from'          => 'user@example.com',  
//   'tos'           => [  
//       [ 'recipient' => 'rcpt@example.net', 'time_sent' => '...', 'status' => 'sent' ],  
//       ...
//   ],
//   'status'        => null,  
//   'message_id'    => null,  
// ];
$messages = [];

/**
 * Ensures that a queue ID entry exists in $messages.
 */
function ensureMessageEntry(&$messages, $queueId) {
    if (!isset($messages[$queueId])) {
        $messages[$queueId] = [
            'queue_id'      => $queueId,  
            'time_received' => null,  
            'time_removed'  => null,  
            'from'          => null,  
            'tos'           => [],  
            //'status'        => null,  
            'message_id'    => null,  
        ];
    }
}

// Remove the script name from the argument list
array_shift($argv);
$logFiles = $argv;

// Iterate through all provided log files
foreach ($logFiles as $logFile) {
    if (!is_readable($logFile)) {
        fwrite(STDERR, "File not readable: $logFile\n");  
        continue;
    }

    $fh = fopen($logFile, 'r');  
    if (!$fh) {
        fwrite(STDERR, "Failed to open file: $logFile\n");  
        continue;
    }

    while (($line = fgets($fh)) !== false) {
        $line = rtrim($line, "\n");  

        // Match the line against our ISO-8601 Postfix regex
        if (preg_match($logLineRegex, $line, $m)) {
            $queueId   = $m['queueid'];  
            //$timestamp = $m['timestamp'];  
			$isoTime   = $m['timestamp'];  
            $msg       = $m['msg'];  
			
			// Convert to Unix timestamp
            $timestamp = isoToTimestamp($isoTime);

            ensureMessageEntry($messages, $queueId);

            // If this is the first time we see this queue ID, record the 'time_received'  
            if ($messages[$queueId]['time_received'] === null) {  
                $messages[$queueId]['time_received'] = $timestamp;  
            }
			
			$FromUsedInArray =  "";  
			$isInfoHeaderLine = (strpos($msg, 'info: header') !== false);  
			if (!$isInfoHeaderLine)
			{
				// Extract "from=<...>"  
				if (preg_match('/from=<([^>]+)>/', $msg, $fm)) {  
					$messages[$queueId]['from'] = $fm[1];  
				}

				// Extract "to=<...>"  
				if (preg_match('/to=<([^>]+)>/', $msg, $tm)) {  
					// Add a new entry in the "tos" array  
					$FromUsedInArray = $tm[1];
					$messages[$queueId]['tos'][$FromUsedInArray]['events'][] = [  
						//'recipient' => $tm[1],  
						'time_sent' => $timestamp,  
						'status'    => null,  
					];
				}
			}

			/*
            // Extract "status=..." 
            if (preg_match('/status=(\w+)/', $msg, $st)) { 
                $statusFound = $st[1];
                $messages[$queueId]['status'] = $statusFound; 

                // (Optional) update the last "to" entry, if you want per-recipient status 
                $lastToIndex = count($messages[$queueId]['tos']) - 1; 
                if ($lastToIndex >= 0) {
                    $messages[$queueId]['tos'][$lastToIndex]['status'] = $statusFound; 
                }
            }
			*/
			
			// Extract status=... plus optional detail in parentheses
			if (preg_match('/status=(\w+)\s*\((.*?)\)/', $msg, $st)) {  
				// st[1] = "sent" (oder "bounced", etc.)  
				// st[2] = Inhalt in den Klammern, z.B. "250 2.0.0 OK <...> Message queued"  

				$statusFound = $st[1];
				$statusDetail = $st[2];
				
				if (strcasecmp($statusFound, "sent") === 0)  
				{
					$messages[$queueId]['tos'][$FromUsedInArray]['send_send'] = 1;  
					$messages[$queueId]['tos'][$FromUsedInArray]['send_status_detail'] = $statusDetail;  
				}

				//$messages[$queueId]['status'] = $statusFound;  
				//$messages[$queueId]['status_detail'] = $statusDetail;  

				// Optionale Zuordnung zum letzten Empfänger
				if ($FromUsedInArray != "")  
				{
					$lastToIndex = count($messages[$queueId]['tos'][$FromUsedInArray]['events']) - 1;  
					if ($lastToIndex >= 0)
					{
						$messages[$queueId]['tos'][$FromUsedInArray]['events'][$lastToIndex]['status'] = $statusFound;  
						//$messages[$queueId]['tos'][$FromUsedInArray]['status_time'] = $timestamp;  

						// Falls du den Detail-Text je Empfänger tracken möchtest:
						$messages[$queueId]['tos'][$FromUsedInArray]['events'][$lastToIndex]['status_detail'] = $statusDetail;  
						
					}
				}

			} elseif (preg_match('/status=(\w+)/', $msg, $st)) {  
				// Hier gibt es keinen Klammerteil, nur "status=sent" o. Ä.  
				$statusFound = $st[1];
				//$messages[$queueId]['status'] = $statusFound;  
				//$messages[$queueId]['status_time'] = $timestamp;  
				
				if (strcasecmp($statusFound, "sent") === 0)  
				{
					$messages[$queueId]['tos'][$FromUsedInArray]['send_send'] = 1;  
					$messages[$queueId]['tos'][$FromUsedInArray]['send_status_detail'] = $statusDetail;  
				}
				

				// Optional dem letzten Empfänger zuordnen
				if ($FromUsedInArray != "")  
				{
					$lastToIndex = count($messages[$queueId]['tos'][$FromUsedInArray]['events']) - 1;  
					if ($lastToIndex >= 0) {
						$messages[$queueId]['tos'][$FromUsedInArray]['events'][$lastToIndex]['status'] = $statusFound;  
						//$messages[$queueId]['tos'][$lastToIndex]['status_time'] = $timestamp;  
					}
				}
			}
			

            // Extract "message-id=<...>"  
            if (preg_match('/message-id=<([^>]+)>/', $msg, $mid)) {  
                $messages[$queueId]['message_id'] = $mid[1];  
            }
			
			// Extract Subject from "!!SUBJECT_START!!...!!SUBJECT_END!!"  
            if (preg_match('/!!SUBJECT_START!!(.*?)!!SUBJECT_END!!/', $msg, $sub)) {  
                $messages[$queueId]['subject'] = $sub[1];  
            }
			
			if (!array_key_exists('files', $messages[$queueId]))  
			{
				$messages[$queueId]['files']=array();  
			}
			
			// Extract filenames
            if (preg_match('/!!ATTACHMENT1_START!!(.*?)!!ATTACHMENT1_END!!/', $msg, $sub)) {  
				if (!in_array($sub[1], $messages[$queueId]['files']))  
				{
					$messages[$queueId]['files'][] = $sub[1];  
				}
            }
            if (preg_match('/!!ATTACHMENT2_START!!(.*?)!!ATTACHMENT2_END!!/', $msg, $sub)) {  
				if (!in_array($sub[1], $messages[$queueId]['files']))  
				{
					$messages[$queueId]['files'][] = $sub[1];  
				}
            }
			
			
			
			

            // Check if the mail is removed from the queue
            if (strpos($msg, 'removed') !== false) {  
                $messages[$queueId]['time_removed'] = $timestamp;  
            }
        }
    }
    fclose($fh);
}

// Convert the associative array to a simple numerical array
$result = array_values($messages);

// Write the results to a JSON file
file_put_contents('postfix_mails.json', json_encode($result, JSON_PRETTY_PRINT));  

// Print a confirmation message
echo "Done. Results stored in postfix_mails.json\n";  
exit(0);