Notimatica / driver

src/Statistics.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 +3 added lines, -3 removed lines

@@ -136,11 +136,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] = [];
             }
 
@@ -202,7 +202,7 @@ 
      */
     protected function bootListeners()
     {
-        if (! is_null($this->statisticsStorage)) {
+        if ( ! is_null($this->statisticsStorage)) {
             static::$events->useListenerProvider($this->statisticsStorage);
         }
     }

Braces +21 added lines, -10 removed lines

@@ -92,10 +92,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);
             }
         }
@@ -133,20 +137,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,
@@ -165,11 +173,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.');
         }
     }
@@ -202,7 +212,8 @@ 
      */
     protected function bootListeners()
     {
-        if (! is_null($this->statisticsStorage)) {
+        if (! is_null($this->statisticsStorage))
+        {
             static::$events->useListenerProvider($this->statisticsStorage);
         }
     }

src/Providers/Firefox.php

Spacing +2 added lines, -2 removed lines

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