@@ -187,11 +187,8 @@ private Map<String, Object> createUserEventMessage(UaaUser user, Map<String, Obj
187187 // Include username instead of user UUID
188188 message .put ("username" , user .getUsername ());
189189
190- // Include identity provider ID
191- String identityProviderId = getIdentityProviderId (user );
192- if (identityProviderId != null ) {
193- message .put ("identityProviderId" , identityProviderId );
194- }
190+ // Include identity zone ID
191+ message .put ("identityZoneId" , user .getZoneId ());
195192
196193 // Add only the changed fields
197194 message .put ("changedFields" , changedFields );
@@ -209,24 +206,4 @@ private String determineEventType(Map<String, Object> changedFields) {
209206 return "USER_DATA_UPDATED" ;
210207 }
211208 }
212-
213- /**
214- * Retrieves the identity provider ID based on the user's zone ID and origin
215- * Following the relationship:
216- * SELECT id FROM identity_provider WHERE identity_zone_id = user.zoneId AND
217- * origin_key = user.origin
218- */
219- private String getIdentityProviderId (UaaUser user ) {
220- try {
221- IdentityProvider identityProvider = identityProviderProvisioning .retrieveByOrigin (
222- user .getOrigin (),
223- user .getZoneId ());
224- return identityProvider .getId ();
225- } catch (Exception e ) {
226- logger .warn ("Failed to retrieve identity provider ID for user: {} (origin: {}, zoneId: {}). Error: {}" ,
227- user .getUsername (), user .getOrigin (), user .getZoneId (), e .getMessage ());
228- return null ;
229- }
230- }
231-
232209}
0 commit comments