FCM Adapter

Author: turbo124

src/Sly/NotificationPusher/Adapter/Fcm.php

@@ -0,0 +1,53 @@
+<?php
+namespace Sly\NotificationPusher\Adapter;
+
+use Sly\NotificationPusher\Adapter\Fcm\Client;
+use Sly\NotificationPusher\Adapter\Fcm\Message;
+use Sly\NotificationPusher\Model\BaseOptionedModel;
+use Sly\NotificationPusher\Model\MessageInterface;
+use ZendService\Google\Gcm\Client as BaseClient;
+
+class Fcm extends Gcm
+{
+    /**
+     * Get opened client.
+     *
+     * @param  \ZendService\Google\Gcm\Client $client
+     * @return Sly\NotificationPusher\Adapter\Fcm\Client
+     */
+    public function getOpenedClient()
+    {
+        return parent::getOpenedClient(new Client);
+    }
+    /**
+     * Get service message from origin.
+     *
+     * @param  array $tokens
+     * @param  \Sly\NotificationPusher\Model\BaseOptionedModel $message
+     * @return Sly\NotificationPusher\Adapter\Fcm\Message
+     */
+    public function getServiceMessageFromOrigin(array $tokens, BaseOptionedModel $message)
+    {
+        $data = $message->getOptions();
+        $data['message'] = $message->getText();
+        $serviceMessage = new Message();
+        $serviceMessage->setRegistrationIds($tokens)
+            ->setData($data)
+            ->setCollapseKey($this->getParameter('collapseKey'))
+            ->setRestrictedPackageName($this->getParameter('restrictedPackageName'))
+            ->setDelayWhileIdle($this->getParameter('delayWhileIdle', false))
+            ->setTimeToLive($this->getParameter('ttl', 600))
+            ->setDryRun($this->getParameter('dryRun', false))
+            ->setPriority($this->getParameter('priority'));
+        return $serviceMessage;
+    }
+    /**
+     * Get the feedback.
+     *
+     * @return array
+     */
+    public function getFeedback()
+    {
+        return $this->response->getResults();
+    }
+}

src/Sly/NotificationPusher/Adapter/Fcm/Client.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace Sly\NotificationPusher\Adapter\Fcm;
+
+use ZendService\Google\Gcm\Client as BaseClient;
+class Client extends BaseClient
+{
+    /**
+     * @const string Server URI
+     */
+    const SERVER_URI = 'https://fcm.googleapis.com/fcm/send';
+}
+?>

src/Sly/NotificationPusher/Adapter/Fcm/Message.php

@@ -0,0 +1,55 @@
+<?php
+
+namespace Sly\NotificationPusher\Adapter\Fcm;
+
+use Zend\Json\Json;
+use ZendService\Google\Gcm\Message as BaseMessage;
+
+class Message extends BaseMessage
+{
+    /**
+     * @var string
+     */
+    const PRIORITY_HIGH = 'high';
+    /**
+     * @var string
+     */
+    const PRIORITY_NORMAL = 'normal';
+    /**
+     * @var string
+     */
+    protected $priority;
+    /**
+     * Set the priority.
+     *
+     * @param  string $priority
+     * @return $this
+     */
+    public function setPriority($priority)
+    {
+        $priority = in_array($priority, [static::PRIORITY_HIGH, static::PRIORITY_NORMAL]) ? $priority : static::PRIORITY_NORMAL;
+        $this->priority = $priority;
+        return $this;
+    }
+    /**
+     * Get priority.
+     *
+     * @return string
+     */
+    public function getPriority()
+    {
+        return $this->priority;
+    }
+    /**
+     * {@inheritdoc}
+     */
+    public function toJson()
+    {
+        $json = parent::toJson();
+        $data = Json::decode($json, Json::TYPE_ARRAY);
+        if ($this->priority) {
+            $data['priority'] = $this->priority;
+        }
+        return Json::encode($data);
+    }
+}