AddMailQueue()

Complexity

Conditions	10
Paths	44

Size

Total Lines	95
Code Lines	40

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	19
CRAP Score	20.5287

Importance

Changes

0

<?php
function AddMailQueue($flush = false, $to_array = [], $subject = '', $message = '', $headers = '', $send_html = false, $priority = 3, $is_private = false, $message_id = '')
{
	global $context;

	$db = database();

	static $cur_insert = [];
	static $cur_insert_len = 0;

	if ($cur_insert_len === 0)
	{
		$cur_insert = [];
	}

	// If we're flushing, make the final inserts - also if we're near the MySQL length limit!
	if (($flush || $cur_insert_len > 800000) && !empty($cur_insert))
	{
		// Only do these once.
		$cur_insert_len = 0;

		// Dump the data...
		$db->insert('',
			'{db_prefix}mail_queue',
			[
				'time_sent' => 'int', 'recipient' => 'string-255', 'body' => 'string', 'subject' => 'string-255',
				'headers' => 'string-65534', 'send_html' => 'int', 'priority' => 'int', 'private' => 'int', 'message_id' => 'string-255',
			],
			$cur_insert,
			['id_mail']
		);

		$cur_insert = [];
		$context['flush_mail'] = false;
	}

	// If we're flushing we're done.
	if ($flush)
	{
		$nextSendTime = time() + 10;

		$db->query('', '
			UPDATE {db_prefix}settings
			SET 
				value = {string:nextSendTime}
			WHERE variable = {string:mail_next_send}
				AND value = {string:no_outstanding}',
			[
				'nextSendTime' => $nextSendTime,
				'mail_next_send' => 'mail_next_send',
				'no_outstanding' => '0',
			]
		);

		return true;
	}

	// Ensure we tell obExit to flush.
	$context['flush_mail'] = true;

	foreach ($to_array as $to)
	{
		// Will this insert go over MySQL's limit?
		$this_insert_len = strlen($to) + strlen($message) + strlen($headers) + 700;

		// Insert limit of 1M (just under the safety) is reached?
		if ($this_insert_len + $cur_insert_len > 1000000)
		{
			// Flush out what we have so far.
			$db->insert('',
				'{db_prefix}mail_queue',
				[
					'time_sent' => 'int', 'recipient' => 'string-255', 'body' => 'string', 'subject' => 'string-255',
					'headers' => 'string-65534', 'send_html' => 'int', 'priority' => 'int', 'private' => 'int', 'message_id' => 'string-255',
				],
				$cur_insert,
				['id_mail']
			);

			// Clear this out.
			$cur_insert = [];
			$cur_insert_len = 0;
		}

		// Now add the current insert to the array...
		$cur_insert[] = [time(), (string) $to, (string) $message, (string) $subject, (string) $headers, ($send_html ? 1 : 0), $priority, (int) $is_private, (string) $message_id];
		$cur_insert_len += $this_insert_len;
	}

	// If they are using SSI there is a good chance obExit will never be called.  So lets be nice and flush it for them.
	if (ELK === 'SSI')

The condition ELK === 'SSI' is always true.

	{
		return AddMailQueue(true);
	}

	return true;
}