feat: ai journey creation revival

apis/api-journeys-modern/src/schema/journey/simple/simplifyJourney.ts

@@ -24,18 +24,44 @@ export function simplifyJourney(
     )
 
     // --- VIDEO BLOCK HANDLING ---
-    const videoBlock = childBlocks.find(
+    const youtubeBlock = childBlocks.find(
       (block) => block.typename === 'VideoBlock' && block.source === 'youTube'
     )
+    if (youtubeBlock) {
+      const card: JourneySimpleCard = {
+        id: `card-${index + 1}`,
+        x: stepBlock.x ?? 0,
+        y: stepBlock.y ?? 0,
+        video: {
+          src: `https://youtube.com/watch?v=${youtubeBlock.videoId}`,
+          startAt: youtubeBlock.startAt ?? undefined,
+          endAt: youtubeBlock.endAt ?? undefined,
+          source: 'youTube'
+        }
+      }
+      if (stepBlock.nextBlockId) {
+        const nextStepBlockIndex = stepBlocks.findIndex(
+          (s) => s.id === stepBlock.nextBlockId
+        )
+        if (nextStepBlockIndex >= 0) {
+          card.defaultNextCard = `card-${nextStepBlockIndex + 1}`
+        }
+      }
+      return card
+    }
+    const videoBlock = childBlocks.find(
+      (block) => block.typename === 'VideoBlock' && block.source === 'internal'
+    )
     if (videoBlock) {
       const card: JourneySimpleCard = {
         id: `card-${index + 1}`,
         x: stepBlock.x ?? 0,
         y: stepBlock.y ?? 0,
         video: {
-          url: `https://youtube.com/watch?v=${videoBlock.videoId}`,
+          src: videoBlock.src ?? '',
           startAt: videoBlock.startAt ?? undefined,
-          endAt: videoBlock.endAt ?? undefined
+          endAt: videoBlock.endAt ?? undefined,
+          source: 'internal'
         }
       }
       if (stepBlock.nextBlockId) {

apis/api-journeys-modern/src/schema/journey/simple/updateSimpleJourney.ts

@@ -228,19 +228,26 @@ export async function updateSimpleJourney(
           card.defaultNextCard != null
             ? stepBlocks.find((s) => s.simpleCardId === card.defaultNextCard)
             : undefined
-        const videoId = extractYouTubeVideoId(card.video.url)
+        const videoId =
+          card.video.source === 'youTube'
+            ? extractYouTubeVideoId(card.video.src ?? '')
+            : card.video.src
         if (videoId == null) {
           throw new Error('Invalid YouTube video URL')
         }
-        const videoDuration = await getYouTubeVideoDuration(videoId)
+        const videoDuration =
+          card.video.source === 'youTube'
+            ? await getYouTubeVideoDuration(videoId)
+            : undefined
         await tx.block.create({
           data: {
             journeyId,
             typename: 'VideoBlock',
             parentBlockId: cardBlockId,
             parentOrder: parentOrder++,
             videoId,
-            source: 'youTube',
+            videoVariantLanguageId: '529',
+            source: card.video.source,
             autoplay: true,
             startAt: card.video.startAt ?? 0,
             endAt: card.video.endAt ?? videoDuration,

apps/journeys-admin/app/api/chat/route.ts

@@ -0,0 +1,119 @@
+import { google } from '@ai-sdk/google'
+import { NoSuchToolError, streamText } from 'ai'
+import { jwtDecode } from 'jwt-decode'
+import { NextRequest } from 'next/server'
+import { v4 as uuidv4 } from 'uuid'
+import { z } from 'zod'
+
+import { messagesSchema } from '../../../src/libs/ai/chatRouteUtils'
+import {
+  langfuse,
+  langfuseEnvironment,
+  langfuseExporter
+} from '../../../src/libs/ai/langfuse/server'
+import { tools } from '../../../src/libs/ai/tools'
+import { createApolloClient } from '../../../src/libs/apolloClient'
+
+// Allow streaming responses up to 30 seconds
+export const maxDuration = 30
+
+export async function POST(req: NextRequest) {
+  const body = await req.json().catch(() => ({}))
+  if (body.messages == null) {
+    return Response.json(
+      {
+        error: 'Missing or invalid request body: messages array is required',
+        detail: 'The chat client must send { messages: [{ role, content }], ... }. Received keys: ' +
+          Object.keys(body).join(', ')
+      },
+      { status: 400 }
+    )
+  }
+  const schema = z.object({
+    messages: messagesSchema,
+    journeyId: z.string().optional(),
+    selectedStepId: z.string().optional(),
+    selectedBlockId: z.string().optional(),
+    sessionId: z.string().optional()
+  })
+  const parseResult = schema.safeParse(body)
+  if (!parseResult.success) {
+    return Response.json(
+      { error: 'Invalid request body', detail: parseResult.error.flatten() },
+      { status: 400 }
+    )
+  }
+  const { messages, journeyId, selectedStepId, selectedBlockId, sessionId } =
+    parseResult.data
+
+  const token = req.headers.get('Authorization')
+
+  if (token == null)
+    return Response.json({ error: 'Missing token' }, { status: 400 })
+  const decoded = z
+    .object({
+      user_id: z.string(),
+      auth_time: z.number()
+    })
+    .parse(jwtDecode(token.split(' ')[1]))
+
+  const client = createApolloClient(token.split(' ')[1])
+
+  const langfuseTraceId = uuidv4()
+
+  const systemPrompt = await langfuse.getPrompt(
+    'system/api/chat/route',
+    undefined,
+    {
+      label: langfuseEnvironment,
+      cacheTtlSeconds: ['development', 'preview'].includes(langfuseEnvironment)
+        ? 0
+        : 60
+    }
+  )
+
+  const result = streamText({
+    model: google('gemini-2.5-flash'),
+    messages: messages.filter((message) => message.role !== 'system'),
+    system: systemPrompt.compile({
+      journeyId: journeyId ?? 'none',
+      selectedStepId: selectedStepId ?? 'none',
+      selectedBlockId: selectedBlockId ?? 'none'
+    }),
+    tools: tools(client, { langfuseTraceId }),
+    experimental_telemetry: {
+      isEnabled: true,
+      functionId: 'ai-chat-stream',
+      metadata: {
+        langfuseTraceId,
+        langfusePrompt: systemPrompt.toJSON(),
+        userId: decoded.user_id,
+        sessionId: sessionId ?? `${decoded.user_id}-${decoded.auth_time}`
+      }
+    },
+    // Repair disabled: AI SDK no longer exposes tool.parameters (Zod) on tools;
+    // only inputSchema (JSONSchema7) is available, and generateObject expects Zod.
+    experimental_repairToolCall: async ({ error }) => {
+      if (NoSuchToolError.isInstance(error)) return null
+      return null // TODO: re-enable when SDK supports repair with current tool types
+    },
+    onFinish: async (result) => {
+      await langfuseExporter.forceFlush()
+      const trace = langfuse.trace({
+        id: langfuseTraceId
+      })
+      await trace.update({
+        output: result.text,
+        tags: ['output-added']
+      })
+    }
+  })
+
+  return result.toUIMessageStreamResponse({
+    headers: {
+      'Transfer-Encoding': 'chunked',
+      Connection: 'keep-alive',
+      'x-trace-id': langfuseTraceId
+    }
+  })
+}

apps/journeys-admin/instrumentation.ts

@@ -0,0 +1,10 @@
+import { registerOTel } from '@vercel/otel'
+
+import { langfuseExporter } from './src/libs/ai/langfuse/server'
+
+export function register() {
+  registerOTel({
+    serviceName: 'journeys-admin',
+    traceExporter: langfuseExporter
+  })
+}

apps/journeys-admin/next-env.d.ts

@@ -1,6 +1,7 @@
 /// <reference types="next" />
 /// <reference types="next/image-types/global" />
+/// <reference types="next/navigation-types/compat/navigation" />
 /// <reference path="./.next/types/routes.d.ts" />
 
 // NOTE: This file should not be edited
-// see https://nextjs.org/docs/pages/api-reference/config/typescript for more information.
+// see https://nextjs.org/docs/app/api-reference/config/typescript for more information.

apps/journeys-admin/next.config.js

@@ -11,6 +11,10 @@ const nextConfig = {
   i18n,
   images: {
     remotePatterns: [
+      {
+        protocol: 'https',
+        hostname: '**'
+      },
       { protocol: 'http', hostname: 'localhost' },
       { protocol: 'https', hostname: 'unsplash.com' },
       { protocol: 'https', hostname: 'images.unsplash.com' },
@@ -107,7 +111,15 @@ const nextConfig = {
     ]
   },
   experimental: {
+    instrumentationHook: true,
     reactCompiler: true
+  },
+  webpack: (config) => {
+    config.module.rules.push({
+      test: /\.md$/,
+      use: 'raw-loader'
+    })
+    return config
   }
 }
 const plugins = [withNx]