feat: setting to anchor sent messages at the top of the timeline

apps/desktop/src/settings/DesktopClientSettings.test.ts

@@ -36,7 +36,7 @@ const clientSettings: ClientSettings = {
   contextWindowMeterEnabled: false,
   composerCollapseOnScroll: true,
   dismissedProviderUpdateNotificationKeys: [],
-  diffFilesCollapsed: true,
+  diffFilesCollapsed: "viewed",
   diffIgnoreWhitespace: true,
   diffLayout: "stacked",
   environmentIdentificationMode: "artwork",
@@ -51,6 +51,7 @@ const clientSettings: ClientSettings = {
   fontSizeTerminal: 12,
   fontSmoothing: true,
   glassOpacity: 80,
+  openLinksInPreviewPattern: "",
   onboardingCompletedAt: null,
   panelAnimationDurationMs: 0,
   planModeEnabled: false,

apps/mobile/src/features/settings/SettingsThreadsRouteScreen.tsx

@@ -44,6 +44,7 @@ export function SettingsThreadsRouteScreen() {
           contentContainerStyle={{ paddingBottom: Math.max(insets.bottom, 18) + 18 }}
         >
           <AutoSettleSettingsRows />
+          <TimelineSettingsSection />
           <LegacySettingsSection />
         </ScrollView>
       </SettingsScreen>
@@ -215,6 +216,33 @@ function AutoSettleSettingsRows() {
   );
 }
 
+/**
+ * Device-local counterpart of web's "Sent message position" client setting.
+ */
+function TimelineSettingsSection() {
+  const savePreferences = useAtomSet(updateMobilePreferencesAtom);
+  const preferences = useAtomValue(mobilePreferencesAtom);
+  const anchorsAtTop =
+    AsyncResult.isSuccess(preferences) && preferences.value.chatTurnAnchor === "top";
+
+  return (
+    <View className="gap-3">
+      <SettingsSection title="Timeline">
+        <SettingsSwitchRow
+          icon="arrow.up"
+          label="Sent messages at top"
+          value={anchorsAtTop}
+          onValueChange={(value) => savePreferences({ chatTurnAnchor: value ? "top" : "bottom" })}
+        />
+      </SettingsSection>
+      <Text className="px-2 text-sm text-foreground-muted">
+        Holds each message you send at the top of the screen so the reply reads downward. Off keeps
+        the conversation pinned to the latest message.
+      </Text>
+    </View>
+  );
+}
+
 /**
  * Device-local legacy toggles. Mobile has no client-settings sync, so this is
  * the counterpart of web's Settings → General → Legacy features backed by

apps/mobile/src/features/threads/ThreadDetailScreen.tsx

@@ -9,6 +9,8 @@ import type {
   CodexFeedbackSubmission,
   EnvironmentThreadStatus,
 } from "@t3tools/client-runtime/state/threads";
+import { useAtomValue } from "@effect/atom-react";
+import { AsyncResult } from "effect/unstable/reactivity";
 import { useKeyboardChatComposerInset, useKeyboardScrollToEnd } from "@legendapp/list/keyboard";
 import { resolveProviderSkillsForCwd } from "@t3tools/client-runtime/providerSkills";
 import type { LegendListRef } from "@legendapp/list/react-native";
@@ -75,6 +77,7 @@ import { CHAT_CONTENT_MAX_WIDTH, type LayoutVariant } from "../../lib/layout";
 import { IOS_NAV_BAR_HEIGHT } from "../../lib/layoutMetrics";
 import { editPendingThreadMessage } from "../../state/edit-pending-thread-message";
 import { deviceEnvironment } from "../../state/device";
+import { mobilePreferencesAtom } from "../../state/preferences";
 import { useEnvironmentQuery } from "../../state/query";
 import { threadDevicePreviews } from "../devices/threadDevicePreviews";
 import type { QueuedThreadMessage } from "../../state/thread-outbox-model";
@@ -337,6 +340,10 @@ export const ThreadDetailScreen = memo(function ThreadDetailScreen(props: Thread
   );
   const [anchorMessageId, setAnchorMessageId] = useState<MessageId | null>(null);
   const [submittedMessageId, setSubmittedMessageId] = useState<MessageId | null>(null);
+  const preferencesResult = useAtomValue(mobilePreferencesAtom);
+  const chatTurnAnchor =
+    (AsyncResult.isSuccess(preferencesResult) ? preferencesResult.value.chatTurnAnchor : null) ??
+    "bottom";
   const [endFollowEnabled, setEndFollowEnabled] = useState(true);
   // Android keys the safe-area padding on keyboard visibility (#5988): the
   // back gesture closes the keyboard while the editor stays focused, and a
@@ -790,12 +797,14 @@ export const ThreadDetailScreen = memo(function ThreadDetailScreen(props: Thread
         hasStartedTurn: props.selectedThread.latestTurn !== null,
         hasUserMessage,
         queuedMessageCount: props.selectedThreadQueueCount,
+        turnAnchor: chatTurnAnchor,
       }),
     );
     composerEditorRef.current?.blur();
     return messageId;
   }, [
     anchorMessageId,
+    chatTurnAnchor,
     clearUsageLimitsFor,
     props.onSendMessage,
     props.selectedThread.latestTurn,

apps/mobile/src/features/threads/thread-feed-live-follow.test.ts

@@ -91,6 +91,7 @@ describe("resolveThreadFeedSubmissionAnchor", () => {
         hasStartedTurn: false,
         hasUserMessage: false,
         queuedMessageCount: 0,
+        turnAnchor: "bottom",
       }),
     ).toBe("first-message");
   });
@@ -103,6 +104,7 @@ describe("resolveThreadFeedSubmissionAnchor", () => {
         hasStartedTurn: false,
         hasUserMessage: false,
         queuedMessageCount: 1,
+        turnAnchor: "bottom",
       }),
     ).toBe("first-message");
   });
@@ -115,6 +117,7 @@ describe("resolveThreadFeedSubmissionAnchor", () => {
         hasStartedTurn: false,
         hasUserMessage: false,
         queuedMessageCount: 0,
+        turnAnchor: "bottom",
       }),
     ).toBe("first-message");
   });
@@ -127,6 +130,7 @@ describe("resolveThreadFeedSubmissionAnchor", () => {
         hasStartedTurn: false,
         hasUserMessage: true,
         queuedMessageCount: 0,
+        turnAnchor: "bottom",
       }),
     ).toBeNull();
   });
@@ -139,9 +143,36 @@ describe("resolveThreadFeedSubmissionAnchor", () => {
         hasStartedTurn: true,
         hasUserMessage: false,
         queuedMessageCount: 0,
+        turnAnchor: "bottom",
       }),
     ).toBeNull();
   });
+
+  it("re-anchors every direct send when messages anchor at the top", () => {
+    expect(
+      resolveThreadFeedSubmissionAnchor({
+        currentAnchorMessageId: "first-message",
+        submittedMessageId: "second-message",
+        hasStartedTurn: true,
+        hasUserMessage: true,
+        queuedMessageCount: 0,
+        turnAnchor: "top",
+      }),
+    ).toBe("second-message");
+  });
+
+  it("keeps the current framing for a send that queues behind others", () => {
+    expect(
+      resolveThreadFeedSubmissionAnchor({
+        currentAnchorMessageId: "first-message",
+        submittedMessageId: "second-message",
+        hasStartedTurn: true,
+        hasUserMessage: true,
+        queuedMessageCount: 1,
+        turnAnchor: "top",
+      }),
+    ).toBe("first-message");
+  });
 });
 
 describe("resolveThreadFeedLiveFollow", () => {

apps/mobile/src/features/threads/thread-feed-live-follow.ts

@@ -1,3 +1,5 @@
+import type { ChatTurnAnchor } from "@t3tools/contracts";
+
 export type ThreadFeedLiveFollowEvent =
   | { readonly type: "reset" }
   | { readonly type: "user-scroll-begin" }
@@ -47,13 +49,24 @@ export function shouldFollowThreadWorkGroupAppend(input: {
   );
 }
 
+/**
+ * Which sent message the feed should hold near the top while its turn streams.
+ * `bottom` anchors only the first message of a thread; `top` re-anchors every
+ * direct send. A message that queues behind others is not the live turn, so it
+ * leaves the current framing alone either way.
+ */
 export function resolveThreadFeedSubmissionAnchor<AnchorId>(input: {
   readonly currentAnchorMessageId: AnchorId | null;
   readonly submittedMessageId: AnchorId;
   readonly hasStartedTurn: boolean;
   readonly hasUserMessage: boolean;
   readonly queuedMessageCount: number;
+  readonly turnAnchor: ChatTurnAnchor;
 }): AnchorId | null {
+  if (input.turnAnchor === "top") {
+    return input.queuedMessageCount > 0 ? input.currentAnchorMessageId : input.submittedMessageId;
+  }
+
   if (input.hasStartedTurn || input.hasUserMessage) {
     return null;
   }

apps/mobile/src/persistence/mobile-preferences.ts

@@ -5,7 +5,11 @@ import * as Option from "effect/Option";
 import * as Ref from "effect/Ref";
 import * as Schema from "effect/Schema";
 import * as Semaphore from "effect/Semaphore";
-import type { ProviderInstanceId, SidebarProjectGroupingMode } from "@t3tools/contracts";
+import type {
+  ChatTurnAnchor,
+  ProviderInstanceId,
+  SidebarProjectGroupingMode,
+} from "@t3tools/contracts";
 import type { ComposerEnterBehavior } from "../lib/composerEnterBehavior";
 import { MOBILE_THEME_IDS, type MobileThemeId, type MobileThemeMode } from "../lib/mobileTheme";
 import * as MobileDatabase from "./mobile-database";
@@ -30,6 +34,8 @@ export interface Preferences {
   readonly collapsedProjectGroups?: readonly string[];
   /** What the Return key does in the composer on a hardware keyboard. iOS only. */
   readonly composerEnterBehavior?: ComposerEnterBehavior;
+  /** Device-local counterpart of the web client's `chatTurnAnchor` setting. */
+  readonly chatTurnAnchor?: ChatTurnAnchor;
   /** @deprecated Kept temporarily so older OTA bundles retain the selected mode. */
   readonly projectGroupingEnabled?: boolean;
   readonly projectGroupingMode?: SidebarProjectGroupingMode;
@@ -97,6 +103,7 @@ function sanitizePreferences(parsed: Preferences): Preferences {
     connectOnboardingOptOutAccounts?: ReadonlyArray<string>;
     collapsedProjectGroups?: readonly string[];
     composerEnterBehavior?: ComposerEnterBehavior;
+    chatTurnAnchor?: ChatTurnAnchor;
     projectGroupingEnabled?: boolean;
     projectGroupingMode?: SidebarProjectGroupingMode;
     planModeEnabled?: boolean;
@@ -157,6 +164,9 @@ function sanitizePreferences(parsed: Preferences): Preferences {
   if (parsed.composerEnterBehavior === "send" || parsed.composerEnterBehavior === "newline") {
     preferences.composerEnterBehavior = parsed.composerEnterBehavior;
   }
+  if (parsed.chatTurnAnchor === "bottom" || parsed.chatTurnAnchor === "top") {
+    preferences.chatTurnAnchor = parsed.chatTurnAnchor;
+  }
   if (typeof parsed.projectGroupingEnabled === "boolean") {
     preferences.projectGroupingEnabled = parsed.projectGroupingEnabled;
   }

apps/server/integration/OrchestrationEngineHarness.integration.ts

@@ -86,6 +86,8 @@ import * as WorkspacePaths from "../src/workspace/WorkspacePaths.ts";
 import * as VcsDriverRegistry from "../src/vcs/VcsDriverRegistry.ts";
 import { VcsStatusBroadcaster } from "../src/vcs/VcsStatusBroadcaster.ts";
 import { GitWorkflowService } from "../src/git/GitWorkflowService.ts";
+import * as GitHubCli from "../src/sourceControl/GitHubCli.ts";
+import { ChildProcessSpawner } from "effect/unstable/process";
 import * as VcsProcess from "../src/vcs/VcsProcess.ts";
 import * as AgentAwarenessRelay from "../src/relay/AgentAwarenessRelay.ts";
 import * as PullRequestService from "../src/pullRequest/PullRequestService.ts";
@@ -335,6 +337,16 @@ export const makeOrchestrationIntegrationHarness = (
       generateBranchName: () => Effect.succeed({ branch: "update" }),
       generateThreadTitle: () => Effect.succeed({ title: "New thread" }),
     } as unknown as TextGeneration["Service"]);
+    const gitHubCliLayer = Layer.mock(GitHubCli.GitHubCli)({
+      execute: () =>
+        Effect.succeed({
+          exitCode: ChildProcessSpawner.ExitCode(1),
+          stdout: "",
+          stderr: "",
+          stdoutTruncated: false,
+          stderrTruncated: false,
+        }),
+    } satisfies Partial<GitHubCli.GitHubCli["Service"]>);
     const providerCommandReactorLayer = ProviderCommandReactorLive.pipe(
       Layer.provide(
         Layer.mock(ProviderAuthService)({
@@ -345,6 +357,7 @@ export const makeOrchestrationIntegrationHarness = (
       Layer.provideMerge(runtimeServicesLayer),
       Layer.provideMerge(gitWorkflowLayer),
       Layer.provideMerge(textGenerationLayer),
+      Layer.provideMerge(gitHubCliLayer),
       Layer.provideMerge(serverSettingsLayer),
     );
     const checkpointReactorLayer = CheckpointReactorLive.pipe(

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

@@ -75,6 +75,8 @@ import { ServerSettingsService } from "../../serverSettings.ts";
 import { ServerActivation } from "../../serverActivation.ts";
 import { VcsStatusBroadcaster } from "../../vcs/VcsStatusBroadcaster.ts";
 import * as GitWorkflowService from "../../git/GitWorkflowService.ts";
+import * as GitHubCli from "../../sourceControl/GitHubCli.ts";
+import { ChildProcessSpawner } from "effect/unstable/process";
 
 const asProjectId = (value: string): ProjectId => ProjectId.make(value);
 const asApprovalRequestId = (value: string): ApprovalRequestId => ApprovalRequestId.make(value);
@@ -347,6 +349,21 @@ describe("ProviderCommandReactor", () => {
         }),
       ),
     );
+    const executeGitHubCli = vi.fn<GitHubCli.GitHubCli["Service"]["execute"]>((_) =>
+      Effect.succeed({
+        exitCode: ChildProcessSpawner.ExitCode(0),
+        stdout: JSON.stringify({
+          hosts: {
+            "github.com": [
+              { state: "success", active: true, host: "github.com", login: "octocat" },
+            ],
+          },
+        }),
+        stderr: "",
+        stdoutTruncated: false,
+        stderrTruncated: false,
+      }),
+    );
     const providerSnapshots = [
       {
         instanceId: modelSelection.instanceId,
@@ -475,6 +492,11 @@ describe("ProviderCommandReactor", () => {
           createWorktree,
         } satisfies Partial<GitWorkflowService.GitWorkflowService["Service"]>),
       ),
+      Layer.provideMerge(
+        Layer.mock(GitHubCli.GitHubCli)({
+          execute: executeGitHubCli,
+        } satisfies Partial<GitHubCli.GitHubCli["Service"]>),
+      ),
       Layer.provideMerge(
         Layer.succeed(VcsStatusBroadcaster, {
           getStatus: () => Effect.die("getStatus should not be called in this test"),
@@ -628,6 +650,7 @@ describe("ProviderCommandReactor", () => {
       refreshStatus,
       generateBranchName,
       generateThreadTitle,
+      executeGitHubCli,
       runtimeSessions,
       stateDir,
       drain,
@@ -2682,6 +2705,9 @@ describe("ProviderCommandReactor", () => {
       `Add a safer reconnect backoff. ${assistantQuoteText}`,
     );
     expect(harness.generateBranchName.mock.calls[0]?.[0].message).not.toContain("t3-citation://");
+    expect(harness.renameBranch.mock.calls[0]?.[0]).toMatchObject({
+      newBranch: expect.stringMatching(/^octocat\//),
+    });
     expect(harness.refreshStatus.mock.calls[0]?.[0]).toBe("/tmp/provider-project-worktree");
     const readModel = await harness.readModel();
     expect(