Function startGenerationFlow

frontend/src/composables/useGenerationRunner.ts:19–73

()

  let isUnmounted = false

  async function startGenerationFlow() {
    if (store.outline.pages.length === 0) {
      router.push('/')
      return
    }

    if (await restoreFromHistory()) return

    await ensureRecord()

    store.startGeneration()

    generateImagesPost(
      store.outline.pages,
      null,
      store.outline.raw,
      (event) => {
        console.log('Progress:', event)
      },
      (event) => {
        console.log('Complete:', event)
        if (event.image_url) {
          store.updateProgress(event.index, 'done', event.image_url)
        }
      },
      (event) => {
        console.error('Error:', event)
        store.updateProgress(
          event.index,
          'error',
          undefined,
          formatErrorMessage(event.error || event.message || '图片生成失败', '图片生成失败')
        )
      },
      (event) => {
        console.log('Finish:', event)
        store.finishGeneration(event.task_id)

        if (!hasFailedImages.value) {
          redirectTimer.value = window.setTimeout(() => {
            if (!isUnmounted) {
              router.push('/result')
            }
          }, 1000)
        }
      },
      (err) => {
        console.error('Stream Error:', err)
        setError(normalizeApiError(err, '图片生成失败'))
      },
      store.userImages.length > 0 ? store.userImages : undefined,
      store.topic,
      store.recordId
    )
  }

  function cleanupGenerationRunner() {
    isUnmounted = true