Method Store

api/pkg/handlers/heartbeat_handler.go:112–157

Store the heartbeat of a phone number @Summary Register heartbeat of an owner phone number @Description Store the heartbeat to make notify that a phone number is still active @Security ApiKeyAuth @Tags Heartbeats @Accept json @Produce json @Param payload body re

(c fiber.Ctx)

// @Failure      500		{object}	responses.InternalServerError
// @Router       /heartbeats [post]
func (h *HeartbeatHandler) Store(c fiber.Ctx) error {
	ctx, span := h.tracer.StartFromFiberCtx(c)
	defer span.End()

	ctxLogger := h.tracer.CtxLogger(h.logger, span)

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

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

	for _, phoneNumber := range request.PhoneNumbers {
		if !h.authorizePhoneAPIKey(c, phoneNumber) {
			ctxLogger.Warn(stacktrace.NewError(fmt.Sprintf("phone API Key ID [%s] is not authorized to store heartbeat for phone number [%s]", h.userFromContext(c).PhoneAPIKeyID, phoneNumber)))
			return h.responsePhoneAPIKeyUnauthorized(c, phoneNumber, h.userFromContext(c))
		}
	}

	params := request.ToStoreParams(h.userFromContext(c), c.OriginalURL(), c.Get("X-Client-Version"))

	wg := sync.WaitGroup{}
	responses := make([]*entities.Heartbeat, len(params))
	for index, value := range params {
		wg.Add(1)
		go func(input services.HeartbeatStoreParams, index int) {
			response, err := h.service.Store(ctx, input)
			if err != nil {
				msg := fmt.Sprintf("cannot store heartbeat with params [%+#v]", request)
				ctxLogger.Error(stacktrace.Propagate(err, msg))
			}
			responses[index] = response
			wg.Done()
		}(value, index)
	}

	wg.Wait()
	return h.responseCreated(c, fmt.Sprintf("[%d] heartbeats received successfully", len(responses)), responses)
}