Method Delete

api/pkg/handlers/message_thread_handler.go:155–184

Delete a message thread @Summary Delete a message thread from the database. @Description Delete a message thread from the database and also deletes all the messages in the thread. @Security ApiKeyAuth @Tags MessageThreads @Accept json @Produce json @Param messageThreadID

(c fiber.Ctx)

// @Failure      500  				{object}  	responses.InternalServerError
// @Router       /message-threads/{messageThreadID} [delete]
func (h *MessageThreadHandler) Delete(c fiber.Ctx) error {
	ctx, span, ctxLogger := h.tracer.StartFromFiberCtxWithLogger(c, h.logger)
	defer span.End()

	messageThreadID := c.Params("messageThreadID")
	if errors := h.validator.ValidateUUID(messageThreadID, "messageThreadID"); len(errors) != 0 {
		msg := fmt.Sprintf("validation errors [%s], while deleting a thread thread with ID [%s]", spew.Sdump(errors), messageThreadID)
		ctxLogger.Warn(stacktrace.NewError(msg))
		return h.responseUnprocessableEntity(c, errors, "validation errors while deleting a thread thread")
	}

	thread, err := h.service.GetThread(ctx, h.userIDFomContext(c), uuid.MustParse(messageThreadID))
	if stacktrace.GetCode(err) == repositories.ErrCodeNotFound {
		return h.responseNotFound(c, fmt.Sprintf("cannot find thread thread with ID [%s]", messageThreadID))
	}

	if err != nil {
		msg := fmt.Sprintf("cannot find thread thread with id [%s]", messageThreadID)
		ctxLogger.Error(h.tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg)))
		return h.responseInternalServerError(c)
	}

	if err = h.service.DeleteThread(ctx, c.OriginalURL(), thread); err != nil {
		msg := fmt.Sprintf("cannot delete thread thread with ID [%s] for user with ID [%s]", messageThreadID, thread.UserID)
		ctxLogger.Error(h.tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg)))
		return h.responseInternalServerError(c)
	}

	return h.responseNoContent(c, "thread thread deleted successfully")
}