Emails processing

DigestService.php

<?php

class DigestService {
	private $events;

	function __construct($events) {
		$this->events = $events;
	}

	function stack(\Closure $func) {
		foreach ($this->events as $event) {
			$func($event);
		}
		return $this;
	}
}

ProcessEmails.php

<?php

$data = json_decode('{
	"sender": "test.myapp.com",
	"order": 1454679154162,
	"recipient": 1,
	"subject": "String",
	"schedule": "2014-07-09 11:23:13",
	"data": {},
	"urgent": false
}');

class ProcessEmails extends \Phalcon\Cli\Task {

	function mainAction($dateTime) {
		/**
		 * Events aggregated and ordered
		 * app_id: 1
		 * recipients: []
		 * body: [[subject, data]]
		 * attachments: [] if needed
		 */
		$events = EmailQueue::findByDateTime($dateTime);

		$emails = (new DigestService($events))
			->stack($transformEmailBody)
			->stack($toc)
			->stack($addTemplate);

		$toc = function ($event) {
			// add toc
			return $event;
		};

		$transformEmailBody = function($event) {
		  // concatenate all email body
			return $event;
		}

		$addTemplate = function($event) {
			// wrap email body in template
			return $event;
		}

		foreach ($emails as $email) {
		  // EmailService
			$this->adapter->send($email);
		}
	}

}