Notimatica / driver

src/Providers/AbstractProvider.php

Doc Comments +1 added lines, -1 removed lines

@@ -68,7 +68,7 @@
     /**
      * Send data to provider.
      *
-     * @param  array $subscribers
+     * @param  Subscriber[] $subscribers
      * @param  \Closure $success
      * @param  \Closure $fail
      */

Spacing +3 added lines, -3 removed lines

@@ -43,7 +43,7 @@ 
      */
     public function setProject(Project $project)
     {
-        $this->project  = $project;
+        $this->project = $project;
 
         return $this;
     }
@@ -75,10 +75,10 @@ 
     protected function flush(array $subscribers, \Closure $success = null, \Closure $fail = null)
     {
         if (is_null($success)) {
-            $success = function ($response, $index) {};
+            $success = function($response, $index) {};
         }
         if (is_null($fail)) {
-            $fail = function ($reason, $index) {};
+            $fail = function($reason, $index) {};
         }
 
         $pool = new Pool(static::$browser, $this->prepareRequests($subscribers), [

Braces +10 added lines, -4 removed lines

@@ -74,11 +74,17 @@
      */
     protected function flush(array $subscribers, \Closure $success = null, \Closure $fail = null)
     {
-        if (is_null($success)) {
-            $success = function ($response, $index) {};
+        if (is_null($success))
+        {
+            $success = function ($response, $index)
+            {
+};
         }
-        if (is_null($fail)) {
-            $fail = function ($reason, $index) {};
+        if (is_null($fail))
+        {
+            $fail = function ($reason, $index)
+            {
+};
         }
 
         $pool = new Pool(static::$browser, $this->prepareRequests($subscribers), [

src/Providers/Safari.php

Doc Comments +1 added lines, -1 removed lines

@@ -65,7 +65,7 @@
      * Send request.
      *
      * @param  Subscriber[] $subscribers
-     * @param  mixed $payload
+     * @param  string $payload
      * @return \Generator
      */
     protected function prepareRequests($subscribers, $payload = null)

Braces +14 added lines, -6 removed lines

@@ -49,11 +49,15 @@ 
         $payload = new Payload($notification);
         $payload = json_encode($payload);
 
-        foreach ($this->prepareRequests($subscribers, $payload) as $message) {
-            try {
+        foreach ($this->prepareRequests($subscribers, $payload) as $message)
+        {
+            try
+            {
                 $stream->write($message);
                 Driver::emit(new NotificationSent($notification));
-            } catch (\Exception $e) {
+            }
+            catch (\Exception $e)
+            {
                 Driver::emit(new NotificationFailed($notification));
             }
         }
@@ -70,10 +74,14 @@ 
      */
     protected function prepareRequests($subscribers, $payload = null)
     {
-        foreach ($subscribers as $subscriber) {
-            try {
+        foreach ($subscribers as $subscriber)
+        {
+            try
+            {
                 yield chr(0) . chr(0) . chr(32) . pack('H*', $subscriber->getToken()) . chr(0) . chr(strlen($payload)) . $payload;
-            } catch (\Exception $e) {
+            }
+            catch (\Exception $e)
+            {
             }
         }
     }

src/Providers/Firefox.php

Spacing +2 added lines, -2 removed lines

@@ -65,7 +65,7 @@ 
 
         $this->flush(
             $subscribers,
-            function (Response $response, $index) use ($notification) {
+            function(Response $response, $index) use ($notification) {
                 try {
                     if ($response->getStatusCode() != 201) {
                         $response = json_decode($response->getBody());
@@ -82,7 +82,7 @@ 
                     Driver::emit(new NotificationFailed($notification));
                 }
             },
-            function ($reason, $index) use ($notification) {
+            function($reason, $index) use ($notification) {
                 Driver::emit(new NotificationFailed($notification));
             }
         );

Braces +17 added lines, -8 removed lines

@@ -31,7 +31,8 @@ 
      */
     protected static function initBrowser(array $config)
     {
-        if (static::$browser) {
+        if (static::$browser)
+        {
             return;
         }
 
@@ -65,12 +66,16 @@ 
 
         $this->flush(
             $subscribers,
-            function (Response $response, $index) use ($notification) {
-                try {
-                    if ($response->getStatusCode() != 201) {
+            function (Response $response, $index) use ($notification)
+            {
+                try
+                {
+                    if ($response->getStatusCode() != 201)
+                    {
                         $response = json_decode($response->getBody());
 
-                        if (json_last_error() !== JSON_ERROR_NONE) {
+                        if (json_last_error() !== JSON_ERROR_NONE)
+                        {
                             throw new \Exception('Firefox: bad json');
                         }
 
@@ -78,11 +83,14 @@ 
                     }
 
                     Driver::emit(new NotificationSent($notification));
-                } catch (\Exception $e) {
+                }
+                catch (\Exception $e)
+                {
                     Driver::emit(new NotificationFailed($notification));
                 }
             },
-            function ($reason, $index) use ($notification) {
+            function ($reason, $index) use ($notification)
+            {
                 Driver::emit(new NotificationFailed($notification));
             }
         );
@@ -100,7 +108,8 @@ 
         $headers = static::$headers;
         $content = '';
 
-        foreach ($subscribers as $subscriber) {
+        foreach ($subscribers as $subscriber)
+        {
             $headers['Content-Length'] = strlen($content);
 
             yield new Request('POST', $this->getUrl($subscriber), $headers, $content);

src/Providers/Chrome.php

Spacing +2 added lines, -2 removed lines

@@ -67,7 +67,7 @@ 
 
         $this->flush(
             $subscribers,
-            function (Response $response, $index) use ($notification, $total) {
+            function(Response $response, $index) use ($notification, $total) {
                 try {
                     $response = json_decode($response->getBody());
 
@@ -86,7 +86,7 @@ 
                     Driver::emit(new NotificationFailed($notification, $this->calculateChunkSize($index, $total)));
                 }
             },
-            function ($reason, $index) use ($notification, $total) {
+            function($reason, $index) use ($notification, $total) {
                 Driver::emit(new NotificationFailed($notification, $this->calculateChunkSize($index, $total)));
             }
         );

Braces +29 added lines, -13 removed lines

@@ -31,7 +31,8 @@ 
      */
     protected static function initBrowser(array $config)
     {
-        if (static::$browser) {
+        if (static::$browser)
+        {
             return;
         }
 
@@ -67,26 +68,34 @@ 
 
         $this->flush(
             $subscribers,
-            function (Response $response, $index) use ($notification, $total) {
-                try {
+            function (Response $response, $index) use ($notification, $total)
+            {
+                try
+                {
                     $response = json_decode($response->getBody());
 
-                    if (json_last_error() !== JSON_ERROR_NONE) {
+                    if (json_last_error() !== JSON_ERROR_NONE)
+                    {
                         throw new \Exception();
                     }
 
-                    if ($response->success > 0) {
+                    if ($response->success > 0)
+                    {
                         Driver::emit(new NotificationSent($notification, (int) $response->success));
                     }
 
-                    if ($response->failure > 0) {
+                    if ($response->failure > 0)
+                    {
                         Driver::emit(new NotificationFailed($notification, (int) $response->failure));
                     }
-                } catch (\Exception $e) {
+                }
+                catch (\Exception $e)
+                {
                     Driver::emit(new NotificationFailed($notification, $this->calculateChunkSize($index, $total)));
                 }
             },
-            function ($reason, $index) use ($notification, $total) {
+            function ($reason, $index) use ($notification, $total)
+            {
                 Driver::emit(new NotificationFailed($notification, $this->calculateChunkSize($index, $total)));
             }
         );
@@ -104,7 +113,8 @@ 
         $url = $this->config['url'];
         $headers = static::$headers;
 
-        foreach ($this->batch($subscribers) as $index => $chunk) {
+        foreach ($this->batch($subscribers) as $index => $chunk)
+        {
             $content = $this->getRequestContent($chunk);
             $headers['Content-Length'] = strlen($content);
 
@@ -127,11 +137,16 @@ 
         $offset = ($index + 1) * $chunkSize;
         $chunks = ceil($total / $chunkSize);
 
-        if ($offset <= $total) {
+        if ($offset <= $total)
+        {
             $return = $chunkSize;
-        } elseif ($offset > $total + $chunkSize) {
+        }
+        elseif ($offset > $total + $chunkSize)
+        {
             $return = 0;
-        } else {
+        }
+        else
+        {
             $return = $total - ($chunks - 1) * $chunkSize;
         }
 
@@ -149,7 +164,8 @@ 
         $tokens = [];
 
         /** @var Subscriber $subscriber */
-        foreach ($subscribers as $subscriber) {
+        foreach ($subscribers as $subscriber)
+        {
             $tokens[] = $subscriber->getToken();
         }
 

src/StatisticsStorages/AbstractStorage.php

Spacing +4 added lines, -4 removed lines

@@ -49,16 +49,16 @@
      */
     public function provideListeners(ListenerAcceptorInterface $listener)
     {
-        $listener->addListener(NotificationSent::class, function ($e) {
+        $listener->addListener(NotificationSent::class, function($e) {
             $this->sent($e);
         });
-        $listener->addListener(NotificationDelivered::class, function ($e) {
+        $listener->addListener(NotificationDelivered::class, function($e) {
             $this->delivered($e);
         });
-        $listener->addListener(NotificationClicked::class, function ($e) {
+        $listener->addListener(NotificationClicked::class, function($e) {
             $this->clicked($e);
         });
-        $listener->addListener(NotificationFailed::class, function ($e) {
+        $listener->addListener(NotificationFailed::class, function($e) {
             $this->failed($e);
         });
 

Braces +8 added lines, -4 removed lines

@@ -49,16 +49,20 @@
      */
     public function provideListeners(ListenerAcceptorInterface $listener)
     {
-        $listener->addListener(NotificationSent::class, function ($e) {
+        $listener->addListener(NotificationSent::class, function ($e)
+        {
             $this->sent($e);
         });
-        $listener->addListener(NotificationDelivered::class, function ($e) {
+        $listener->addListener(NotificationDelivered::class, function ($e)
+        {
             $this->delivered($e);
         });
-        $listener->addListener(NotificationClicked::class, function ($e) {
+        $listener->addListener(NotificationClicked::class, function ($e)
+        {
             $this->clicked($e);
         });
-        $listener->addListener(NotificationFailed::class, function ($e) {
+        $listener->addListener(NotificationFailed::class, function ($e)
+        {
             $this->failed($e);
         });
 

src/Driver.php

Spacing +2 added lines, -2 removed lines

@@ -127,11 +127,11 @@
         foreach ($this->subscribers as $subscriber) {
             $provider = $subscriber->getProvider();
 
-            if (! $this->project->providerConnected($provider)) {
+            if ( ! $this->project->providerConnected($provider)) {
                 continue;
             }
 
-            if (! isset($partials[$provider])) {
+            if ( ! isset($partials[$provider])) {
                 $partials[$provider] = [];
             }
 

Braces +19 added lines, -9 removed lines

@@ -83,10 +83,14 @@ 
 
         $partials = $this->splitSubscribers();
 
-        foreach ($partials as $provider => $subscribers) {
-            try {
+        foreach ($partials as $provider => $subscribers)
+        {
+            try
+            {
                 $this->provider($provider)->send($this->notification, $subscribers);
-            } catch (\RuntimeException $e) {
+            }
+            catch (\RuntimeException $e)
+            {
                 static::emit('flush.exception', $e);
             }
         }
@@ -124,20 +128,24 @@ 
         $partials = [];
 
         /** @var Subscriber $subscriber */
-        foreach ($this->subscribers as $subscriber) {
+        foreach ($this->subscribers as $subscriber)
+        {
             $provider = $subscriber->getProvider();
 
-            if (! $this->project->providerConnected($provider)) {
+            if (! $this->project->providerConnected($provider))
+            {
                 continue;
             }
 
-            if (! isset($partials[$provider])) {
+            if (! isset($partials[$provider]))
+            {
                 $partials[$provider] = [];
             }
 
             $partials[$provider][] = $subscriber;
 
-            if ($this->payloadStorage) {
+            if ($this->payloadStorage)
+            {
                 $this->payloadStorage->assignNotificationToSubscriber($subscriber, $this->notification);
             }
         }
@@ -152,11 +160,13 @@ 
      */
     protected function validate()
     {
-        if (is_null($this->notification)) {
+        if (is_null($this->notification))
+        {
             throw new \RuntimeException("Notification wasn't set.");
         }
 
-        if (is_null($this->subscribers)) {
+        if (is_null($this->subscribers))
+        {
             throw new \RuntimeException('No subscribers set.');
         }
     }

src/Project.php

Spacing +2 added lines, -2 removed lines

@@ -57,7 +57,7 @@ 
      */
     public function getProvider($name)
     {
-        if (! $this->providerConnected($name)) {
+        if ( ! $this->providerConnected($name)) {
             throw new \RuntimeException("Unsupported provider '{$name}'");
         }
 
@@ -82,7 +82,7 @@ 
     {
         $providersFactory = new ProvidersFactory($this);
 
-        if (! empty($this->config['providers']) && is_array($this->config['providers'])) {
+        if ( ! empty($this->config['providers']) && is_array($this->config['providers'])) {
             foreach ($this->config['providers'] as $name => $options) {
                 $this->providers[$name] = $providersFactory->make($name, $options)->setProject($this);
             }

Braces +6 added lines, -3 removed lines

@@ -57,7 +57,8 @@ 
      */
     public function getProvider($name)
     {
-        if (! $this->providerConnected($name)) {
+        if (! $this->providerConnected($name))
+        {
             throw new \RuntimeException("Unsupported provider '{$name}'");
         }
 
@@ -82,8 +83,10 @@ 
     {
         $providersFactory = new ProvidersFactory($this);
 
-        if (! empty($this->config['providers']) && is_array($this->config['providers'])) {
-            foreach ($this->config['providers'] as $name => $options) {
+        if (! empty($this->config['providers']) && is_array($this->config['providers']))
+        {
+            foreach ($this->config['providers'] as $name => $options)
+            {
                 $this->providers[$name] = $providersFactory->make($name, $options)->setProject($this);
             }
         }

src/Apns/Payload.php

Braces +2 added lines, -1 removed lines

@@ -63,7 +63,8 @@
      */
     protected function limitString($value, $limit = 10, $end = '...')
     {
-        if (mb_strwidth($value, 'UTF-8') <= $limit) {
+        if (mb_strwidth($value, 'UTF-8') <= $limit)
+        {
             return $value;
         }
 

src/Apns/Package.php

Spacing +2 added lines, -2 removed lines

@@ -155,7 +155,7 @@ 
         $password = $this->certificate->getPassword();
 
         $certs = [];
-        if (! openssl_pkcs12_read($pkcs12, $certs, $password)) {
+        if ( ! openssl_pkcs12_read($pkcs12, $certs, $password)) {
             throw new \RuntimeException(openssl_error_string());
         }
 
@@ -171,7 +171,7 @@ 
         // Convert the signature from PEM to DER
         $signature_pem = file_get_contents($signaturePath);
         $matches = [];
-        if (! preg_match('~Content-Disposition:[^\n]+\s*?([A-Za-z0-9+=/\r\n]+)\s*?-----~', $signature_pem, $matches)) {
+        if ( ! preg_match('~Content-Disposition:[^\n]+\s*?([A-Za-z0-9+=/\r\n]+)\s*?-----~', $signature_pem, $matches)) {
             throw new \RuntimeException(openssl_error_string());
         }
 

Braces +10 added lines, -5 removed lines

@@ -74,12 +74,14 @@ 
     {
         $packagePath = $this->storage->getAdapter()->applyPathPrefix(static::PACKAGE_FILENAME);
 
-        if ($this->storage->exists(static::PACKAGE_FILENAME)) {
+        if ($this->storage->exists(static::PACKAGE_FILENAME))
+        {
             return $packagePath;
         }
 
         $this->zip = new \ZipArchive();
-        if ($this->zip->open($packagePath, \ZipArchive::CREATE) !== true) {
+        if ($this->zip->open($packagePath, \ZipArchive::CREATE) !== true)
+        {
             return false;
         }
 
@@ -104,7 +106,8 @@ 
      */
     protected function addIcons()
     {
-        foreach ($this->icons as $file) {
+        foreach ($this->icons as $file)
+        {
             $this->addFile('icon.iconset/' . $file, $file);
         }
     }
@@ -155,7 +158,8 @@ 
         $password = $this->certificate->getPassword();
 
         $certs = [];
-        if (! openssl_pkcs12_read($pkcs12, $certs, $password)) {
+        if (! openssl_pkcs12_read($pkcs12, $certs, $password))
+        {
             throw new \RuntimeException(openssl_error_string());
         }
 
@@ -171,7 +175,8 @@ 
         // Convert the signature from PEM to DER
         $signature_pem = file_get_contents($signaturePath);
         $matches = [];
-        if (! preg_match('~Content-Disposition:[^\n]+\s*?([A-Za-z0-9+=/\r\n]+)\s*?-----~', $signature_pem, $matches)) {
+        if (! preg_match('~Content-Disposition:[^\n]+\s*?([A-Za-z0-9+=/\r\n]+)\s*?-----~', $signature_pem, $matches))
+        {
             throw new \RuntimeException(openssl_error_string());
         }