TaskFlow is a real-time, event-driven collaborative task orchestration system that combines group-based coordination, priority scheduling, and parallel worker execution — all while persisting chat and job data in MongoDB.
Live demo: https://1taskflow.netlify.app/
TaskFlow lets users create or join groups, assign jobs, chat, and coordinate workflows — all in real time.
It’s powered by Redis (Upstash), BullMQ, and Socket.io, and built using React, Zustand, and Firebase Auth on the frontend.
When a new job or message is created, it’s broadcast instantly to every group member.
All data (groups, members, jobs, and chat messages) is stored in MongoDB — so even if users disconnect, they can return and see the full history.
- Create a new group or join via a unique invite code.
- All members receive instant notifications when someone joins.
- Real-time group chat using Socket.io.
- Chats and messages are stored in MongoDB for persistence.
- Each group defines a number of workers (different from group members).
- Any member can assign jobs to the queue.
- Jobs are processed by workers based on priority scheduling (like an OS scheduler).
- Multiple workers run in parallel, ensuring efficient job throughput.
- Jobs are simulated executions (for demo purposes), with retry logic if a job fails.
- Job results and statuses are stored in MongoDB.
- Uses Pub/Sub model with Redis (Upstash) to broadcast events across the system.
- BullMQ manages job queues and worker execution.
- Every key event (job added, job completed, member joined, message sent) is published and delivered in real time.
- MongoDB stores:
- Groups & members
- Jobs & their statuses
- Chat messages
- When users reload or revisit the page, all past data (messages + jobs) is restored automatically.
- Secure login and group access via Firebase Authentication.
- Users are identified and authorized before accessing any group or task data.
Frontend
- React (Vite)
- Tailwind CSS
- Zustand (global state)
- Firebase Auth
- Socket.io-client (real-time updates)
Backend
- Node.js (Express)
- Redis (Upstash, message broker)
- BullMQ (job queue management)
- MongoDB (persistent storage)
- Socket.io (real-time events)
- Event-driven system design
Deployment
- Frontend → Netlify
- Backend → Render (Node.js + Redis + MongoDB)
- User logs in via Firebase Auth.
- User can create or join a group using a unique code.
- Each group has:
- A set of members (real people).
- A defined number of workers (parallel job executors).
- Any member can add jobs to the group queue.
- BullMQ + Redis (Upstash) manages the queue — highest priority job executes first.
- Socket.io broadcasts updates (new jobs, completions, messages) to all connected clients.
- MongoDB stores all messages and job history for persistence.
- Jobs are simulated; failures can retry a limited number of times.
Deployment - Frontend → Netlify - Backend → Node.js + Redis + MongoDB (local/cloud)