EventProcessor::getQueue

private function getQueue(): array
{
	$res = MarketingTable::getList([
		'filter' => [
			'=DATE_EXECUTED' => 0,
			' DateTime::getCurrentTimestamp(),
		],
		'limit' => $this->getLimit(),
	]);

	$queue = [];
	while ($row = $res->fetch())
	{
		$queue[] = [
			'ID' => (int) $row['ID'],
			'USER_ID' => (int) $row['USER_ID'],
			'EVENT' => $row['EVENT'],
			'PARAMS' => !empty($row['PARAMS']) ? Json::decode($row['PARAMS']) : null,
			'DATE_SHEDULED' => $row['DATE_SHEDULED'],
		];
	}

	return $queue;
}