Method Event

api/pkg/handlers/lemonsqueezy_handler.go:48–66

Event handles lemonsqueezy events

(c fiber.Ctx)

// Event handles lemonsqueezy events
func (h *LemonsqueezyHandler) Event(c fiber.Ctx) error {
	ctx, span, ctxLogger := h.tracer.StartFromFiberCtxWithLogger(c, h.logger)
	defer span.End()

	signature := c.Get("X-Signature")
	if errors := h.validator.ValidateEvent(ctx, signature, c.Body()); len(errors) != 0 {
		msg := fmt.Sprintf("validation errors [%s], while storing request [%s] and signature [%s]", spew.Sdump(errors), c.Body(), signature)
		ctxLogger.Warn(stacktrace.NewError(msg))
		return h.responseUnprocessableEntity(c, errors, "validation errors while storing lemonsqueezy event")
	}

	if err := h.handleRequest(ctx, c); err != nil {
		msg := fmt.Sprintf("cannot handle lemonsqueezy event [%s]", c.Body())
		ctxLogger.Error(stacktrace.Propagate(err, msg))
		return h.responseInternalServerError(c)
	}

	return h.responseNoContent(c, "event consumed successfully")
}

func (h *LemonsqueezyHandler) handleRequest(ctx context.Context, c fiber.Ctx) error {
	eventName := c.Get("X-Event-Name")