Adds one entry point for both JSON and MP APIs

Removes endpoints folder and moves versions to the root JSON API folder
2017-05-10 18:20:32 -04:00
parent 3c7ac5488a
commit 8b13889c7a
30 changed files with 49 additions and 48 deletions
--- a/lib/API/JSON/v1/SendingQueue.php
+++ b/lib/API/JSON/v1/SendingQueue.php
@ -0,0 +1,158 @@
+<?php
+namespace MailPoet\API\JSON\v1;
+use MailPoet\API\JSON\Endpoint as APIEndpoint;
+use MailPoet\API\JSON\Error as APIError;
+
+use MailPoet\Mailer\Mailer;
+use MailPoet\Models\Newsletter;
+use MailPoet\Models\Subscriber;
+use MailPoet\Newsletter\Scheduler\Scheduler;
+use MailPoet\Models\SendingQueue as SendingQueueModel;
+use MailPoet\Util\Helpers;
+
+if(!defined('ABSPATH')) exit;
+
+class SendingQueue extends APIEndpoint {
+  function add($data = array()) {
+    $newsletter_id = (isset($data['newsletter_id'])
+      ? (int)$data['newsletter_id']
+      : false
+    );
+
+    // check that the newsletter exists
+    $newsletter = Newsletter::filter('filterWithOptions')
+      ->findOne($newsletter_id);
+
+    if($newsletter === false) {
+      return $this->errorResponse(array(
+        APIError::NOT_FOUND => __('This newsletter does not exist.', 'mailpoet')
+      ));
+    }
+
+    // check that the sending method has been configured properly
+    try {
+      new Mailer(false);
+    } catch(\Exception $e) {
+      return $this->errorResponse(array(
+        $e->getCode() => $e->getMessage()
+      ));
+    }
+
+    // add newsletter to the sending queue
+    $queue = SendingQueueModel::whereNull('status')
+    ->where('newsletter_id', $newsletter->id)
+    ->findOne();
+
+    if(!empty($queue)) {
+      return $this->errorResponse(array(
+        APIError::NOT_FOUND => __('This newsletter is already being sent.', 'mailpoet')
+      ));
+    }
+    $queue = SendingQueueModel::where('newsletter_id', $newsletter->id)
+      ->where('status', SendingQueueModel::STATUS_SCHEDULED)
+      ->findOne();
+    if(!$queue) {
+      $queue = SendingQueueModel::create();
+      $queue->newsletter_id = $newsletter->id;
+    }
+
+    if((bool)$newsletter->isScheduled) {
+      // set newsletter status
+      $newsletter->setStatus(Newsletter::STATUS_SCHEDULED);
+
+      // set queue status
+      $queue->status = SendingQueueModel::STATUS_SCHEDULED;
+      $queue->scheduled_at = Scheduler::formatDatetimeString(
+        $newsletter->scheduledAt
+      );
+      $queue->subscribers = null;
+      $queue->count_total = $queue->count_to_process = 0;
+    } else {
+      $segments = $newsletter->segments()->findArray();
+      $segment_ids = array_map(function($segment) {
+        return $segment['id'];
+      }, $segments);
+      $subscribers = Subscriber::getSubscribedInSegments($segment_ids)->findArray();
+      $subscribers = Helpers::flattenArray($subscribers);
+      if(!count($subscribers)) {
+        return $this->errorResponse(array(
+          APIError::UNKNOWN => __('There are no subscribers in that list!', 'mailpoet')
+        ));
+      }
+      $queue->status = null;
+      $queue->scheduled_at = null;
+      $queue->subscribers = serialize(
+        array(
+          'to_process' => $subscribers
+        )
+      );
+      $queue->count_total = $queue->count_to_process = count($subscribers);
+
+      // set newsletter status
+      $newsletter->setStatus(Newsletter::STATUS_SENDING);
+    }
+    $queue->save();
+
+    $errors = $queue->getErrors();
+    if(!empty($errors)) {
+      return $this->errorResponse($errors);
+    } else {
+      return $this->successResponse(
+        $newsletter->getQueue()->asArray()
+      );
+    }
+  }
+
+  function pause($data = array()) {
+    $newsletter_id = (isset($data['newsletter_id'])
+      ? (int)$data['newsletter_id']
+      : false
+    );
+    $newsletter = Newsletter::findOne($newsletter_id);
+
+    if($newsletter === false) {
+      return $this->errorResponse(array(
+        APIError::NOT_FOUND => __('This newsletter does not exist.', 'mailpoet')
+      ));
+    } else {
+      $queue = $newsletter->getQueue();
+
+      if($queue === false) {
+        return $this->errorResponse(array(
+          APIError::UNKNOWN => __('This newsletter has not been sent yet.', 'mailpoet')
+        ));
+      } else {
+        $queue->pause();
+        return $this->successResponse(
+          $newsletter->getQueue()->asArray()
+        );
+      }
+    }
+  }
+
+  function resume($data = array()) {
+    $newsletter_id = (isset($data['newsletter_id'])
+      ? (int)$data['newsletter_id']
+      : false
+    );
+    $newsletter = Newsletter::findOne($newsletter_id);
+    if($newsletter === false) {
+      return $this->errorResponse(array(
+        APIError::NOT_FOUND => __('This newsletter does not exist.', 'mailpoet')
+      ));
+    } else {
+      $queue = $newsletter->getQueue();
+
+      if($queue === false) {
+        return $this->errorResponse(array(
+          APIError::UNKNOWN => __('This newsletter has not been sent yet.', 'mailpoet')
+        ));
+      } else {
+        $queue->resume();
+        return $this->successResponse(
+          $newsletter->getQueue()->asArray()
+        );
+      }
+    }
+  }
+}