refactor(provider-pi): move Pi into its own provider package

apps/mobile/package.json

@@ -69,6 +69,8 @@
     "@t3tools/mobile-markdown-text": "file:./modules/t3-markdown-text",
     "@t3tools/mobile-review-diff-native": "file:./modules/t3-review-diff",
     "@t3tools/mobile-terminal-native": "file:./modules/t3-terminal",
+    "@t3tools/provider-core": "workspace:*",
+    "@t3tools/provider-pi": "workspace:*",
     "@t3tools/shared": "workspace:*",
     "@tabler/icons-react-native": "^3.44.0",
     "clsx": "^2.1.1",

apps/mobile/src/components/ProviderIcon.tsx

@@ -6,6 +6,7 @@ import { useState } from "react";
 import { resolveOfficialAcpRegistryIconUrl } from "@t3tools/contracts";
 import { useAppearancePreferences } from "../features/settings/appearance/AppearancePreferencesProvider";
 import { AppText as Text } from "./AppText";
+import { getProviderClient } from "../lib/providerClients";
 
 type ProviderIconProps = {
   readonly provider: string | null | undefined;
@@ -131,16 +132,20 @@ export function ProviderIcon(props: ProviderIconProps) {
     );
   }
 
-  if (props.provider === "pi") {
-    const foreground = isDarkMode ? "#F5F5F5" : "#0F0F0F";
+  const packageIcon = getProviderClient(props.provider)?.icon;
+  if (packageIcon) {
+    const themeFill = (fill: { readonly light: string; readonly dark: string }) =>
+      isDarkMode ? fill.dark : fill.light;
     return (
-      <Svg width={size} height={size} viewBox="165.29 165.29 469.43 469.43" fill="none">
-        <Path
-          fill={foreground}
-          fillRule="evenodd"
-          d="M165.29 165.29H517.36V400H400V517.36H282.65V634.72H165.29ZM282.65 282.65V400H400V282.65Z"
-        />
-        <Path fill={foreground} d="M517.36 400H634.72V634.72H517.36Z" />
+      <Svg width={size} height={size} viewBox={packageIcon.viewBox} fill="none">
+        {packageIcon.paths.map((path) => (
+          <Path
+            key={path.d}
+            d={path.d}
+            fillRule={path.fillRule}
+            fill={themeFill(path.fill ?? packageIcon.fill)}
+          />
+        ))}
       </Svg>
     );
   }

apps/mobile/src/lib/providerClients.ts

@@ -0,0 +1,11 @@
+import { isProviderDriverKind } from "@t3tools/contracts";
+import { makeProviderClientRegistry } from "@t3tools/provider-core/client";
+import { piClient } from "@t3tools/provider-pi/client";
+
+/** The provider client definitions this mobile build ships. */
+const providerClients = makeProviderClientRegistry([piClient]);
+
+/** The client definition for a driver kind, or `undefined` for drivers drawn by hand. */
+export function getProviderClient(driver: string | null | undefined) {
+  return isProviderDriverKind(driver) ? providerClients.get(driver) : undefined;
+}

apps/server/package.json

@@ -42,6 +42,7 @@
     "@opencode/protocol": "2.0.23",
     "@opencode/schema": "2.0.23",
     "@t3tools/provider-core": "workspace:*",
+    "@t3tools/provider-pi": "workspace:*",
     "diff": "8.0.3",
     "effect": "catalog:",
     "jose": "catalog:",

apps/server/scripts/record-grok-acp-replay-fixture.ts

@@ -34,7 +34,7 @@ import {
 import { ACP_PROTOCOL } from "../src/orchestration-v2/Adapters/AcpAdapterV2.ts";
 import * as IdAllocator from "@t3tools/provider-core/server/ids";
 import type { ProviderAdapterV2SessionRuntime } from "@t3tools/provider-core/server/adapter";
-import * as ProviderContinuationRequests from "../src/orchestration-v2/ProviderContinuationRequests.ts";
+import * as ProviderContinuationRequests from "@t3tools/provider-core/server/continuationRequests";
 import * as ProviderAdapterRegistry from "../src/orchestration-v2/ProviderAdapterRegistry.ts";
 import { provideDeterministicTestRuntime } from "../src/orchestration-v2/testkit/DeterministicRuntime.ts";
 import { ORCHESTRATOR_REPLAY_FIXTURES } from "../src/orchestration-v2/testkit/fixtures/index.ts";

apps/server/scripts/record-pi-rpc-replay-fixture.ts

@@ -29,7 +29,7 @@ import {
   PiOrchestratorReplayHarness,
 } from "../src/orchestration-v2/Adapters/PiAdapterV2.testkit.ts";
 import * as PiAdapterV2Testkit from "../src/orchestration-v2/Adapters/PiAdapterV2.testkit.ts";
-import { PI_PROVIDER } from "../src/orchestration-v2/Adapters/PiAdapterV2.ts";
+import { PI_PROVIDER } from "@t3tools/provider-pi/server";
 import * as IdAllocator from "@t3tools/provider-core/server/ids";
 import { provideDeterministicTestRuntime } from "../src/orchestration-v2/testkit/DeterministicRuntime.ts";
 import { ORCHESTRATOR_REPLAY_FIXTURES } from "../src/orchestration-v2/testkit/fixtures/index.ts";

apps/server/src/mcp/OrchestratorMcpToolkit.integration.test.ts

@@ -64,7 +64,7 @@ import {
   type ProviderAdapterV2TurnInput,
 } from "@t3tools/provider-core/server/adapter";
 import * as ProviderAdapterRegistry from "../orchestration-v2/ProviderAdapterRegistry.ts";
-import * as ProviderContinuationRequests from "../orchestration-v2/ProviderContinuationRequests.ts";
+import * as ProviderContinuationRequests from "@t3tools/provider-core/server/continuationRequests";
 import { checkpointWorkspace } from "@t3tools/provider-testing/replayWorkspace";
 import * as ProviderReplayHarness from "../orchestration-v2/testkit/ProviderReplayHarness.ts";
 import {

apps/server/src/orchestration-v2/Adapters/AcpAdapterV2.test.ts

@@ -71,7 +71,7 @@ import {
   type ProviderAdapterV2Event,
   type ProviderAdapterV2TurnInput,
 } from "@t3tools/provider-core/server/adapter";
-import type { ProviderContinuationRequest } from "../ProviderContinuationRequests.ts";
+import type { ProviderContinuationRequest } from "@t3tools/provider-core/server/continuationRequests";
 import {
   AcpProviderCapabilitiesV2,
   acpProviderItemNativeId,

apps/server/src/orchestration-v2/Adapters/AcpAdapterV2.ts

@@ -100,7 +100,7 @@ import {
 } from "@t3tools/provider-core/server/orchestrationInstructions";
 import { buildRuntimeInstructions } from "../../provider/RuntimeInstructions.ts";
 import * as IdAllocator from "@t3tools/provider-core/server/ids";
-import { type ProviderContinuationRequest } from "../ProviderContinuationRequests.ts";
+import { type ProviderContinuationRequest } from "@t3tools/provider-core/server/continuationRequests";
 import {
   type BackgroundWork,
   type BackgroundWorkReport,

apps/server/src/orchestration-v2/Adapters/ClaudeAdapterV2.test.ts

@@ -67,7 +67,7 @@ import {
   type ProviderAdapterV2Event,
   type ProviderAdapterV2TurnInput,
 } from "@t3tools/provider-core/server/adapter";
-import type { ProviderContinuationRequest } from "../ProviderContinuationRequests.ts";
+import type { ProviderContinuationRequest } from "@t3tools/provider-core/server/continuationRequests";
 import { makeProviderFailure } from "@t3tools/provider-core/server/failure";
 import * as ClaudeAdapterV2 from "./ClaudeAdapterV2.ts";
 import * as IdAllocator from "@t3tools/provider-core/server/ids";

apps/server/src/orchestration-v2/Adapters/ClaudeAdapterV2.ts

@@ -132,7 +132,7 @@ import {
   type ProviderAdapterDriverCreateInput,
 } from "@t3tools/provider-core/server/adapterDriver";
 import { type BackgroundWorkReport, backgroundWorkNotification } from "../Notification.ts";
-import * as ProviderContinuationRequests from "../ProviderContinuationRequests.ts";
+import * as ProviderContinuationRequests from "@t3tools/provider-core/server/continuationRequests";
 import {
   makeSubagentChildThread,
   makeSubagentConversationArtifacts,

apps/server/src/orchestration-v2/Adapters/CodexAdapterV2.test.ts

@@ -1,6 +1,6 @@
 import * as NodeOS from "node:os";
 
-import { historyResponseItems } from "../ContextHandoffBudget.ts";
+import { historyResponseItems } from "@t3tools/provider-core/server/handoffBudget";
 import type { ProviderAdapterV2HistoricalContext } from "@t3tools/provider-core/server/adapter";
 import {
   makeProviderTextDeltaCoalescer,
@@ -70,7 +70,7 @@ import {
   type ProviderAdapterV2Event,
   type ProviderAdapterV2TurnInput,
 } from "@t3tools/provider-core/server/adapter";
-import type { ProviderContinuationRequest } from "../ProviderContinuationRequests.ts";
+import type { ProviderContinuationRequest } from "@t3tools/provider-core/server/continuationRequests";
 import * as CodexAdapterV2 from "./CodexAdapterV2.ts";
 import { makeReplayServerConfig, withCodexReplayChildMetadata } from "./CodexAdapterV2.testkit.ts";
 import * as CodexAdapterV2Testkit from "./CodexAdapterV2.testkit.ts";

apps/server/src/orchestration-v2/Adapters/CodexAdapterV2.ts

@@ -1,5 +1,5 @@
 import { revertCodexThread } from "../../provider/CodexThreadRevert.ts";
-import { historyResponseItems } from "../ContextHandoffBudget.ts";
+import { historyResponseItems } from "@t3tools/provider-core/server/handoffBudget";
 import { makeProviderTextDeltaCoalescer } from "./ProviderTextDeltaCoalescer.ts";
 import {
   mcpToolPresentation,
@@ -125,7 +125,7 @@ import { IdAllocatorV2, type IdAllocatorV2Shape } from "@t3tools/provider-core/s
 import {
   type ProviderContinuationRequest,
   ProviderContinuationRequests,
-} from "../ProviderContinuationRequests.ts";
+} from "@t3tools/provider-core/server/continuationRequests";
 import { backgroundWorkNotification } from "../Notification.ts";
 import {
   makeProviderFailure,

apps/server/src/orchestration-v2/Adapters/GrokAdapterV2.testkit.ts

@@ -17,7 +17,7 @@ import {
 } from "../../provider/acp/GrokAcpSupport.ts";
 import { makeXAiPromptCompletionRuntime } from "../../provider/acp/XAiAcpExtension.ts";
 import * as IdAllocator from "@t3tools/provider-core/server/ids";
-import * as ProviderContinuationRequests from "../ProviderContinuationRequests.ts";
+import * as ProviderContinuationRequests from "@t3tools/provider-core/server/continuationRequests";
 import * as ProviderAdapterRegistry from "../ProviderAdapterRegistry.ts";
 import type { ProviderReplayGate } from "@t3tools/provider-testing/replayGate";
 import type { OrchestratorV2ProviderReplayHarness } from "../testkit/ProviderReplayHarness.ts";

apps/server/src/orchestration-v2/Adapters/GrokAdapterV2.ts

@@ -58,7 +58,7 @@ import { acpPermissionDisposition } from "../../provider/acp/AcpClientPolicy.ts"
 import * as AcpSessionRuntime from "../../provider/acp/AcpSessionRuntime.ts";
 import * as ProviderEventLoggers from "../../provider/ProviderEventLoggers.ts";
 import * as IdAllocator from "@t3tools/provider-core/server/ids";
-import * as ProviderContinuationRequests from "../ProviderContinuationRequests.ts";
+import * as ProviderContinuationRequests from "@t3tools/provider-core/server/continuationRequests";
 import * as ProviderAdapter from "@t3tools/provider-core/server/adapter";
 import {
   ProviderAdapterDriverCreateError,

apps/server/src/orchestration-v2/Adapters/MuseAdapterV2.test.ts

@@ -41,7 +41,7 @@ import {
   type ProviderAdapterV2Event,
   type ProviderAdapterV2TurnInput,
 } from "@t3tools/provider-core/server/adapter";
-import type { ProviderContinuationRequest } from "../ProviderContinuationRequests.ts";
+import type { ProviderContinuationRequest } from "@t3tools/provider-core/server/continuationRequests";
 import { makeMuseAdapterV2, type MuseAdapterV2Options } from "./MuseAdapterV2.ts";
 
 const testLayer = Layer.mergeAll(

apps/server/src/orchestration-v2/Adapters/MuseAdapterV2.testkit.ts

@@ -37,7 +37,7 @@ import {
 } from "../../provider/museSdk.ts";
 import * as IdAllocator from "@t3tools/provider-core/server/ids";
 import * as ProviderAdapterRegistry from "../ProviderAdapterRegistry.ts";
-import * as ProviderContinuationRequests from "../ProviderContinuationRequests.ts";
+import * as ProviderContinuationRequests from "@t3tools/provider-core/server/continuationRequests";
 import {
   makeReplayServerConfig,
   type OrchestratorV2ProviderReplayHarness,

apps/server/src/orchestration-v2/Adapters/MuseAdapterV2.ts

@@ -96,7 +96,7 @@ import {
   type ProviderAdapterV2TurnMessage,
 } from "@t3tools/provider-core/server/adapter";
 import { backgroundWorkNotification, type BackgroundWorkReport } from "../Notification.ts";
-import type * as ProviderContinuationRequests from "../ProviderContinuationRequests.ts";
+import type * as ProviderContinuationRequests from "@t3tools/provider-core/server/continuationRequests";
 import { makeProviderFailure } from "@t3tools/provider-core/server/failure";
 import { turnScopedSelectionTransition } from "@t3tools/provider-core/server/selectionTransition";
 import { museItemStatus, museToolPresentation } from "./MuseItemPresentation.ts";

apps/server/src/orchestration-v2/Adapters/OpenCode2AdapterV2.test.ts

@@ -44,8 +44,8 @@ import type {
 } from "@t3tools/provider-core/server/adapter";
 import * as McpProviderSession from "@t3tools/provider-core/server/mcpSession";
 import * as IdAllocator from "@t3tools/provider-core/server/ids";
-import type { ProviderContinuationRequest } from "../ProviderContinuationRequests.ts";
-import * as ProviderContinuationRequests from "../ProviderContinuationRequests.ts";
+import type { ProviderContinuationRequest } from "@t3tools/provider-core/server/continuationRequests";
+import * as ProviderContinuationRequests from "@t3tools/provider-core/server/continuationRequests";
 import { OPENCODE_PROVIDER } from "./OpenCodeAdapterV2.ts";
 import { OPENCODE_2_STILL_STOPPING, t3McpServerName } from "./OpenCode2AdapterV2.ts";
 import { openCode2ReplayRuntime } from "./OpenCode2AdapterV2.testkit.ts";

apps/server/src/orchestration-v2/Adapters/OpenCode2AdapterV2.ts

@@ -88,7 +88,7 @@ import { causeErrorTag } from "@t3tools/shared/observability";
 import { providerMessageTextWithAttachmentPaths } from "../AttachmentPrompt.ts";
 import * as IdAllocator from "@t3tools/provider-core/server/ids";
 import { backgroundWorkNotification, type BackgroundWorkReport } from "../Notification.ts";
-import * as ProviderContinuationRequests from "../ProviderContinuationRequests.ts";
+import * as ProviderContinuationRequests from "@t3tools/provider-core/server/continuationRequests";
 import { makeProviderFailure } from "@t3tools/provider-core/server/failure";
 import {
   makeSubagentChildThread,

apps/server/src/orchestration-v2/Adapters/PiAdapterV2.testkit.ts

@@ -35,7 +35,7 @@ import * as IdAllocator from "@t3tools/provider-core/server/ids";
 import { ProviderAdapterDriverCreateError } from "@t3tools/provider-core/server/adapterDriver";
 import * as ProviderAdapterRegistry from "../ProviderAdapterRegistry.ts";
 import type { OrchestratorV2ProviderReplayHarness } from "../testkit/ProviderReplayHarness.ts";
-import { PI_PROVIDER, PiAdapterV2Driver } from "./PiAdapterV2.ts";
+import { PI_PROVIDER, PiAdapterV2Driver } from "@t3tools/provider-pi/server";
 
 export const PI_RPC_REPLAY_PROTOCOL = "pi.rpc-jsonl";
 export const PI_REPLAY_ANY = "<any>";

apps/server/src/orchestration-v2/ContextHandoffBudget.test.ts

@@ -23,7 +23,7 @@ import {
   historyResponseItems,
   selectHistory,
   historicalMessage,
-} from "./ContextHandoffBudget.ts";
+} from "@t3tools/provider-core/server/handoffBudget";
 import { projectContextHandoffForWire } from "./WireProjection.ts";
 import { deliverContextHandoffs } from "./ContextHandoffDelivery.ts";
 

apps/server/src/orchestration-v2/ContextHandoffDelivery.ts

@@ -6,7 +6,11 @@ import type { ProviderAdapterV2HistoricalContext } from "@t3tools/provider-core/
 import { ContextHandoffBudgetError } from "@t3tools/provider-core/server/failure";
 import * as Effect from "effect/Effect";
 import * as Schema from "effect/Schema";
-import { historyCost, renderHistory, selectHistory } from "./ContextHandoffBudget.ts";
+import {
+  historyCost,
+  renderHistory,
+  selectHistory,
+} from "@t3tools/provider-core/server/handoffBudget";
 
 /**
  * Persist before/after injection: an ambiguous pending delivery requires a fresh native thread.

apps/server/src/orchestration-v2/ContextHandoffService.ts

@@ -20,7 +20,7 @@ import {
   historicalMessage,
   renderHistory,
   selectHistory,
-} from "./ContextHandoffBudget.ts";
+} from "@t3tools/provider-core/server/handoffBudget";
 import * as IdAllocator from "@t3tools/provider-core/server/ids";
 
 export class ContextHandoffPrepareError extends Schema.TaggedError<ContextHandoffPrepareError>()(

apps/server/src/orchestration-v2/OpenCode2OrchestratorV2.live.test.ts

@@ -67,7 +67,7 @@ import * as ProviderInstanceRegistry from "../provider/ProviderInstanceRegistry.
 import * as ProviderTurnStartServiceTestkit from "./ProviderTurnStartService.testkit.ts";
 import * as RuntimeLayer from "./runtimeLayer.ts";
 import * as IdAllocator from "@t3tools/provider-core/server/ids";
-import * as ProviderContinuationRequests from "./ProviderContinuationRequests.ts";
+import * as ProviderContinuationRequests from "@t3tools/provider-core/server/continuationRequests";
 import * as ProviderContinuationService from "./ProviderContinuationService.ts";
 import * as ThreadManagementService from "./ThreadManagementService.ts";
 import * as McpSessionRegistry from "../mcp/McpSessionRegistry.ts";

apps/server/src/orchestration-v2/Orchestrator.ts

@@ -109,7 +109,7 @@ import {
 } from "./ProjectionStore.ts";
 import type { ProviderAdapterV2Shape } from "@t3tools/provider-core/server/adapter";
 import { ProviderAdapterRegistryV2 } from "./ProviderAdapterRegistry.ts";
-import { ProviderContinuationRequests } from "./ProviderContinuationRequests.ts";
+import { ProviderContinuationRequests } from "@t3tools/provider-core/server/continuationRequests";
 import { makeProviderFailure } from "@t3tools/provider-core/server/failure";
 import * as RunExecutionService from "./RunExecutionService.ts";
 import { ProviderSessionManagerV2 } from "./ProviderSessionManager.ts";

apps/server/src/orchestration-v2/ProviderContinuationService.test.ts

@@ -19,7 +19,7 @@ import * as Semaphore from "effect/Semaphore";
 import * as TestClock from "effect/testing/TestClock";
 
 import * as IdAllocator from "@t3tools/provider-core/server/ids";
-import * as ProviderContinuationRequests from "./ProviderContinuationRequests.ts";
+import * as ProviderContinuationRequests from "@t3tools/provider-core/server/continuationRequests";
 import * as ProviderContinuationService from "./ProviderContinuationService.ts";
 import * as ThreadManagementService from "./ThreadManagementService.ts";
 

apps/server/src/orchestration-v2/ProviderContinuationService.ts

@@ -4,7 +4,7 @@ import * as Layer from "effect/Layer";
 import * as Ref from "effect/Ref";
 
 import * as IdAllocator from "@t3tools/provider-core/server/ids";
-import * as ProviderContinuationRequests from "./ProviderContinuationRequests.ts";
+import * as ProviderContinuationRequests from "@t3tools/provider-core/server/continuationRequests";
 import * as ThreadManagementService from "./ThreadManagementService.ts";
 import { isUndeliveredMailboxSteer } from "./NotificationMailbox.ts";
 

apps/server/src/orchestration-v2/ProviderTurnStartService.ts

@@ -35,7 +35,7 @@ import {
   contextUsageForHandoff,
   historicalMessage,
   latestNativeContextUsage,
-} from "./ContextHandoffBudget.ts";
+} from "@t3tools/provider-core/server/handoffBudget";
 import { deliverContextHandoffs } from "./ContextHandoffDelivery.ts";
 import {
   ProviderAdapterTurnStartError,

apps/server/src/orchestration-v2/builtInProviderAdapterDrivers.ts

@@ -18,7 +18,7 @@ import {
   OpenCodeAdapterV2Driver,
   type OpenCodeAdapterV2DriverEnv,
 } from "./Adapters/OpenCodeAdapterV2.ts";
-import { PiAdapterV2Driver, type PiAdapterV2DriverEnv } from "./Adapters/PiAdapterV2.ts";
+import { PiAdapterV2Driver, type PiAdapterV2DriverEnv } from "@t3tools/provider-pi/server";
 import type { AnyProviderAdapterDriver } from "@t3tools/provider-core/server/adapterDriver";
 
 export type BuiltInProviderAdapterDriversV2Env =

apps/server/src/orchestration-v2/runtimeLayer.ts

@@ -30,7 +30,7 @@ import * as ProjectionStore from "./ProjectionStore.ts";
 import * as ProjectionMaintenance from "./ProjectionMaintenance.ts";
 import * as ProjectStore from "./ProjectStore.ts";
 import * as ProviderAdapterRegistry from "./ProviderAdapterRegistry.ts";
-import * as ProviderContinuationRequests from "./ProviderContinuationRequests.ts";
+import * as ProviderContinuationRequests from "@t3tools/provider-core/server/continuationRequests";
 import * as ProviderContinuationService from "./ProviderContinuationService.ts";
 import * as ThreadTitleRegenerationService from "./ThreadTitleRegenerationService.ts";
 import * as ProviderEventIngestor from "./ProviderEventIngestor.ts";

apps/server/src/orchestration-v2/testkit/ProviderReplayHarness.ts

@@ -35,7 +35,7 @@ import * as ProjectionStore from "../ProjectionStore.ts";
 import * as ProjectStore from "../ProjectStore.ts";
 import * as ProviderAdapterRegistry from "../ProviderAdapterRegistry.ts";
 import * as ProviderAuthService from "../../provider/ProviderAuthService.ts";
-import * as ProviderContinuationRequests from "../ProviderContinuationRequests.ts";
+import * as ProviderContinuationRequests from "@t3tools/provider-core/server/continuationRequests";
 import * as ProviderContinuationService from "../ProviderContinuationService.ts";
 import * as ProviderEventIngestor from "../ProviderEventIngestor.ts";
 import * as ProviderRuntimeRecoveryService from "../ProviderRuntimeRecoveryService.ts";

apps/server/src/orchestration-v2/testkit/ProviderSwitch.integration.test.ts

@@ -1,5 +1,5 @@
 import { vi } from "vite-plus/test";
-import { historyResponseItems } from "../ContextHandoffBudget.ts";
+import { historyResponseItems } from "@t3tools/provider-core/server/handoffBudget";
 import { assert, describe, it } from "@effect/vitest";
 import {
   CommandId,

apps/server/src/provider/AntigravityProvider.ts

@@ -19,7 +19,7 @@ import type * as EffectAcpErrors from "effect-acp/errors";
 import type * as EffectAcpSchema from "effect-acp/compat";
 
 import type { AcpSessionRuntimeStartResult } from "./acp/AcpSessionRuntime.ts";
-import { makeManagedServerProvider } from "./makeManagedServerProvider.ts";
+import { makeManagedServerProvider } from "@t3tools/provider-core/server/managedProvider";
 import {
   makeManualOnlyProviderMaintenanceCapabilities,
   type ProviderMaintenanceCapabilities,