File tree Expand file tree Collapse file tree
services/apps/data_sink_worker/src/service Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -335,8 +335,8 @@ export default class ActivityService extends LoggerBase {
335335 activity . username = identities [ 0 ] . value
336336 } else if ( identities . length === 0 ) {
337337 // Fall back to same-platform email identity — handles old gerrit records where
338- // only a type:email identity was stored (before parse-member.ts gained the
339- // email-as-username fallback).
338+ // only a type:email identity was stored (before the gerrit integration
339+ // gained the email-as-username fallback).
340340 const emailFallback = activity . member . identities . find (
341341 ( i ) => i . platform === platform && i . type === MemberIdentityType . EMAIL && i . value ,
342342 )
@@ -465,7 +465,13 @@ export default class ActivityService extends LoggerBase {
465465 if ( ! success ) {
466466 resultMap . set ( resultId , { success : false , err } )
467467 } else {
468- relevantPayloads . push ( single ( payloads , ( a ) => a . resultId === resultId ) )
468+ const payload = single ( payloads , ( a ) => a . resultId === resultId )
469+ if ( ! payload . activity . username ) {
470+ // prepareMemberData found no usable identity — mark as processed and skip.
471+ resultMap . set ( resultId , { success : true } )
472+ } else {
473+ relevantPayloads . push ( payload )
474+ }
469475 }
470476 }
471477
You can’t perform that action at this time.
0 commit comments