default-stats-capture_spec.ts

/**
 * @license
 * Copyright Google LLC All Rights Reserved.
 *
 * Use of this source code is governed by an MIT-style license that can be
 * found in the LICENSE file at https://angular.io/license
 */

import { Observable } from 'rxjs';
import { toArray } from 'rxjs/operators';
import { defaultStatsCapture } from './default-stats-capture';
import { AggregatedProcessStats } from './interfaces';

describe('defaultStatsCapture', () => {
  it('works', async () => {
    const stats$ = new Observable<AggregatedProcessStats>((obs) => {
      const ignoredStats = { ppid: 1, pid: 1, ctime: 1, timestamp: 1 };
      obs.next({
        processes: 1,
        cpu: 0,
        memory: 10 * 1e6,
        elapsed: 1000,
        ...ignoredStats,
      });
      obs.next({
        processes: 3,
        cpu: 40,
        memory: 2 * 1e6,
        elapsed: 2000,
        ...ignoredStats,
      });
      obs.next({
        processes: 5,
        cpu: 20,
        memory: 3 * 1e6,
        elapsed: 3000,
        ...ignoredStats,
      });
      obs.complete();
    });

    const res = await defaultStatsCapture(stats$).pipe(toArray()).toPromise();
    expect(res).toEqual([
      {
        name: 'Process Stats',
        metrics: [
          { name: 'Elapsed Time', unit: 'ms', value: 3000 },
          { name: 'Average Process usage', unit: 'process(es)', value: 3 },
          { name: 'Peak Process usage', unit: 'process(es)', value: 5 },
          { name: 'Average CPU usage', unit: '%', value: 20 },
          { name: 'Peak CPU usage', unit: '%', value: 40 },
          { name: 'Average Memory usage', unit: 'MB', value: 5 },
          { name: 'Peak Memory usage', unit: 'MB', value: 10 },
        ],
      },
    ]);
  });
});