Notimatica / driver

src/Driver.php

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/StatisticsStorages/AbstractStorage.php

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/Project.php

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/Streamer.php

Braces +6 added lines, -3 removed lines

@@ -54,7 +54,8 @@ 
     {
         $length = strlen($binaryMessage);
 
-        if ($length > self::PAYLOAD_MAX_BYTES) {
+        if ($length > self::PAYLOAD_MAX_BYTES)
+        {
             throw new \InvalidArgumentException(
                 sprintf('The maximum size allowed for a notification payload is %s bytes; Apple Push Notification Service refuses any notification that exceeds this limit.', self::PAYLOAD_MAX_BYTES)
             );
@@ -70,7 +71,8 @@ 
      */
     protected function getApnsResource()
     {
-        if (! is_resource($this->apnsResource)) {
+        if (! is_resource($this->apnsResource))
+        {
             $this->apnsResource = $this->createStreamClient();
         }
 
@@ -114,7 +116,8 @@ 
      */
     public function close()
     {
-        if (is_resource($this->apnsResource)) {
+        if (is_resource($this->apnsResource))
+        {
             fclose($this->apnsResource);
         }
     }

src/Apns/Certificate.php

Braces +15 added lines, -6 removed lines

@@ -43,9 +43,12 @@ 
      */
     public function getP12Certificate()
     {
-        try {
+        try
+        {
             return $this->storage->get($this->paths['p12']);
-        } catch (\Exception $e) {
+        }
+        catch (\Exception $e)
+        {
             return '';
         }
     }
@@ -57,9 +60,12 @@ 
      */
     public function getPassword()
     {
-        try {
+        try
+        {
             return $this->storage->get($this->paths['password']);
-        } catch (\Exception $e) {
+        }
+        catch (\Exception $e)
+        {
             return '';
         }
     }
@@ -71,9 +77,12 @@ 
      */
     public function getPemCertificate()
     {
-        try {
+        try
+        {
             return $this->storage->get($this->paths['pem']);
-        } catch (\Exception $e) {
+        }
+        catch (\Exception $e)
+        {
             return '';
         }
     }

src/Providers/Chrome.php

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/Providers/Firefox.php

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/AbstractProvider.php

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), [