1: | <?php
|
2: | |
3: | |
4: |
|
5: | namespace Opencart\System\Library\Mail;
|
6: | |
7: | |
8: |
|
9: | class Smtp {
|
10: | |
11: | |
12: |
|
13: | protected array $option = [];
|
14: | |
15: | |
16: |
|
17: | protected array $default = [
|
18: | 'smtp_port' => 25,
|
19: | 'smtp_timeout' => 5,
|
20: | 'max_attempts' => 3,
|
21: | 'verp' => false
|
22: | ];
|
23: |
|
24: | |
25: | |
26: | |
27: | |
28: |
|
29: | public function __construct(array &$option = []) {
|
30: | foreach ($this->default as $key => $value) {
|
31: | if (!isset($option[$key])) {
|
32: | $option[$key] = $value;
|
33: | }
|
34: | }
|
35: |
|
36: | $this->option = &$option;
|
37: | }
|
38: |
|
39: | |
40: | |
41: | |
42: | |
43: |
|
44: | public function send(): bool {
|
45: | if (empty($this->option['smtp_hostname'])) {
|
46: | throw new \Exception('Error: SMTP hostname required!');
|
47: | }
|
48: |
|
49: | if (empty($this->option['smtp_username'])) {
|
50: | throw new \Exception('Error: SMTP username required!');
|
51: | }
|
52: |
|
53: | if (empty($this->option['smtp_password'])) {
|
54: | throw new \Exception('Error: SMTP password required!');
|
55: | }
|
56: |
|
57: | if (empty($this->option['smtp_port'])) {
|
58: | throw new \Exception('Error: SMTP port required!');
|
59: | }
|
60: |
|
61: | if (empty($this->option['smtp_timeout'])) {
|
62: | throw new \Exception('Error: SMTP timeout required!');
|
63: | }
|
64: |
|
65: | if (is_array($this->option['to'])) {
|
66: | $to = implode(',', $this->option['to']);
|
67: | } else {
|
68: | $to = $this->option['to'];
|
69: | }
|
70: |
|
71: | $boundary = '----=_NextPart_' . md5((string)time());
|
72: |
|
73: | $header = 'MIME-Version: 1.0' . PHP_EOL;
|
74: | $header .= 'To: <' . $to . '>' . PHP_EOL;
|
75: | $header .= 'Subject: =?UTF-8?B?' . base64_encode($this->option['subject']) . '?=' . PHP_EOL;
|
76: | $header .= 'Date: ' . date('D, d M Y H:i:s O') . PHP_EOL;
|
77: | $header .= 'From: =?UTF-8?B?' . base64_encode($this->option['sender']) . '?= <' . $this->option['from'] . '>' . PHP_EOL;
|
78: |
|
79: | if (empty($this->option['reply_to'])) {
|
80: | $header .= 'Reply-To: =?UTF-8?B?' . base64_encode($this->option['sender']) . '?= <' . $this->option['from'] . '>' . PHP_EOL;
|
81: | } else {
|
82: | $header .= 'Reply-To: =?UTF-8?B?' . base64_encode($this->option['reply_to']) . '?= <' . $this->option['reply_to'] . '>' . PHP_EOL;
|
83: | }
|
84: |
|
85: | $header .= 'Return-Path: ' . $this->option['from'] . PHP_EOL;
|
86: | $header .= 'X-Mailer: PHP/' . PHP_VERSION . PHP_EOL;
|
87: | $header .= 'Content-Type: multipart/mixed; boundary="' . $boundary . '"' . PHP_EOL . PHP_EOL;
|
88: |
|
89: | $message = '--' . $boundary . PHP_EOL;
|
90: |
|
91: | if (empty($this->option['html'])) {
|
92: | $message .= 'Content-Type: text/plain; charset="utf-8"' . PHP_EOL;
|
93: | $message .= 'Content-Transfer-Encoding: base64' . PHP_EOL . PHP_EOL;
|
94: | $message .= chunk_split(base64_encode($this->option['text']), 950) . PHP_EOL;
|
95: | } else {
|
96: | $message .= 'Content-Type: multipart/alternative; boundary="' . $boundary . '_alt"' . PHP_EOL . PHP_EOL;
|
97: | $message .= '--' . $boundary . '_alt' . PHP_EOL;
|
98: | $message .= 'Content-Type: text/plain; charset="utf-8"' . PHP_EOL;
|
99: | $message .= 'Content-Transfer-Encoding: base64' . PHP_EOL . PHP_EOL;
|
100: |
|
101: | if (!empty($this->option['text'])) {
|
102: | $message .= chunk_split(base64_encode($this->option['text']), 950) . PHP_EOL;
|
103: | } else {
|
104: | $message .= chunk_split(base64_encode('This is a HTML email and your email client software does not support HTML email!'), 950) . PHP_EOL;
|
105: | }
|
106: |
|
107: | $message .= '--' . $boundary . '_alt' . PHP_EOL;
|
108: | $message .= 'Content-Type: text/html; charset="utf-8"' . PHP_EOL;
|
109: | $message .= 'Content-Transfer-Encoding: base64' . PHP_EOL . PHP_EOL;
|
110: | $message .= chunk_split(base64_encode($this->option['html']), 950) . PHP_EOL;
|
111: | $message .= '--' . $boundary . '_alt--' . PHP_EOL;
|
112: | }
|
113: |
|
114: | if (!empty($this->option['attachments'])) {
|
115: | foreach ($this->option['attachments'] as $attachment) {
|
116: | if (is_file($attachment)) {
|
117: | $handle = fopen($attachment, 'r');
|
118: |
|
119: | $content = fread($handle, filesize($attachment));
|
120: |
|
121: | fclose($handle);
|
122: |
|
123: | $message .= '--' . $boundary . PHP_EOL;
|
124: | $message .= 'Content-Type: application/octet-stream; name="' . basename($attachment) . '"' . PHP_EOL;
|
125: | $message .= 'Content-Transfer-Encoding: base64' . PHP_EOL;
|
126: | $message .= 'Content-Disposition: attachment; filename="' . basename($attachment) . '"' . PHP_EOL;
|
127: | $message .= 'Content-ID: <' . urlencode(basename($attachment)) . '>' . PHP_EOL;
|
128: | $message .= 'X-Attachment-Id: ' . urlencode(basename($attachment)) . PHP_EOL . PHP_EOL;
|
129: | $message .= chunk_split(base64_encode($content), 950);
|
130: | }
|
131: | }
|
132: | }
|
133: |
|
134: | $message .= '--' . $boundary . '--' . PHP_EOL;
|
135: |
|
136: | if (substr($this->option['smtp_hostname'], 0, 3) == 'tls') {
|
137: | $hostname = substr($this->option['smtp_hostname'], 6);
|
138: | } else {
|
139: | $hostname = $this->option['smtp_hostname'];
|
140: | }
|
141: |
|
142: | $handle = fsockopen($hostname, $this->option['smtp_port'], $errno, $errstr, $this->option['smtp_timeout']);
|
143: |
|
144: | if ($handle) {
|
145: | if (substr(PHP_OS, 0, 3) != 'WIN') {
|
146: | stream_set_timeout($handle, $this->option['smtp_timeout'], 0);
|
147: | }
|
148: |
|
149: | while ($line = fgets($handle, 515)) {
|
150: | if (substr($line, 3, 1) == ' ') {
|
151: | break;
|
152: | }
|
153: | }
|
154: |
|
155: | fwrite($handle, 'EHLO ' . getenv('SERVER_NAME') . "\r\n");
|
156: |
|
157: | $reply = '';
|
158: |
|
159: | while ($line = fgets($handle, 515)) {
|
160: | $reply .= $line;
|
161: |
|
162: |
|
163: | if (substr($reply, 0, 3) == 220 && substr($line, 3, 1) == ' ') {
|
164: | $reply = '';
|
165: |
|
166: | continue;
|
167: | } elseif (substr($line, 3, 1) == ' ') {
|
168: | break;
|
169: | }
|
170: | }
|
171: |
|
172: | if (substr($reply, 0, 3) != 250) {
|
173: | throw new \Exception('Error: EHLO not accepted from server!');
|
174: | }
|
175: |
|
176: | if (substr($this->option['smtp_hostname'], 0, 3) == 'tls') {
|
177: | fwrite($handle, 'STARTTLS' . "\r\n");
|
178: |
|
179: | $this->handleReply($handle, 220, 'Error: STARTTLS not accepted from server!');
|
180: |
|
181: | if (stream_socket_enable_crypto($handle, true, STREAM_CRYPTO_METHOD_TLS_CLIENT) !== true) {
|
182: | throw new \Exception('Error: TLS could not be established!');
|
183: | }
|
184: |
|
185: | fwrite($handle, 'EHLO ' . getenv('SERVER_NAME') . "\r\n");
|
186: |
|
187: | $this->handleReply($handle, 250, 'Error: EHLO not accepted from server!');
|
188: | }
|
189: |
|
190: | fwrite($handle, 'AUTH LOGIN' . "\r\n");
|
191: |
|
192: | $this->handleReply($handle, 334, 'Error: AUTH LOGIN not accepted from server!');
|
193: |
|
194: | fwrite($handle, base64_encode($this->option['smtp_username']) . "\r\n");
|
195: |
|
196: | $this->handleReply($handle, 334, 'Error: Username not accepted from server!');
|
197: |
|
198: | fwrite($handle, base64_encode($this->option['smtp_password']) . "\r\n");
|
199: |
|
200: | $this->handleReply($handle, 235, 'Error: Password not accepted from server!');
|
201: |
|
202: | if ($this->option['verp']) {
|
203: | fwrite($handle, 'MAIL FROM: <' . $this->option['from'] . '>XVERP' . "\r\n");
|
204: | } else {
|
205: | fwrite($handle, 'MAIL FROM: <' . $this->option['from'] . '>' . "\r\n");
|
206: | }
|
207: |
|
208: | $this->handleReply($handle, 250, 'Error: MAIL FROM not accepted from server!');
|
209: |
|
210: | if (!is_array($this->option['to'])) {
|
211: | fwrite($handle, 'RCPT TO: <' . $this->option['to'] . '>' . "\r\n");
|
212: |
|
213: | $reply = $this->handleReply($handle, false, 'RCPT TO [!array]');
|
214: |
|
215: | if ((substr($reply, 0, 3) != 250) && (substr($reply, 0, 3) != 251)) {
|
216: | throw new \Exception('Error: RCPT TO not accepted from server!');
|
217: | }
|
218: | } else {
|
219: | foreach ($this->option['to'] as $recipient) {
|
220: | fwrite($handle, 'RCPT TO: <' . $recipient . '>' . "\r\n");
|
221: |
|
222: | $reply = $this->handleReply($handle, false, 'RCPT TO [array]');
|
223: |
|
224: | if ((substr($reply, 0, 3) != 250) && (substr($reply, 0, 3) != 251)) {
|
225: | throw new \Exception('Error: RCPT TO not accepted from server!');
|
226: | }
|
227: | }
|
228: | }
|
229: |
|
230: | fwrite($handle, 'DATA' . "\r\n");
|
231: |
|
232: | $this->handleReply($handle, 354, 'Error: DATA not accepted from server!');
|
233: |
|
234: |
|
235: | $message = str_replace("\r\n", "\n", $header . $message);
|
236: | $message = str_replace("\r", "\n", $message);
|
237: |
|
238: | $lines = explode("\n", $message);
|
239: |
|
240: | foreach ($lines as $line) {
|
241: |
|
242: | $results = ($line === '') ? [''] : str_split($line, 998);
|
243: |
|
244: | foreach ($results as $result) {
|
245: | fwrite($handle, $result . "\r\n");
|
246: | }
|
247: | }
|
248: |
|
249: | fwrite($handle, '.' . "\r\n");
|
250: |
|
251: | $this->handleReply($handle, 250, 'Error: DATA not accepted from server!');
|
252: |
|
253: | fwrite($handle, 'QUIT' . "\r\n");
|
254: |
|
255: | $this->handleReply($handle, 221, 'Error: QUIT not accepted from server!');
|
256: |
|
257: | fclose($handle);
|
258: |
|
259: | return true;
|
260: | } else {
|
261: | throw new \Exception('Error: ' . $errstr . ' (' . $errno . ')');
|
262: | }
|
263: | }
|
264: |
|
265: | |
266: | |
267: | |
268: | |
269: | |
270: | |
271: | |
272: |
|
273: | private function handleReply($handle, $status_code = false, $error_text = false, int $counter = 0): string {
|
274: | $reply = '';
|
275: |
|
276: | while (($line = fgets($handle, 515)) !== false) {
|
277: | $reply .= $line;
|
278: |
|
279: | if (substr($line, 3, 1) == ' ') {
|
280: | break;
|
281: | }
|
282: | }
|
283: |
|
284: |
|
285: | if (!$line && empty($reply) && $counter < $this->option['max_attempts']) {
|
286: | sleep(1);
|
287: |
|
288: | $counter++;
|
289: |
|
290: | return $this->handleReply($handle, $status_code, $error_text, $counter);
|
291: | }
|
292: |
|
293: | if ($status_code) {
|
294: | if (substr($reply, 0, 3) != $status_code) {
|
295: | throw new \Exception($error_text);
|
296: | }
|
297: | }
|
298: |
|
299: | return $reply;
|
300: | }
|
301: | }
|
302: | |