- (API) Added the new Queue Service to handle sending items to the queue

Author: objectivehtml

controllers/Postmaster_QueueController.php

@@ -0,0 +1,10 @@
+<?php
+namespace Craft;
+
+class Postmaster_QueueController extends BaseController
+{
+	public function actionMarshal()
+	{
+		craft()->postmaster_queue->marshal();
+	}
+}

migrations/m141212_003800_postmaster_queue_table.php

@@ -0,0 +1,15 @@
+<?php
+namespace Craft;
+
+class m141212_003800_postmaster_queue_table extends BaseMigration
+{
+	public function safeUp()
+	{
+		$this->createTable('postmasterqueue', array(
+            'model'  => array(AttributeType::Mixed, 'column' => ColumnType::LongText),
+            'sendDate'  => array(AttributeType::Mixed, 'column' => ColumnType::LongText),
+        ));
+
+		return true;
+	}
+}

records/Postmaster_QueueRecord.php

@@ -0,0 +1,20 @@
+<?php
+namespace Craft;
+
+class Postmaster_QueueRecord extends BaseRecord
+{
+    public function getTableName()
+    {
+        return 'postmasterqueue';
+    }
+
+    protected function defineAttributes()
+    {
+        return array(
+            'recordId' => array(AttributeType::Number, 'column' => ColumnType::Int),
+            'recordType' => array(AttributeType::String, 'column' => ColumnType::Text),
+            'model'  => array(AttributeType::Mixed, 'column' => ColumnType::LongText),
+            'sendDate'  => array(AttributeType::Mixed, 'column' => ColumnType::LongText),
+        );
+    }
+}

services/Postmaster_QueueService.php

@@ -0,0 +1,54 @@
+<?php
+namespace Craft;
+
+class Postmaster_QueueService extends BaseApplicationComponent
+{
+	public function query()
+    {
+        $record = new Postmaster_QueueRecord();
+
+        return craft()->db->createCommand()
+            ->select('*')
+            ->from($record->getTableName());
+    }
+
+    public function remove($id)
+    {
+        return (new Postmaster_QueueRecord())->deleteByPk($id);
+    }
+    
+    public function marshal()
+    {
+        foreach($this->expired() as $model)
+        {
+            craft()->postmaster->send($model);
+        }
+    }
+
+    public function expired()
+    {
+        $data = $this->query()->where('sendDate <= :date', array(':date' => new DateTime()));
+
+        return $this->_populateModelsFromArray($data->queryAll());
+    }
+
+    protected function _populateModelsFromArray(Array $array)
+    {
+        $models = array();
+
+        foreach($array as $row)
+        {
+            $model = json_decode($row['model'], true);
+            $model = ModelHelper::expandModelsInArray($model);
+            
+            $class = $model['service']['__class__'];
+
+            $model->service = new $class($model->service);
+            $model->queueId = $row['id'];
+
+            $models[] = new Postmaster_TransportModel($model);
+        }
+
+        return $models;
+    }
+}