notify

Author: tmokmss

webapp/src/app/page.tsx

@@ -1,17 +1,16 @@
 import { prisma } from '@/lib/prisma';
 import { getSession } from '@/lib/auth';
-import { redirect } from 'next/navigation';
 import TodoItemComponent from '@/components/TodoItem';
 import CreateTodoForm from '@/components/CreateTodoForm';
 import { TodoItemStatus } from '@prisma/client';
 import Header from '@/components/Header';
 
 export default async function Home() {
-  const session = await getSession();
+  const { userId } = await getSession();
 
   const todos = await prisma.todoItem.findMany({
     where: {
-      userId: session.user.id,
+      userId,
     },
     orderBy: {
       createdAt: 'desc',
@@ -29,7 +28,7 @@ export default async function Home() {
         <div className="max-w-4xl mx-auto px-4 py-8">
           <h1 className="text-3xl font-bold mb-8 text-center">My Todo List</h1>
 
-          <CreateTodoForm />
+          <CreateTodoForm userId={userId} />
 
           <div className="mb-8">
             <h2 className="text-xl font-semibold mb-4">Pending Tasks ({pendingTodos.length})</h2>

webapp/src/components/CreateTodoForm.tsx

@@ -7,14 +7,17 @@ import { createTodo } from '@/actions/todo';
 import { createTodoSchema } from '@/actions/schemas/todo';
 import { toast } from 'sonner';
 import { useEventBus } from '@/hooks/use-event-bus';
+import { useRouter } from 'next/navigation';
 
-export default function CreateTodoForm() {
+export default function CreateTodoForm(props: { userId: string }) {
   const [isFormOpen, setIsFormOpen] = useState(false);
+  const router = useRouter();
 
   useEventBus({
-    channelName: 'test',
+    channelName: `user/${props.userId}/jobs`,
     onReceived: (data) => {
       console.log('received', data);
+      router.refresh();
     },
   });
 

webapp/src/jobs/async-job/translate.ts

@@ -21,22 +21,21 @@ export const translateJobHandler = async (params: z.infer<typeof translateJobSch
     region: process.env.AWS_REGION || 'ap-northeast-1',
   });
 
-  // Translate the title from English to Japanese
-  const translateParams: TranslateTextCommandInput = {
-    Text: todoItem.title,
-    SourceLanguageCode: 'auto',
-    TargetLanguageCode: 'ja',
-  };
-
-  const translateCommand = new TranslateTextCommand(translateParams);
-  const translateResult = await translateClient.send(translateCommand);
+  const targetLanguage = 'ja';
+  const translateResult = await translateClient.send(
+    new TranslateTextCommand({
+      Text: todoItem.title,
+      SourceLanguageCode: 'auto',
+      TargetLanguageCode: targetLanguage,
+    }),
+  );
 
   if (translateResult.TranslatedText) {
     // Create a new todo item with the translated title
     const translatedTodoItem = await prisma.todoItem.create({
       data: {
         title: translateResult.TranslatedText,
-        description: `Translated from: ${todoItem.title} (detected language: ${translateResult.SourceLanguageCode})`,
+        description: `Translated from: ${todoItem.title} (from ${translateResult.SourceLanguageCode} to ${targetLanguage})`,
         userId: params.userId,
         status: todoItem.status,
       },
@@ -45,5 +44,5 @@ export const translateJobHandler = async (params: z.infer<typeof translateJobSch
     console.log(`Created translated todo item: ${translatedTodoItem.id}`);
   }
 
-  await sendEvent(`${params.userId}/jobs`, { type: 'completed' });
+  await sendEvent(`user/${params.userId}/jobs`, { type: 'completed' });
 };