Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
73 commits
Select commit Hold shift + click to select a range
8685b53
feat(provider): add usage limits and retries
Aditya190803 Apr 17, 2026
9eff609
feat(provider): add usage limits and retries
Aditya190803 Apr 17, 2026
a19efe4
feat(provider): enhance rate limit handling and telemetry filtering
Aditya190803 Apr 17, 2026
ed12bb8
feat(migrations): rename and reorganize migration files for cleanup a…
Aditya190803 Apr 17, 2026
caf52c7
fix(migrations): remove leftover conflict markers
Aditya190803 Apr 17, 2026
0199fa3
feat(provider): add timestamp for usage limit checks and improve key …
Aditya190803 Apr 17, 2026
7d83cca
feat(provider): update latestSpawnedChild to async and improve window…
Aditya190803 Apr 17, 2026
b4551d6
Merge branch 'main' into feat/provider-usage-limits
Aditya190803 Apr 18, 2026
e5be35c
Enhance usage reset label formatting and update styles for provider c…
Aditya190803 Apr 18, 2026
1aeaa7a
Refactor ClaudeProvider and usage probe to enhance error handling and…
Aditya190803 Apr 18, 2026
c239261
Refactor ClaudeProvider to improve variable naming and enhance clarit…
Aditya190803 Apr 18, 2026
e82c5fc
feat: add provider usage limits schema and server-side persistence
Aditya190803 Apr 18, 2026
178e462
feat: implement OpenCode usage limits probing and display filtering
Aditya190803 Apr 18, 2026
6cec3e5
feat: add usage limits support to Cursor provider
Aditya190803 Apr 18, 2026
0bd668e
feat: add usage limits to OpenCode provider and ACP runtime model
Aditya190803 Apr 18, 2026
499d730
feat: render usage limits in Settings UI with progress bars
Aditya190803 Apr 18, 2026
0260b13
feat: remove check for official provider IDs in flattenOpenCodeModels…
Aditya190803 Apr 19, 2026
ce7e1a5
Merge remote-tracking branch 'origin/main' into feat/provider-usage-l…
Aditya190803 Apr 23, 2026
a895cda
fix: update account rate limits request signature and error handling …
Aditya190803 Apr 23, 2026
f5e1f47
refactor: standardize Codex rate limit window calculations and remove…
Aditya190803 Apr 23, 2026
0acd2e2
refactor: remove unused toIsoDateTimeFromUnixSeconds helper function
Aditya190803 Apr 23, 2026
b9fb0c9
Merge remote-tracking branch 'origin/main' into feat/provider-usage-l…
Aditya190803 Apr 28, 2026
ad00bbe
fix: resolve 5 code issues from Cursor Bugbot review + lint warnings
Aditya190803 Apr 28, 2026
4d9c423
feat: per-thread usage limits tracking + bug fixes
Aditya190803 Apr 28, 2026
4437685
refactor: enhance auth session and pairing link migrations
Aditya190803 Apr 28, 2026
e089547
fix: usage state bugs - cache key collision, labeling, and asymmetric…
Aditya190803 Apr 28, 2026
31a22d4
Merge remote-tracking branch 'origin/main' into feat/provider-usage-l…
Aditya190803 Apr 30, 2026
e934d22
Improvement in provider usage limits UI
Aditya190803 Apr 30, 2026
8fd9e0d
fix(provider): pass environment to probeClaudeUsageLimits for improve…
Aditya190803 Apr 30, 2026
381f68b
refactor: formalize Cursor ACP capability probe results using a tagge…
Aditya190803 Apr 30, 2026
c27d805
refactor: replace static progress bar with animated wrapper and remov…
Aditya190803 Apr 30, 2026
d5b5fb3
Merge branch 'main' into feat/provider-usage-limits
Aditya190803 May 1, 2026
8496471
Merge branch 'main' into feat/provider-usage-limits
Aditya190803 May 1, 2026
99511d1
Enhance provider usage display with reset date and improved styling
Aditya190803 May 1, 2026
174dda2
Add ProviderUsageStateLive integration and improve usage bar styling
Aditya190803 May 1, 2026
4254a3d
Merge remote-tracking branch 'origin/main' into feat/provider-usage-l…
Aditya190803 May 3, 2026
8938dba
feat(tests): add migration tests for provider_instance_id column
Aditya190803 May 3, 2026
163d828
Merge branch 'main' into feat/provider-usage-limits
Aditya190803 May 4, 2026
e68c351
feat(server): add provider usage limits with PTY adapter integration
Aditya190803 May 4, 2026
44c5772
refactor(migrations): streamline auth_sessions migration by removing …
Aditya190803 May 4, 2026
abc4160
feat(provider): add usage limits and retries
Aditya190803 Apr 17, 2026
89252d4
feat(provider): add timestamp for usage limit checks and improve key …
Aditya190803 May 6, 2026
cb35f3e
feat(provider): update latestSpawnedChild to async and improve window…
Aditya190803 May 6, 2026
d1ecb3a
Enhance usage reset label formatting and update styles for provider c…
Aditya190803 Apr 18, 2026
5c20bed
Refactor ClaudeProvider and usage probe to enhance error handling and…
Aditya190803 May 6, 2026
d024d7e
Refactor ClaudeProvider to improve variable naming and enhance clarit…
Aditya190803 Apr 18, 2026
d4e8bd1
feat: add provider usage limits schema and server-side persistence
Aditya190803 Apr 18, 2026
ab7694e
feat: render usage limits in Settings UI with progress bars
Aditya190803 Apr 18, 2026
281dfe3
fix: resolve 5 code issues from Cursor Bugbot review + lint warnings
Aditya190803 Apr 28, 2026
6a5bbc8
feat: per-thread usage limits tracking + bug fixes
Aditya190803 Apr 28, 2026
6efe6aa
refactor: enhance auth session and pairing link migrations
Aditya190803 Apr 28, 2026
4fc02a3
fix: usage state bugs - cache key collision, labeling, and asymmetric…
Aditya190803 Apr 28, 2026
377deff
Improvement in provider usage limits UI
Aditya190803 Apr 30, 2026
5092e83
fix(provider): pass environment to probeClaudeUsageLimits for improve…
Aditya190803 Apr 30, 2026
5bb6856
refactor: formalize Cursor ACP capability probe results using a tagge…
Aditya190803 Apr 30, 2026
1a69aff
Add ProviderUsageStateLive integration and improve usage bar styling
Aditya190803 May 1, 2026
42e3848
feat(tests): add migration tests for provider_instance_id column
Aditya190803 May 3, 2026
184feb0
feat(server): add provider usage limits with PTY adapter integration
Aditya190803 May 4, 2026
ec30593
refactor(migrations): streamline auth_sessions migration by removing …
Aditya190803 May 4, 2026
d4d45ba
feat(provider): enhance ClaudeProvider with usage limits parsing and …
Aditya190803 May 6, 2026
2243d19
feat(provider): implement provider instance ID handling in usage stat…
Aditya190803 May 6, 2026
d1c0982
feat(provider): enhance usage limits probing with clock abstraction a…
Aditya190803 May 6, 2026
c7a580a
Merge branch 'main' into feat/provider-usage-limits
Aditya190803 May 7, 2026
7528f75
feat: adjust usage threshold to 70% and remove ProviderUsageStateLive…
Aditya190803 May 7, 2026
c5ba79e
refactor(settings): remove unused usage limit functions and clean up …
Aditya190803 May 7, 2026
8ce8f64
test(provider): add test for maintaining intermediate windows as sess…
Aditya190803 May 7, 2026
fee4110
chore(migrations): remove AuthCompatibilityColumns migration and upda…
Aditya190803 May 7, 2026
5fa2c79
Merge branch 'main' into feat/provider-usage-limits
Aditya190803 May 8, 2026
1d9fabf
refactor(server): clean up imports in server.ts and ClaudeProvider.ts
Aditya190803 May 8, 2026
59613c4
Merge branch 'main' into feat/provider-usage-limits
Aditya190803 May 8, 2026
1dc1911
Merge branch 'main' into feat/provider-usage-limits
Aditya190803 May 9, 2026
54a87a2
Merge branch 'feat/provider-usage-limits' of https://github.com/Adity…
Aditya190803 May 9, 2026
76c23db
Add providerInstanceId to event payloads in makeClaudeAdapter
Aditya190803 May 9, 2026
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 11 additions & 0 deletions apps/server/src/provider/Drivers/ClaudeDriver.ts
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@ import * as Cache from "effect/Cache";
import * as Duration from "effect/Duration";
import * as Effect from "effect/Effect";
import * as FileSystem from "effect/FileSystem";
import * as Option from "effect/Option";
import * as Path from "effect/Path";
import * as Schema from "effect/Schema";
import * as Stream from "effect/Stream";
Expand Down Expand Up @@ -48,6 +49,9 @@ import {
resolveProviderMaintenanceCapabilitiesEffect,
} from "../providerMaintenance.ts";
import { makeClaudeCapabilitiesCacheKey, makeClaudeContinuationGroupKey } from "./ClaudeHome.ts";
import { PtyAdapter } from "../../terminal/Services/PTY.ts";
import { ProviderUsageState } from "../Services/ProviderUsageState.ts";

const decodeClaudeSettings = Schema.decodeSync(ClaudeSettings);

const DRIVER_KIND = ProviderDriverKind.make("claudeAgent");
Expand Down Expand Up @@ -112,6 +116,10 @@ export const ClaudeDriver: ProviderDriver<ClaudeSettings, ClaudeDriverEnv> = {
const spawner = yield* ChildProcessSpawner.ChildProcessSpawner;
const path = yield* Path.Path;
const httpClient = yield* HttpClient.HttpClient;
const ptyAdapter = Option.getOrUndefined(yield* Effect.serviceOption(PtyAdapter));
const providerUsageState = Option.getOrUndefined(
yield* Effect.serviceOption(ProviderUsageState),
);
const eventLoggers = yield* ProviderEventLoggers;
const processEnv = mergeProviderInstanceEnvironment(environment);
const fallbackContinuationIdentity = defaultProviderContinuationIdentity({
Expand Down Expand Up @@ -155,6 +163,9 @@ export const ClaudeDriver: ProviderDriver<ClaudeSettings, ClaudeDriverEnv> = {
effectiveConfig,
() => Cache.get(capabilitiesProbeCache, capabilitiesCacheKey),
processEnv,
ptyAdapter ?? undefined,
instanceId,
providerUsageState,
).pipe(
Effect.map(stampIdentity),
Effect.provideService(ChildProcessSpawner.ChildProcessSpawner, spawner),
Expand Down
12 changes: 11 additions & 1 deletion apps/server/src/provider/Drivers/CursorDriver.ts
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@ import { CursorSettings, ProviderDriverKind, type ServerProvider } from "@t3tool
import * as Duration from "effect/Duration";
import * as Effect from "effect/Effect";
import * as FileSystem from "effect/FileSystem";
import * as Option from "effect/Option";
import * as Path from "effect/Path";
import * as Schema from "effect/Schema";
import * as Stream from "effect/Stream";
Expand All @@ -32,6 +33,7 @@ import {
enrichCursorSnapshot,
} from "../Layers/CursorProvider.ts";
import { ProviderEventLoggers } from "../Layers/ProviderEventLoggers.ts";
import { ProviderUsageState } from "../Services/ProviderUsageState.ts";
import { makeManagedServerProvider } from "../makeManagedServerProvider.ts";
import {
defaultProviderContinuationIdentity,
Expand Down Expand Up @@ -121,8 +123,16 @@ export const CursorDriver: ProviderDriver<CursorSettings, CursorDriverEnv> = {
instanceId,
});
const textGeneration = yield* makeCursorTextGeneration(effectiveConfig, processEnv);
const providerUsageState = Option.getOrUndefined(
yield* Effect.serviceOption(ProviderUsageState),
);

const checkProvider = checkCursorProviderStatus(effectiveConfig, processEnv).pipe(
const checkProvider = checkCursorProviderStatus(
effectiveConfig,
processEnv,
instanceId,
providerUsageState,
).pipe(
Effect.map(stampIdentity),
Effect.provideService(ChildProcessSpawner.ChildProcessSpawner, spawner),
Effect.provideService(FileSystem.FileSystem, fileSystem),
Expand Down
39 changes: 38 additions & 1 deletion apps/server/src/provider/Layers/ClaudeAdapter.ts
Original file line number Diff line number Diff line change
Expand Up @@ -1025,7 +1025,11 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (

const nowIso = Effect.map(DateTime.now, DateTime.formatIso);
const nextEventId = Effect.map(Random.nextUUIDv4, (id) => EventId.make(id));
const makeEventStamp = () => Effect.all({ eventId: nextEventId, createdAt: nowIso });
const makeEventStamp = () =>
Comment thread
macroscopeapp[bot] marked this conversation as resolved.
Effect.map(Effect.all({ eventId: nextEventId, createdAt: nowIso }), (stamp) => ({
...stamp,
providerInstanceId: boundInstanceId,
}));

const offerRuntimeEvent = (event: ProviderRuntimeEvent): Effect.Effect<void> =>
Queue.offer(runtimeEventQueue, event).pipe(Effect.asVoid);
Expand Down Expand Up @@ -1185,6 +1189,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: deltaStamp.eventId,
provider: PROVIDER,
createdAt: deltaStamp.createdAt,
providerInstanceId: deltaStamp.providerInstanceId,
threadId: context.session.threadId,
turnId: turnState.turnId,
itemId: asRuntimeItemId(block.itemId),
Expand Down Expand Up @@ -1216,6 +1221,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: stamp.eventId,
provider: PROVIDER,
createdAt: stamp.createdAt,
providerInstanceId: stamp.providerInstanceId,
itemId: asRuntimeItemId(block.itemId),
threadId: context.session.threadId,
turnId: turnState.turnId,
Expand Down Expand Up @@ -1308,6 +1314,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: stamp.eventId,
provider: PROVIDER,
createdAt: stamp.createdAt,
providerInstanceId: stamp.providerInstanceId,
threadId: context.session.threadId,
payload: {
providerThreadId: nextThreadId,
Expand Down Expand Up @@ -1339,6 +1346,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: stamp.eventId,
provider: PROVIDER,
createdAt: stamp.createdAt,
providerInstanceId: stamp.providerInstanceId,
threadId: context.session.threadId,
...(turnState ? { turnId: asCanonicalTurnId(turnState.turnId) } : {}),
payload: {
Expand All @@ -1362,6 +1370,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: stamp.eventId,
provider: PROVIDER,
createdAt: stamp.createdAt,
providerInstanceId: stamp.providerInstanceId,
threadId: context.session.threadId,
...(turnState ? { turnId: asCanonicalTurnId(turnState.turnId) } : {}),
payload: {
Expand Down Expand Up @@ -1403,6 +1412,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: stamp.eventId,
provider: PROVIDER,
createdAt: stamp.createdAt,
providerInstanceId: stamp.providerInstanceId,
threadId: context.session.threadId,
turnId: turnState.turnId,
payload: {
Expand Down Expand Up @@ -1468,6 +1478,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: usageStamp.eventId,
provider: PROVIDER,
createdAt: usageStamp.createdAt,
providerInstanceId: usageStamp.providerInstanceId,
threadId: context.session.threadId,
payload: {
usage: usageSnapshot,
Expand All @@ -1482,6 +1493,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: stamp.eventId,
provider: PROVIDER,
createdAt: stamp.createdAt,
providerInstanceId: stamp.providerInstanceId,
threadId: context.session.threadId,
payload: {
state: status,
Expand All @@ -1505,6 +1517,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: toolStamp.eventId,
provider: PROVIDER,
createdAt: toolStamp.createdAt,
providerInstanceId: toolStamp.providerInstanceId,
threadId: context.session.threadId,
turnId: turnState.turnId,
itemId: asRuntimeItemId(tool.itemId),
Expand Down Expand Up @@ -1552,6 +1565,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: usageStamp.eventId,
provider: PROVIDER,
createdAt: usageStamp.createdAt,
providerInstanceId: usageStamp.providerInstanceId,
threadId: context.session.threadId,
turnId: turnState.turnId,
payload: {
Expand All @@ -1567,6 +1581,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: stamp.eventId,
provider: PROVIDER,
createdAt: stamp.createdAt,
providerInstanceId: stamp.providerInstanceId,
threadId: context.session.threadId,
turnId: turnState.turnId,
payload: {
Expand Down Expand Up @@ -1639,6 +1654,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: stamp.eventId,
provider: PROVIDER,
createdAt: stamp.createdAt,
providerInstanceId: stamp.providerInstanceId,
threadId: context.session.threadId,
turnId: context.turnState.turnId,
...(assistantBlockEntry?.block
Expand Down Expand Up @@ -1702,6 +1718,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: stamp.eventId,
provider: PROVIDER,
createdAt: stamp.createdAt,
providerInstanceId: stamp.providerInstanceId,
threadId: context.session.threadId,
...(context.turnState
? {
Expand Down Expand Up @@ -1739,6 +1756,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: planStamp.eventId,
provider: PROVIDER,
createdAt: planStamp.createdAt,
providerInstanceId: planStamp.providerInstanceId,
threadId: context.session.threadId,
...(context.turnState
? {
Expand Down Expand Up @@ -1801,6 +1819,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: stamp.eventId,
provider: PROVIDER,
createdAt: stamp.createdAt,
providerInstanceId: stamp.providerInstanceId,
threadId: context.session.threadId,
...(context.turnState ? { turnId: asCanonicalTurnId(context.turnState.turnId) } : {}),
itemId: asRuntimeItemId(tool.itemId),
Expand Down Expand Up @@ -1878,6 +1897,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: updatedStamp.eventId,
provider: PROVIDER,
createdAt: updatedStamp.createdAt,
providerInstanceId: updatedStamp.providerInstanceId,
threadId: context.session.threadId,
...(context.turnState ? { turnId: asCanonicalTurnId(context.turnState.turnId) } : {}),
itemId: asRuntimeItemId(tool.itemId),
Expand Down Expand Up @@ -1906,6 +1926,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: deltaStamp.eventId,
provider: PROVIDER,
createdAt: deltaStamp.createdAt,
providerInstanceId: deltaStamp.providerInstanceId,
threadId: context.session.threadId,
turnId: context.turnState.turnId,
itemId: asRuntimeItemId(tool.itemId),
Expand All @@ -1930,6 +1951,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: completedStamp.eventId,
provider: PROVIDER,
createdAt: completedStamp.createdAt,
providerInstanceId: completedStamp.providerInstanceId,
threadId: context.session.threadId,
...(context.turnState ? { turnId: asCanonicalTurnId(context.turnState.turnId) } : {}),
itemId: asRuntimeItemId(tool.itemId),
Expand Down Expand Up @@ -1988,6 +2010,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: turnStartedStamp.eventId,
provider: PROVIDER,
createdAt: turnStartedStamp.createdAt,
providerInstanceId: turnStartedStamp.providerInstanceId,
threadId: context.session.threadId,
turnId,
payload: {},
Expand Down Expand Up @@ -2072,6 +2095,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: stamp.eventId,
provider: PROVIDER,
createdAt: stamp.createdAt,
providerInstanceId: stamp.providerInstanceId,
threadId: context.session.threadId,
...(context.turnState ? { turnId: asCanonicalTurnId(context.turnState.turnId) } : {}),
providerRefs: nativeProviderRefs(context),
Expand Down Expand Up @@ -2175,6 +2199,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
...base,
eventId: usageStamp.eventId,
createdAt: usageStamp.createdAt,
providerInstanceId: usageStamp.providerInstanceId,
type: "thread.token-usage.updated",
payload: {
usage: normalizedUsage,
Expand Down Expand Up @@ -2207,6 +2232,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
...base,
eventId: usageStamp.eventId,
createdAt: usageStamp.createdAt,
providerInstanceId: usageStamp.providerInstanceId,
type: "thread.token-usage.updated",
payload: {
usage: normalizedUsage,
Expand Down Expand Up @@ -2266,6 +2292,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: stamp.eventId,
provider: PROVIDER,
createdAt: stamp.createdAt,
providerInstanceId: stamp.providerInstanceId,
threadId: context.session.threadId,
...(context.turnState ? { turnId: asCanonicalTurnId(context.turnState.turnId) } : {}),
providerRefs: nativeProviderRefs(context),
Expand Down Expand Up @@ -2428,6 +2455,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: stamp.eventId,
provider: PROVIDER,
createdAt: stamp.createdAt,
providerInstanceId: stamp.providerInstanceId,
threadId: context.session.threadId,
...(context.turnState ? { turnId: asCanonicalTurnId(context.turnState.turnId) } : {}),
requestId: asRuntimeRequestId(requestId),
Expand Down Expand Up @@ -2482,6 +2510,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: stamp.eventId,
provider: PROVIDER,
createdAt: stamp.createdAt,
providerInstanceId: stamp.providerInstanceId,
threadId: context.session.threadId,
payload: {
reason: "Session stopped",
Expand Down Expand Up @@ -2625,6 +2654,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: requestedStamp.eventId,
provider: PROVIDER,
createdAt: requestedStamp.createdAt,
providerInstanceId: requestedStamp.providerInstanceId,
threadId: context.session.threadId,
...(context.turnState
? {
Expand Down Expand Up @@ -2672,6 +2702,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: resolvedStamp.eventId,
provider: PROVIDER,
createdAt: resolvedStamp.createdAt,
providerInstanceId: resolvedStamp.providerInstanceId,
threadId: context.session.threadId,
...(context.turnState
? {
Expand Down Expand Up @@ -2775,6 +2806,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: requestedStamp.eventId,
provider: PROVIDER,
createdAt: requestedStamp.createdAt,
providerInstanceId: requestedStamp.providerInstanceId,
threadId: context.session.threadId,
...(context.turnState ? { turnId: asCanonicalTurnId(context.turnState.turnId) } : {}),
requestId: asRuntimeRequestId(requestId),
Expand Down Expand Up @@ -2823,6 +2855,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: resolvedStamp.eventId,
provider: PROVIDER,
createdAt: resolvedStamp.createdAt,
providerInstanceId: resolvedStamp.providerInstanceId,
threadId: context.session.threadId,
...(context.turnState ? { turnId: asCanonicalTurnId(context.turnState.turnId) } : {}),
requestId: asRuntimeRequestId(requestId),
Expand Down Expand Up @@ -3012,6 +3045,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: sessionStartedStamp.eventId,
provider: PROVIDER,
createdAt: sessionStartedStamp.createdAt,
providerInstanceId: sessionStartedStamp.providerInstanceId,
threadId,
payload: input.resumeCursor !== undefined ? { resume: input.resumeCursor } : {},
providerRefs: {},
Expand All @@ -3023,6 +3057,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: configuredStamp.eventId,
provider: PROVIDER,
createdAt: configuredStamp.createdAt,
providerInstanceId: configuredStamp.providerInstanceId,
threadId,
payload: {
config: {
Expand All @@ -3042,6 +3077,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: readyStamp.eventId,
provider: PROVIDER,
createdAt: readyStamp.createdAt,
providerInstanceId: readyStamp.providerInstanceId,
threadId,
payload: {
state: "ready",
Expand Down Expand Up @@ -3146,6 +3182,7 @@ export const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
eventId: turnStartedStamp.eventId,
provider: PROVIDER,
createdAt: turnStartedStamp.createdAt,
providerInstanceId: turnStartedStamp.providerInstanceId,
threadId: context.session.threadId,
turnId,
payload: modelSelection?.model ? { model: modelSelection.model } : {},
Expand Down
Loading
Loading