feat(payments): remove search data when uninstalling connector (#987)

formancehq · Dec 11, 2023 · a199205 · a199205 · vercel · Dec 11, 2023
1 parent f9bf5e1
commit a199205
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/components/payments/cmd/connectors/internal/api/connectors_manager/manager.go b/components/payments/cmd/connectors/internal/api/connectors_manager/manager.go
@@ -211,6 +211,14 @@ func (l *ConnectorsManager[ConnectorConfig]) Uninstall(ctx context.Context, conn
 		return newStorageError(err, "uninstalling connector")
 	}
 
+	if l.publisher != nil {
+		err = l.publisher.Publish(events.TopicPayments,
+			publish.NewMessage(ctx, messages.NewEventResetConnector(connectorID)))
+		if err != nil {
+			l.logger(ctx).Errorf("Publishing message: %w", err)
+		}
+	}
+
 	l.mu.Lock()
 	delete(l.connectors, connectorID.String())
 	l.mu.Unlock()