('closed')
+ const [inviteHintVisible, setInviteHintVisible] = useState(false)
const accountMenuOpen = accountMenuState === 'open'
const creditBalance = useQuotaBalance(
accountMenuState !== 'closed' && session.state.status === 'authenticated',
@@ -99,15 +101,40 @@ export function AppHeader({ quotaApis = defaultQuotaApis }: AppHeaderProps = {})
return () => window.clearTimeout(timer)
}, [accountMenuState])
+ useEffect(() => {
+ if (pathname !== '/workspace' || session.state.status !== 'authenticated') {
+ setInviteHintVisible(false)
+ return
+ }
+
+ if (window.sessionStorage.getItem(inviteHintStorageKey) === '1') return
+
+ window.sessionStorage.setItem(inviteHintStorageKey, '1')
+ setInviteHintVisible(true)
+
+ const timer = window.setTimeout(() => {
+ setInviteHintVisible(false)
+ }, 15_000)
+
+ return () => window.clearTimeout(timer)
+ }, [pathname, session.state.status])
+
function signOut() {
+ window.sessionStorage.removeItem(inviteHintStorageKey)
const returnHome = () => navigate('/', { replace: true })
void session.logout().then(returnHome, returnHome)
}
function toggleAccountMenu() {
+ dismissInviteHint()
setAccountMenuState((state) => (state === 'open' ? 'closing' : 'open'))
}
+ function dismissInviteHint() {
+ window.sessionStorage.setItem(inviteHintStorageKey, '1')
+ setInviteHintVisible(false)
+ }
+
function finishAccountMenuMotion() {
if (accountMenuState === 'closing') {
setAccountMenuState('closed')
@@ -210,6 +237,36 @@ export function AppHeader({ quotaApis = defaultQuotaApis }: AppHeaderProps = {})
) : (
<>
+ {inviteHintVisible ? (
+
+
+
+
+ 邀请好友，双方各得 200 积分
+
+
+ 去看看邀请奖励
+
+
+
+
+
{
nodes,
})
expect(request?.method).toBe('PATCH')
- await expect(request?.json()).resolves.toEqual({ nodes, status: 'active' })
+ await expect(request?.json()).resolves.toEqual({ nodes, status: 'active', version: 3 })
expect(updated.version).toBe(4)
})
+ it('exposes a version conflict as a workflow-run domain error', async () => {
+ const apis = await loadWorkflowRunApis(
+ async () =>
+ new Response(
+ JSON.stringify({ code: 409, message: '执行记录版本冲突，请刷新后重试', data: null }),
+ { headers: { 'content-type': 'application/json' } },
+ ),
+ )
+
+ await expect(
+ apis.update({
+ id: '17',
+ projectId: '42',
+ version: 3,
+ storageStatus: 'active',
+ nodes,
+ }),
+ ).rejects.toMatchObject({
+ name: 'WorkflowRunConflictError',
+ message: '执行记录版本冲突，请刷新后重试',
+ })
+ })
+
+ it('preserves non-conflict API errors from an update', async () => {
+ const apis = await loadWorkflowRunApis(
+ async () =>
+ new Response(JSON.stringify({ code: 500, message: '保存失败', data: null }), {
+ headers: { 'content-type': 'application/json' },
+ }),
+ )
+
+ await expect(
+ apis.update({
+ id: '17',
+ projectId: '42',
+ version: 3,
+ storageStatus: 'active',
+ nodes,
+ }),
+ ).rejects.toMatchObject({ name: 'ApiError', code: 500, message: '保存失败' })
+ })
+
it('soft deletes through the backend DELETE endpoint', async () => {
let request: Request | undefined
const apis = await loadWorkflowRunApis(async (input, init) => {
diff --git a/frontend/src/entities/workflow-run/api.ts b/frontend/src/entities/workflow-run/api.ts
index b1493317..a9569c45 100644
--- a/frontend/src/entities/workflow-run/api.ts
+++ b/frontend/src/entities/workflow-run/api.ts
@@ -17,6 +17,14 @@ import {
WORKFLOW_RUN_STORAGE_STATUSES,
} from './constants'
+/** 当前 WorkflowRun 已被其他请求更新，调用方需要重新读取后再继续修改。 */
+export class WorkflowRunConflictError extends Error {
+ constructor(message: string, options?: ErrorOptions) {
+ super(message, options)
+ this.name = 'WorkflowRunConflictError'
+ }
+}
+
interface WorkflowRunDto {
id: number
project_id: number
@@ -299,12 +307,22 @@ export const workflowRunApis: WorkflowRunApis & Required
(`/workflow-runs/${encodeURIComponent(run.id)}`, {
- method: 'PATCH',
- json: { nodes: run.nodes, status: run.storageStatus },
- }),
- )
+ try {
+ return mapWorkflowRun(
+ await getApiClient().request(
+ `/workflow-runs/${encodeURIComponent(run.id)}`,
+ {
+ method: 'PATCH',
+ json: { nodes: run.nodes, status: run.storageStatus, version: run.version },
+ },
+ ),
+ )
+ } catch (cause) {
+ if (cause instanceof ApiError && cause.kind === 'business' && cause.code === 409) {
+ throw new WorkflowRunConflictError(cause.message, { cause })
+ }
+ throw cause
+ }
},
async remove(id) {
await getApiClient().request(`/workflow-runs/${encodeURIComponent(id)}`, {
diff --git a/frontend/src/entities/workflow-run/index.ts b/frontend/src/entities/workflow-run/index.ts
index 3eae85c1..1c45613d 100644
--- a/frontend/src/entities/workflow-run/index.ts
+++ b/frontend/src/entities/workflow-run/index.ts
@@ -121,7 +121,7 @@ export type WorkflowNode =
export interface WorkflowRun {
id: string
projectId: string
- /** 后端更新序号；当前仅随 PATCH 递增，不承担并发冲突检测。 */
+ /** 后端乐观锁版本；更新时原样回传，保存成功后使用响应中的新版本。 */
version: number
/** 后端资源状态，仅表示正常或软删除。 */
storageStatus: WorkflowRunStorageStatus
@@ -143,4 +143,4 @@ export interface WorkflowRunApis {
remove(id: WorkflowRun['id']): Promise
}
-export { workflowRunApis } from './api'
+export { WorkflowRunConflictError, workflowRunApis } from './api'
diff --git a/frontend/src/features/auth-session/index.test.tsx b/frontend/src/features/auth-session/index.test.tsx
index 126b7b6a..38c212dd 100644
--- a/frontend/src/features/auth-session/index.test.tsx
+++ b/frontend/src/features/auth-session/index.test.tsx
@@ -93,6 +93,7 @@ async function expectState(value: string) {
afterEach(() => {
cleanup()
clearRefreshToken()
+ window.sessionStorage.clear()
currentSession = null
vi.useRealTimers()
})
@@ -164,6 +165,7 @@ describe('AuthSessionProvider', () => {
)
it('clears local state before best-effort logout finishes and never restores it on failure', async () => {
+ window.sessionStorage.setItem('windup.auth-session.invite-hint-seen.v1', '1')
const logout = deferred()
const apis = createApis()
apis.logout.mockReturnValue(logout.promise)
@@ -176,6 +178,7 @@ describe('AuthSessionProvider', () => {
logoutPromise = session().logout()
})
await expectState('guest:logged-out:')
+ expect(window.sessionStorage.getItem('windup.auth-session.invite-hint-seen.v1')).toBeNull()
expect(getApiAccessToken()).toBeNull()
expect(window.localStorage.getItem(REFRESH_TOKEN_STORAGE_KEY)).toBeNull()
expect(apis.logout).toHaveBeenCalledWith('refresh-token')
diff --git a/frontend/src/features/auth-session/index.tsx b/frontend/src/features/auth-session/index.tsx
index fa5e568c..80499175 100644
--- a/frontend/src/features/auth-session/index.tsx
+++ b/frontend/src/features/auth-session/index.tsx
@@ -14,11 +14,14 @@ import type { AuthTokens, User, UserApis } from '@/entities'
import { registerApiAccessTokenProvider, registerApiUnauthorizedRecovery } from '@/shared/api'
import {
REFRESH_TOKEN_STORAGE_KEY,
+ clearAuthSessionScopedStorage,
clearRefreshToken,
loadRefreshToken,
saveRefreshToken,
} from './session-storage'
+export { AUTH_SESSION_STORAGE_PREFIX } from './session-storage'
+
export type AuthGuestReason = null | 'logged-out' | 'session-expired' | 'password-changed'
export type AuthSessionState =
@@ -97,6 +100,7 @@ export function AuthSessionProvider({ apis, children }: AuthSessionProviderProps
accessTokenRef.current = null
refreshTokenRef.current = null
if (persist) clearRefreshToken()
+ clearAuthSessionScopedStorage()
setAccessTokenVersion((version) => version + 1)
updateState({ status: 'guest', user: null, reason })
},
diff --git a/frontend/src/features/auth-session/session-storage.test.ts b/frontend/src/features/auth-session/session-storage.test.ts
index 8edf5824..6f2726a1 100644
--- a/frontend/src/features/auth-session/session-storage.test.ts
+++ b/frontend/src/features/auth-session/session-storage.test.ts
@@ -1,8 +1,47 @@
import { describe, expect, it, vi } from 'vitest'
-import { REFRESH_TOKEN_STORAGE_KEY, createRefreshTokenStorage } from './session-storage'
+import {
+ AUTH_SESSION_STORAGE_PREFIX,
+ REFRESH_TOKEN_STORAGE_KEY,
+ clearAuthSessionScopedStorage,
+ createRefreshTokenStorage,
+} from './session-storage'
describe('refresh token storage', () => {
+ it('clears only values owned by the current auth session namespace', () => {
+ const values = new Map([
+ [`${AUTH_SESSION_STORAGE_PREFIX}invite-hint-seen.v1`, '1'],
+ ['unrelated.preference', 'keep'],
+ ])
+ const storage = {
+ get length() {
+ return values.size
+ },
+ key: (index: number) => [...values.keys()][index] ?? null,
+ removeItem: vi.fn((key: string) => values.delete(key)),
+ }
+
+ clearAuthSessionScopedStorage(storage)
+
+ expect(storage.removeItem).toHaveBeenCalledWith(
+ `${AUTH_SESSION_STORAGE_PREFIX}invite-hint-seen.v1`,
+ )
+ expect(values.get('unrelated.preference')).toBe('keep')
+ })
+
+ it('does not let unavailable session storage block session teardown', () => {
+ expect(() => clearAuthSessionScopedStorage(null)).not.toThrow()
+ expect(() =>
+ clearAuthSessionScopedStorage({
+ length: 1,
+ key: () => {
+ throw new DOMException('Storage is disabled', 'SecurityError')
+ },
+ removeItem: vi.fn(),
+ }),
+ ).not.toThrow()
+ })
+
it('persists only the refresh token under the contracted key', () => {
const values = new Map()
const storage = {
diff --git a/frontend/src/features/auth-session/session-storage.ts b/frontend/src/features/auth-session/session-storage.ts
index a79851a8..811f4248 100644
--- a/frontend/src/features/auth-session/session-storage.ts
+++ b/frontend/src/features/auth-session/session-storage.ts
@@ -1,6 +1,8 @@
export const REFRESH_TOKEN_STORAGE_KEY = 'windup.auth.refresh-token'
+export const AUTH_SESSION_STORAGE_PREFIX = 'windup.auth-session.'
type RefreshTokenStorage = Pick
+type SessionScopedStorage = Pick
export interface RefreshTokenStore {
load(): string | null
@@ -16,6 +18,29 @@ function getLocalStorage(): RefreshTokenStorage | null {
}
}
+function getSessionStorage(): SessionScopedStorage | null {
+ try {
+ return globalThis.sessionStorage
+ } catch {
+ return null
+ }
+}
+
+/** 清除只属于一次登录会话的 UI 标记；登出、过期和改密都经过这一边界。 */
+export function clearAuthSessionScopedStorage(storage = getSessionStorage()): void {
+ if (!storage) return
+ try {
+ const keys: string[] = []
+ for (let index = 0; index < storage.length; index += 1) {
+ const key = storage.key(index)
+ if (key?.startsWith(AUTH_SESSION_STORAGE_PREFIX)) keys.push(key)
+ }
+ for (const key of keys) storage.removeItem(key)
+ } catch {
+ // sessionStorage 不可用不应阻断登出或会话失效。
+ }
+}
+
/**
* localStorage 是跨刷新、跨标签的增强能力，不是维持当前页面登录的前提。
* 浏览器拒绝存储访问时，闭包中的副本继续支撑本标签页会话。
diff --git a/frontend/src/features/workflow-controller/controller.test.ts b/frontend/src/features/workflow-controller/controller.test.ts
index fe62ab39..a6d28de0 100644
--- a/frontend/src/features/workflow-controller/controller.test.ts
+++ b/frontend/src/features/workflow-controller/controller.test.ts
@@ -15,6 +15,7 @@ import type {
WorkflowRun,
WorkflowRunApis,
} from '@/entities'
+import { WorkflowRunConflictError } from '@/entities'
import { createWorkflowController } from '.'
function setupNode(
@@ -255,20 +256,6 @@ async function flushAsyncWork() {
}
describe('WorkflowController', () => {
- it('绑定角色后拒绝把同一条 WorkflowRun 改绑到另一角色', async () => {
- const { controller } = createController()
-
- await controller.bindCharacter('setup-1', 'character-1')
-
- expect(controller.getWorkflow().nodes[0]).toMatchObject({
- type: 'character-setup',
- input: { characterId: 'character-1' },
- })
- await expect(controller.bindCharacter('setup-1', 'character-2')).rejects.toThrow(
- 'WorkflowRun 已绑定到另一角色，不能改绑',
- )
- })
-
it('只在角色设定节点仍处于配置阶段时更新提示词和参考媒体', async () => {
const { controller } = createController()
@@ -288,10 +275,19 @@ describe('WorkflowController', () => {
it('接受上传母版时完成角色设定和母版节点', async () => {
const { controller } = createController()
- await controller.acceptUploadedCharacterTemplate('setup-1', 'https://img/uploaded-template.png')
+ await controller.acceptUploadedCharacterTemplate(
+ 'setup-1',
+ 'https://img/uploaded-template.png',
+ 'character-1',
+ )
expect(controller.getWorkflow().nodes).toMatchObject([
- { type: 'character-setup', status: 'passed', phase: 'completed' },
+ {
+ type: 'character-setup',
+ status: 'passed',
+ phase: 'completed',
+ input: { characterId: 'character-1' },
+ },
{
type: 'character-template',
status: 'passed',
@@ -301,6 +297,64 @@ describe('WorkflowController', () => {
])
})
+ it('母版确认和上传都拒绝错误节点状态与角色改绑', async () => {
+ const { controller: lockedController } = createController()
+ await expect(
+ lockedController.confirmCharacterTemplate(
+ 'template-1',
+ 'https://img/knight.png',
+ 'character-1',
+ ),
+ ).rejects.toThrow('角色母版节点当前不能确认候选图')
+ await expect(
+ lockedController.confirmCharacterTemplate(
+ 'setup-1' as never,
+ 'https://img/knight.png',
+ 'character-1',
+ ),
+ ).rejects.toThrow('目标节点不是角色母版')
+
+ const boundRun = createRun([
+ setupNode({
+ status: 'passed',
+ phase: 'completed',
+ input: {
+ prompt: '像素骑士',
+ referenceMedia: [],
+ characterId: 'character-existing',
+ },
+ }),
+ templateNode({ status: 'active', phase: 'selecting' }),
+ ])
+ const { controller: boundController } = createController(boundRun)
+ await expect(
+ boundController.confirmCharacterTemplate(
+ 'template-1',
+ 'https://img/knight.png',
+ 'character-other',
+ ),
+ ).rejects.toThrow('WorkflowRun 已绑定到另一角色，不能改绑')
+
+ const uploadRun = createRun([
+ setupNode({
+ input: {
+ prompt: '像素骑士',
+ referenceMedia: [],
+ characterId: 'character-existing',
+ },
+ }),
+ templateNode(),
+ ])
+ const { controller: uploadController } = createController(uploadRun)
+ await expect(
+ uploadController.acceptUploadedCharacterTemplate(
+ 'setup-1',
+ 'https://img/uploaded.png',
+ 'character-other',
+ ),
+ ).rejects.toThrow('WorkflowRun 已绑定到另一角色，不能改绑')
+ })
+
it('页面通过订阅接收命令保存和 SSE 写回后的同一份 WorkflowRun', async () => {
const { controller, generation } = createController()
let renderedWorkflow = controller.getWorkflow()
@@ -711,10 +765,14 @@ describe('WorkflowController', () => {
])
const { controller } = createController(run)
- await controller.confirmCharacterTemplate('template-1', 'https://img/knight.png')
+ await controller.confirmCharacterTemplate('template-1', 'https://img/knight.png', 'character-1')
expect(controller.getWorkflow().nodes).toEqual(
expect.arrayContaining([
+ expect.objectContaining({
+ id: 'setup-1',
+ input: expect.objectContaining({ characterId: 'character-1' }),
+ }),
expect.objectContaining({ id: 'template-1', status: 'passed', phase: 'completed' }),
expect.objectContaining({ id: 'action-walk', status: 'active' }),
expect.objectContaining({ id: 'action-jump', status: 'active' }),
@@ -1294,7 +1352,7 @@ describe('WorkflowController', () => {
])
const { controller } = createController(run)
- await controller.confirmCharacterTemplate('template-1', 'https://img/knight.png')
+ await controller.confirmCharacterTemplate('template-1', 'https://img/knight.png', 'character-1')
expect(controller.getWorkflow().nodes[2]).toMatchObject({
status: 'locked',
@@ -1311,7 +1369,7 @@ describe('WorkflowController', () => {
vi.mocked(workflow.apis.update).mockRejectedValueOnce(new Error('后端保存失败'))
await expect(
- controller.confirmCharacterTemplate('template-1', 'https://img/knight.png'),
+ controller.confirmCharacterTemplate('template-1', 'https://img/knight.png', 'character-1'),
).rejects.toThrow('后端保存失败')
expect(controller.getWorkflow().nodes[1]).toMatchObject({
@@ -1321,6 +1379,47 @@ describe('WorkflowController', () => {
})
})
+ it('PATCH 已落库但响应丢失时接纳回读快照并将命令视为成功', async () => {
+ const run = createRun([
+ setupNode({ status: 'passed', phase: 'completed' }),
+ templateNode({ status: 'active', phase: 'selecting' }),
+ ])
+ const { controller, workflow } = createController(run)
+ const update = vi.mocked(workflow.apis.update)
+ const get = vi.mocked(workflow.apis.get)
+ const persist = update.getMockImplementation()!
+ const read = get.getMockImplementation()!
+ update.mockImplementationOnce(async (candidate) => {
+ await persist(candidate)
+ throw new WorkflowRunConflictError('执行记录版本冲突')
+ })
+ get.mockImplementationOnce(async (id) => {
+ const reverseObjectKeys = (value: unknown): unknown => {
+ if (Array.isArray(value)) return value.map(reverseObjectKeys)
+ if (value === null || typeof value !== 'object') return value
+ return Object.fromEntries(
+ Object.entries(value)
+ .reverse()
+ .map(([key, item]) => [key, reverseObjectKeys(item)]),
+ )
+ }
+ return reverseObjectKeys(await read(id)) as WorkflowRun
+ })
+
+ await controller.confirmCharacterTemplate('template-1', 'https://img/knight.png', 'character-1')
+
+ expect(controller.getWorkflow()).toMatchObject({
+ version: 2,
+ nodes: expect.arrayContaining([
+ expect.objectContaining({
+ id: 'setup-1',
+ input: expect.objectContaining({ characterId: 'character-1' }),
+ }),
+ expect.objectContaining({ id: 'template-1', status: 'passed' }),
+ ]),
+ })
+ })
+
it('生成任务创建成功但引用保存失败时，重试复用同一个任务', async () => {
const run = createRun([...completedCharacterNodes(), ...actionNodes()])
const { controller, workflow, generation } = createController(run)
diff --git a/frontend/src/features/workflow-controller/controller.ts b/frontend/src/features/workflow-controller/controller.ts
index c9fbe637..ad14106c 100644
--- a/frontend/src/features/workflow-controller/controller.ts
+++ b/frontend/src/features/workflow-controller/controller.ts
@@ -88,8 +88,6 @@ export interface WorkflowController {
nodeId: CharacterSetupWorkflowNode['id'],
options: GenerateCharacterTemplateOptions,
): Promise
- /** 将已创建的 Character 绑定到入口节点；一条 Run 不允许改绑到另一角色。 */
- bindCharacter(nodeId: CharacterSetupWorkflowNode['id'], characterId: string): Promise
/** 仅在入口节点尚未提交时修改角色描述和参考媒体。 */
updateCharacterSetup(
nodeId: CharacterSetupWorkflowNode['id'],
@@ -99,10 +97,12 @@ export interface WorkflowController {
acceptUploadedCharacterTemplate(
nodeId: CharacterSetupWorkflowNode['id'],
selectedImageUrl: string,
+ characterId: string,
): Promise
confirmCharacterTemplate(
nodeId: CharacterTemplateWorkflowNode['id'],
selectedImageUrl: string,
+ characterId: string,
): Promise
generateFirstFrame(
nodeId: ActionFirstFrameWorkflowNode['id'],
@@ -213,8 +213,19 @@ export function createWorkflowController({
const candidate = transform(before)
if (candidate === before) return structuredClone(before)
- // 只有后端确认保存后才替换内存快照；失败时页面不会看到“假成功”。
- const saved = await workflowRunApis.update(candidate)
+ // 只有更新响应或回读结果确认已落库后才替换内存快照，避免页面显示“假成功”。
+ let saved: WorkflowRun
+ try {
+ saved = await workflowRunApis.update(candidate)
+ } catch (cause) {
+ try {
+ const latest = await workflowRunApis.get(candidate.id)
+ if (!hasSamePersistedState(candidate, latest)) throw cause
+ saved = latest
+ } catch {
+ throw cause
+ }
+ }
current = structuredClone(saved)
notifyListeners()
return structuredClone(saved)
@@ -395,42 +406,42 @@ export function createWorkflowController({
function confirmCharacterTemplate(
nodeId: CharacterTemplateWorkflowNode['id'],
selectedImageUrl: string,
+ characterId: string,
) {
ensureRunning()
const imageUrl = nonEmpty(selectedImageUrl, 'selectedImageUrl')
- return persist((run) =>
- updateNode(run, nodeId, (node) => {
- if (node.type !== 'character-template') throw new Error('目标节点不是角色母版')
- if (node.status !== 'active' || node.phase !== 'selecting') {
- throw new Error('角色母版节点当前不能确认候选图')
- }
- return unlockReadyNodes({
- ...run,
- nodes: run.nodes.map((item) =>
- item.id === node.id
- ? { ...node, selectedImageUrl: imageUrl, phase: 'completed', status: 'passed' }
- : item,
- ),
- })
- }),
- )
- }
-
- function bindCharacter(nodeId: CharacterSetupWorkflowNode['id'], characterId: string) {
- ensureRunning()
const normalizedCharacterId = nonEmpty(characterId, 'characterId')
- return persist((run) =>
- updateNode(run, nodeId, (node) => {
- if (node.type !== 'character-setup') throw new Error('目标节点不是角色设定')
- if (node.input.characterId && node.input.characterId !== normalizedCharacterId) {
- throw new Error('WorkflowRun 已绑定到另一角色，不能改绑')
- }
- return replaceNode(run, {
- ...node,
- input: { ...node.input, characterId: normalizedCharacterId },
- })
- }),
- )
+ return persist((run) => {
+ const templateNode = findNode(run, nodeId)
+ if (templateNode.type !== 'character-template') throw new Error('目标节点不是角色母版')
+ if (templateNode.status !== 'active' || templateNode.phase !== 'selecting') {
+ throw new Error('角色母版节点当前不能确认候选图')
+ }
+ const setupNode = findSingleDependencyNode(run, templateNode, 'character-setup')
+ if (setupNode.input.characterId && setupNode.input.characterId !== normalizedCharacterId) {
+ throw new Error('WorkflowRun 已绑定到另一角色，不能改绑')
+ }
+ return unlockReadyNodes({
+ ...run,
+ nodes: run.nodes.map((node) => {
+ if (node.id === setupNode.id) {
+ return {
+ ...setupNode,
+ input: { ...setupNode.input, characterId: normalizedCharacterId },
+ }
+ }
+ if (node.id === templateNode.id) {
+ return {
+ ...templateNode,
+ selectedImageUrl: imageUrl,
+ phase: 'completed',
+ status: 'passed',
+ }
+ }
+ return node
+ }),
+ })
+ })
}
function updateCharacterSetup(
@@ -460,9 +471,11 @@ export function createWorkflowController({
function acceptUploadedCharacterTemplate(
nodeId: CharacterSetupWorkflowNode['id'],
selectedImageUrl: string,
+ characterId: string,
) {
ensureRunning()
const imageUrl = nonEmpty(selectedImageUrl, 'selectedImageUrl')
+ const normalizedCharacterId = nonEmpty(characterId, 'characterId')
return persist((run) => {
const setupNode = findNode(run, nodeId)
if (setupNode.type !== 'character-setup') throw new Error('目标节点不是角色设定')
@@ -473,11 +486,20 @@ export function createWorkflowController({
if (templateNode.status !== 'locked' || templateNode.phase !== 'ready') {
throw new Error('角色母版节点当前不能使用上传图片')
}
+ if (setupNode.input.characterId && setupNode.input.characterId !== normalizedCharacterId) {
+ throw new Error('WorkflowRun 已绑定到另一角色，不能改绑')
+ }
return unlockReadyNodes({
...run,
nodes: run.nodes.map((node) => {
if (node.id === setupNode.id) {
- return { ...setupNode, status: 'passed', phase: 'completed', error: null }
+ return {
+ ...setupNode,
+ status: 'passed',
+ phase: 'completed',
+ error: null,
+ input: { ...setupNode.input, characterId: normalizedCharacterId },
+ }
}
if (node.id === templateNode.id) {
return {
@@ -980,7 +1002,6 @@ export function createWorkflowController({
setCharacterName: asCommand(setCharacterName),
addAction: asCommand(addAction),
generateCharacterTemplate: asCommand(generateCharacterTemplate),
- bindCharacter: asCommand(bindCharacter),
updateCharacterSetup: asCommand(updateCharacterSetup),
acceptUploadedCharacterTemplate: asCommand(acceptUploadedCharacterTemplate),
confirmCharacterTemplate: asCommand(confirmCharacterTemplate),
@@ -999,6 +1020,26 @@ export function createWorkflowController({
}
}
+function hasSamePersistedState(expected: WorkflowRun, actual: WorkflowRun) {
+ return (
+ expected.id === actual.id &&
+ expected.projectId === actual.projectId &&
+ expected.storageStatus === actual.storageStatus &&
+ JSON.stringify(canonicalizeJson(expected.nodes)) ===
+ JSON.stringify(canonicalizeJson(actual.nodes))
+ )
+}
+
+function canonicalizeJson(value: unknown): unknown {
+ if (Array.isArray(value)) return value.map(canonicalizeJson)
+ if (value === null || typeof value !== 'object') return value
+ return Object.fromEntries(
+ Object.entries(value)
+ .sort(([left], [right]) => left.localeCompare(right))
+ .map(([key, item]) => [key, canonicalizeJson(item)]),
+ )
+}
+
function asCommand(
operation: (...args: TArgs) => Promise,
): (...args: TArgs) => Promise {
diff --git a/frontend/src/index.css b/frontend/src/index.css
index b622fe2f..b4fb77b8 100644
--- a/frontend/src/index.css
+++ b/frontend/src/index.css
@@ -141,6 +141,7 @@ body,
--shadow-app-card: 0 18px 45px rgb(29 37 31 / 9%);
--shadow-app-panel: 0 22px 60px rgb(29 37 31 / 12%);
+ --shadow-app-composer-focus: 0 18px 48px rgb(29 37 31 / 14%);
--shadow-app-page: 0 26px 80px rgb(29 37 31 / 10%);
--shadow-app-header: inset 0 1px 0 rgb(255 255 255 / 55%);
--shadow-app-menu: 0 8px 24px rgb(29 37 31 / 10%);
diff --git a/frontend/src/pages/quick-start/index.test.tsx b/frontend/src/pages/quick-start/index.test.tsx
index 9868b59a..bfc92522 100644
--- a/frontend/src/pages/quick-start/index.test.tsx
+++ b/frontend/src/pages/quick-start/index.test.tsx
@@ -1,10 +1,10 @@
import { StrictMode } from 'react'
import { act, cleanup, fireEvent, render, screen, waitFor } from '@testing-library/react'
-import { MemoryRouter, Route, Routes, useLocation } from 'react-router'
+import { MemoryRouter, Route, Routes, useLocation, useNavigate } from 'react-router'
import { afterEach, describe, expect, it, vi } from 'vitest'
import type { QuickStartEntryService, QuickStartSession } from './service'
-import type { WorkflowRun } from '@/entities'
+import { WorkflowRunConflictError, type WorkflowRun } from '@/entities'
import type { ExportPackageModel } from '@/features/export-package'
import { QuickStartPage } from './index'
@@ -119,6 +119,7 @@ function serviceFor(run: WorkflowRun | null, overrides: Partial
startAction: vi.fn(async () => service),
getWorkflow: vi.fn(() => fallbackRun),
subscribe: vi.fn(() => () => undefined),
+ subscribeErrors: vi.fn(() => () => undefined),
resume: vi.fn(async () => fallbackRun),
interrupt: vi.fn(async () => fallbackRun),
dispose: vi.fn(),
@@ -137,6 +138,16 @@ function serviceFor(run: WorkflowRun | null, overrides: Partial
return service
}
+function deferred() {
+ let resolve!: (value: T) => void
+ let reject!: (reason?: unknown) => void
+ const promise = new Promise((nextResolve, nextReject) => {
+ resolve = nextResolve
+ reject = nextReject
+ })
+ return { promise, resolve, reject }
+}
+
function renderAt(path: string, service: QuickStartEntryService) {
function PlaytestLocation() {
const location = useLocation()
@@ -154,6 +165,34 @@ function renderAt(path: string, service: QuickStartEntryService) {
)
}
+function renderWithRunSwitcher(
+ service: QuickStartEntryService,
+ initialRunId: string,
+ nextRunId: string,
+) {
+ function Controls() {
+ const navigate = useNavigate()
+ const location = useLocation()
+ return (
+ <>
+
+
+
+ )
+ }
+
+ return render(
+
+
+
+ } />
+
+ ,
+ )
+}
+
function renderStateFixture(
state:
| 'template-generating'
@@ -338,8 +377,6 @@ describe('QuickStartPage', () => {
expect(screen.getByRole('button', { name: /16-bit 日式 RPG/u })).toBeTruthy()
expect(screen.getByRole('button', { name: /暗黑哥特像素/u })).toBeTruthy()
expect(screen.getByRole('button', { name: /温暖手绘像素/u })).toBeTruthy()
- expect(screen.getByRole('button', { name: '像素守夜人' })).toBeTruthy()
- expect(screen.getByRole('button', { name: '轻装信使' })).toBeTruthy()
fireEvent.change(screen.getByRole('textbox', { name: '创作指令' }), {
target: { value: '戴银色面具的游侠' },
@@ -350,18 +387,27 @@ describe('QuickStartPage', () => {
expect(screen.queryByRole('button', { name: /暗黑哥特像素/u })).toBeNull()
})
- it('keeps the original Quick Start prompt shortcuts functional', () => {
- const view = renderAt('/quick-start', serviceFor(null))
- fireEvent.click(screen.getByRole('button', { name: '像素守夜人' }))
- expect((screen.getByRole('textbox', { name: '创作指令' }) as HTMLTextAreaElement).value).toBe(
- '一位提着风灯、披深色斗篷的像素守夜人',
+ it('offers style prompts only, without the retired role-example shortcuts', () => {
+ renderAt('/quick-start', serviceFor(null))
+
+ // 入口只保留三张风格卡：角色样例会让人误以为这些形象是现成资产。
+ expect(screen.queryByRole('button', { name: '像素守夜人' })).toBeNull()
+ expect(screen.queryByRole('button', { name: '轻装信使' })).toBeNull()
+
+ fireEvent.click(screen.getByRole('button', { name: /16-bit 日式 RPG/u }))
+ expect((screen.getByRole('textbox', { name: '创作指令' }) as HTMLInputElement).value).toBe(
+ '16-bit 日式 RPG 像素风，清晰轮廓，明亮配色',
)
+ })
- view.unmount()
+ it('keeps the entry composer on a single line', () => {
renderAt('/quick-start', serviceFor(null))
- fireEvent.click(screen.getByRole('button', { name: '轻装信使' }))
- expect((screen.getByRole('textbox', { name: '创作指令' }) as HTMLTextAreaElement).value).toBe(
- '轻装信使，侧视像素风，轮廓清晰，动作轻快',
+ const composer = screen.getByRole('textbox', { name: '创作指令' })
+
+ expect(composer.tagName).toBe('INPUT')
+ expect(composer.className).toContain('h-10')
+ expect(composer.closest('form')?.className).toContain(
+ 'focus-within:shadow-[var(--shadow-app-composer-focus)]',
)
})
@@ -748,7 +794,7 @@ describe('QuickStartPage', () => {
expect(screen.getByRole('textbox', { name: '创作指令' })).toBeTruthy()
fireEvent.click(screen.getByRole('button', { name: /16-bit 日式 RPG/u }))
- expect((screen.getByRole('textbox') as HTMLTextAreaElement).value).toBe(
+ expect((screen.getByRole('textbox') as HTMLInputElement).value).toBe(
'16-bit 日式 RPG 像素风，清晰轮廓，明亮配色',
)
expect(screen.queryByRole('button', { name: /暗黑哥特像素/u })).toBeNull()
@@ -806,7 +852,7 @@ describe('QuickStartPage', () => {
it('hands the created session to the run page under the production StrictMode lifecycle', async () => {
const service = serviceFor(null)
- render(
+ const view = render(
@@ -822,7 +868,10 @@ describe('QuickStartPage', () => {
await waitFor(() => expect(service.resume).toHaveBeenCalled())
expect(service.open).not.toHaveBeenCalled()
- expect(service.dispose).toHaveBeenCalled()
+ expect(service.dispose).not.toHaveBeenCalled()
+
+ view.unmount()
+ await waitFor(() => expect(service.dispose).toHaveBeenCalledOnce())
})
it('shows entry errors and supports removing an uploaded template', async () => {
@@ -846,7 +895,7 @@ describe('QuickStartPage', () => {
fireEvent.change(screen.getByLabelText('上传角色母版'), { target: { files: [file] } })
const composer = screen.getByLabelText('创作指令').closest('form')
- expect(screen.getByLabelText('创作指令').tagName).toBe('TEXTAREA')
+ expect(screen.getByLabelText('创作指令').tagName).toBe('INPUT')
expect(composer?.textContent).toContain('hero.png')
expect(screen.getByRole('button', { name: '移除图片' }).closest('form')).toBe(composer)
expect(composer?.querySelector('[data-layout="quick-start-attachment-row"]')).toBeNull()
@@ -923,6 +972,304 @@ describe('QuickStartPage', () => {
expect(screen.getByTestId('quick-start-run')).toBeTruthy()
})
+ it('freezes the current conversation and offers a full reload after a version conflict', async () => {
+ const run = workflow(setupAndTemplate())
+ const service = serviceFor(run, {
+ getTemplateCandidates: vi.fn(async () => ['https://example.test/candidate.png']),
+ confirmCandidate: vi.fn(async () => {
+ throw new WorkflowRunConflictError('执行记录版本冲突，请刷新后重试')
+ }),
+ })
+ renderAt('/quick-start/run-1?source=test#selection', service)
+
+ fireEvent.click(await screen.findByRole('img', { name: '角色图候选 1' }))
+ fireEvent.click(screen.getByRole('button', { name: '确认选择，继续下一步' }))
+
+ const alert = await screen.findByRole('alert')
+ expect(alert.textContent).toContain('工作流已在其他位置更新，请加载最新版本后继续。')
+ expect(screen.getByRole('link', { name: '加载最新版本' }).getAttribute('href')).toBe(
+ '/quick-start/run-1?source=test#selection',
+ )
+ const confirm = screen.getByRole('button', { name: '确认选择，继续下一步' })
+ expect((confirm as HTMLButtonElement).disabled).toBe(true)
+ fireEvent.click(confirm)
+ expect(service.confirmCandidate).toHaveBeenCalledTimes(1)
+ })
+
+ it('keeps a reported conflict visible when an earlier result read fails later', async () => {
+ const run = workflow(setupAndTemplate())
+ let reportError: ((error: Error) => void) | null = null
+ let rejectRead: ((error: Error) => void) | null = null
+ const pendingRead = new Promise((_resolve, reject) => {
+ rejectRead = reject
+ })
+ const service = serviceFor(run, {
+ getTemplateCandidates: vi.fn(() => pendingRead),
+ subscribeErrors: vi.fn((listener) => {
+ reportError = listener
+ return () => undefined
+ }),
+ })
+ renderAt('/quick-start/run-1', service)
+
+ await waitFor(() => expect(service.getTemplateCandidates).toHaveBeenCalled())
+ act(() => {
+ reportError?.(new WorkflowRunConflictError('执行记录版本冲突，请刷新后重试'))
+ })
+ expect(await screen.findByRole('link', { name: '加载最新版本' })).toBeTruthy()
+
+ await act(async () => {
+ rejectRead?.(new Error('候选读取失败'))
+ await pendingRead.catch(() => undefined)
+ })
+ expect(screen.getByRole('alert').textContent).toContain(
+ '工作流已在其他位置更新，请加载最新版本后继续。',
+ )
+ })
+
+ it('does not auto-save a completed action after the session reports a conflict', async () => {
+ const run = workflow(setupAndTemplate())
+ const completed = actionWorkflow({ fullStatus: 'passed', reviewStatus: 'active' })
+ let reportError: ((error: Error) => void) | null = null
+ let reportRun: ((run: WorkflowRun) => void) | null = null
+ const service = serviceFor(run, {
+ subscribeErrors: vi.fn((listener) => {
+ reportError = listener
+ return () => undefined
+ }),
+ subscribe: vi.fn((listener) => {
+ reportRun = listener
+ return () => undefined
+ }),
+ })
+ renderAt('/quick-start/run-1', service)
+
+ await waitFor(() => expect(service.subscribeErrors).toHaveBeenCalledOnce())
+ act(() => {
+ reportError?.(new WorkflowRunConflictError('执行记录版本冲突，请刷新后重试'))
+ reportRun?.(completed)
+ })
+
+ expect(await screen.findByRole('link', { name: '加载最新版本' })).toBeTruthy()
+ await waitFor(() => expect(service.approveReview).not.toHaveBeenCalled())
+ })
+
+ it('ignores an old session resume result after navigating to another run', async () => {
+ const oldRun = workflow(setupAndTemplate(), 'run-old')
+ const newNodes = setupAndTemplate()
+ const newSetup = newNodes[0]
+ if (newSetup?.type !== 'character-setup') throw new Error('测试工作流缺少角色设定节点')
+ newSetup.input.prompt = '新角色'
+ const newRun = workflow(newNodes, 'run-new')
+ let resolveOldResume: ((run: WorkflowRun) => void) | null = null
+ const oldResume = new Promise((resolve) => {
+ resolveOldResume = resolve
+ })
+ const oldSession = serviceFor(oldRun, { resume: vi.fn(() => oldResume) })
+ const newSession = serviceFor(newRun)
+ const entryService = serviceFor(null, {
+ open: vi.fn(async (id) => (id === oldRun.id ? oldSession : newSession)),
+ })
+
+ renderWithRunSwitcher(entryService, oldRun.id, newRun.id)
+
+ expect(await screen.findByText('像素骑士')).toBeTruthy()
+ fireEvent.click(screen.getByRole('button', { name: '切换当前运行' }))
+ expect(await screen.findByText('新角色')).toBeTruthy()
+
+ await act(async () => {
+ resolveOldResume?.(oldRun)
+ await oldResume
+ })
+ expect(screen.getByText('新角色')).toBeTruthy()
+ expect(screen.queryByText('像素骑士')).toBeNull()
+ })
+
+ it('ignores old session result reads and error events after switching runs', async () => {
+ const oldRun = workflow(setupAndTemplate(), 'run-old')
+ const newNodes = setupAndTemplate()
+ const newSetup = newNodes[0]
+ if (newSetup?.type !== 'character-setup') throw new Error('测试工作流缺少角色设定节点')
+ newSetup.input.prompt = '当前新运行'
+ const newRun = workflow(newNodes, 'run-new')
+ const oldRead = deferred()
+ let reportOldError: ((error: Error) => void) | null = null
+ const oldSession = serviceFor(oldRun, {
+ getTemplateCandidates: vi.fn(() => oldRead.promise),
+ subscribeErrors: vi.fn((listener) => {
+ reportOldError = listener
+ return () => undefined
+ }),
+ })
+ const newSession = serviceFor(newRun)
+ const entryService = serviceFor(null, {
+ open: vi.fn(async (id) => (id === oldRun.id ? oldSession : newSession)),
+ })
+
+ renderWithRunSwitcher(entryService, oldRun.id, newRun.id)
+
+ await waitFor(() => expect(oldSession.getTemplateCandidates).toHaveBeenCalled())
+ fireEvent.click(screen.getByRole('button', { name: '切换当前运行' }))
+ expect(await screen.findByText('当前新运行')).toBeTruthy()
+
+ await act(async () => {
+ reportOldError?.(new Error('旧会话错误'))
+ oldRead.reject(new Error('旧候选读取失败'))
+ await oldRead.promise.catch(() => undefined)
+ })
+ expect(screen.queryByText(/旧会话错误|旧候选读取失败/u)).toBeNull()
+ })
+
+ it('ignores completed commands from the previous session after switching runs', async () => {
+ const oldRun = actionWorkflow({ fullStatus: 'passed', reviewStatus: 'passed' })
+ oldRun.id = 'run-old'
+ const newNodes = setupAndTemplate()
+ const newSetup = newNodes[0]
+ if (newSetup?.type !== 'character-setup') throw new Error('测试工作流缺少角色设定节点')
+ newSetup.input.prompt = '当前新运行'
+ const newRun = workflow(newNodes, 'run-new')
+ const playtest = deferred<{ characterId: string; outfitId: string } | null>()
+ const failedPlaytest = deferred<{ characterId: string; outfitId: string } | null>()
+ const oldSession = serviceFor(oldRun, {
+ getCharacterInfo: vi.fn(() => null),
+ resolveCharacterInfo: vi
+ .fn()
+ .mockImplementationOnce(() => playtest.promise)
+ .mockImplementationOnce(() => failedPlaytest.promise),
+ getActionFrames: vi.fn(async () => [
+ { index: 0, imageUrl: 'https://example.test/frame.png', durationMs: 80 },
+ ]),
+ })
+ const newSession = serviceFor(newRun)
+ const entryService = serviceFor(null, {
+ open: vi.fn(async (id) => (id === oldRun.id ? oldSession : newSession)),
+ })
+
+ renderWithRunSwitcher(entryService, oldRun.id, newRun.id)
+
+ fireEvent.click(await screen.findByRole('button', { name: '跳转到 Play Test' }))
+ fireEvent.click(screen.getByRole('button', { name: '跳转到 Play Test' }))
+ await waitFor(() => expect(oldSession.resolveCharacterInfo).toHaveBeenCalledTimes(2))
+ fireEvent.click(screen.getByRole('button', { name: '切换当前运行' }))
+ expect(await screen.findByText('当前新运行')).toBeTruthy()
+
+ await act(async () => {
+ playtest.resolve({ characterId: 'old-character', outfitId: 'old-outfit' })
+ failedPlaytest.reject(new Error('旧 Play Test 打开失败'))
+ await Promise.allSettled([playtest.promise, failedPlaytest.promise])
+ })
+ expect(screen.getByRole('status', { name: '当前位置' }).textContent).toBe(
+ '/quick-start/run-new',
+ )
+ expect(screen.queryByText('旧 Play Test 打开失败')).toBeNull()
+ })
+
+ it('ignores automatic publishing completed by the previous session after switching runs', async () => {
+ const oldRun = actionWorkflow({ fullStatus: 'passed', reviewStatus: 'active' })
+ oldRun.id = 'run-old'
+ const newNodes = setupAndTemplate()
+ const newSetup = newNodes[0]
+ if (newSetup?.type !== 'character-setup') throw new Error('测试工作流缺少角色设定节点')
+ newSetup.input.prompt = '当前新运行'
+ const newRun = workflow(newNodes, 'run-new')
+ const publish = deferred()
+ const oldSession = serviceFor(oldRun, {
+ approveReview: vi.fn(() => publish.promise),
+ getActionFrames: vi.fn(async () => [
+ { index: 0, imageUrl: 'https://example.test/frame.png', durationMs: 80 },
+ ]),
+ })
+ const newSession = serviceFor(newRun)
+ const entryService = serviceFor(null, {
+ open: vi.fn(async (id) => (id === oldRun.id ? oldSession : newSession)),
+ })
+
+ renderWithRunSwitcher(entryService, oldRun.id, newRun.id)
+
+ await waitFor(() => expect(oldSession.approveReview).toHaveBeenCalled())
+ fireEvent.click(screen.getByRole('button', { name: '切换当前运行' }))
+ expect(await screen.findByText('当前新运行')).toBeTruthy()
+
+ await act(async () => {
+ publish.resolve(actionWorkflow({ fullStatus: 'passed', reviewStatus: 'passed' }))
+ await publish.promise
+ })
+ expect(screen.getByText('当前新运行')).toBeTruthy()
+ })
+
+ it('disposes a regenerated session that resolves after navigating to another run', async () => {
+ const oldRun = workflow(setupAndTemplate(), 'run-old')
+ const newNodes = setupAndTemplate()
+ const newSetup = newNodes[0]
+ if (newSetup?.type !== 'character-setup') throw new Error('测试工作流缺少角色设定节点')
+ newSetup.input.prompt = '当前新运行'
+ const newRun = workflow(newNodes, 'run-new')
+ const regeneratedRun = workflow(setupAndTemplate(), 'run-regenerated')
+ const regeneratedSession = serviceFor(regeneratedRun)
+ let resolveRegeneration: ((session: QuickStartSession) => void) | null = null
+ const pendingRegeneration = new Promise((resolve) => {
+ resolveRegeneration = resolve
+ })
+ const oldSession = serviceFor(oldRun, {
+ getTemplateCandidates: vi.fn(async () => ['https://example.test/candidate.png']),
+ })
+ const newSession = serviceFor(newRun)
+ const entryService = serviceFor(null, {
+ start: vi.fn(() => pendingRegeneration),
+ open: vi.fn(async (id) => (id === oldRun.id ? oldSession : newSession)),
+ })
+
+ renderWithRunSwitcher(entryService, oldRun.id, newRun.id)
+
+ fireEvent.click(await screen.findByRole('button', { name: '重新生成' }))
+ await waitFor(() => expect(entryService.start).toHaveBeenCalledWith('像素骑士'))
+ fireEvent.click(screen.getByRole('button', { name: '切换当前运行' }))
+ expect(await screen.findByText('当前新运行')).toBeTruthy()
+
+ await act(async () => {
+ resolveRegeneration?.(regeneratedSession)
+ await pendingRegeneration
+ })
+ expect(screen.getByRole('status', { name: '当前位置' }).textContent).toBe(
+ '/quick-start/run-new',
+ )
+ expect(regeneratedSession.dispose).toHaveBeenCalledOnce()
+ })
+
+ it('ignores a regeneration error after navigating to another run', async () => {
+ const oldRun = workflow(setupAndTemplate(), 'run-old')
+ const newNodes = setupAndTemplate()
+ const newSetup = newNodes[0]
+ if (newSetup?.type !== 'character-setup') throw new Error('测试工作流缺少角色设定节点')
+ newSetup.input.prompt = '当前新运行'
+ const newRun = workflow(newNodes, 'run-new')
+ const regeneration = deferred()
+ const oldSession = serviceFor(oldRun, {
+ getTemplateCandidates: vi.fn(async () => ['https://example.test/candidate.png']),
+ })
+ const newSession = serviceFor(newRun)
+ const entryService = serviceFor(null, {
+ start: vi.fn(() => regeneration.promise),
+ open: vi.fn(async (id) => (id === oldRun.id ? oldSession : newSession)),
+ })
+
+ renderWithRunSwitcher(entryService, oldRun.id, newRun.id)
+
+ fireEvent.click(await screen.findByRole('button', { name: '重新生成' }))
+ await waitFor(() => expect(entryService.start).toHaveBeenCalled())
+ fireEvent.click(screen.getByRole('button', { name: '切换当前运行' }))
+ expect(await screen.findByText('当前新运行')).toBeTruthy()
+
+ await act(async () => {
+ regeneration.reject(new Error('旧重新生成失败'))
+ await regeneration.promise.catch(() => undefined)
+ })
+ expect(screen.getByRole('status', { name: '当前位置' }).textContent).toBe(
+ '/quick-start/run-new',
+ )
+ expect(screen.queryByText('旧重新生成失败')).toBeNull()
+ })
+
it('keeps the original regenerate and new-creation controls reachable', async () => {
const run = workflow(setupAndTemplate())
const service = serviceFor(run, {
diff --git a/frontend/src/pages/quick-start/index.tsx b/frontend/src/pages/quick-start/index.tsx
index 7cf3e2ae..ddd86922 100644
--- a/frontend/src/pages/quick-start/index.tsx
+++ b/frontend/src/pages/quick-start/index.tsx
@@ -10,12 +10,13 @@ import {
type ReactNode,
} from 'react'
import { ArrowUp, ImageSquare, X } from '@phosphor-icons/react'
-import { Link, useNavigate, useParams, useSearchParams } from 'react-router'
+import { Link, useLocation, useNavigate, useParams, useSearchParams } from 'react-router'
import {
type ActionFirstFrameWorkflowNode,
type CharacterTemplateWorkflowNode,
type WorkflowRun,
+ WorkflowRunConflictError,
} from '@/entities'
import { ExportButton, type ExportPackageModel } from '@/features/export-package'
import { KineticCopyCycle, type KineticCopyMessage } from './kinetic-copy-cycle'
@@ -128,14 +129,19 @@ export function QuickStartPage({ service }: QuickStartPageProps) {
return service ?? quickStartService
}, [service])
const [createdSession, setCreatedSession] = useState(null)
+ const consumeCreatedSession = useCallback((consumed: QuickStartSession) => {
+ setCreatedSession((current) => (current === consumed ? null : current))
+ }, [])
const characterId = searchParams.get('characterId')
const outfitId = searchParams.get('outfitId')
return runId ? (
) : characterId && outfitId ? (
() => {
submitAbortController.current?.abort()
@@ -361,47 +356,25 @@ function QuickStartInput({
))}
- {originalPromptShortcuts.map((shortcut) => (
-
- ))}
-
+ 
+ 
+ 
+
+