Merge pull request #559 from LerianStudio/feature/RPRTR-377

feat: implementing deadlines CRUD

Author: arthurkz

.trivyignore

@@ -8,4 +8,7 @@ CVE-2025-58186
 CVE-2025-58187
 CVE-2025-58188
 CVE-2025-61723
-CVE-2025-61724
+CVE-2025-61724
+CVE-2026-25882
+CVE-2026-22184
+CVE-2026-27171

components/manager/docker-compose.yml

@@ -43,4 +43,4 @@ networks:
     # Shared network from broader Lerian platform (created by midaz infra)
     external: true
   reporter-manager-network:
-    driver: bridge
+    driver: bridge

components/manager/internal/adapters/http/in/deadline.go

@@ -0,0 +1,338 @@
+// Copyright (c) 2026 Lerian Studio. All rights reserved.
+// Use of this source code is governed by the Elastic License 2.0
+// that can be found in the LICENSE file.
+
+package in
+
+import (
+	"errors"
+
+	"github.com/LerianStudio/reporter/components/manager/internal/services"
+	"github.com/LerianStudio/reporter/pkg/model"
+	"github.com/LerianStudio/reporter/pkg/mongodb/deadline"
+	"github.com/LerianStudio/reporter/pkg/net/http"
+
+	"github.com/LerianStudio/lib-commons/v3/commons"
+	commonsHttp "github.com/LerianStudio/lib-commons/v3/commons/net/http"
+	libOpentelemetry "github.com/LerianStudio/lib-commons/v3/commons/opentelemetry"
+	"github.com/gofiber/fiber/v2"
+	"github.com/google/uuid"
+	"go.opentelemetry.io/otel/attribute"
+)
+
+// DeadlineHandler handles HTTP requests for deadline operations.
+type DeadlineHandler struct {
+	service *services.UseCase
+}
+
+// NewDeadlineHandler creates a new DeadlineHandler with the given service dependency.
+// It returns an error if service is nil.
+func NewDeadlineHandler(service *services.UseCase) (*DeadlineHandler, error) {
+	if service == nil {
+		return nil, errors.New("service must not be nil for DeadlineHandler")
+	}
+
+	return &DeadlineHandler{service: service}, nil
+}
+
+// CreateDeadline is a method that creates a deadline.
+//
+//	@Summary		Create a Deadline
+//	@Description	Create a deadline with the input payload
+//	@Tags			Deadlines
+//	@Accept			json
+//	@Produce		json
+//	@Security		BearerAuth
+//	@Param			body	deadline.CreateDeadlineInput	true	"Deadline input"
+//	@Success		201		{object}	deadline.Deadline
+//	@Failure		400		{object}	http.HTTPError
+//	@Failure		401		{object}	http.HTTPError
+//	@Failure		403		{object}	http.HTTPError
+//	@Failure		500		{object}	http.HTTPError
+//	@Router			/v1/deadlines [post]
+func (dh *DeadlineHandler) CreateDeadline(p any, c *fiber.Ctx) error {
+	ctx := c.UserContext()
+	logger, tracer, reqId, _ := commons.NewTrackingFromContext(ctx)
+
+	ctx, span := tracer.Start(ctx, "handler.deadline.create")
+	defer span.End()
+
+	span.SetAttributes(
+		attribute.String("app.request.request_id", reqId),
+	)
+
+	logger.Info("Request to create deadline")
+
+	input := p.(*deadline.CreateDeadlineInput)
+
+	err := libOpentelemetry.SetSpanAttributesFromStruct(&span, "app.request.payload", input)
+	if err != nil {
+		libOpentelemetry.HandleSpanError(&span, "Failed to set span attributes from struct", err)
+	}
+
+	result, err := dh.service.CreateDeadline(ctx, input)
+	if err != nil {
+		if http.IsBusinessError(err) {
+			libOpentelemetry.HandleSpanBusinessErrorEvent(&span, "Failed to create deadline", err)
+		} else {
+			libOpentelemetry.HandleSpanError(&span, "Failed to create deadline", err)
+		}
+
+		return http.WithError(c, err)
+	}
+
+	logger.Infof("Successfully created deadline %s", result.ID)
+
+	return commonsHttp.Created(c, result)
+}
+
+// GetAllDeadlines is a method that retrieves all deadlines.
+//
+//	@Summary		Get all deadlines
+//	@Description	List all the deadlines
+//	@Tags			Deadlines
+//	@Produce		json
+//	@Security		BearerAuth
+//	@Param			limit	query		int		false	"Limit"	default(10)
+//	@Param			page	query		int		false	"Page"	default(1)
+//	@Success		200		{object}	model.Pagination{items=[]deadline.Deadline,page=int,limit=int,total=int}
+//	@Failure		400		{object}	http.HTTPError
+//	@Failure		401		{object}	http.HTTPError
+//	@Failure		403		{object}	http.HTTPError
+//	@Failure		500		{object}	http.HTTPError
+//	@Router			/v1/deadlines [get]
+func (dh *DeadlineHandler) GetAllDeadlines(c *fiber.Ctx) error {
+	ctx := c.UserContext()
+
+	logger, tracer, reqId, _ := commons.NewTrackingFromContext(ctx)
+
+	ctx, span := tracer.Start(ctx, "handler.deadline.get_all")
+	defer span.End()
+
+	headerParams, err := http.ValidateParameters(c.Queries())
+	if err != nil {
+		libOpentelemetry.HandleSpanBusinessErrorEvent(&span, "Failed to validate query parameters", err)
+
+		logger.Errorf("Failed to validate query parameters, Error: %s", err.Error())
+
+		return http.WithError(c, err)
+	}
+
+	pagination := model.Pagination{
+		Limit: headerParams.Limit,
+		Page:  headerParams.Page,
+	}
+
+	logger.Infof("Initiating retrieval of all deadlines")
+
+	span.SetAttributes(
+		attribute.String("app.request.request_id", reqId),
+	)
+
+	err = libOpentelemetry.SetSpanAttributesFromStruct(&span, "app.request.query_params", headerParams)
+	if err != nil {
+		libOpentelemetry.HandleSpanError(&span, "Failed to convert query params to JSON string", err)
+	}
+
+	deadlines, total, err := dh.service.GetAllDeadlines(ctx, *headerParams)
+	if err != nil {
+		if http.IsBusinessError(err) {
+			libOpentelemetry.HandleSpanBusinessErrorEvent(&span, "Failed to retrieve all deadlines on query", err)
+		} else {
+			libOpentelemetry.HandleSpanError(&span, "Failed to retrieve all deadlines on query", err)
+		}
+
+		logger.Errorf("Failed to retrieve all deadlines, Error: %s", err.Error())
+
+		return http.WithError(c, err)
+	}
+
+	logger.Infof("Successfully retrieved all deadlines")
+
+	pagination.SetItems(deadlines)
+	pagination.SetTotal(int(total))
+
+	return commonsHttp.OK(c, pagination)
+}
+
+// UpdateDeadlineByID is a method that updates a deadline by a given id.
+//
+//	@Summary		Update a deadline
+//	@Description	Update a deadline with the input payload
+//	@Tags			Deadlines
+//	@Accept			json
+//	@Produce		json
+//	@Security		BearerAuth
+//	@Param			id		path		string							true	"Deadline ID"
+//	@Param			body	deadline.UpdateDeadlineInput		true	"Deadline update input"
+//	@Success		200		{object}	deadline.Deadline
+//	@Failure		400		{object}	http.HTTPError
+//	@Failure		401		{object}	http.HTTPError
+//	@Failure		403		{object}	http.HTTPError
+//	@Failure		404		{object}	http.HTTPError
+//	@Failure		500		{object}	http.HTTPError
+//	@Router			/v1/deadlines/{id} [patch]
+func (dh *DeadlineHandler) UpdateDeadlineByID(p any, c *fiber.Ctx) error {
+	ctx := c.UserContext()
+
+	logger, tracer, reqId, _ := commons.NewTrackingFromContext(ctx)
+
+	ctx, span := tracer.Start(ctx, "handler.deadline.update")
+	defer span.End()
+
+	raw := c.Locals("id")
+
+	id, ok := raw.(uuid.UUID)
+	if !ok {
+		return http.WithError(c, fiber.ErrBadRequest)
+	}
+
+	logger.Infof("Initiating update of deadline with ID: %s", id)
+
+	span.SetAttributes(
+		attribute.String("app.request.request_id", reqId),
+		attribute.String("app.request.deadline_id", id.String()),
+	)
+
+	input := p.(*deadline.UpdateDeadlineInput)
+
+	err := libOpentelemetry.SetSpanAttributesFromStruct(&span, "app.request.payload", input)
+	if err != nil {
+		libOpentelemetry.HandleSpanError(&span, "Failed to set span attributes from struct", err)
+	}
+
+	result, errUpdate := dh.service.UpdateDeadlineByID(ctx, id, input)
+	if errUpdate != nil {
+		if http.IsBusinessError(errUpdate) {
+			libOpentelemetry.HandleSpanBusinessErrorEvent(&span, "Failed to update deadline", errUpdate)
+		} else {
+			libOpentelemetry.HandleSpanError(&span, "Failed to update deadline", errUpdate)
+		}
+
+		logger.Errorf("Failed to update deadline with ID: %s, Error: %s", id, errUpdate.Error())
+
+		return http.WithError(c, errUpdate)
+	}
+
+	logger.Infof("Successfully updated deadline with ID: %s", id)
+
+	return commonsHttp.OK(c, result)
+}
+
+// DeleteDeadlineByID is a method that removes a deadline by a given id.
+//
+//	@Summary		SoftDelete a Deadline by ID
+//	@Description	SoftDelete a deadline with the input ID. Returns 204 with no content on success.
+//	@Tags			Deadlines
+//	@Produce		json
+//	@Security		BearerAuth
+//	@Param			id	path	string	true	"Deadline ID"
+//	@Success		204	"No content"
+//	@Failure		400	{object}	http.HTTPError
+//	@Failure		401	{object}	http.HTTPError
+//	@Failure		403	{object}	http.HTTPError
+//	@Failure		404	{object}	http.HTTPError
+//	@Failure		500	{object}	http.HTTPError
+//	@Router			/v1/deadlines/{id} [delete]
+func (dh *DeadlineHandler) DeleteDeadlineByID(c *fiber.Ctx) error {
+	ctx := c.UserContext()
+
+	logger, tracer, reqId, _ := commons.NewTrackingFromContext(ctx)
+
+	ctx, span := tracer.Start(ctx, "handler.deadline.delete")
+	defer span.End()
+
+	raw := c.Locals("id")
+
+	id, ok := raw.(uuid.UUID)
+	if !ok {
+		return http.WithError(c, fiber.ErrBadRequest)
+	}
+
+	logger.Infof("Initiating removal of deadline with ID: %s", id.String())
+
+	span.SetAttributes(
+		attribute.String("app.request.request_id", reqId),
+		attribute.String("app.request.deadline_id", id.String()),
+	)
+
+	if err := dh.service.DeleteDeadlineByID(ctx, id); err != nil {
+		if http.IsBusinessError(err) {
+			libOpentelemetry.HandleSpanBusinessErrorEvent(&span, "Failed to remove deadline on database", err)
+		} else {
+			libOpentelemetry.HandleSpanError(&span, "Failed to remove deadline on database", err)
+		}
+
+		logger.Errorf("Failed to remove deadline with ID: %s, Error: %s", id.String(), err.Error())
+
+		return http.WithError(c, err)
+	}
+
+	logger.Infof("Successfully removed deadline with ID: %s", id.String())
+
+	return commonsHttp.NoContent(c)
+}
+
+// DeliverDeadline is a method that marks a deadline as delivered or clears the delivery status.
+//
+//	@Summary		Deliver a Deadline
+//	@Description	Mark a deadline as delivered or clear the delivery status
+//	@Tags			Deadlines
+//	@Accept			json
+//	@Produce		json
+//	@Security		BearerAuth
+//	@Param			id		path		string								true	"Deadline ID"
+//	@Param			body	deadline.DeliverDeadlineInput		true	"Deliver input"
+//	@Success		200		{object}	deadline.Deadline
+//	@Failure		400		{object}	http.HTTPError
+//	@Failure		401		{object}	http.HTTPError
+//	@Failure		403		{object}	http.HTTPError
+//	@Failure		404		{object}	http.HTTPError
+//	@Failure		500		{object}	http.HTTPError
+//	@Router			/v1/deadlines/{id}/deliver [patch]
+func (dh *DeadlineHandler) DeliverDeadline(p any, c *fiber.Ctx) error {
+	ctx := c.UserContext()
+
+	logger, tracer, reqId, _ := commons.NewTrackingFromContext(ctx)
+
+	ctx, span := tracer.Start(ctx, "handler.deadline.deliver")
+	defer span.End()
+
+	raw := c.Locals("id")
+
+	id, ok := raw.(uuid.UUID)
+	if !ok {
+		return http.WithError(c, fiber.ErrBadRequest)
+	}
+
+	logger.Infof("Initiating deliver of deadline with ID: %s", id)
+
+	span.SetAttributes(
+		attribute.String("app.request.request_id", reqId),
+		attribute.String("app.request.deadline_id", id.String()),
+	)
+
+	input := p.(*deadline.DeliverDeadlineInput)
+
+	err := libOpentelemetry.SetSpanAttributesFromStruct(&span, "app.request.payload", input)
+	if err != nil {
+		libOpentelemetry.HandleSpanError(&span, "Failed to set span attributes from struct", err)
+	}
+
+	result, errDeliver := dh.service.DeliverDeadline(ctx, id, input)
+	if errDeliver != nil {
+		if http.IsBusinessError(errDeliver) {
+			libOpentelemetry.HandleSpanBusinessErrorEvent(&span, "Failed to deliver deadline", errDeliver)
+		} else {
+			libOpentelemetry.HandleSpanError(&span, "Failed to deliver deadline", errDeliver)
+		}
+
+		logger.Errorf("Failed to deliver deadline with ID: %s, Error: %s", id, errDeliver.Error())
+
+		return http.WithError(c, errDeliver)
+	}
+
+	logger.Infof("Successfully delivered deadline with ID: %s", id)
+
+	return commonsHttp.OK(c, result)
+}