catchしたエラーとチャットエラーをsentryに送信

Author: na-trium-144

app/(docs)/@docs/[lang]/[pageId]/chatForm.tsx

@@ -1,6 +1,13 @@
 "use client";
 
-import { useState, FormEvent, useEffect, useRef, useCallback, useMemo } from "react";
+import {
+  useState,
+  FormEvent,
+  useEffect,
+  useRef,
+  useCallback,
+  useMemo,
+} from "react";
 // import useSWR from "swr";
 // import {
 //   getQuestionExample,
@@ -13,6 +20,7 @@ import { usePathname, useRouter } from "next/navigation";
 import { ChatStreamEvent } from "@/api/chat/route";
 import { useStreamingChatContext } from "@/(docs)/streamingChatContext";
 import { revalidateChatAction } from "@/actions/revalidateChat";
+import { captureException } from "@sentry/nextjs";
 
 interface ChatFormProps {
   path: PagePath;
@@ -84,7 +92,6 @@ export function ChatForm({ path, sectionContent, close }: ChatFormProps) {
   }, [exampleChoice]);
 
   const handleSubmit = async (e: FormEvent<HTMLFormElement>) => {
-
     let userQuestion = inputValue;
     if (!userQuestion && exampleData.length > 0 && exampleChoice) {
       // 質問が空欄なら、質問例を使用
@@ -114,7 +121,8 @@ export function ChatForm({ path, sectionContent, close }: ChatFormProps) {
           execResults,
         }),
       });
-    } catch {
+    } catch (e) {
+      captureException(e);
       setErrorMessage("AIへの接続に失敗しました");
       setIsLoading(false);
       return;
@@ -184,12 +192,14 @@ export function ChatForm({ path, sectionContent, close }: ChatFormProps) {
                 streamingChatContext.finishStreaming();
                 router.refresh();
               }
-            } catch {
+            } catch (e) {
+              captureException(e);
               // ignore JSON parse errors
             }
           }
         }
       } catch (err) {
+        captureException(err);
         console.error("Stream reading failed:", err);
         // ナビゲーション後のエラーはストリーミングを終了してローディングを止める
         if (!navigated) {

app/api/chat/route.ts

@@ -18,6 +18,7 @@ import {
   ReplOutputSchema,
 } from "@my-code/runtime/interface";
 import { z } from "zod";
+import { captureException } from "@sentry/nextjs";
 
 const ChatParamsSchema = z.object({
   path: PagePathSchema,
@@ -209,9 +210,9 @@ export async function POST(request: NextRequest) {
       function send(event: ChatStreamEvent) {
         controller.enqueue(encoder.encode(JSON.stringify(event) + "\n"));
       }
+      let fullText = "";
 
       try {
-        let fullText = "";
         let headerParsed = false;
         let chatId: string | undefined;
         let contentAfterHeader = "";
@@ -244,6 +245,15 @@ export async function POST(request: NextRequest) {
                   type: "error",
                   message: "AIからの応答にタイトルが含まれていませんでした",
                 });
+                captureException(
+                  "AIからの応答にタイトルが含まれていませんでした",
+                  {
+                    extra: {
+                      prompt,
+                      fullText,
+                    },
+                  }
+                );
                 controller.close();
                 return;
               }
@@ -286,6 +296,12 @@ export async function POST(request: NextRequest) {
             type: "error",
             message: "AIからの応答の形式が正しくありませんでした",
           });
+          captureException("AIからの応答の形式が正しくありませんでした", {
+            extra: {
+              prompt,
+              fullText,
+            },
+          });
           controller.close();
           return;
         }
@@ -321,6 +337,7 @@ export async function POST(request: NextRequest) {
         send({ type: "done" });
         controller.close();
       } catch (error: unknown) {
+        captureException(error, { extra: { prompt, fullText } });
         console.error("Error in AI streaming:", error);
         try {
           controller.enqueue(