Method Search

api/pkg/handlers/message_handler.go:551–579

Search returns a filtered list of messages of a user @Summary Search all messages of a user @Description This returns the list of all messages based on the filter criteria including missed calls @Security ApiKeyAuth @Tags Messages @Accept json @Produce json @Param to

(c fiber.Ctx)

// @Failure      500		{object}	responses.InternalServerError
// @Router       /messages/search [get]
func (h *MessageHandler) Search(c fiber.Ctx) error {
	ctx, span, ctxLogger := h.tracer.StartFromFiberCtxWithLogger(c, h.logger)
	defer span.End()

	var request requests.MessageSearch
	if err := c.Bind().Query(&request); err != nil {
		msg := fmt.Sprintf("cannot marshall params in [%s] into [%T]", c.OriginalURL(), request)
		ctxLogger.Warn(stacktrace.Propagate(err, msg))
		return h.responseBadRequest(c, err)
	}

	request.IPAddress = c.IP()
	request.Token = c.Get("token")

	if errors := h.validator.ValidateMessageSearch(ctx, request.Sanitize()); len(errors) != 0 {
		msg := fmt.Sprintf("validation errors [%s], while searching messages [%+#v]", spew.Sdump(errors), request)
		ctxLogger.Warn(stacktrace.NewError(msg))
		return h.responseUnprocessableEntity(c, errors, "validation errors while searching messages")
	}

	messages, err := h.service.SearchMessages(ctx, request.ToSearchParams(h.userIDFomContext(c)))
	if err != nil {
		msg := fmt.Sprintf("cannot search messages with params [%+#v]", request)
		ctxLogger.Error(stacktrace.Propagate(err, msg))
		return h.responseInternalServerError(c)
	}

	return h.responseOK(c, fmt.Sprintf("found %d %s", len(messages), h.pluralize("message", len(messages))), messages)
}