obsidian-plugin/murashit_codex-panel
1
0
Fork 0
mirror of https://github.com/murashit/codex-panel.git synced 2026-07-22 06:57:10 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Extract chat session graph responsibilities

Browse source
This commit is contained in:
murashit 2026-06-23 19:32:51 +09:00
parent 8f14f89098
commit 28857413b3
2 changed files with 38 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

28
src/features/chat/application/threads/start-new-thread-actions.ts Normal file
View file

@ -0,0 +1,28 @@
import type { ActiveThreadIdentitySync } from "./active-thread-identity-sync";
import { chatTurnBusy } from "../state/root-reducer";
import type { ChatStateStore } from "../state/store";
export interface StartNewThreadActions {
startNewThread(): Promise<void>;
}
interface StartNewThreadActionsHost {
stateStore: ChatStateStore;
identity: ActiveThreadIdentitySync;
focusComposer: () => void;
}
export function createStartNewThreadActions(host: StartNewThreadActionsHost): StartNewThreadActions {
return {
startNewThread: () => startNewThread(host),
};
}
async function startNewThread(host: StartNewThreadActionsHost): Promise<void> {
if (chatTurnBusy(host.stateStore.getState())) return;
host.identity.clearActiveThreadIdentity();
host.stateStore.dispatch({ type: "ui/panel-set", panel: null });
host.stateStore.dispatch({ type: "connection/status-set", statusText: "New chat." });
host.focusComposer();
}

19
src/features/chat/host/session-graph.ts
View file

@ -18,7 +18,7 @@ import type { ComposerSubmitActions } from "../application/conversation/composer
import { reconnectPanel, type ChatReconnectActionsHost } from "../application/connection/reconnect-actions";
import { runtimeSnapshotForChatState } from "../application/runtime/snapshot";
import { createChatRuntimeSettingsActions } from "../application/runtime/settings-actions";
import { chatTurnBusy, type ChatAction, type ChatConnectionPhase } from "../application/state/root-reducer";
import type { ChatAction, ChatConnectionPhase } from "../application/state/root-reducer";
import { messageStreamItems } from "../application/state/message-stream";
import type { ChatStateStore } from "../application/state/store";
import type { ChatResumeWorkTracker, ChatViewDeferredTasks } from "../application/lifecycle";
@ -35,6 +35,7 @@ import {
import type { RestorationController } from "../application/threads/restoration-controller";
import type { ResumeActions } from "../application/threads/resume-actions";
import { createSelectionActions } from "../application/threads/selection-actions";
import { createStartNewThreadActions } from "../application/threads/start-new-thread-actions";
import { createThreadManagementActions, type ThreadManagementActionsHost } from "../application/threads/thread-management-actions";
import type { ChatServerDiagnosticsActions } from "../app-server/actions/diagnostics";
import type { ChatServerMetadataActions } from "../app-server/actions/metadata";
@ -278,14 +279,14 @@ export function createChatPanelSessionGraph(host: ChatPanelSessionGraphHost): Ch
const composerSurface = createSessionComposerSurface(threadLifecycle, runtimeSettings);
const composerController = createSessionComposerController(host, composerSurface, runtimeSettings);
const startNewThread = async (): Promise<void> => {
if (chatTurnBusy(stateStore.getState())) return;
identity.clearActiveThreadIdentity();
stateStore.dispatch({ type: "ui/panel-set", panel: null });
stateStore.dispatch({ type: "connection/status-set", statusText: "New chat." });
composerController.focus();
};
const newThreadActions = createStartNewThreadActions({
stateStore,
identity,
focusComposer: () => {
composerController.focus();
},
});
const startNewThread = () => newThreadActions.startNewThread();
const threadActionParts = createThreadActionParts(host, {
operations: threadOperations,
connectedClient,