Endpoints for task comments

src/backend/app/db/db_models.py

@@ -384,6 +384,32 @@ class DbTaskHistory(Base):
     )
 
 
+class TaskComment(Base):
+    """Represents a comment associated with a task."""
+
+    __tablename__ = "task_comment"
+
+    id = Column(Integer, primary_key=True)
+    task_id = Column(Integer, nullable=False)
+    project_id = Column(Integer, ForeignKey("projects.id"), index=True)
+    comment_text = Column(String)
+    commented_by = Column(
+        BigInteger,
+        ForeignKey("users.id", name="fk_users"),
+        index=True,
+        nullable=False,
+    )
+    created_at = Column(DateTime, nullable=False, default=timestamp)
+
+    __table_args__ = (
+        ForeignKeyConstraint(
+            [task_id, project_id], ["tasks.id", "tasks.project_id"], name="fk_tasks"
+        ),
+        Index("idx_task_comment_composite", "task_id", "project_id"),
+        {},
+    )
+
+
 class DbTask(Base):
     """Describes an individual mapping Task."""
 

src/backend/app/tasks/tasks_crud.py

@@ -29,6 +29,7 @@
 from sqlalchemy.orm import Session
 from sqlalchemy.sql import text
 
+from app.auth.osm import AuthUser
 from app.central import central_crud
 from app.db import database, db_models
 from app.models.enums import (
@@ -315,6 +316,82 @@ async def edit_task_boundary(db: Session, task_id: int, boundary: str):
     return True
 
 
+async def get_task_comments(db: Session, project_id: int, task_id: int):
+    """Get a list of tasks id for a project."""
+    query = text(
+        f"""
+        SELECT task_history.id,task_history.task_id,users.username,task_history.action_text,
+        task_history.action_date FROM task_history
+        LEFT JOIN users ON task_history.user_id = users.id
+        where project_id = {project_id} AND task_id = {task_id} AND action = 'COMMENT'
+    """
+    )
+
+    # Then execute the query with the desired parameter
+    result = db.execute(query)
+
+    # Convert the result to a list of dictionaries
+    result_dict_list = [
+        {
+            "id": row[0],
+            "task_id": row[1],
+            "commented_by": row[2],
+            "comment": row[3],
+            "created_at": row[4],
+        }
+        for row in result.fetchall()
+    ]
+
+    return result_dict_list
+
+
+async def add_task_comments(
+    db: Session, comment: tasks_schemas.TaskCommentBase, user_data: AuthUser
+):
+    """Add a comment to a task.
+
+    Parameters:
+    - db: SQLAlchemy database session
+    - comment: TaskCommentBase instance containing the comment details
+    - user_data: AuthUser instance containing the user details
+
+    Returns:
+    - Dictionary with the details of the added comment
+    """
+    currentdate = datetime.now()
+    # Construct the query to insert the comment and retrieve inserted comment details
+    query = text(
+        f"""
+        WITH inserted_comment AS (
+        INSERT INTO task_history
+        (project_id,task_id,"action",action_text,action_date,user_id)
+        VALUES({comment.project_id},{comment.task_id},'COMMENT',
+        '{comment.comment}','{currentdate}',{user_data.id})
+        RETURNING
+        task_history.id,task_history.task_id, task_history.action_text,
+        task_history.action_date,task_history.user_id )
+        SELECT ic.id, ic.task_id,username as user_id,action_text,action_date
+        FROM inserted_comment ic
+        LEFT JOIN users u ON ic.user_id = u.id;
+    """
+    )
+    # Execute the query and commit the transaction
+    result = db.execute(query)
+    db.commit()
+
+    # Fetch the first row of the query result
+    row = result.fetchone()
+
+    # Return the details of the added comment as a dictionary
+    return {
+        "id": row[0],
+        "task_id": row[1],
+        "commented_by": row[2],
+        "comment": row[3],
+        "created_at": row[4],
+    }
+
+
 async def update_task_history(
     tasks: List[tasks_schemas.Task], db: Session = Depends(database.get_db)
 ):

src/backend/app/tasks/tasks_routes.py

@@ -33,6 +33,8 @@
 from app.projects import project_crud, project_schemas
 from app.tasks import tasks_crud, tasks_schemas
 
+from ..auth.osm import AuthUser, login_required
+
 router = APIRouter(
     prefix="/tasks",
     tags=["tasks"],
@@ -196,6 +198,47 @@ async def task_features_count(
     return data
 
 
+@router.get("/task-comments/", response_model=list[tasks_schemas.TaskCommentResponse])
+async def task_comments(
+    project_id: int,
+    task_id: int,
+    db: Session = Depends(database.get_db),
+):
+    """Retrieve a list of task comments for a specific project and task.
+
+    Args:
+        project_id (int): The ID of the project.
+        task_id (int): The ID of the task.
+        db (Session, optional): The database session.
+
+    Returns:
+        List[tasks_schemas.TaskCommentResponse]: A list of task comments.
+    """
+    task_comment_list = await tasks_crud.get_task_comments(db, project_id, task_id)
+
+    return task_comment_list
+
+
+@router.post("/task-comments/", response_model=tasks_schemas.TaskCommentResponse)
+async def add_task_comments(
+    comment: tasks_schemas.TaskCommentRequest,
+    db: Session = Depends(database.get_db),
+    user_data: AuthUser = Depends(login_required),
+):
+    """Create a new task comment.
+
+    Parameters:
+        comment (TaskCommentRequest): The task comment to be created.
+        db (Session): The database session.
+        user_data (AuthUser): The authenticated user.
+
+    Returns:
+        TaskCommentResponse: The created task comment.
+    """
+    task_comment_list = await tasks_crud.add_task_comments(db, comment, user_data)
+    return task_comment_list
+
+
 @router.get("/activity/", response_model=List[tasks_schemas.TaskHistoryCount])
 async def task_activity(
     project_id: int, days: int = 10, db: Session = Depends(database.get_db)

src/backend/app/tasks/tasks_schemas.py

@@ -133,6 +133,32 @@ def decrypt_password(self, value: str) -> Optional[str]:
         return decrypt_value(value)
 
 
+class TaskCommentResponse(BaseModel):
+    """Task mapping history."""
+
+    id: int
+    task_id: int
+    comment: Optional[str] = None
+    commented_by: str
+    created_at: datetime
+
+
+class TaskCommentBase(BaseModel):
+    """Task mapping history."""
+
+    comment: str
+    commented_by: str
+    created_at: datetime
+
+
+class TaskCommentRequest(BaseModel):
+    """Task mapping history."""
+
+    task_id: int
+    project_id: int
+    comment: str
+
+
 class ReadTask(Task):
     """Task details plus updated task history."""