import { useAtomValue } from "@effect/atom-react";import type { EnvironmentProject, EnvironmentThread, EnvironmentThreadShell,} from "@t3tools/client-runtime/state/shell";import { type EnvironmentThreadStatus, mergeEnvironmentThread,} from "@t3tools/client-runtime/state/threads";import type { OrchestrationMessage, OrchestrationProposedPlan, OrchestrationSession, OrchestrationThreadActivity, ScopedProjectRef, ScopedThreadRef, ServerConfig,} from "@t3tools/contracts";import type { EnvironmentId, ThreadId } from "@t3tools/contracts";import { Atom } from "effect/unstable/reactivity";import { useMemo } from "react";import { appAtomRegistry } from "../rpc/atomRegistry";import { environmentProjects } from "./projects";import { environmentServerConfigsAtom } from "./server";import { allEnvironmentShellsBootstrappedAtom } from "./shell";import { environmentThreadDetails, environmentThreadShells } from "./threads"; const EMPTY_PROJECT_REFS: ReadonlyArray<ScopedProjectRef> = Object.freeze([]);const EMPTY_THREAD_REFS: ReadonlyArray<ScopedThreadRef> = Object.freeze([]);const EMPTY_MESSAGES: ReadonlyArray<OrchestrationMessage> = Object.freeze([]);const EMPTY_ACTIVITIES: ReadonlyArray<OrchestrationThreadActivity> = Object.freeze([]);const EMPTY_PROPOSED_PLANS: ReadonlyArray<OrchestrationProposedPlan> = Object.freeze([]); const EMPTY_PROJECT_ATOM = Atom.make<EnvironmentProject | null>(null).pipe( Atom.withLabel("web-project:empty"),);const EMPTY_PROJECT_REFS_ATOM = Atom.make(EMPTY_PROJECT_REFS).pipe( Atom.withLabel("web-project-refs:empty"),);const EMPTY_THREAD_REFS_ATOM = Atom.make(EMPTY_THREAD_REFS).pipe( Atom.withLabel("web-thread-refs:empty"),);const EMPTY_THREAD_SHELL_ATOM = Atom.make<EnvironmentThreadShell | null>(null).pipe( Atom.withLabel("web-thread-shell:empty"),);const EMPTY_THREAD_DETAIL_ATOM = Atom.make<EnvironmentThread | null>(null).pipe( Atom.withLabel("web-thread-detail:empty"),);const EMPTY_THREAD_STATUS_ATOM = Atom.make<EnvironmentThreadStatus>("empty").pipe( Atom.withLabel("web-thread-status:empty"),);const EMPTY_MESSAGES_ATOM = Atom.make(EMPTY_MESSAGES).pipe( Atom.withLabel("web-thread-messages:empty"),);const EMPTY_ACTIVITIES_ATOM = Atom.make(EMPTY_ACTIVITIES).pipe( Atom.withLabel("web-thread-activities:empty"),);const EMPTY_PROPOSED_PLANS_ATOM = Atom.make(EMPTY_PROPOSED_PLANS).pipe( Atom.withLabel("web-thread-proposed-plans:empty"),);const EMPTY_SESSION_ATOM = Atom.make<OrchestrationSession | null>(null).pipe( Atom.withLabel("web-thread-session:empty"),); export const activeEnvironmentIdAtom = Atom.make<EnvironmentId | null>(null).pipe( Atom.keepAlive, Atom.withLabel("web-active-environment-id"),); export function useActiveEnvironmentId(): EnvironmentId | null { return useAtomValue(activeEnvironmentIdAtom);} export function readActiveEnvironmentId(): EnvironmentId | null { return appAtomRegistry.get(activeEnvironmentIdAtom);} export function setActiveEnvironmentId(environmentId: EnvironmentId | null): void { appAtomRegistry.set(activeEnvironmentIdAtom, environmentId);} export function useProjectRefs(): ReadonlyArray<ScopedProjectRef> { return useAtomValue(environmentProjects.projectRefsAtom);} export function useThreadRefs(): ReadonlyArray<ScopedThreadRef> { return useAtomValue(environmentThreadShells.threadRefsAtom);} export function useEnvironmentProjectRefs( environmentId: EnvironmentId | null,): ReadonlyArray<ScopedProjectRef> { return useAtomValue( environmentId === null ? EMPTY_PROJECT_REFS_ATOM : environmentProjects.environmentProjectRefsAtom(environmentId), );} export function useEnvironmentThreadRefs( environmentId: EnvironmentId | null,): ReadonlyArray<ScopedThreadRef> { return useAtomValue( environmentId === null ? EMPTY_THREAD_REFS_ATOM : environmentThreadShells.environmentThreadRefsAtom(environmentId), );} export function useProjects(): ReadonlyArray<EnvironmentProject> { return useAtomValue(environmentProjects.projectsAtom);} export function useServerConfigs(): ReadonlyMap<EnvironmentId, ServerConfig> { return useAtomValue(environmentServerConfigsAtom);} export function useThreadShells(): ReadonlyArray<EnvironmentThreadShell> { return useAtomValue(environmentThreadShells.threadShellsAtom);} export function useAllEnvironmentShellsBootstrapped(): boolean { return useAtomValue(allEnvironmentShellsBootstrappedAtom);} export function useThreadShellsForProjectRefs( refs: ReadonlyArray<ScopedProjectRef>,): ReadonlyArray<EnvironmentThreadShell> { return useAtomValue(environmentThreadShells.threadShellsForProjectRefsAtom(refs));} export function useProject(ref: ScopedProjectRef | null): EnvironmentProject | null { return useAtomValue(ref === null ? EMPTY_PROJECT_ATOM : environmentProjects.projectAtom(ref));} export function useThreadShell(ref: ScopedThreadRef | null): EnvironmentThreadShell | null { return useAtomValue( ref === null ? EMPTY_THREAD_SHELL_ATOM : environmentThreadShells.threadShellAtom(ref), );} export function useThreadDetail(ref: ScopedThreadRef | null): EnvironmentThread | null { return useAtomValue( ref === null ? EMPTY_THREAD_DETAIL_ATOM : environmentThreadDetails.detailAtom(ref), );} export function useThreadStatus(ref: ScopedThreadRef | null): EnvironmentThreadStatus { return useAtomValue( ref === null ? EMPTY_THREAD_STATUS_ATOM : environmentThreadDetails.statusAtom(ref), );} export function resolveThreadDetailRef( ref: ScopedThreadRef | null, options: { shellExists: boolean; waitForShell: boolean; },): ScopedThreadRef | null { return ref !== null && (!options.waitForShell || options.shellExists) ? ref : null;} /** Detail collections composed with shell-authoritative thread/workspace metadata. */export function useThread( ref: ScopedThreadRef | null, options?: { /** * Client-reserved draft thread ids do not exist on the server until the * first send. Waiting for the shell index avoids polling the detail * endpoint for an intentionally missing thread during that window. */ waitForShell?: boolean; },): EnvironmentThread | null { const shell = useThreadShell(ref); const detail = useThreadDetail( resolveThreadDetailRef(ref, { shellExists: shell !== null, waitForShell: options?.waitForShell === true, }), ); return useMemo(() => mergeEnvironmentThread(detail, shell), [detail, shell]);} export function useThreadMessages( ref: ScopedThreadRef | null,): ReadonlyArray<OrchestrationMessage> { return useAtomValue( ref === null ? EMPTY_MESSAGES_ATOM : environmentThreadDetails.messagesAtom(ref), );} export function useThreadActivities( ref: ScopedThreadRef | null,): ReadonlyArray<OrchestrationThreadActivity> { return useAtomValue( ref === null ? EMPTY_ACTIVITIES_ATOM : environmentThreadDetails.activitiesAtom(ref), );} export function useThreadProposedPlans( ref: ScopedThreadRef | null,): ReadonlyArray<OrchestrationProposedPlan> { return useAtomValue( ref === null ? EMPTY_PROPOSED_PLANS_ATOM : environmentThreadDetails.proposedPlansAtom(ref), );} export function useThreadSession(ref: ScopedThreadRef | null): OrchestrationSession | null { return useAtomValue( ref === null ? EMPTY_SESSION_ATOM : environmentThreadDetails.sessionAtom(ref), );} export function readProject(ref: ScopedProjectRef): EnvironmentProject | null { return appAtomRegistry.get(environmentProjects.projectAtom(ref));} export function readThreadShell(ref: ScopedThreadRef): EnvironmentThreadShell | null { return appAtomRegistry.get(environmentThreadShells.threadShellAtom(ref));} /** Whether the environment's server understands thread.settle/unsettle. False for pre-settlement servers (capability defaults false on decode), so clients under version skew fall back instead of erroring. */export function readEnvironmentSupportsSettlement(environmentId: EnvironmentId): boolean { return ( appAtomRegistry.get(environmentServerConfigsAtom).get(environmentId)?.environment.capabilities .threadSettlement === true );} /** Whether the environment's server understands thread.snooze/unsnooze. Same version-skew contract as settlement. */export function readEnvironmentSupportsSnooze(environmentId: EnvironmentId): boolean { return ( appAtomRegistry.get(environmentServerConfigsAtom).get(environmentId)?.environment.capabilities .threadSnooze === true );} /** Whether the environment's server understands thread.pin/unpin. Same version-skew contract as settlement. */export function readEnvironmentSupportsPinning(environmentId: EnvironmentId): boolean { return ( appAtomRegistry.get(environmentServerConfigsAtom).get(environmentId)?.environment.capabilities .threadPinning === true );} /** Whether the environment's server understands thread title regeneration. Same version-skew contract as settlement. */export function readEnvironmentSupportsTitleRegeneration(environmentId: EnvironmentId): boolean { return ( appAtomRegistry.get(environmentServerConfigsAtom).get(environmentId)?.environment.capabilities .threadTitleRegeneration === true );} /** Whether the environment's server understands thread.pin.reorder (and orderKey on thread.pin). Same version-skew contract as settlement. */export function readEnvironmentSupportsPinReorder(environmentId: EnvironmentId): boolean { return ( appAtomRegistry.get(environmentServerConfigsAtom).get(environmentId)?.environment.capabilities .threadPinReorder === true );} export function readThreadDetail(ref: ScopedThreadRef): EnvironmentThread | null { return appAtomRegistry.get(environmentThreadDetails.detailAtom(ref));} export function readEnvironmentThreadRefs( environmentId: EnvironmentId,): ReadonlyArray<ScopedThreadRef> { return appAtomRegistry.get(environmentThreadShells.environmentThreadRefsAtom(environmentId));} export function readThreadRefs(): ReadonlyArray<ScopedThreadRef> { return appAtomRegistry.get(environmentThreadShells.threadRefsAtom);} export function readThreadShells(): ReadonlyArray<EnvironmentThreadShell> { return appAtomRegistry.get(environmentThreadShells.threadShellsAtom);} export function findThreadRef(threadId: ThreadId): ScopedThreadRef | null { return ( appAtomRegistry .get(environmentThreadShells.threadRefsAtom) .find((ref) => ref.threadId === threadId) ?? null );}
import { useAtomValue } from "@effect/atom-react";
import type {
EnvironmentProject,
EnvironmentThread,
EnvironmentThreadShell,
} from "@t3tools/client-runtime/state/shell";
import {
type EnvironmentThreadStatus,
mergeEnvironmentThread,
} from "@t3tools/client-runtime/state/threads";
import type {
OrchestrationMessage,
OrchestrationProposedPlan,
OrchestrationSession,
OrchestrationThreadActivity,
ScopedProjectRef,
ScopedThreadRef,
ServerConfig,
} from "@t3tools/contracts";
import type { EnvironmentId, ThreadId } from "@t3tools/contracts";
import { Atom } from "effect/unstable/reactivity";
import { useMemo } from "react";
import { appAtomRegistry } from "../rpc/atomRegistry";
import { environmentProjects } from "./projects";
import { environmentServerConfigsAtom } from "./server";
import { allEnvironmentShellsBootstrappedAtom } from "./shell";
import { environmentThreadDetails, environmentThreadShells } from "./threads";
const EMPTY_PROJECT_REFS: ReadonlyArray<ScopedProjectRef> = Object.freeze([]);
const EMPTY_THREAD_REFS: ReadonlyArray<ScopedThreadRef> = Object.freeze([]);
const EMPTY_MESSAGES: ReadonlyArray<OrchestrationMessage> = Object.freeze([]);
const EMPTY_ACTIVITIES: ReadonlyArray<OrchestrationThreadActivity> = Object.freeze([]);
const EMPTY_PROPOSED_PLANS: ReadonlyArray<OrchestrationProposedPlan> = Object.freeze([]);
const EMPTY_PROJECT_ATOM = Atom.make<EnvironmentProject | null>(null).pipe(
Atom.withLabel("web-project:empty"),
);
const EMPTY_PROJECT_REFS_ATOM = Atom.make(EMPTY_PROJECT_REFS).pipe(
Atom.withLabel("web-project-refs:empty"),
);
const EMPTY_THREAD_REFS_ATOM = Atom.make(EMPTY_THREAD_REFS).pipe(
Atom.withLabel("web-thread-refs:empty"),
);
const EMPTY_THREAD_SHELL_ATOM = Atom.make<EnvironmentThreadShell | null>(null).pipe(
Atom.withLabel("web-thread-shell:empty"),
);
const EMPTY_THREAD_DETAIL_ATOM = Atom.make<EnvironmentThread | null>(null).pipe(
Atom.withLabel("web-thread-detail:empty"),
);
const EMPTY_THREAD_STATUS_ATOM = Atom.make<EnvironmentThreadStatus>("empty").pipe(
Atom.withLabel("web-thread-status:empty"),
);
const EMPTY_MESSAGES_ATOM = Atom.make(EMPTY_MESSAGES).pipe(
Atom.withLabel("web-thread-messages:empty"),
);
const EMPTY_ACTIVITIES_ATOM = Atom.make(EMPTY_ACTIVITIES).pipe(
Atom.withLabel("web-thread-activities:empty"),
);
const EMPTY_PROPOSED_PLANS_ATOM = Atom.make(EMPTY_PROPOSED_PLANS).pipe(
Atom.withLabel("web-thread-proposed-plans:empty"),
);
const EMPTY_SESSION_ATOM = Atom.make<OrchestrationSession | null>(null).pipe(
Atom.withLabel("web-thread-session:empty"),
);
export const activeEnvironmentIdAtom = Atom.make<EnvironmentId | null>(null).pipe(
Atom.keepAlive,
Atom.withLabel("web-active-environment-id"),
);
export function useActiveEnvironmentId(): EnvironmentId | null {
return useAtomValue(activeEnvironmentIdAtom);
}
export function readActiveEnvironmentId(): EnvironmentId | null {
return appAtomRegistry.get(activeEnvironmentIdAtom);
}
export function setActiveEnvironmentId(environmentId: EnvironmentId | null): void {
appAtomRegistry.set(activeEnvironmentIdAtom, environmentId);
}
export function useProjectRefs(): ReadonlyArray<ScopedProjectRef> {
return useAtomValue(environmentProjects.projectRefsAtom);
}
export function useThreadRefs(): ReadonlyArray<ScopedThreadRef> {
return useAtomValue(environmentThreadShells.threadRefsAtom);
}
export function useEnvironmentProjectRefs(
environmentId: EnvironmentId | null,
): ReadonlyArray<ScopedProjectRef> {
return useAtomValue(
environmentId === null
? EMPTY_PROJECT_REFS_ATOM
: environmentProjects.environmentProjectRefsAtom(environmentId),
);
}
export function useEnvironmentThreadRefs(
environmentId: EnvironmentId | null,
): ReadonlyArray<ScopedThreadRef> {
return useAtomValue(
environmentId === null
? EMPTY_THREAD_REFS_ATOM
: environmentThreadShells.environmentThreadRefsAtom(environmentId),
);
}
export function useProjects(): ReadonlyArray<EnvironmentProject> {
return useAtomValue(environmentProjects.projectsAtom);
}
export function useServerConfigs(): ReadonlyMap<EnvironmentId, ServerConfig> {
return useAtomValue(environmentServerConfigsAtom);
}
export function useThreadShells(): ReadonlyArray<EnvironmentThreadShell> {
return useAtomValue(environmentThreadShells.threadShellsAtom);
}
export function useAllEnvironmentShellsBootstrapped(): boolean {
return useAtomValue(allEnvironmentShellsBootstrappedAtom);
}
export function useThreadShellsForProjectRefs(
refs: ReadonlyArray<ScopedProjectRef>,
): ReadonlyArray<EnvironmentThreadShell> {
return useAtomValue(environmentThreadShells.threadShellsForProjectRefsAtom(refs));
}
export function useProject(ref: ScopedProjectRef | null): EnvironmentProject | null {
return useAtomValue(ref === null ? EMPTY_PROJECT_ATOM : environmentProjects.projectAtom(ref));
}
export function useThreadShell(ref: ScopedThreadRef | null): EnvironmentThreadShell | null {
return useAtomValue(
ref === null ? EMPTY_THREAD_SHELL_ATOM : environmentThreadShells.threadShellAtom(ref),
);
}
export function useThreadDetail(ref: ScopedThreadRef | null): EnvironmentThread | null {
return useAtomValue(
ref === null ? EMPTY_THREAD_DETAIL_ATOM : environmentThreadDetails.detailAtom(ref),
);
}
export function useThreadStatus(ref: ScopedThreadRef | null): EnvironmentThreadStatus {
return useAtomValue(
ref === null ? EMPTY_THREAD_STATUS_ATOM : environmentThreadDetails.statusAtom(ref),
);
}
export function resolveThreadDetailRef(
ref: ScopedThreadRef | null,
options: {
shellExists: boolean;
waitForShell: boolean;
},
): ScopedThreadRef | null {
return ref !== null && (!options.waitForShell || options.shellExists) ? ref : null;
}
/** Detail collections composed with shell-authoritative thread/workspace metadata. */
export function useThread(
ref: ScopedThreadRef | null,
options?: {
/**
* Client-reserved draft thread ids do not exist on the server until the
* first send. Waiting for the shell index avoids polling the detail
* endpoint for an intentionally missing thread during that window.
*/
waitForShell?: boolean;
},
): EnvironmentThread | null {
const shell = useThreadShell(ref);
const detail = useThreadDetail(
resolveThreadDetailRef(ref, {
shellExists: shell !== null,
waitForShell: options?.waitForShell === true,
}),
);
return useMemo(() => mergeEnvironmentThread(detail, shell), [detail, shell]);
}
export function useThreadMessages(
ref: ScopedThreadRef | null,
): ReadonlyArray<OrchestrationMessage> {
return useAtomValue(
ref === null ? EMPTY_MESSAGES_ATOM : environmentThreadDetails.messagesAtom(ref),
);
}
export function useThreadActivities(
ref: ScopedThreadRef | null,
): ReadonlyArray<OrchestrationThreadActivity> {
return useAtomValue(
ref === null ? EMPTY_ACTIVITIES_ATOM : environmentThreadDetails.activitiesAtom(ref),
);
}
export function useThreadProposedPlans(
ref: ScopedThreadRef | null,
): ReadonlyArray<OrchestrationProposedPlan> {
return useAtomValue(
ref === null ? EMPTY_PROPOSED_PLANS_ATOM : environmentThreadDetails.proposedPlansAtom(ref),
);
}
export function useThreadSession(ref: ScopedThreadRef | null): OrchestrationSession | null {
return useAtomValue(
ref === null ? EMPTY_SESSION_ATOM : environmentThreadDetails.sessionAtom(ref),
);
}
export function readProject(ref: ScopedProjectRef): EnvironmentProject | null {
return appAtomRegistry.get(environmentProjects.projectAtom(ref));
}
export function readThreadShell(ref: ScopedThreadRef): EnvironmentThreadShell | null {
return appAtomRegistry.get(environmentThreadShells.threadShellAtom(ref));
}
/** Whether the environment's server understands thread.settle/unsettle.
False for pre-settlement servers (capability defaults false on decode),
so clients under version skew fall back instead of erroring. */
export function readEnvironmentSupportsSettlement(environmentId: EnvironmentId): boolean {
return (
appAtomRegistry.get(environmentServerConfigsAtom).get(environmentId)?.environment.capabilities
.threadSettlement === true
);
}
/** Whether the environment's server understands thread.snooze/unsnooze.
Same version-skew contract as settlement. */
export function readEnvironmentSupportsSnooze(environmentId: EnvironmentId): boolean {
return (
appAtomRegistry.get(environmentServerConfigsAtom).get(environmentId)?.environment.capabilities
.threadSnooze === true
);
}
/** Whether the environment's server understands thread.pin/unpin.
Same version-skew contract as settlement. */
export function readEnvironmentSupportsPinning(environmentId: EnvironmentId): boolean {
return (
appAtomRegistry.get(environmentServerConfigsAtom).get(environmentId)?.environment.capabilities
.threadPinning === true
);
}
/** Whether the environment's server understands thread title regeneration.
Same version-skew contract as settlement. */
export function readEnvironmentSupportsTitleRegeneration(environmentId: EnvironmentId): boolean {
return (
appAtomRegistry.get(environmentServerConfigsAtom).get(environmentId)?.environment.capabilities
.threadTitleRegeneration === true
);
}
/** Whether the environment's server understands thread.pin.reorder (and
orderKey on thread.pin). Same version-skew contract as settlement. */
export function readEnvironmentSupportsPinReorder(environmentId: EnvironmentId): boolean {
return (
appAtomRegistry.get(environmentServerConfigsAtom).get(environmentId)?.environment.capabilities
.threadPinReorder === true
);
}
export function readThreadDetail(ref: ScopedThreadRef): EnvironmentThread | null {
return appAtomRegistry.get(environmentThreadDetails.detailAtom(ref));
}
export function readEnvironmentThreadRefs(
environmentId: EnvironmentId,
): ReadonlyArray<ScopedThreadRef> {
return appAtomRegistry.get(environmentThreadShells.environmentThreadRefsAtom(environmentId));
}
export function readThreadRefs(): ReadonlyArray<ScopedThreadRef> {
return appAtomRegistry.get(environmentThreadShells.threadRefsAtom);
}
export function readThreadShells(): ReadonlyArray<EnvironmentThreadShell> {
return appAtomRegistry.get(environmentThreadShells.threadShellsAtom);
}
export function findThreadRef(threadId: ThreadId): ScopedThreadRef | null {
return (
appAtomRegistry
.get(environmentThreadShells.threadRefsAtom)
.find((ref) => ref.threadId === threadId) ?? null
);
}