Method handleWebhook

admin/billing/orb_webhook.go:45–155

(w http.ResponseWriter, r *http.Request)

}

func (o *orbWebhook) handleWebhook(w http.ResponseWriter, r *http.Request) error {
	r.Body = http.MaxBytesReader(w, r.Body, maxBodyBytes)
	payload, err := io.ReadAll(r.Body)
	if err != nil {
		return httputil.Errorf(http.StatusServiceUnavailable, "error reading request body: %w", err)
	}

	// unmarshal event first before even verifying signature, so we can ignore unwanted events as Orb does not have an option to selectively deliver only required events
	var e genericEvent
	err = json.Unmarshal(payload, &e)
	if err != nil {
		return httputil.Errorf(http.StatusBadRequest, "error parsing event data: %w", err)
	}

	if !slices.Contains(interestingEvents, e.Type) {
		w.WriteHeader(http.StatusOK)
		return nil
	}

	now := time.Now().UTC()
	err = o.verifySignature(payload, r.Header, now)
	if err != nil {
		return httputil.Errorf(http.StatusBadRequest, "error verifying webhook signature: %w", err)
	}

	switch e.Type {
	case "invoice.payment_succeeded":
		var ie invoiceEvent
		err = json.Unmarshal(payload, &ie)
		if err != nil {
			return httputil.Errorf(http.StatusBadRequest, "error parsing event data: %w", err)
		}
		err = o.handleInvoicePaymentSucceeded(r.Context(), ie)
		if err != nil {
			return httputil.Errorf(http.StatusInternalServerError, "error handling event: %w", err)
		}
	case "invoice.payment_failed":
		var ie invoiceEvent
		err = json.Unmarshal(payload, &ie)
		if err != nil {
			return httputil.Errorf(http.StatusBadRequest, "error parsing event data: %w", err)
		}
		err = o.handleInvoicePaymentFailed(r.Context(), ie)
		if err != nil {
			return httputil.Errorf(http.StatusInternalServerError, "error handling event: %w", err)
		}
	case "invoice.issue_failed":
		var ie invoiceEvent
		err = json.Unmarshal(payload, &ie)
		if err != nil {
			return httputil.Errorf(http.StatusBadRequest, "error parsing event data: %w", err)
		}
		// inefficient one time conversion to named logger as its rare event and no need to log every thing else with named logger
		o.orb.logger.Named("billing").Warn("invoice issue failed", zap.String("customer_id", ie.OrbInvoice.Customer.ExternalCustomerID), zap.String("invoice_id", ie.OrbInvoice.ID), zap.String("props", fmt.Sprintf("%v", ie.Properties)))
	case "subscription.started":
		var se subscriptionEvent
		err = json.Unmarshal(payload, &se)
		if err != nil {