#!env php -q
<?php
$user = "username";
$pass = "password";
$host = "mailserver";
$port = 110;
$logpath = "/www/swenlogs/";

$socket = socket_create(AF_INET, SOCK_STREAM, 0);
if ($socket < 0) {
    echo "socket_create() failed: reason: ".socket_strerror($socket)."\n";
} else {
    echo "Socket opened.\n";
}

echo "Connection to host '$host' on port '$port'\n";
$res = socket_connect($socket, $host, $port) or die("Couldn't connect to server.");

// Display welcome message
$fromServer = socket_read($socket, 1024);
print "Server: $fromServer\n";

// Login
$msg = "user $user\n";
socket_write($socket, $msg, strlen($msg));
$fromServer = socket_read($socket, 1024);
print "Server: $fromServer\n";

$msg = "pass $pass\n";
socket_write($socket, $msg, strlen($msg));
$fromServer = socket_read($socket, 1024);
print "Server: $fromServer\n";

// List all e-mails
$msg = "list\n";
socket_write($socket, $msg, strlen($msg));
$fromServer = socket_read($socket, 32768);

$swen = 0;

str_replace("\r", "", $fromServer);
foreach (explode("\n", $fromServer) as $line) {
    if (ereg("[0-9][ ][0-9]", $line)) {
        $mail = explode(" ", $line);
        if (140000 < $mail[1] && $mail[1] < 165000) {
            $msg = "top $mail[0] 0\n";
            socket_write($socket, $msg, strlen($msg));
            $reply = socket_read($socket, 32768);
            unset($headers);
            $headers = array();

            foreach (explode("\n", $reply) as $line) {
                if (preg_match("/^subject: (.+)/i", $line, $matches)) {
                    $headers["subject"] = $matches[1];
                }
                if (preg_match("/^to: (.+)/i", $line, $matches)) {
                    $headers["to"] = $matches[1];
                }
                if (preg_match("/^from: (.+)/i", $line, $matches)) {
                    $headers["from"] = $matches[1];
                }
            }

            $words = array(
                "MS",
                "Microsoft",
                "Network",
                "Inet",
                "Internet",
                "Admin",
                "Announcement",
                "Client",
                "Recipient",
                "Commercial",
                "Postmaster",
                "Receiver"
            );

            $wordsfound = 0;

            foreach ($words as $word) {
                if (stristr($headers["subject"], $word)) $wordsfound++;
                if (stristr($headers["to"], $word)) $wordsfound++;
                if (stristr($headers["from"], $word)) $wordsfound++;
            }
            echo "Words found: $wordsfound\n";

            // Delete mail if it contains more than two matching words
            if ($wordsfound >= 2) {

                // Write headers to file
                $filename = $logpath."swen-".md5($reply).".txt";
                $handle = fopen($filename, "a");
                fwrite($handle, $reply);
                fclose($handle);

                // Deleting file from server
                $msg = "dele $mail[0]\n";
                socket_write($socket, $msg, strlen($msg));
                $swen++;
            }
        }
    }
}

echo "$swen swen mails removed from mailbox.\n";

echo "Closing connection to server.\n";
$msg = "quit\n";
socket_write($socket, $msg, strlen($msg));
socket_close($socket);
echo "Quit\n";
echo "------------------------------\n\n";

?>