Function assertKeyedResults

packages/db-ivm/tests/test-utils.ts:218–263

(
  testName: string,
  actual: KeyedTestResult<K, V>,
  expected: Array<[K, V]>,
  maxExpectedMessages?: number,
)

 * Assert that keyed results match expected, with message count logging
 */
export function assertKeyedResults<K, V>(
  testName: string,
  actual: KeyedTestResult<K, V>,
  expected: Array<[K, V]>,
  maxExpectedMessages?: number,
) {
  const expectedSorted = expected.sort((a, b) => {
    return JSON.stringify(a[0]).localeCompare(JSON.stringify(b[0]))
  })

  if (LOG_RESULTS) {
    console.log(
      `${testName}: ${actual.messageCount} messages, ${actual.sortedResults.length} final results per key`,
    )
    console.log(`  Messages:`, actual.messages)
    console.log(`  Final results:`, actual.sortedResults)
  }

  // Check that materialized results match expected
  expect(actual.sortedResults).toEqual(expectedSorted)

  // Check message count constraints if provided
  if (maxExpectedMessages !== undefined) {
    expect(actual.messageCount).toBeLessThanOrEqual(maxExpectedMessages)
  }

  // Log for debugging - use more reasonable threshold
  // Account for scenarios where messages cancel out due to object identity
  // Allow up to 4x the expected count to accommodate remove/add pairs
  const reasonableThreshold = Math.max(expected.length * 4, 2)
  if (actual.messageCount > reasonableThreshold) {
    console.warn(
      `⚠️  ${testName}: High message count (${actual.messageCount} messages for ${expected.length} expected key-value pairs)`,
    )
  }

  // Log key insights
  const affectedKeys = new Set(
    actual.messages.map(([[key, _value], _mult]) => key),
  )
  if (LOG_RESULTS) {
    console.log(
      `${testName}: ✅ ${affectedKeys.size} keys affected, ${actual.sortedResults.length} final keys`,
    )
  }
}

/**
 * Extract unique keys from messages to verify incremental behavior