Mục đích
Module jobs gom toàn bộ pipeline bất đồng bộ: email, Bloom filter, vector search, full-text search, like sync, notification debounce, AI evaluation, giảm HP circle và tự gỡ ban.
Về mặt kỹ thuật, module này bám pattern route -> controller -> service -> repository. Những việc chậm hoặc phụ thuộc service ngoài được đẩy sang Redis/BullMQ khi code có producer tương ứng.
Phạm vi
| Trong phạm vi ✓ | Ngoài phạm vi ✗ |
|---|---|
| Các endpoint dưới workers | UI frontend và copy hiển thị trong app |
| Validation, business rules, side effects từ code | Ý định product không thể thấy trong source |
| DB/cache/queue/service ngoài module gọi trực tiếp | SLA chính thức nếu không có trong config/code |
Công nghệ & thư viện sử dụng
| Thành phần | Công nghệ | Phiên bản | Lý do chọn | Ghi chú |
|---|---|---|---|---|
| HTTP | Express | 5.1.0 | Router/middleware rõ ràng | package.json |
| Validation | Zod | 3.25.76 | Validate request trước controller | Route nào có validate() mới enforce |
| DB | Prisma + MySQL/MariaDB | Prisma 7 | Repository truy cập database | schema.prisma |
| Async | BullMQ + Redis | BullMQ 5 | Tách tác vụ nền | Không phải module nào cũng enqueue |
Cấu trúc file
Sơ đồ này cho thấy module được chia theo vai trò: route nhận URL, controller đọc request, service quyết định nghiệp vụ, repository chạm database.
File này là một phần của luồng jobs. Đọc nó để trace request từ entrypoint tới nghiệp vụ.
snippet định vị
// đọc file này để trace module jobs import ... from "workers/index.ts"
File này là một phần của luồng jobs. Đọc nó để trace request từ entrypoint tới nghiệp vụ.
snippet định vị
// đọc file này để trace module jobs import ... from "workers/evaluate.worker.ts"
File này là một phần của luồng jobs. Đọc nó để trace request từ entrypoint tới nghiệp vụ.
snippet định vị
// đọc file này để trace module jobs import ... from "workers/like.worker.ts"
File này là một phần của luồng jobs. Đọc nó để trace request từ entrypoint tới nghiệp vụ.
snippet định vị
// đọc file này để trace module jobs import ... from "workers/notification.worker.ts"
File này là một phần của luồng jobs. Đọc nó để trace request từ entrypoint tới nghiệp vụ.
snippet định vị
// đọc file này để trace module jobs import ... from "workers/message.worker.ts"
File này là một phần của luồng jobs. Đọc nó để trace request từ entrypoint tới nghiệp vụ.
snippet định vị
// đọc file này để trace module jobs import ... from "src/server.ts"
Dependency map
Module này dùng các dependency ở bên trái và có thể được module bên phải gọi hoặc phụ thuộc gián tiếp.
Tóm tắt luồng chính
Request đồng bộ enqueue job; worker lấy job từ Redis/BullMQ, gọi service ngoài hoặc DB, rồi cập nhật dữ liệu phụ trợ.