Method handleInvoicePaid

backend/api/stripe/webhook.go:230–348

(ctx context.Context, event *stripego.Event)

}

func (h *WebhookHandler) handleInvoicePaid(ctx context.Context, event *stripego.Event) error {
	var inv stripego.Invoice
	if err := json.Unmarshal(event.Data.Raw, &inv); err != nil {
		slog.Error("failed to unmarshal stripe invoice from webhook",
			log.BBError(err),
			slog.String("event_id", event.ID),
		)
		return errors.Wrap(err, "failed to unmarshal invoice")
	}

	if len(inv.Lines.Data) == 0 {
		slog.Error("stripe invoice has no line items",
			slog.String("invoice_id", inv.ID),
			slog.String("event_id", event.ID),
		)
		return errors.Errorf("invoice %s has no line items", inv.ID)
	}

	metadata := inv.Lines.Data[0].Metadata
	if metadata["source"] != stripeplugin.WebhookSource {
		return nil
	}

	workspace := metadata["workspace"]
	if workspace == "" {
		slog.Error("missing workspace in invoice metadata",
			slog.String("invoice_id", inv.ID),
			slog.String("event_id", event.ID),
		)
		return nil
	}

	stripeCustomer, err := getStripeCustomer(inv.Customer)
	if err != nil {
		slog.Error("failed to get stripe customer from invoice",
			log.BBError(err),
			slog.String("workspace", workspace),
			slog.String("invoice_id", inv.ID),
		)
		return err
	}

	payload, err := buildPayloadFromMetadata(metadata)
	if err != nil {
		slog.Error("failed to build payload from invoice metadata",
			log.BBError(err),
			slog.String("workspace", workspace),
			slog.String("invoice_id", inv.ID),
		)
		return errors.Wrapf(err, "failed to build payload from invoice metadata for workspace %s", workspace)
	}

	// Get Stripe subscription ID from invoice parent.
	var stripeSubID string
	if inv.Parent != nil && inv.Parent.SubscriptionDetails != nil && inv.Parent.SubscriptionDetails.Subscription != nil {
		stripeSubID = inv.Parent.SubscriptionDetails.Subscription.ID
	}