Run formatter

Author: JasonTame

src/Exceptions/LangGraphException.php

@@ -13,7 +13,9 @@
 class LangGraphException extends Exception
 {
     protected ?ResponseInterface $response = null;
+
     protected array $responseData = [];
+
     protected ?string $errorType = null;
 
     public function __construct(
@@ -59,6 +61,7 @@ public function getErrorType(): ?string
     public function setErrorType(?string $errorType): self
     {
         $this->errorType = $errorType;
+
         return $this;
     }
 

src/Http/Client.php

@@ -23,7 +23,9 @@
 class Client
 {
     private GuzzleClient $client;
+
     private array $config;
+
     private int $retryCount = 0;
 
     public function __construct(array $config = [])
@@ -59,7 +61,7 @@ private function createClient(): GuzzleClient
         ));
 
         return new GuzzleClient([
-            'base_uri' => rtrim($this->config['base_url'], '/') . '/',
+            'base_uri' => rtrim($this->config['base_url'], '/').'/',
             'timeout' => $this->config['timeout'],
             'connect_timeout' => $this->config['connect_timeout'],
             'verify' => $this->config['verify_ssl'],
@@ -220,7 +222,7 @@ public function stream(string $path, string $method = 'GET', array $data = [], a
                 RequestOptions::STREAM => true,
             ];
 
-            if ($method === 'POST' && !empty($data)) {
+            if ($method === 'POST' && ! empty($data)) {
                 $options[RequestOptions::JSON] = $data;
             }
 
@@ -240,7 +242,7 @@ private function parseEventStream(StreamInterface $body): \Generator
     {
         $buffer = '';
 
-        while (!$body->eof()) {
+        while (! $body->eof()) {
             $chunk = $body->read(1024);
             if ($chunk === '') {
                 continue;
@@ -261,7 +263,7 @@ private function parseEventStream(StreamInterface $body): \Generator
         }
 
         // Process any remaining buffer
-        if (!empty($buffer)) {
+        if (! empty($buffer)) {
             $event = $this->parseEventStreamLine($buffer);
             if ($event !== null) {
                 yield $event;
@@ -323,7 +325,7 @@ private function parseResponse(ResponseInterface $response): array
 
         if (json_last_error() !== JSON_ERROR_NONE) {
             throw new LangGraphException(
-                'Failed to decode JSON response: ' . json_last_error_msg(),
+                'Failed to decode JSON response: '.json_last_error_msg(),
                 $response->getStatusCode(),
                 null,
                 $response

src/LanggraphPlatform.php

@@ -6,21 +6,26 @@
 
 use LangGraphPlatform\Http\Client as HttpClient;
 use LangGraphPlatform\Resources\AssistantsClient;
-use LangGraphPlatform\Resources\ThreadsClient;
-use LangGraphPlatform\Resources\RunsClient;
 use LangGraphPlatform\Resources\CronsClient;
+use LangGraphPlatform\Resources\RunsClient;
 use LangGraphPlatform\Resources\StoreClient;
+use LangGraphPlatform\Resources\ThreadsClient;
 
 /**
  * Main LangGraph Platform SDK client.
  */
 class LangGraphPlatform
 {
     private HttpClient $httpClient;
+
     private AssistantsClient $assistants;
+
     private ThreadsClient $threads;
+
     private RunsClient $runs;
+
     private CronsClient $crons;
+
     private StoreClient $store;
 
     public function __construct(?array $config = null)
@@ -100,6 +105,7 @@ public function getHttpClient(): HttpClient
     public function configure(array $config): self
     {
         $this->httpClient->configure($config);
+
         return $this;
     }
 

src/LanggraphPlatformServiceProvider.php

@@ -29,7 +29,7 @@ public function registeringPackage(): void
     {
         // Register the main LangGraph Platform client as a singleton
         $this->app->singleton(LangGraphPlatform::class, function ($app) {
-            return new LangGraphPlatform();
+            return new LangGraphPlatform;
         });
 
         // Bind the client to the container using the interface if needed

src/Resources/RunsClient.php

@@ -88,9 +88,9 @@ public function search(array $params = []): array
     public function stream(string $threadId, array $params, ?callable $callback = null): \Generator
     {
         $streamParams = array_merge($params, ['stream' => true]);
-        
+
         $stream = $this->httpClient->stream("threads/{$threadId}/runs", 'POST', $streamParams);
-        
+
         foreach ($stream as $event) {
             if ($callback !== null) {
                 $callback($event);
@@ -105,9 +105,9 @@ public function stream(string $threadId, array $params, ?callable $callback = nu
     public function streamStateless(array $params, ?callable $callback = null): \Generator
     {
         $streamParams = array_merge($params, ['stream' => true]);
-        
+
         $stream = $this->httpClient->stream('runs', 'POST', $streamParams);
-        
+
         foreach ($stream as $event) {
             if ($callback !== null) {
                 $callback($event);
@@ -126,7 +126,7 @@ public function wait(string $threadId, array $params, int $pollInterval = 1): ar
 
         while (true) {
             $currentRun = $this->get($threadId, $runId);
-            
+
             if (in_array($currentRun['status'], ['success', 'error', 'cancelled', 'failed'])) {
                 return $currentRun;
             }
@@ -146,7 +146,7 @@ public function waitStateless(array $params, int $pollInterval = 1): array
         while (true) {
             // For stateless runs, we need to check via a different endpoint
             $currentRun = $this->getStateless($runId);
-            
+
             if (in_array($currentRun['status'], ['success', 'error', 'cancelled', 'failed'])) {
                 return $currentRun;
             }
@@ -177,12 +177,12 @@ public function join(string $threadId, string $runId): array
     public function joinStream(string $threadId, string $runId, ?callable $callback = null): \Generator
     {
         $stream = $this->httpClient->stream("threads/{$threadId}/runs/{$runId}/stream", 'GET');
-        
+
         foreach ($stream as $event) {
             if ($callback !== null) {
                 $callback($event);
             }
             yield $event;
         }
     }
-} 
+}

src/Resources/StoreClient.php

@@ -137,6 +137,7 @@ public function exists(string $namespace, string $key): bool
     {
         try {
             $this->get($namespace, $key);
+
             return true;
         } catch (\Exception $e) {
             return false;
@@ -156,6 +157,7 @@ public function getMultiple(string $namespace, array $keys): array
                 $items[$key] = null;
             }
         }
+
         return $items;
     }
 
@@ -168,6 +170,7 @@ public function putMultiple(string $namespace, array $items): array
         foreach ($items as $key => $value) {
             $results[$key] = $this->put($namespace, $key, $value);
         }
+
         return $results;
     }
 }