Function getNotificationService

packages/server/src/core/container.ts:72–101

()

}

export function getNotificationService(): NotificationService {
  if (!notificationService) {
    notificationService = new NotificationService();

    // 监听 task:updated，当任务进入 IN_REVIEW 时发送通知
    getEventBus().on('task:updated', ({ taskId, status }) => {
      if (status !== 'IN_REVIEW') return;
      prisma.task.findUnique({
        where: { id: taskId },
        select: { title: true, projectId: true },
      })
        .then((task) => {
          notificationService!.notify({
            type: 'task_in_review',
            title: 'Agent Tower', // 模板里会覆盖
            body: '', // 模板里会覆盖
            metadata: {
              taskId,
              taskTitle: task?.title ?? taskId,
              projectId: task?.projectId ?? '',
            },
          });
        })
        .catch((err) => {
          console.error('[NotificationService] Failed to fetch task for notification:', err);
        });
    });
  }
  return notificationService;
}