Merge branch '8.x'

# Conflicts:
#	CHANGELOG-6.x.md
#	CHANGELOG-8.x.md
#	src/Illuminate/Broadcasting/Broadcasters/AblyBroadcaster.php
#	src/Illuminate/Collections/Traits/EnumeratesValues.php
#	src/Illuminate/Database/DBAL/TimestampType.php
#	src/Illuminate/Database/Eloquent/Builder.php
#	src/Illuminate/Filesystem/FilesystemAdapter.php
#	src/Illuminate/Foundation/Application.php
#	src/Illuminate/Mail/Transport/MailgunTransport.php
#	src/Illuminate/Mail/Transport/SesTransport.php
#	tests/Http/HttpClientTest.php

Author: driesvints

src/Illuminate/Broadcasting/Broadcasters/AblyBroadcaster.php

@@ -4,6 +4,7 @@
 
 use Ably\AblyRest;
 use Ably\Exceptions\AblyException;
+use Ably\Models\Message as AblyMessage;
 use Illuminate\Broadcasting\BroadcastException;
 use Illuminate\Support\Str;
 use Symfony\Component\HttpKernel\Exception\AccessDeniedHttpException;
@@ -126,7 +127,9 @@ public function broadcast(array $channels, $event, array $payload = [])
     {
         try {
             foreach ($this->formatChannels($channels) as $channel) {
-                $this->ably->channels->get($channel)->publish($event, $payload);
+                $this->ably->channels->get($channel)->publish(
+                    $this->buildAblyMessage($event, $payload)
+                );
             }
         } catch (AblyException $e) {
             throw new BroadcastException(
@@ -135,6 +138,22 @@ public function broadcast(array $channels, $event, array $payload = [])
         }
     }
 
+    /**
+     * Build an Ably message object for broadcasting.
+     *
+     * @param  string  $event
+     * @param  array  $payload
+     * @return \Ably\Models\Message
+     */
+    protected function buildAblyMessage($event, array $payload = [])
+    {
+        return tap(new AblyMessage, function ($message) use ($event, $payload) {
+            $message->name = $event;
+            $message->data = $payload;
+            $message->connectionKey = data_get($payload, 'socket');
+        });
+    }
+
     /**
      * Return true if the channel is protected by authentication.
      *

src/Illuminate/Cache/Repository.php

@@ -578,7 +578,7 @@ public function getStore()
     /**
      * Fire an event for this cache instance.
      *
-     * @param  string  $event
+     * @param  object|string  $event
      * @return void
      */
     protected function event($event)

src/Illuminate/Cache/TaggedCache.php

@@ -105,7 +105,7 @@ public function taggedItemKey($key)
     /**
      * Fire an event for this cache instance.
      *
-     * @param  string  $event
+     * @param  \Illuminate\Cache\Events\CacheEvent  $event
      * @return void
      */
     protected function event($event)

src/Illuminate/Collections/Collection.php

@@ -1350,7 +1350,7 @@ protected function sortByMany(array $comparisons = [])
 
                 $result = 0;
 
-                if (is_callable($prop)) {
+                if (! is_string($prop) && is_callable($prop)) {
                     $result = $prop($a, $b);
                 } else {
                     $values = [data_get($a, $prop), data_get($b, $prop)];

src/Illuminate/Collections/Traits/EnumeratesValues.php

@@ -720,6 +720,22 @@ public function pipeInto($class)
         return new $class($this);
     }
 
+    /**
+     * Pass the collection through a series of callable pipes and return the result.
+     *
+     * @param  array<callable>  $pipes
+     * @return mixed
+     */
+    public function pipeThrough($pipes)
+    {
+        return static::make($pipes)->reduce(
+            function ($carry, $pipe) {
+                return $pipe($carry);
+            },
+            $this,
+        );
+    }
+
     /**
      * Reduce the collection to a single value.
      *

src/Illuminate/Console/Application.php

@@ -218,7 +218,7 @@ protected function parseCommand($command, $parameters)
             $input = new ArrayInput($parameters);
         }
 
-        return [$command, $input ?? null];
+        return [$command, $input];
     }
 
     /**

src/Illuminate/Console/Scheduling/ScheduleClearCacheCommand.php

@@ -0,0 +1,47 @@
+<?php
+
+namespace Illuminate\Console\Scheduling;
+
+use Illuminate\Console\Command;
+
+class ScheduleClearCacheCommand extends Command
+{
+    /**
+     * The console command name.
+     *
+     * @var string
+     */
+    protected $name = 'schedule:clear-cache';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = 'Delete the cached mutex files created by scheduler';
+
+    /**
+     * Execute the console command.
+     *
+     * @param  \Illuminate\Console\Scheduling\Schedule  $schedule
+     * @return void
+     */
+    public function handle(Schedule $schedule)
+    {
+        $mutexCleared = false;
+
+        foreach ($schedule->events($this->laravel) as $event) {
+            if ($event->mutex->exists($event)) {
+                $this->line('<info>Deleting mutex for:</info> '.$event->command);
+
+                $event->mutex->forget($event);
+
+                $mutexCleared = true;
+            }
+        }
+
+        if (! $mutexCleared) {
+            $this->info('No mutex files were found.');
+        }
+    }
+}

src/Illuminate/Container/BoundMethod.php

@@ -172,7 +172,15 @@ protected static function addDependencyForCallParameter($container, $parameter,
 
                 unset($parameters[$className]);
             } else {
-                $dependencies[] = $container->make($className);
+                if ($parameter->isVariadic()) {
+                    $variadicDependencies = $container->make($className);
+
+                    $dependencies = array_merge($dependencies, is_array($variadicDependencies)
+                                ? $variadicDependencies
+                                : [$variadicDependencies]);
+                } else {
+                    $dependencies[] = $container->make($className);
+                }
             }
         } elseif ($parameter->isDefaultValueAvailable()) {
             $dependencies[] = $parameter->getDefaultValue();

src/Illuminate/Database/Connection.php

@@ -5,6 +5,7 @@
 use Closure;
 use DateTimeInterface;
 use Doctrine\DBAL\Connection as DoctrineConnection;
+use Doctrine\DBAL\Types\Type;
 use Exception;
 use Illuminate\Contracts\Events\Dispatcher;
 use Illuminate\Database\Events\QueryExecuted;
@@ -21,6 +22,7 @@
 use LogicException;
 use PDO;
 use PDOStatement;
+use RuntimeException;
 
 class Connection implements ConnectionInterface
 {
@@ -1007,6 +1009,34 @@ public function getDoctrineConnection()
         return $this->doctrineConnection;
     }
 
+    /**
+     * Register a custom Doctrine mapping type.
+     *
+     * @param  string  $class
+     * @param  string  $name
+     * @param  string  $type
+     * @return void
+     *
+     * @throws \Doctrine\DBAL\DBALException
+     * @throws \RuntimeException
+     */
+    public function registerDoctrineType(string $class, string $name, string $type): void
+    {
+        if (! $this->isDoctrineAvailable()) {
+            throw new RuntimeException(
+                'Registering a custom Doctrine type requires Doctrine DBAL (doctrine/dbal).'
+            );
+        }
+
+        if (! Type::hasType($name)) {
+            Type::addType($name, $class);
+        }
+
+        $this->getDoctrineSchemaManager()
+            ->getDatabasePlatform()
+            ->registerDoctrineTypeMapping($type, $name);
+    }
+
     /**
      * Get the current PDO connection.
      *

src/Illuminate/Database/Console/DbCommand.php

@@ -67,8 +67,16 @@ public function getConnection()
         }
 
         if ($this->option('read')) {
+            if (is_array($connection['read']['host'])) {
+                $connection['read']['host'] = $connection['read']['host'][0];
+            }
+
             $connection = array_merge($connection, $connection['read']);
         } elseif ($this->option('write')) {
+            if (is_array($connection['write']['host'])) {
+                $connection['write']['host'] = $connection['write']['host'][0];
+            }
+
             $connection = array_merge($connection, $connection['write']);
         }