task celery task

Author: devsylva

README.md

@@ -21,10 +21,10 @@ The ultimate goal of a task management application is to empower users to manage
 - [x] Task Creation and Organization:
 Allow users to create tasks easily and organize them based on different parameters such as due dates, priority, categories, and projects. 
 
-- Task Tracking and Status Updates:
+- [x] Task Tracking and Status Updates:
 Enable users to track the progress of their tasks, update task statuses (e.g., to-do, in progress, completed), and get a clear overview of tasks that need attention.
 
-- Deadline Management:
+- [x] Deadline Management:
 Help users keep track of task deadlines by providing reminders, notifications, and a clear visualization of upcoming due dates.
 
 - Collaboration and Sharing:
@@ -33,10 +33,10 @@ Facilitate collaboration among teams by allowing users to assign tasks to collea
 - Time Management:
 Provide tools to estimate and track the time required to complete tasks, helping users allocate their time effectively and avoid overloading themselves.
 
-- Prioritization and Sorting:
+- [x] Prioritization and Sorting:
 Allow users to set task priorities and sort tasks based on importance, urgency, or custom criteria, aiding in making informed decisions about task order.
 
-- Customization:
+- [x] Customization:
 Offer flexibility in customizing task categories, labels, tags, and views to match users' preferred workflows and organizational methods.
 
 - Data Visualization and Insights:
@@ -110,4 +110,25 @@ The following endpoints are available in the API:
 - `api/task/task_view/` (GET): getting all task owned by the logged in user in order or priority and deadline if provided.
 - `api/task/task_detail/` (GET): getting a single task.
 - `api/task/task_detail/` (PUT): updating a task.
-- `api/task/task_detail/` (DELETE): deleting a task.
+- `api/task/task_detail/` (DELETE): deleting a task.
+- `api/task/tag_view/` (POST): allow users create tag.
+- `api/task/tag_view/` (GET): getting all tags owned by the logged in user.
+- `api/task/tag_detail/` (GET): getting a single tag.
+- `api/task/tag_detail/` (PUT): updating a tag.
+- `api/task/tag_detail/` (DELETE): deleting a tag.
+- `api/task/category_view/` (POST): allow users create category.
+- `api/task/category_view/` (GET): getting all category owned by the logged in user.
+- `api/task/category_detail/` (GET): getting a single category.
+- `api/task/category_detail/` (PUT): updating a category.
+- `api/task/category_detail/` (DELETE): deleting a category.
+
+
+
+# Contributing
+
+Contributions to this project are welcome! Go through our [GUIDELINES]()
+
+
+# License
+
+This project is licensed under the MIT License - see the [LICENSE](LICENSE) file for details.

src/task_app/admin.py

@@ -4,4 +4,5 @@
 # Register your models here.
 admin.site.register(Task)
 admin.site.register(Tag)
-admin.site.register(Category)
+admin.site.register(Category)
+admin.site.register(Reminder)

src/task_app/apps.py

@@ -4,3 +4,6 @@
 class TaskAppConfig(AppConfig):
     default_auto_field = "django.db.models.BigAutoField"
     name = "task_app"
+
+    def ready(self):
+        import task_app.signals

src/task_app/migrations/0004_category_user_tag_user_reminder.py

@@ -0,0 +1,62 @@
+# Generated by Django 4.2.4 on 2023-08-23 23:40
+
+from django.conf import settings
+from django.db import migrations, models
+import django.db.models.deletion
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        migrations.swappable_dependency(settings.AUTH_USER_MODEL),
+        ("task_app", "0003_alter_task_deadline"),
+    ]
+
+    operations = [
+        migrations.AddField(
+            model_name="category",
+            name="user",
+            field=models.ForeignKey(
+                null=True,
+                on_delete=django.db.models.deletion.CASCADE,
+                to=settings.AUTH_USER_MODEL,
+            ),
+        ),
+        migrations.AddField(
+            model_name="tag",
+            name="user",
+            field=models.ForeignKey(
+                null=True,
+                on_delete=django.db.models.deletion.CASCADE,
+                to=settings.AUTH_USER_MODEL,
+            ),
+        ),
+        migrations.CreateModel(
+            name="Reminder",
+            fields=[
+                (
+                    "id",
+                    models.BigAutoField(
+                        auto_created=True,
+                        primary_key=True,
+                        serialize=False,
+                        verbose_name="ID",
+                    ),
+                ),
+                ("notified", models.BooleanField(default=False)),
+                (
+                    "task",
+                    models.ForeignKey(
+                        on_delete=django.db.models.deletion.CASCADE, to="task_app.task"
+                    ),
+                ),
+                (
+                    "user",
+                    models.ForeignKey(
+                        on_delete=django.db.models.deletion.CASCADE,
+                        to=settings.AUTH_USER_MODEL,
+                    ),
+                ),
+            ],
+        ),
+    ]

src/task_app/migrations/0005_reminder_reminder_time.py

@@ -0,0 +1,18 @@
+# Generated by Django 4.2.4 on 2023-08-23 23:49
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ("task_app", "0004_category_user_tag_user_reminder"),
+    ]
+
+    operations = [
+        migrations.AddField(
+            model_name="reminder",
+            name="reminder_time",
+            field=models.DateTimeField(blank=True, null=True),
+        ),
+    ]

src/task_app/models.py

@@ -5,7 +5,7 @@
 # Create your models here.
 
 class Category(models.Model):
-    user = models.ForeignKey(get_user_model(), on_delete=models.CASCADE)
+    user = models.ForeignKey(get_user_model(), on_delete=models.CASCADE, null=True)
     name = models.CharField(max_length=50)
 
     def __str__(self):
@@ -17,7 +17,7 @@ class Meta:
 
 
 class Tag(models.Model):
-    user = models.ForeignKey(get_user_model(), on_delete=models.CASCADE)
+    user = models.ForeignKey(get_user_model(), on_delete=models.CASCADE, null=True)
     name = models.CharField(max_length=50)
 
     def __str__(self):
@@ -51,3 +51,13 @@ class Task(models.Model):
 
     def __str__(self):
         return self.title
+
+
+class Reminder(models.Model):
+    user = models.ForeignKey(get_user_model(), on_delete=models.CASCADE)
+    task = models.ForeignKey(Task, on_delete=models.CASCADE)
+    reminder_time = models.DateTimeField(null=True, blank=True)
+    notified = models.BooleanField(default=False)
+
+    def __str__(self) -> str:
+        return f"{self.user.first_name}'s reminder"

src/task_app/signals.py

@@ -0,0 +1,18 @@
+from django.db.models.signals import post_save
+from .models import Task, Reminder
+from django.dispatch import receiver
+from datetime import timedelta
+from django.utils import timezone
+
+
+
+@receiver(post_save, sender=Task)
+def create_reminder(sender, instance, created, **kwargs):
+    if created and instance.deadline:
+        reminder_time = instance.deadline - timedelta(minutes=20) #send reminder 20mins before the deadline
+        if reminder_time > timezone.now():
+            Reminder.objects.create(
+                user=instance.user,
+                task=instance,
+                reminder_time=reminder_time
+            )

src/task_app/tasks.py

@@ -0,0 +1,28 @@
+from django.utils import timezone
+from .models import Reminder
+from datetime import timedelta
+from django.core.mail import send_mail
+from celery.utils.log import get_task_logger
+from celery import shared_task
+
+
+logger = get_task_logger(__name__)
+
+
+@shared_task()
+def send_task_reminder():
+    now = timezone.now()
+    near_reminders = Reminder.objects.filter(reminder_time__gte=now, reminder_time__lte=now + timedelta(minutes=15), notified=False)
+    
+    for reminder in near_reminders:
+        # Send a reminder notification
+        send_mail(
+            'Reminder',
+            f"Your reminder for '{reminder.task}' is due soon.",
+            'noreply@example.com',
+            [reminder.user.email],
+            fail_silently=False,
+        )
+        
+        reminder.notified = True
+        reminder.save()

src/task_app/urls.py

@@ -6,4 +6,6 @@
     path("task_detail/<str:pk>/", TaskDetail.as_view()),
     path("tag_view/", TagView.as_view()),
     path("tag_detail/<str:pk>/", TaskDetail.as_view()),
+    path("category_view/", CategoryView.as_view()),
+    path("category_detail/<str:pk>/", CategoryDetail.as_view()),
 ]

src/task_app/views.py

@@ -18,6 +18,19 @@ class TaskView(APIView):
     list all task or create a new task
     """
     def get(self, request, format=None):
+        if "category" in request.GET:
+            category = request.GET["category"]
+            categoryid = get_object_or_404(Category, name=category).id
+            tasks = get_list_or_404(Task, user=request.user, category=categoryid)
+            serializer = TaskSerializer(tasks, many=True)
+            return Response(serializer.data)
+        elif "tag" in request.GET:
+            tag = request.GET["tag"]
+            tagid = get_object_or_404(Tag, user=request.user, name=tag).id
+            tags = get_list_or_404(Task, user=request.user, tag=tagid)
+            serializer = TagSerializer(tags, many=True)
+            return Response(serializer.data)
+
         tasks = Task.objects.filter(user=request.user).order_by('priority', 'deadline')
         serializer = TaskSerializer(tasks, many=True)
         return Response(serializer.data)
@@ -97,6 +110,49 @@ def get(self, request, pk, format=None):
         serializer = TagSerializer(tag)
         return Response(serializer.data)
 
+    def put(self, request, pk, format=None):
+        tag = self.get_object(pk)
+        serializer = TagSerializer(tag, data=request.data)
+        if serializer.is_valid():
+            serializer.save()
+            return Response(serializer.data)
+        return Response(serializer.errors, status=status.HTTP_400_BAD_REQUEST)
+
+
+class CategoryView(APIView):
+    permission_classes = [IsAuthenticated]
+    """
+    list all task or create a new task
+    """
+    def get(self, request, format=None):
+        tags = Tag.objects.filter(user=request.user)
+        serializer = TagSerializer(tags, many=True)
+        return Response(serializer.data)
+
+    def post(self, request, format=None):
+        serializer = TagSerializer(data=request.data)
+        if serializer.is_valid():
+            serializer.save()   
+            return Response(serializer.data, status=status.HTTP_201_CREATED)
+        return Response(serializer.errors, status=status.HTTP_400_BAD_REQUEST)
+
+
+class CategoryDetail(APIView):
+    permission_classes = [IsAuthenticated]
+    """
+    Retrieve, update or delete a snippet instance.
+    """
+    def get_object(self, pk):
+        try:
+            return Tag.objects.get(pk=pk)
+        except Tag.DoesNotExist:
+            raise Http404
+
+    def get(self, request, pk, format=None):
+        tag = self.get_object(pk)
+        serializer = TagSerializer(tag)
+        return Response(serializer.data)
+
     def put(self, request, pk, format=None):
         tag = self.get_object(pk)
         serializer = TagSerializer(tag, data=request.data)