fix: add filter for providerID on invoice repo, and remove unnecessar…

…y invoice sync event
raystack · Aug 29, 2024 · f396e01 · f396e01
1 parent b61d9b9
commit f396e01
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/core/event/service.go b/core/event/service.go
@@ -235,7 +235,7 @@ func (p *Service) BillingWebhook(ctx context.Context, payload ProviderWebhookEve
 			if err != nil {
 				stdLogger.Error("error syncing customer", zap.Error(err), zap.String("provider_id", providerID))
 			}
-		case "invoice.payment_succeeded", "customer.subscription.created",
+		case "customer.subscription.created",
 			"customer.subscription.updated", "customer.subscription.deleted":
 			// trigger subscriptions sync
 			deDupKey := fmt.Sprintf("subscription-%s-%d", providerID, currentExecutionUnit)

diff --git a/internal/store/postgres/billing_subscription_repository.go b/internal/store/postgres/billing_subscription_repository.go
@@ -353,6 +353,11 @@ func (r BillingSubscriptionRepository) List(ctx context.Context, filter subscrip
 			"customer_id": filter.CustomerID,
 		})
 	}
+	if filter.ProviderID != "" {
+		stmt = stmt.Where(goqu.Ex{
+			"provider_id": filter.ProviderID,
+		})
+	}
 	if filter.PlanID != "" {
 		stmt = stmt.Where(goqu.Ex{
 			"plan_id": filter.PlanID,