feat: added configurable base directory.

apps/desktop/src/main.ts

@@ -41,8 +41,8 @@ const UPDATE_STATE_CHANNEL = "desktop:update-state";
 const UPDATE_GET_STATE_CHANNEL = "desktop:update-get-state";
 const UPDATE_DOWNLOAD_CHANNEL = "desktop:update-download";
 const UPDATE_INSTALL_CHANNEL = "desktop:update-install";
-const STATE_DIR =
-  process.env.T3CODE_STATE_DIR?.trim() || Path.join(OS.homedir(), ".t3", "userdata");
+const BASE_DIR = process.env.T3CODE_BASE_DIR?.trim() || Path.join(OS.homedir(), ".t3");
+const STATE_DIR = process.env.T3CODE_STATE_DIR?.trim() || Path.join(BASE_DIR, "userdata");
 const DESKTOP_SCHEME = "t3";
 const ROOT_DIR = Path.resolve(__dirname, "../../..");
 const isDevelopment = Boolean(process.env.VITE_DEV_SERVER_URL);
@@ -865,6 +865,7 @@ function backendEnv(): NodeJS.ProcessEnv {
     T3CODE_MODE: "desktop",
     T3CODE_NO_BROWSER: "1",
     T3CODE_PORT: String(backendPort),
+    T3CODE_BASE_DIR: BASE_DIR,
     T3CODE_STATE_DIR: STATE_DIR,
     T3CODE_AUTH_TOKEN: backendAuthToken,
   };

apps/server/integration/OrchestrationEngineHarness.integration.ts

@@ -245,7 +245,7 @@ export const makeOrchestrationIntegrationHarness = (
       }),
     ).pipe(
       Layer.provide(makeCodexAdapterLive()),
-      Layer.provideMerge(ServerConfig.layerTest(workspaceDir, stateDir)),
+      Layer.provideMerge(ServerConfig.layerTest(workspaceDir, stateDir, rootDir)),
       Layer.provideMerge(NodeServices.layer),
       Layer.provideMerge(providerSessionDirectoryLayer),
     );
@@ -294,7 +294,7 @@ export const makeOrchestrationIntegrationHarness = (
     );
     const layer = orchestrationReactorLayer.pipe(
       Layer.provide(persistenceLayer),
-      Layer.provideMerge(ServerConfig.layerTest(workspaceDir, stateDir)),
+      Layer.provideMerge(ServerConfig.layerTest(workspaceDir, stateDir, rootDir)),
       Layer.provideMerge(NodeServices.layer),
     );
 

apps/server/src/config.ts

@@ -21,6 +21,7 @@ export interface ServerConfigShape {
   readonly host: string | undefined;
   readonly cwd: string;
   readonly keybindingsConfigPath: string;
+  readonly baseDir: string;
   readonly stateDir: string;
   readonly staticDir: string | undefined;
   readonly devUrl: URL | undefined;
@@ -36,13 +37,14 @@ export interface ServerConfigShape {
 export class ServerConfig extends ServiceMap.Service<ServerConfig, ServerConfigShape>()(
   "t3/config/ServerConfig",
 ) {
-  static readonly layerTest = (cwd: string, statedir: string) =>
+  static readonly layerTest = (cwd: string, statedir: string, baseDir: string) =>
     Layer.effect(
       ServerConfig,
       Effect.gen(function* () {
         const path = yield* Path.Path;
         return {
           cwd,
+          baseDir,
           stateDir: statedir,
           mode: "web",
           autoBootstrapProjectFromCwd: false,

apps/server/src/git/Layers/CodexTextGeneration.test.ts

@@ -8,9 +8,9 @@ import { CodexTextGenerationLive } from "./CodexTextGeneration.ts";
 import { TextGenerationError } from "../Errors.ts";
 import { TextGeneration } from "../Services/TextGeneration.ts";
 
-const makeCodexTextGenerationTestLayer = (stateDir: string) =>
+const makeCodexTextGenerationTestLayer = (baseDir: string) =>
   CodexTextGenerationLive.pipe(
-    Layer.provideMerge(ServerConfig.layerTest(process.cwd(), stateDir)),
+    Layer.provideMerge(ServerConfig.layerTest(process.cwd(), `${baseDir}/userdata`, baseDir)),
     Layer.provideMerge(NodeServices.layer),
   );
 

apps/server/src/git/Layers/GitCore.test.ts

@@ -12,12 +12,15 @@ import { GitCoreLive } from "./GitCore.ts";
 import { GitCore, type GitCoreShape } from "../Services/GitCore.ts";
 import { GitCommandError } from "../Errors.ts";
 import { type ProcessRunResult, runProcess } from "../../processRunner.ts";
+import { ServerConfig } from "../../config.ts";
 
 // ── Helpers ──
 
 const GitServiceTestLayer = GitServiceLive.pipe(Layer.provide(NodeServices.layer));
+const ServerConfigLayer = ServerConfig.layerTest(process.cwd(), process.cwd(), process.cwd());
 const GitCoreTestLayer = GitCoreLive.pipe(
   Layer.provide(GitServiceTestLayer),
+  Layer.provide(ServerConfigLayer),
   Layer.provide(NodeServices.layer),
 );
 const TestLayer = Layer.mergeAll(NodeServices.layer, GitServiceTestLayer, GitCoreTestLayer);
@@ -90,6 +93,7 @@ const makeIsolatedGitCore = (gitService: GitServiceShape) =>
     const gitServiceLayer = Layer.succeed(GitService, gitService);
     const coreLayer = GitCoreLive.pipe(
       Layer.provide(gitServiceLayer),
+      Layer.provide(ServerConfigLayer),
       Layer.provide(NodeServices.layer),
     );
     const core = await Effect.runPromise(Effect.service(GitCore).pipe(Effect.provide(coreLayer)));

apps/server/src/git/Layers/GitCore.ts

@@ -3,6 +3,7 @@ import { Cache, Data, Duration, Effect, Exit, FileSystem, Layer, Path } from "ef
 import { GitCommandError } from "../Errors.ts";
 import { GitService } from "../Services/GitService.ts";
 import { GitCore, type GitCoreShape } from "../Services/GitCore.ts";
+import { ServerConfig } from "../../config.ts";
 
 const STATUS_UPSTREAM_REFRESH_INTERVAL = Duration.seconds(15);
 const STATUS_UPSTREAM_REFRESH_TIMEOUT = Duration.seconds(5);
@@ -221,6 +222,8 @@ const makeGitCore = Effect.gen(function* () {
   const git = yield* GitService;
   const fileSystem = yield* FileSystem.FileSystem;
   const path = yield* Path.Path;
+  const { baseDir } = yield* ServerConfig;
+  const worktreesDir = path.join(baseDir, "worktrees");
 
   const executeGit = (
     operation: string,
@@ -1105,9 +1108,7 @@ const makeGitCore = Effect.gen(function* () {
       const targetBranch = input.newBranch ?? input.branch;
       const sanitizedBranch = targetBranch.replace(/\//g, "-");
       const repoName = path.basename(input.cwd);
-      const homeDir = process.env.HOME ?? process.env.USERPROFILE ?? "/tmp";
-      const worktreePath =
-        input.path ?? path.join(homeDir, ".t3", "worktrees", repoName, sanitizedBranch);
+      const worktreePath = input.path ?? path.join(worktreesDir, repoName, sanitizedBranch);
       const args = input.newBranch
         ? ["worktree", "add", "-b", input.newBranch, worktreePath, input.branch]
         : ["worktree", "add", worktreePath, input.branch];

apps/server/src/git/Layers/GitManager.test.ts

@@ -19,6 +19,7 @@ import { GitServiceLive } from "./GitService.ts";
 import { GitService } from "../Services/GitService.ts";
 import { GitCoreLive } from "./GitCore.ts";
 import { makeGitManager } from "./GitManager.ts";
+import { ServerConfig } from "../../config.ts";
 
 interface FakeGhScenario {
   prListSequence?: string[];
@@ -463,17 +464,20 @@ function makeManager(input?: {
 }) {
   const { service: gitHubCli, ghCalls } = createGitHubCliWithFakeGh(input?.ghScenario);
   const textGeneration = createTextGeneration(input?.textGeneration);
+  const ServerConfigLayer = ServerConfig.layerTest(process.cwd(), process.cwd(), process.cwd());
 
   const gitCoreLayer = GitCoreLive.pipe(
     Layer.provideMerge(GitServiceLive),
     Layer.provideMerge(NodeServices.layer),
+    Layer.provideMerge(ServerConfigLayer),
   );
 
   const managerLayer = Layer.mergeAll(
     Layer.succeed(GitHubCli, gitHubCli),
     Layer.succeed(TextGeneration, textGeneration),
     gitCoreLayer,
-    NodeServices.layer,
+  ).pipe(
+    Layer.provideMerge(NodeServices.layer),
   );
 
   return makeGitManager.pipe(

apps/server/src/main.ts

@@ -16,7 +16,7 @@ import {
   type RuntimeMode,
   type ServerConfigShape,
 } from "./config";
-import { fixPath, resolveStateDir } from "./os-jank";
+import { fixPath, resolveBaseDir, resolveStateDir } from "./os-jank";
 import { Open } from "./open";
 import * as SqlitePersistence from "./persistence/Layers/Sqlite";
 import { makeServerProviderLayer, makeServerRuntimeServicesLayer } from "./serverLayers";
@@ -36,6 +36,7 @@ interface CliInput {
   readonly mode: Option.Option<RuntimeMode>;
   readonly port: Option.Option<number>;
   readonly host: Option.Option<string>;
+  readonly baseDir: Option.Option<string>;
   readonly stateDir: Option.Option<string>;
   readonly devUrl: Option.Option<URL>;
   readonly noBrowser: Option.Option<boolean>;
@@ -99,6 +100,7 @@ const CliEnvConfig = Config.all({
   ),
   port: Config.port("T3CODE_PORT").pipe(Config.option, Config.map(Option.getOrUndefined)),
   host: Config.string("T3CODE_HOST").pipe(Config.option, Config.map(Option.getOrUndefined)),
+  baseDir: Config.string("T3CODE_BASE_DIR").pipe(Config.option, Config.map(Option.getOrUndefined)),
   stateDir: Config.string("T3CODE_STATE_DIR").pipe(
     Config.option,
     Config.map(Option.getOrUndefined),
@@ -152,8 +154,11 @@ const ServerConfigLive = (input: CliInput) =>
           return findAvailablePort(DEFAULT_PORT);
         },
       });
+
+      const baseDir = yield* resolveBaseDir(Option.getOrUndefined(input.baseDir) ?? env.baseDir);
       const stateDir = yield* resolveStateDir(
         Option.getOrUndefined(input.stateDir) ?? env.stateDir,
+        baseDir,
       );
       const devUrl = Option.getOrElse(input.devUrl, () => env.devUrl);
       const noBrowser = resolveBooleanFlag(input.noBrowser, env.noBrowser ?? mode === "desktop");
@@ -180,6 +185,7 @@ const ServerConfigLive = (input: CliInput) =>
         cwd: cliConfig.cwd,
         keybindingsConfigPath,
         host,
+        baseDir,
         stateDir,
         staticDir,
         devUrl,
@@ -299,6 +305,10 @@ const hostFlag = Flag.string("host").pipe(
   Flag.withDescription("Host/interface to bind (for example 127.0.0.1, 0.0.0.0, or a Tailnet IP)."),
   Flag.optional,
 );
+const baseDirFlag = Flag.string("base-dir").pipe(
+  Flag.withDescription("Base directory for all T3 Code data (equivalent to T3CODE_BASE_DIR)."),
+  Flag.optional,
+);
 const stateDirFlag = Flag.string("state-dir").pipe(
   Flag.withDescription("State directory path (equivalent to T3CODE_STATE_DIR)."),
   Flag.optional,
@@ -335,6 +345,7 @@ export const t3Cli = Command.make("t3", {
   mode: modeFlag,
   port: portFlag,
   host: hostFlag,
+  baseDir: baseDirFlag,
   stateDir: stateDirFlag,
   devUrl: devUrlFlag,
   noBrowser: noBrowserFlag,

apps/server/src/orchestration/Layers/CheckpointReactor.test.ts

@@ -254,7 +254,7 @@ describe("CheckpointReactor", () => {
       Layer.provideMerge(orchestrationLayer),
       Layer.provideMerge(Layer.succeed(ProviderService, provider.service)),
       Layer.provideMerge(CheckpointStoreLive),
-      Layer.provideMerge(ServerConfig.layerTest(process.cwd(), process.cwd())),
+      Layer.provideMerge(ServerConfig.layerTest(process.cwd(), process.cwd(), process.cwd())),
       Layer.provideMerge(NodeServices.layer),
     );
 

apps/server/src/orchestration/Layers/OrchestrationEngine.test.ts

@@ -40,7 +40,7 @@ async function createOrchestrationSystem() {
     Layer.provide(OrchestrationEventStoreLive),
     Layer.provide(OrchestrationCommandReceiptRepositoryLive),
     Layer.provide(SqlitePersistenceMemory),
-    Layer.provideMerge(ServerConfig.layerTest(process.cwd(), process.cwd())),
+    Layer.provideMerge(ServerConfig.layerTest(process.cwd(), process.cwd(), process.cwd())),
     Layer.provideMerge(NodeServices.layer),
   );
   const runtime = ManagedRuntime.make(orchestrationLayer);
@@ -323,7 +323,7 @@ describe("OrchestrationEngine", () => {
         Layer.provide(Layer.succeed(OrchestrationEventStore, flakyStore)),
         Layer.provide(OrchestrationCommandReceiptRepositoryLive),
         Layer.provide(SqlitePersistenceMemory),
-        Layer.provideMerge(ServerConfig.layerTest(process.cwd(), process.cwd())),
+        Layer.provideMerge(ServerConfig.layerTest(process.cwd(), process.cwd(), process.cwd())),
         Layer.provideMerge(NodeServices.layer),
       ),
     );