server interaction * The comunication is based upon the SMPT standards defined in http://www.lesnikowski.com/mail/Rfc/rfc2821.txt */ class fakeSMTP { public $logFile = false; public $serverHello = 'fakeSMTP ESMTP PHP Mail Server Ready'; public function __construct($fd) { $this->mail = []; $this->mail['ipaddress'] = false; $this->mail['emailSender'] = ''; $this->mail['emailRecipients'] = []; $this->mail['emailSubject'] = false; $this->mail['rawEmail'] = false; $this->mail['emailHeaders'] = false; $this->mail['emailBody'] = false; $this->fd = $fd; } public function receive() { $hasValidFrom = false; $hasValidTo = false; $receivingData = false; $header = true; $this->reply('220 '.$this->serverHello); $this->mail['ipaddress'] = $this->detectIP(); while ($data = fgets($this->fd)) { $data = preg_replace('@\r\n@', "\n", $data); if (!$receivingData) { $this->log($data); } if (!$receivingData && preg_match('/^MAIL FROM:\s?<(.*)>/i', $data, $match)) { if (preg_match('/(.*)@\[.*\]/i', $match[1]) || $match[1] != '' || $this->validateEmail($match[1])) { $this->mail['emailSender'] = $match[1]; $this->reply('250 2.1.0 Ok'); $hasValidFrom = true; } else { $this->reply('551 5.1.7 Bad sender address syntax'); } } elseif (!$receivingData && preg_match('/^RCPT TO:\s?<(.*)>/i', $data, $match)) { if (!$hasValidFrom) { $this->reply('503 5.5.1 Error: need MAIL command'); } else { if (preg_match('/postmaster@\[.*\]/i', $match[1]) || $this->validateEmail($match[1])) { array_push($this->mail['emailRecipients'], $match[1]); $this->reply('250 2.1.5 Ok'); $hasValidTo = true; } else { $this->reply('501 5.1.3 Bad recipient address syntax '.$match[1]); } } } elseif (!$receivingData && preg_match('/^RSET$/i', trim($data))) { $this->reply('250 2.0.0 Ok'); $hasValidFrom = false; $hasValidTo = false; } elseif (!$receivingData && preg_match('/^NOOP$/i', trim($data))) { $this->reply('250 2.0.0 Ok'); } elseif (!$receivingData && preg_match('/^VRFY (.*)/i', trim($data), $match)) { $this->reply('250 2.0.0 '.$match[1]); } elseif (!$receivingData && preg_match('/^DATA/i', trim($data))) { if (!$hasValidTo) { $this->reply('503 5.5.1 Error: need RCPT command'); } else { $this->reply('354 Ok Send data ending with .'); $receivingData = true; } } elseif (!$receivingData && preg_match('/^(HELO|EHLO)/i', $data)) { $this->reply('250 HELO '.$this->mail['ipaddress']); } elseif (!$receivingData && preg_match('/^QUIT/i', trim($data))) { break; } elseif (!$receivingData) { //~ $this->reply('250 Ok'); $this->reply('502 5.5.2 Error: command not recognized'); } elseif ($receivingData && $data == ".\n") { /* Email Received, now let's look at it */ $receivingData = false; $this->reply('250 2.0.0 Ok: queued as '.$this->generateRandom(10)); $splitmail = explode("\n\n", $this->mail['rawEmail'], 2); if (count($splitmail) == 2) { $this->mail['emailHeaders'] = $splitmail[0]; $this->mail['emailBody'] = $splitmail[1]; $headers = preg_replace("/ \s+/", ' ', preg_replace("/\n\s/", ' ', $this->mail['emailHeaders'])); $headerlines = explode("\n", $headers); for ($i = 0; $i < count($headerlines); $i++) { if (preg_match('/^Subject: (.*)/i', $headerlines[$i], $matches)) { $this->mail['emailSubject'] = trim($matches[1]); } } } else { $this->mail['emailBody'] = $splitmail[0]; } set_time_limit(5); // Just run the exit to prevent open threads / abuse } elseif ($receivingData) { $this->mail['rawEmail'] .= $data; } } /* Say good bye */ $this->reply('221 2.0.0 Bye '.$this->mail['ipaddress']); fclose($this->fd); } public function log($s) { if ($this->logFile) { file_put_contents($this->logFile, trim($s)."\n", FILE_APPEND); } } private function reply($s) { $this->log("REPLY:$s"); fwrite($this->fd, $s . "\r\n"); } private function detectIP() { $raw = explode(':', stream_socket_get_name($this->fd, true)); return $raw[0]; } private function validateEmail($email) { return preg_match('/^[_a-z0-9-+]+(\.[_a-z0-9-+]+)*@[a-z0-9-]+(\.[a-z0-9-]+)*(\.[a-z]{2,4})$/', strtolower($email)); } private function generateRandom($length = 8) { $password = ''; $possible = '2346789BCDFGHJKLMNPQRTVWXYZ'; $maxlength = strlen($possible); $i = 0; for ($i = 0; $i < $length; $i++) { $char = substr($possible, mt_rand(0, $maxlength - 1), 1); if (!strstr($password, $char)) { $password .= $char; } } return $password; } } $socket = stream_socket_server('tcp://127.0.0.1:2525', $errno, $errstr); if (!$socket) { exit(); } while ($fd = stream_socket_accept($socket)) { $fakeSMTP = new fakeSMTP($fd); $fakeSMTP->receive(); } fclose($socket);