Function benchmarkLiveQueryRegex

benchmark/performance.js:754–798

* Benchmark: LiveQuery $regex end-to-end * * Measures the full round-trip of a LiveQuery subscription with a $regex constraint: * subscribe with a unique regex pattern, save an object that matches, and measure * the time until the LiveQuery event fires. Each iteration uses a different regex * t

(name)

 * to avoid cache hits on the RE2JS compile step.
 */
async function benchmarkLiveQueryRegex(name) {
  // Enable LiveQuery on the running server
  const { default: ParseServer } = require('../lib/index.js');
  const liveQueryServer = await ParseServer.createLiveQueryServer(httpServer, {
    appId: APP_ID,
    masterKey: MASTER_KEY,
    serverURL: SERVER_URL,
  });
  Parse.liveQueryServerURL = 'ws://localhost:1337';

  let counter = 0;

  // Cycle through different regex patterns to avoid RE2JS cache hits
  const patterns = [
    { base: '^BenchLQ_', fieldValue: i => `BenchLQ_${i} data` },
    { base: 'benchfield_', fieldValue: i => `some benchfield_${i} here` },
    { base: '[a-z]+_benchclass_', fieldValue: i => `abc_benchclass_${i}` },
  ];

  try {
    return await measureOperation({
      name,
      iterations: 500,
      operation: async () => {
        const idx = counter++;
        const pattern = patterns[idx % patterns.length];
        const regex = pattern.base + idx;
        const query = new Parse.Query('BenchmarkLiveQuery');
        query._addCondition('field', '$regex', regex);
        const subscription = await query.subscribe();
        const eventPromise = new Promise(resolve => {
          subscription.on('create', () => resolve());
        });
        const obj = new Parse.Object('BenchmarkLiveQuery');
        obj.set('field', pattern.fieldValue(idx));
        await obj.save();
        await eventPromise;
        subscription.unsubscribe();
      },
    });
  } finally {
    await liveQueryServer.shutdown();
    Parse.liveQueryServerURL = undefined;
  }
}

/**
 * Benchmark: Object.save with nested data (denylist scanning)