Function writeSessionFacts

packages/node-runtime/src/services/contacts/compute.ts:403–430

(
  adapter: SessionRuntimeAdapter,
  sessionId: string,
  timeRange: ContactsTimeRangeState,
  factsCache: ContactsFactsCacheContext | null,
  facts: ContactsSessionFacts,
  expectedDbVersion: string
)

}

function writeSessionFacts(
  adapter: SessionRuntimeAdapter,
  sessionId: string,
  timeRange: ContactsTimeRangeState,
  factsCache: ContactsFactsCacheContext | null,
  facts: ContactsSessionFacts,
  expectedDbVersion: string
): void {
  if (!factsCache) return
  const dbVersion = getSessionDbVersion(adapter, sessionId)
  if (dbVersion !== expectedDbVersion) {
    appLogger.debug('contacts', 'skipped contacts session facts cache write because db version changed', {
      sessionId,
    })
    return
  }
  writeCachedContactsSessionFacts(
    sessionId,
    factsCache.dir,
    buildContactsSessionFactsCacheKey(CONTACTS_ALGORITHM_VERSION, timeRange),
    dbVersion,
    facts
  )
  writeCachedContactsSessionLatest(sessionId, factsCache.dir, factsCache.latestKey, dbVersion, {
    latestMessageTs: facts.latestMessageTs,
  })
  factsCache.stats.writes += 2
}

function getSessionDbVersion(adapter: SessionRuntimeAdapter, sessionId: string): string {
  return getDbFileVersion(adapter.getDbPath(sessionId))