Skip to content

Commit 6381ba9

Browse files
committed
🎨
1 parent a6c7836 commit 6381ba9

File tree

60 files changed

+156
-167
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

60 files changed

+156
-167
lines changed

src/Agents/Registry.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,7 @@ public function toArray(): array
9797
->map(function (string|Agent $agent) {
9898
return $agent instanceof Agent ? $agent : $agent::make();
9999
})
100-
->map(function (Agent $agent) {
100+
->map(function (Agent $agent): array {
101101
return [
102102
'id' => $agent->getId(),
103103
'name' => $agent->getName(),

src/Http/Controllers/AgentsController.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -99,9 +99,9 @@ public function stream(string $agent, Request $request): StreamedResponse
9999
messages: $messages,
100100
input: $request->input('input', []),
101101
config: new RuntimeConfig(
102+
tools: $tools->all(),
102103
// temporary hack to get a unique thread id for the session
103104
threadId: $request->input('id') . '-' . Arr::get($request->collect('messages')->first(), 'id', ''),
104-
tools: $tools->all(),
105105
),
106106
);
107107

src/SDK/OpenAI/Data/Responses/Meta.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ public static function from(array $payload): self
2525

2626
$filteredMetadata = array_filter(
2727
$payload,
28-
static fn (mixed $value, string $key): bool =>
28+
static fn(mixed $value, string $key): bool =>
2929
str_starts_with($key, 'openai-') || str_starts_with($key, 'x-'),
3030
ARRAY_FILTER_USE_BOTH,
3131
);

src/SDK/OpenAI/Data/Responses/OutputItems/ReasoningOutputItem.php

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,6 @@
44

55
namespace Cortex\SDK\OpenAI\Data\Responses\OutputItems;
66

7-
use Illuminate\Support\Arr;
87
use Cortex\SDK\OpenAI\Contracts\OutputItem;
98
use Cortex\SDK\OpenAI\Data\Responses\Reasoning\ReasoningText;
109
use Cortex\SDK\OpenAI\Data\Responses\Reasoning\ReasoningSummaryText;
@@ -29,21 +28,21 @@ public function __construct(
2928
public static function from(array $payload): self
3029
{
3130
$summaries = array_map(
32-
fn(array $summary) => ReasoningSummaryText::from($summary),
33-
$payload['summary'] ?? []
31+
ReasoningSummaryText::from(...),
32+
$payload['summary'] ?? [],
3433
);
3534

3635
$contents = array_map(
37-
fn(array $content) => ReasoningText::from($content),
38-
$payload['content'] ?? []
36+
ReasoningText::from(...),
37+
$payload['content'] ?? [],
3938
);
4039

4140
return new self(
4241
id: $payload['id'],
4342
summary: $summaries,
4443
content: $contents,
45-
encryptedContent: $payload['encrypted_content'] ?? null,
4644
status: $payload['status'] ?? 'completed',
45+
encryptedContent: $payload['encrypted_content'] ?? null,
4746
);
4847
}
4948
}

src/SDK/OpenAI/Data/Responses/Response.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,7 @@ public function setMeta(Meta $meta): self
9999
return $this;
100100
}
101101

102-
public function getResponse(): ?Response
102+
public function getResponse(): ?self
103103
{
104104
return $this->response;
105105
}

src/SDK/OpenAI/Data/Responses/ResponseStream.php

Lines changed: 37 additions & 38 deletions
Original file line numberDiff line numberDiff line change
@@ -8,58 +8,57 @@
88
use IteratorAggregate;
99
use Saloon\Http\Response;
1010
use Psr\Http\Message\StreamInterface;
11-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\Done;
11+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\Error;
1212
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\Unknown;
13+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseFailed;
14+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseQueued;
1315
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseCreated;
14-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseInProgress;
1516
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseCompleted;
16-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseFailed;
1717
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseIncomplete;
18-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseOutputItemAdded;
18+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseInProgress;
19+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseRefusalDone;
20+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseRefusalDelta;
21+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseMcpCallFailed;
1922
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseOutputItemDone;
20-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseContentPartAdded;
23+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseOutputTextDone;
2124
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseContentPartDone;
25+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseOutputItemAdded;
2226
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseOutputTextDelta;
23-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseOutputTextDone;
24-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseRefusalDelta;
25-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseRefusalDone;
26-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseFunctionCallArgumentsDelta;
27-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseFunctionCallArgumentsDone;
28-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseFileSearchCallInProgress;
29-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseFileSearchCallSearching;
27+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseContentPartAdded;
28+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseMcpCallCompleted;
29+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseMcpCallInProgress;
30+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseReasoningTextDone;
31+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseMcpListToolsFailed;
32+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseReasoningTextDelta;
33+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseMcpCallArgumentsDone;
34+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseMcpCallArgumentsDelta;
35+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseMcpListToolsCompleted;
36+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseMcpListToolsInProgress;
37+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseWebSearchCallCompleted;
38+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseWebSearchCallSearching;
3039
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseFileSearchCallCompleted;
40+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseFileSearchCallSearching;
3141
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseWebSearchCallInProgress;
32-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseWebSearchCallSearching;
33-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseWebSearchCallCompleted;
42+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseFileSearchCallInProgress;
43+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseReasoningContentPartDone;
44+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseReasoningSummaryPartDone;
45+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseReasoningSummaryTextDone;
46+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseFunctionCallArgumentsDone;
47+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseOutputTextAnnotationAdded;
48+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseReasoningContentPartAdded;
3449
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseReasoningSummaryPartAdded;
3550
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseReasoningSummaryTextDelta;
36-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseReasoningSummaryTextDone;
37-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseReasoningTextDelta;
38-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseReasoningTextDone;
39-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseImageGenerationCallInProgress;
40-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseImageGenerationCallGenerating;
41-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseImageGenerationCallPartialImage;
51+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseFunctionCallArgumentsDelta;
52+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseCodeInterpreterCallCodeDone;
53+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseCodeInterpreterCallCodeDelta;
54+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseCodeInterpreterCallCompleted;
55+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseCodeInterpreterCallExecuting;
4256
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseImageGenerationCallCompleted;
4357
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseCodeInterpreterCallInProgress;
44-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseCodeInterpreterCallExecuting;
45-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseCodeInterpreterCallCompleted;
46-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseMcpCallInProgress;
47-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseMcpCallCompleted;
48-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseMcpCallFailed;
49-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseQueued;
50-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseOutputTextAnnotationAdded;
51-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseReasoningSummaryPartDone;
52-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseReasoningContentPartAdded;
53-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseReasoningContentPartDone;
58+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseImageGenerationCallGenerating;
59+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseImageGenerationCallInProgress;
5460
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseCodeInterpreterCallInterpreting;
55-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseCodeInterpreterCallCodeDelta;
56-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseCodeInterpreterCallCodeDone;
57-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseMcpCallArgumentsDelta;
58-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseMcpCallArgumentsDone;
59-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseMcpListToolsInProgress;
60-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseMcpListToolsCompleted;
61-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseMcpListToolsFailed;
62-
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\Error;
61+
use Cortex\SDK\OpenAI\Data\Responses\Streaming\Events\ResponseImageGenerationCallPartialImage;
6362

6463
/**
6564
* @implements IteratorAggregate<int, \Cortex\SDK\OpenAI\Contracts\StreamEvent>

src/SDK/OpenAI/Data/Responses/Streaming/Events/Error.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,8 @@ public function __construct(
1717
*/
1818
public static function from(array $payload): self
1919
{
20-
return (new self(
20+
return new self(
2121
error: $payload['error'],
22-
))->setRaw($payload);
22+
)->setRaw($payload);
2323
}
2424
}

src/SDK/OpenAI/Data/Responses/Streaming/Events/ResponseCodeInterpreterCallCodeDelta.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,10 +19,10 @@ public function __construct(
1919
*/
2020
public static function from(array $payload): self
2121
{
22-
return (new self(
22+
return new self(
2323
itemId: $payload['item_id'],
2424
outputIndex: $payload['output_index'],
2525
delta: $payload['delta'],
26-
))->setRaw($payload);
26+
)->setRaw($payload);
2727
}
2828
}

src/SDK/OpenAI/Data/Responses/Streaming/Events/ResponseCodeInterpreterCallCodeDone.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,10 +19,10 @@ public function __construct(
1919
*/
2020
public static function from(array $payload): self
2121
{
22-
return (new self(
22+
return new self(
2323
itemId: $payload['item_id'],
2424
outputIndex: $payload['output_index'],
2525
code: $payload['code'],
26-
))->setRaw($payload);
26+
)->setRaw($payload);
2727
}
2828
}

src/SDK/OpenAI/Data/Responses/Streaming/Events/ResponseCodeInterpreterCallCompleted.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,10 +19,10 @@ public function __construct(
1919
*/
2020
public static function from(array $payload): self
2121
{
22-
return (new self(
22+
return new self(
2323
itemId: $payload['item_id'],
2424
outputIndex: $payload['output_index'],
2525
outputs: $payload['outputs'] ?? [],
26-
))->setRaw($payload);
26+
)->setRaw($payload);
2727
}
2828
}

0 commit comments

Comments
 (0)