added get monitor incidents endpoint

Author: TeisNP

internal/incident/repository.go

@@ -15,6 +15,7 @@ var ErrNotFound = errors.New("incident not found")
 type Repository interface {
 	GetByID(ctx context.Context, id uint) (*entities.Incident, error)
 	GetByTeamIDPaginated(ctx context.Context, teamID uint, offset, limit *int) (*[]entities.Incident, error)
+	GetByMonitorIDPaginated(ctx context.Context, monitorID uint, offset, limit *int) (*[]entities.Incident, error)
 	Upsert(ctx context.Context, incidents *[]entities.Incident) error
 	Create(ctx context.Context, incidents *[]entities.Incident) error
 	Update(ctx context.Context, incident *entities.Incident) error
@@ -63,6 +64,23 @@ func (r *RepositoryImpl) GetByTeamIDPaginated(ctx context.Context, teamID uint,
 	return &incidents, nil
 }
 
+func (r *RepositoryImpl) GetByMonitorIDPaginated(ctx context.Context, monitorID uint, offset, limit *int) (*[]entities.Incident, error) {
+	var incidents []entities.Incident
+	if err := r.db.WithContext(
+		ctx,
+	).Where(entities.Incident{
+		MonitorID: monitorID,
+	}).Order(
+		"created_at desc",
+	).Scopes(
+		postgres.Paginated(offset, limit),
+	).Find(&incidents).Error; err != nil {
+		return nil, err
+	}
+
+	return &incidents, nil
+}
+
 func (r *RepositoryImpl) Upsert(ctx context.Context, incidents *[]entities.Incident) error {
 	return r.db.WithContext(ctx).Clauses(clause.OnConflict{
 		Columns:   []clause.Column{{Name: "monitor_assertion_id"}, {Name: "resolved"}},

internal/incident/service.go

@@ -9,6 +9,7 @@ import (
 type Service interface {
 	GetByID(ctx context.Context, id uint) (*entities.Incident, error)
 	GetByTeamIDPaginated(ctx context.Context, teamID uint, offset, limit *int) (*[]entities.Incident, error)
+	GetByMonitorIDPaginated(ctx context.Context, monitorID uint, offset, limit *int) (*[]entities.Incident, error)
 	Upsert(ctx context.Context, incidents *[]entities.Incident) error
 	Create(ctx context.Context, incidents *[]entities.Incident) error
 	Update(ctx context.Context, incident *entities.Incident) error
@@ -33,6 +34,10 @@ func (s *ServiceImpl) GetByTeamIDPaginated(ctx context.Context, teamID uint, off
 	return s.repository.GetByTeamIDPaginated(ctx, teamID, offset, limit)
 }
 
+func (s *ServiceImpl) GetByMonitorIDPaginated(ctx context.Context, monitorID uint, offset, limit *int) (*[]entities.Incident, error) {
+	return s.repository.GetByMonitorIDPaginated(ctx, monitorID, offset, limit)
+}
+
 func (s *ServiceImpl) Upsert(ctx context.Context, incidents *[]entities.Incident) error {
 	return s.repository.Upsert(ctx, incidents)
 }

internal/rest/controllers/incidents/incidents.go

@@ -16,7 +16,7 @@ type GetIncidentsRequest struct {
 }
 
 type GetIncidentsResponse struct {
-	Checks []GetIncidentsResponseIncident `json:"incidents"`
+	Incidents []GetIncidentsResponseIncident `json:"incidents"`
 }
 
 type GetIncidentsResponseIncident struct {
@@ -56,11 +56,11 @@ func (h *Handlers) GetIncidents(c hs.AuthenticatedContext) error {
 
 func (h *Handlers) newGetIncidentResponse(incidents *[]entities.Incident) *GetIncidentsResponse {
 	resp := &GetIncidentsResponse{
-		Checks: make([]GetIncidentsResponseIncident, len(*incidents)),
+		Incidents: make([]GetIncidentsResponseIncident, len(*incidents)),
 	}
 
 	for i, incident := range *incidents {
-		resp.Checks[i] = GetIncidentsResponseIncident{
+		resp.Incidents[i] = GetIncidentsResponseIncident{
 			ID:          incident.ID,
 			TeamID:      incident.TeamID,
 			MonitorID:   incident.MonitorID,
@@ -135,3 +135,68 @@ func (h *Handlers) newGetIncidentOverviewResponse(incidents *[]entities.Incident
 
 	return resp
 }
+
+type GetMonitorIncidentsRequest struct {
+	TeamID    uint `param:"teamId" validate:"required,numeric,gte=0"`
+	MonitorID uint `param:"monitorId" validate:"required,numeric,gte=0"`
+	Offset    *int `query:"offset" validate:"omitempty,numeric,gte=0"`
+	Limit     *int `query:"limit" validate:"omitempty,numeric,gte=0,max=255"`
+}
+
+type GetMonitorIncidentsResponse struct {
+	Incidents []GetMonitorIncidentsResponseIncident `json:"incidents"`
+}
+
+type GetMonitorIncidentsResponseIncident struct {
+	ID          uint   `json:"id"`
+	TeamID      uint   `json:"teamId"`
+	MonitorID   uint   `json:"monitorId"`
+	Title       string `json:"title"`
+	Description string `json:"description"`
+	CreatedAt   string `json:"createdAt"`
+}
+
+func (h *Handlers) GetMonitorIncidents(c hs.AuthenticatedContext) error {
+	req, err := helpers.Bind[GetMonitorIncidentsRequest](c)
+	if err != nil {
+		c.Log.WithError(err).Debug("failed to bind GetMonitorIncidentsRequest")
+
+		return echo.ErrBadRequest
+	}
+
+	ctx := c.Request().Context()
+
+	incidents, err := h.IncidentService.GetByTeamIDPaginated(
+		ctx,
+		req.TeamID,
+		req.Offset,
+		req.Limit)
+	if err != nil {
+		c.Log.WithError(err).Error("failed to get incidents")
+
+		return echo.ErrInternalServerError
+	}
+
+	resp := h.newGetIncidentResponse(incidents)
+
+	return c.JSON(http.StatusOK, resp)
+}
+
+func (h *Handlers) GetMonitorIncidentsResponse(incidents *[]entities.Incident) *GetMonitorIncidentsResponse {
+	resp := &GetMonitorIncidentsResponse{
+		Incidents: make([]GetMonitorIncidentsResponseIncident, len(*incidents)),
+	}
+
+	for i, incident := range *incidents {
+		resp.Incidents[i] = GetMonitorIncidentsResponseIncident{
+			ID:          incident.ID,
+			TeamID:      incident.TeamID,
+			MonitorID:   incident.MonitorID,
+			Title:       incident.Title,
+			Description: *incident.Description,
+			CreatedAt:   incident.CreatedAt.Format("2006-01-02T15:04:05Z07:00"),
+		}
+	}
+
+	return resp
+}

internal/rest/controllers/incidents/routes.go

@@ -37,4 +37,5 @@ func Register(
 
 	monitorsGroup.GET("", AuthHandler(h.GetIncidents))
 	monitorsGroup.GET("/overview", AuthHandler(h.GetIncidents))
+	monitorsGroup.GET("/monitor/:monitorId", AuthHandler(h.GetIncidents))
 }