Sync upstream updates: read replica commit IDs, duration handlers and MCP OAuth discovery

.github/workflows/databases.yml

@@ -67,6 +67,7 @@ jobs:
     services:
       mysql:
         image: mysql:8.4
+        command: --gtid-mode=ON --enforce-gtid-consistency=ON
         env:
           MYSQL_ROOT_PASSWORD: password
           MYSQL_DATABASE: testing
@@ -167,6 +168,7 @@ jobs:
     services:
       mariadb:
         image: mariadb:10.11
+        command: --log-bin --server-id=1
         env:
           MARIADB_ROOT_PASSWORD: password
           MARIADB_DATABASE: testing
@@ -214,6 +216,7 @@ jobs:
     services:
       mariadb:
         image: mariadb:11
+        command: --log-bin --server-id=1
         env:
           MARIADB_ROOT_PASSWORD: password
           MARIADB_DATABASE: testing
@@ -261,6 +264,7 @@ jobs:
     services:
       mariadb:
         image: mariadb:12.3
+        command: --log-bin --server-id=1
         env:
           MARIADB_ROOT_PASSWORD: password
           MARIADB_DATABASE: testing

AGENTS.md

@@ -121,11 +121,11 @@ Anything found follows When to Stop and Report — "the task didn't ask me to fi
 
 Do not routinely run formatting or PHPStan during edits. Run targeted PHPStan earlier only when investigating a typing issue or when its feedback is needed to guide implementation.
 
-**At the end of a coherent implementation slice**, run `composer analyse` and the affected tests, in that order. Use PHPUnit for one test file or `composer test:parallel -- --processes=4 tests/PackageName` for multiple files. Use `--filter` when needed to narrow the selection.
+At the end of a coherent implementation slice, run `composer analyse` and any outstanding tests needed to verify the changed behavior and affected callers. Use PHPUnit for one test file or `composer test:parallel -- --processes=4` for multiple files, selecting the relevant files or using `--filter`. Reuse passing results unless subsequent changes invalidate them.
 
 Run `composer lint:fix` before a scheduled code review or commit checkpoint, not after individual changes within a batch.
 
-Run the full test suite only when the change has framework-wide impact. In that case, use `composer fix`, which includes formatting, analysis and all test suites; do not run those checks separately first. For focused changes, include separate Testbench or dogfood checks when the changed behavior affects those workflows.
+Run only the local tests needed to give strong confidence in the change. Leave full suites and CI matrices to CI, unless a specific unresolved issue requires broader local testing.
 
 After a failure or review correction, fix the cause, repeat only checks affected by the correction, and finish any outstanding verification. Do not restart the entire sequence merely because another review round occurred.
 

src/ai/src/Gateway/Concerns/AnswersQuestions.php

@@ -65,14 +65,14 @@ public function classify(
             }
         }
 
-        return new ClassificationResponse(
+        return (new ClassificationResponse(
             $answers,
             new TextUsage(
                 inputTokens: $data['usage']['input_tokens'] ?? 0,
                 outputTokens: $data['usage']['output_tokens'] ?? 0,
             ),
             new Meta($provider->name(), $this->answeringModel($data, $model)),
-        );
+        ))->withRawResponse($response);
     }
 
     /**

src/ai/src/Gateway/Concerns/HandlesFailoverErrors.php

@@ -41,16 +41,16 @@ protected function withErrorHandling(string $providerName, Closure $callback): m
         } catch (RequestException $requestException) {
             $status = $requestException->response->status();
 
-            if ($status === 429) {
-                throw RateLimitedException::forProvider(
+            if ($this->isInsufficientCredits($requestException)) {
+                throw InsufficientCreditsException::forProvider(
                     $providerName,
                     $requestException->getCode(),
                     $requestException
                 );
             }
 
-            if ($status === 402) {
-                throw InsufficientCreditsException::forProvider(
+            if ($status === 429) {
+                throw RateLimitedException::forProvider(
                     $providerName,
                     $requestException->getCode(),
                     $requestException
@@ -65,8 +65,10 @@ protected function withErrorHandling(string $providerName, Closure $callback): m
                 );
             }
 
-            if ($patterns = $this->insufficientCreditPatterns()) {
-                $message = strtolower($requestException->response->json('error.message', ''));
+            $message = $requestException->response->json('error.message');
+
+            if (is_string($message) && $patterns = $this->insufficientCreditPatterns()) {
+                $message = strtolower($message);
 
                 foreach ($patterns as $pattern) {
                     if (str_contains($message, (string) $pattern)) {
@@ -92,6 +94,10 @@ protected function retryAfterSeconds(Throwable $exception): ?int
             return null;
         }
 
+        if ($this->isInsufficientCredits($exception)) {
+            return null;
+        }
+
         $status = $exception->response->status();
 
         if ($status !== 429 && ! in_array($status, $this->overloadedStatusCodes(), true)) {
@@ -103,6 +109,27 @@ protected function retryAfterSeconds(Throwable $exception): ?int
         return ctype_digit($retryAfter) && (int) $retryAfter <= 10 ? (int) $retryAfter : null;
     }
 
+    /**
+     * Determine if the response is a 402, or a 429 insufficient credits or quota error rather than a rate limit.
+     */
+    protected function isInsufficientCredits(RequestException $exception): bool
+    {
+        $status = $exception->response->status();
+
+        if ($status === 402) {
+            return true;
+        }
+
+        if ($status !== 429) {
+            return false;
+        }
+
+        $codes = $this->insufficientCreditCodes();
+
+        return in_array($exception->response->json('error.code'), $codes, true)
+            || in_array($exception->response->json('error.type'), $codes, true);
+    }
+
     /**
      * Get the status codes that indicate a provider is transiently unavailable and the request should fail over.
      *
@@ -122,4 +149,21 @@ protected function insufficientCreditPatterns(): array
     {
         return [];
     }
+
+    /**
+     * Get the error codes or types that indicate insufficient credits or quota on a 429 response.
+     *
+     * @return list<string>
+     */
+    protected function insufficientCreditCodes(): array
+    {
+        // OpenAI sends these with a 429 status, and may still use "insufficient_quota" as the error type.
+        return [
+            'insufficient_quota',
+            'credit_balance_exhausted',
+            'organization_spend_limit_exceeded',
+            'project_spend_limit_exceeded',
+            'organization_usage_limit_exceeded',
+        ];
+    }
 }

src/ai/src/Gateway/OpenAi/OpenAiClassificationGateway.php

@@ -73,14 +73,14 @@ public function classify(
             }
         }
 
-        return new ClassificationResponse(
+        return (new ClassificationResponse(
             $answers,
             new TextUsage(
                 inputTokens: $data['usage']['input_tokens'] ?? 0,
                 outputTokens: $data['usage']['output_tokens'] ?? 0,
             ),
             new Meta($provider->name(), $data['model'] ?? $model),
-        );
+        ))->withRawResponse($response);
     }
 
     /**

src/ai/src/Providers/MistralProvider.php

@@ -90,7 +90,7 @@ public function transcriptionGateway(): TranscriptionGateway
      */
     public function defaultTextModel(): string
     {
-        return $this->config['models']['text']['default'] ?? 'mistral-large-2512';
+        return $this->config['models']['text']['default'] ?? 'mistral-large-4-0';
     }
 
     /**
@@ -106,23 +106,23 @@ public function cheapestTextModel(): string
      */
     public function smartestTextModel(): string
     {
-        return $this->config['models']['text']['smartest'] ?? 'mistral-medium-3-5';
+        return $this->config['models']['text']['smartest'] ?? 'mistral-large-4-0';
     }
 
     /**
      * Get the name of the default audio (TTS) model.
      */
     public function defaultAudioModel(): string
     {
-        return $this->config['models']['audio']['default'] ?? 'voxtral-mini-tts-2603';
+        return $this->config['models']['audio']['default'] ?? 'voxtral-mini-tts-3-0';
     }
 
     /**
      * Get the name of the default transcription (STT) model.
      */
     public function defaultTranscriptionModel(): string
     {
-        return $this->config['models']['transcription']['default'] ?? 'voxtral-mini-2602';
+        return $this->config['models']['transcription']['default'] ?? 'voxtral-mini-transcribe-3-0';
     }
 
     /**

src/ai/src/Responses/ClassificationResponse.php

@@ -6,6 +6,7 @@
 
 use ArrayAccess;
 use Countable;
+use Hypervel\Ai\Responses\Concerns\HasRawResponse;
 use Hypervel\Ai\Responses\Data\Answer;
 use Hypervel\Ai\Responses\Data\Meta;
 use Hypervel\Ai\Responses\Data\TextUsage;
@@ -19,6 +20,8 @@
 
 class ClassificationResponse implements Arrayable, ArrayAccess, Countable, IteratorAggregate, JsonSerializable
 {
+    use HasRawResponse;
+
     /**
      * Create a new classification response instance.
      *

src/ai/src/Streaming/Protocols/AgentUserInteractionProtocol.php

@@ -234,16 +234,18 @@ protected function stepFinishedPart(): array
      */
     protected function runFinishedPart(array $attributes = []): array
     {
-        $assistantMessageId = $this->response?->assistantMessageId;
-        $userMessageId = $this->response?->userMessageId;
+        $messageIds = array_filter([
+            'messageId' => $this->response?->assistantMessageId,
+            'userMessageId' => $this->response?->userMessageId,
+        ]);
 
         return [
             'type' => 'RUN_FINISHED',
             'threadId' => $this->threadId,
             'runId' => $this->runId,
-            ...($assistantMessageId ? ['messageId' => $assistantMessageId] : []),
-            ...($userMessageId ? ['userMessageId' => $userMessageId] : []),
+            ...$messageIds,
             ...$attributes,
+            ...($messageIds ? ['metadata' => [...($attributes['metadata'] ?? []), ...$messageIds]] : []),
         ];
     }
 

src/broadcasting/src/Broadcasters/PusherBroadcaster.php

@@ -133,12 +133,18 @@ public function broadcast(array $channels, string $event, array $payload = []):
 
         $parameters = $socket !== null ? ['socket_id' => $socket] : [];
 
-        $channels = new Collection($this->formatChannels($channels));
+        [$encryptedChannels, $channels] = (new Collection($this->formatChannels($channels)))
+            ->partition(fn ($channel) => str_starts_with($channel, 'private-encrypted-'));
 
         try {
             $channels->chunk(100)->each(function ($channels) use ($event, $payload, $parameters) {
                 ConnectionResolver::releaseIdleConnections();
-                $this->pusher->trigger($channels->toArray(), $event, $payload, $parameters);
+                $this->pusher->trigger($channels->values()->all(), $event, $payload, $parameters);
+            });
+
+            $encryptedChannels->each(function ($channel) use ($event, $payload, $parameters) {
+                ConnectionResolver::releaseIdleConnections();
+                $this->pusher->trigger([$channel], $event, $payload, $parameters);
             });
         } catch (ApiErrorException $e) {
             throw new BroadcastException(

src/collections/src/helpers.php

@@ -91,9 +91,10 @@ function data_get($target, $key, $default = null)
             }
 
             if ($segment === '*') {
+                // Unlike upstream, wildcards also select stdClass properties, since they may target any key of an array or object.
                 if ($target instanceof Collection) {
                     $target = $target->all();
-                } elseif (! is_iterable($target)) {
+                } elseif (! is_iterable($target) && ! $target instanceof stdClass) {
                     return value($default);
                 }
 
@@ -143,7 +144,8 @@ function data_set(&$target, $key, $value, $overwrite = true)
         $segments = is_array($key) ? $key : explode('.', (string) $key);
 
         if (($segment = array_shift($segments)) === '*') {
-            if (! Arr::accessible($target)) {
+            // Unlike upstream, wildcards also set stdClass properties instead of replacing the object with an array.
+            if (! Arr::accessible($target) && ! $target instanceof stdClass) {
                 $target = [];
             }
 
@@ -202,7 +204,8 @@ function data_forget(&$target, $key)
     {
         $segments = is_array($key) ? $key : explode('.', (string) $key);
 
-        if (($segment = array_shift($segments)) === '*' && Arr::accessible($target)) {
+        // Unlike upstream, wildcards also remove values from stdClass properties.
+        if (($segment = array_shift($segments)) === '*' && (Arr::accessible($target) || $target instanceof stdClass)) {
             if ($segments) {
                 foreach ($target as &$inner) {
                     data_forget($inner, $segments);
@@ -217,7 +220,8 @@ function data_forget(&$target, $key)
         } elseif (is_object($target)) {
             if ($segments && isset($target->{$segment})) {
                 data_forget($target->{$segment}, $segments);
-            } elseif (isset($target->{$segment})) {
+            } elseif (! $segments) {
+                // Unlike upstream, this does not check isset(), so null properties are removed too.
                 unset($target->{$segment});
             }
         }

src/console/src/Commands/ScheduleRunCommand.php

@@ -448,8 +448,10 @@ protected function runSingleServerEvent(Event $event, CarbonInterface $startedAt
         if ($this->schedule->serverShouldRun($event, $startedAt)) {
             $this->runEvent($event);
         } else {
+            $this->dispatchTaskSkipped($event);
+
             $this->components->info(sprintf(
-                'Skipping [%s], as command already run on another server.',
+                'Skipping [%s] because the command already ran on another server.',
                 $event->getSummaryForDisplay()
             ));
         }
@@ -488,16 +490,15 @@ protected function runEvent(Event $event): void
 
         $failed = false;
         $skippedBecauseOverlapping = false;
+        $runtime = null;
 
         try {
             $event->run($this->hypervel);
+            $runtime = round(microtime(true) - $start, 2);
             $skippedBecauseOverlapping = $event->wasSkippedDueToOverlapping();
 
             if ($this->dispatcher->hasListeners(ScheduledTaskFinished::class)) {
-                $this->dispatcher->dispatch(new ScheduledTaskFinished(
-                    $event,
-                    round(microtime(true) - $start, 2)
-                ));
+                $this->dispatcher->dispatch(new ScheduledTaskFinished($event, $runtime));
             }
 
             $this->eventsRan = true;
@@ -524,10 +525,12 @@ protected function runEvent(Event $event): void
             CoroutineContext::set(self::TASK_FAILED_CONTEXT_KEY, true);
 
             if ($this->dispatcher->hasListeners(ScheduledTaskFailed::class)) {
+                // Unlike upstream, a run that fails after the task finished (a failing exit code or a throwing
+                // Finished listener) reports the task's own runtime, without the time its Finished listeners took.
                 $this->dispatcher->dispatch(new ScheduledTaskFailed(
                     $event,
                     $e,
-                    round(microtime(true) - $start, 2)
+                    $runtime ?? round(microtime(true) - $start, 2)
                 ));
             }