Function applyGroupFacts

packages/node-runtime/src/services/contacts/compute.ts:304–334

(
  accumulators: Map<string, ContactAccumulator>,
  sessionId: string,
  meta: ContactsSessionMetaFacts,
  sessionFacts: ContactsCachedGroupFacts[]
)

}

function applyGroupFacts(
  accumulators: Map<string, ContactAccumulator>,
  sessionId: string,
  meta: ContactsSessionMetaFacts,
  sessionFacts: ContactsCachedGroupFacts[]
): void {
  for (const facts of sessionFacts) {
    if (!hasGroupContactSignal(facts)) continue
    const acc = getOrCreateAccumulator(accumulators, sessionId, meta, facts.contact)
    acc.commonGroupSessionIds.add(sessionId)
    acc.coOccurrenceCount += facts.coOccurrenceCount
    acc.coOccurrenceRawScore += facts.coOccurrenceRawScore
    acc.replyInteractionCount += facts.replyInteractionCount
    acc.repliesFromOwnerToContact += facts.repliesFromOwnerToContact
    acc.repliesFromContactToOwner += facts.repliesFromContactToOwner
    updateLastInteraction(acc, facts.lastInteractionTs)
    acc.sourceSessions.push({
      id: sessionId,
      name: meta.name,
      platform: meta.platform,
      type: ChatType.GROUP,
      messageCount: facts.messageCount,
      coOccurrenceCount: facts.coOccurrenceCount,
      coOccurrenceRawScore: facts.coOccurrenceRawScore,
      replyInteractionCount: facts.replyInteractionCount,
      repliesFromOwnerToContact: facts.repliesFromOwnerToContact,
      repliesFromContactToOwner: facts.repliesFromContactToOwner,
      lastInteractionTs: facts.lastInteractionTs,
    })
  }
}

function hasGroupContactSignal(facts: ContactsCachedGroupFacts): boolean {
  return facts.messageCount > 0 || facts.coOccurrenceCount > 0 || facts.replyInteractionCount > 0