umbrellio / php-table-sync

src/Integration/Laravel/TableSyncServiceProvider.php

Spacing +9 added lines, -9 removed lines

@@ -35,7 +35,7 @@ 
 
     public function configureChannel()
     {
-        $this->app->bind(ChannelContainer::class, function ($app) {
+        $this->app->bind(ChannelContainer::class, function($app) {
             $channel = new ChannelContainer($app->make(ConnectionContainer::class));
             $channel->setChannelOption(ConfigRepository::get('table_sync.channel'));
             return $channel;
@@ -84,7 +84,7 @@ 
 
     private function configurePublish(array $config): void
     {
-        $this->app->singleton(Publisher::class, function ($app) use ($config) {
+        $this->app->singleton(Publisher::class, function($app) use ($config) {
             if (isset($config['custom_publisher'])) {
                 return $app->make($config['custom_publisher']);
             }
@@ -94,7 +94,7 @@ 
             ]);
         });
 
-        $this->app->bind(Config\PublishMessage::class, function () use ($config) {
+        $this->app->bind(Config\PublishMessage::class, function() use ($config) {
             [
                 'appId' => $appId,
                 'headers' => $headers,
@@ -103,7 +103,7 @@ 
             return new Config\PublishMessage($appId, new AMQPTable($headers));
         });
 
-        $this->app->bind(Config\Publisher::class, function () use ($config) {
+        $this->app->bind(Config\Publisher::class, function() use ($config) {
             [
                 'exchangeName' => $exchange,
                 'confirmSelect' => $confirm,
@@ -115,12 +115,12 @@ 
 
     private function configureReceive(array $config): void
     {
-        $this->app->bind(MessageDataRetriever::class, function () use ($config) {
+        $this->app->bind(MessageDataRetriever::class, function() use ($config) {
             $config = $config['message_configs'] ?? [];
             return new MessageDataRetriever($config);
         });
 
-        $this->app->bind(Config\Consumer::class, function ($app) use ($config) {
+        $this->app->bind(Config\Consumer::class, function($app) use ($config) {
             $queue = $config['queue'] ?? '';
             $handler = $config['custom_received_message_handler'] ?? QueueReceivedMessageHandler::class;
             $microsecondsToSleep = $config['microseconds_to_sleep'];
@@ -130,7 +130,7 @@ 
 
         $pidPath = $config['pid_path'] ?? storage_path('table_sync.pid');
 
-        $this->app->bind(PidManager::class, function () use ($pidPath) {
+        $this->app->bind(PidManager::class, function() use ($pidPath) {
             return new PidManager($pidPath);
         });
 
@@ -140,7 +140,7 @@ 
     private function configureLogs(array $config): void
     {
         if (($logManager = $this->app->make('log')) instanceof LogManager) {
-            $this->app->singleton('table_sync.logger', function () use ($logManager, $config) {
+            $this->app->singleton('table_sync.logger', function() use ($logManager, $config) {
                 return $logManager->channel($config['channel']);
             });
         }
@@ -154,7 +154,7 @@ 
 
     private function configureConnection(): void
     {
-        $this->app->singleton(ConnectionContainer::class, function () {
+        $this->app->singleton(ConnectionContainer::class, function() {
             [
                 'host' => $host,
                 'port' => $port,

src/Integration/Laravel/InfluxDBServiceProvider.php

Spacing +3 added lines, -3 removed lines

@@ -26,11 +26,11 @@ 
         $this->mergeConfigFrom($this->telegrafConfigPath(), 'telegraf');
 
         if (($logManager = $this->app->make('log')) instanceof LogManager) {
-            $logManager->extend('influxdb', function ($app, array $config) {
+            $logManager->extend('influxdb', function($app, array $config) {
                 return (new InfluxDBLogChannel($app))($config);
             });
 
-            $logManager->extend('telegraf', function ($app, array $config) {
+            $logManager->extend('telegraf', function($app, array $config) {
                 return (new TelegrafLogChannel($app))($config);
             });
         }
@@ -38,7 +38,7 @@ 
 
     public function register()
     {
-        $this->app->singleton(InfluxDB::class, function ($app) {
+        $this->app->singleton(InfluxDB::class, function($app) {
             try {
                 $client = new InfluxClient(
                     config('influxdb.host'),

src/Integration/Laravel/Receive/MessageData/MessageDataRetriever.php

Spacing +3 added lines, -3 removed lines

@@ -74,7 +74,7 @@ 
     {
         $keys = array_keys($attributes);
 
-        $isArray = collect($keys)->every(function ($key) {
+        $isArray = collect($keys)->every(function($key) {
             return is_numeric($key);
         });
 
@@ -88,14 +88,14 @@ 
     ): array {
         $handler = $this->resolveAdditionalDataHandler($additionalDataHandlerClass);
 
-        return array_map(function (array $item) use ($handler, $message) {
+        return array_map(function(array $item) use ($handler, $message) {
             return $handler->handle($message, $item);
         }, $data);
     }
 
     private function overrideData(array $data, array $override): array
     {
-        return array_map(function (array $item) use ($override) {
+        return array_map(function(array $item) use ($override) {
             foreach ($override as $from => $to) {
                 $item[$to] = $item[$from];
                 unset($item[$from]);

src/Integration/Laravel/Receive/Upserter.php

Spacing +5 added lines, -5 removed lines

@@ -20,7 +20,7 @@ 
         $data = $this->addVersionToItems($messageData->getData(), $version);
 
         $columns = array_keys($data[0]);
-        $columnString = implode(',', array_map(function (string $column): string {
+        $columnString = implode(',', array_map(function(string $column): string {
             return "\"{$column}\"";
         }, $columns));
 
@@ -45,14 +45,14 @@ 
 
     private function addVersionToItems(array $items, float $version): array
     {
-        return array_map(function ($item) use ($version) {
+        return array_map(function($item) use ($version) {
             return array_merge($item, compact('version'));
         }, $items);
     }
 
     private function convertInsertValues(array $items): string
     {
-        $values = array_map(function (array $item) {
+        $values = array_map(function(array $item) {
             $item = $this->implodedPlaceholders($item);
             return "({$item})";
         }, $items);
@@ -62,7 +62,7 @@ 
 
     private function updateSpec(array $columns): string
     {
-        $values = array_map(function (string $column) {
+        $values = array_map(function(string $column) {
             return "\"{$column}\" = EXCLUDED.{$column}";
         }, $columns);
 
@@ -71,7 +71,7 @@ 
 
     private function implodedPlaceholders(array $items, string $placeholder = '?'): string
     {
-        return implode(',', array_map(function () use ($placeholder) {
+        return implode(',', array_map(function() use ($placeholder) {
             return $placeholder;
         }, $items));
     }

src/Integration/Laravel/Receive/Destroyer.php

Spacing +1 added lines, -1 removed lines

@@ -19,7 +19,7 @@
 
         $query = DB::table($message->getTable());
         foreach ($message->getData() as $itemData) {
-            $query->orWhere(function (Builder $builder) use ($message, $itemData) {
+            $query->orWhere(function(Builder $builder) use ($message, $itemData) {
                 $builder->where(Arr::only($itemData, $message->getTargetKeys()));
             });
         }

src/Integration/Laravel/Console/Commands/WorkCommand.php

Spacing +2 added lines, -2 removed lines

@@ -34,13 +34,13 @@
     {
         pcntl_async_signals(true);
 
-        pcntl_signal(SIGTERM, function () use ($consumer) {
+        pcntl_signal(SIGTERM, function() use ($consumer) {
             $this->line('Shutting down by SIGTERM.');
 
             $consumer->terminate();
         });
 
-        pcntl_signal(SIGINT, function () use ($consumer) {
+        pcntl_signal(SIGINT, function() use ($consumer) {
             $this->line('Shutting down by SIGINT');
 
             $consumer->terminate();

src/Monolog/Formatter/TableSyncFormatter.php

Spacing +2 added lines, -2 removed lines

@@ -62,7 +62,7 @@ 
     {
         $keys = array_keys($attributes);
 
-        $isArray = collect($keys)->every(function ($key) {
+        $isArray = collect($keys)->every(function($key) {
             return is_numeric($key);
         });
 
@@ -71,7 +71,7 @@ 
 
     private function addVersions(array $items, float $version): array
     {
-        return array_map(function ($item) use ($version) {
+        return array_map(function($item) use ($version) {
             return array_merge($item, compact('version'));
         }, $items);
     }