summaryrefslogtreecommitdiffstats
path: root/src/pybind/mgr/dashboard/frontend/src/app/shared/services/timer.service.spec.ts
blob: 10b528e3ad036a24947078e4ff88dbffbb948ce2 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
import { fakeAsync, TestBed, tick } from '@angular/core/testing';

import { of, Subscription } from 'rxjs';

import { configureTestBed } from '~/testing/unit-test-helper';
import { TimerService } from './timer.service';

describe('TimerService', () => {
  let service: TimerService;
  let subs: Subscription;
  let receivedData: any[];
  const next = () => of(true);
  const observer = (data: boolean) => {
    receivedData.push(data);
  };

  configureTestBed({
    providers: [TimerService]
  });

  beforeEach(() => {
    service = TestBed.inject(TimerService);
    receivedData = [];
  });

  it('should be created', () => {
    expect(service).toBeTruthy();
  });

  it('should not emit any value when no subscribers', fakeAsync(() => {
    subs = service.get(next).subscribe(observer);
    tick(service.DEFAULT_REFRESH_INTERVAL);
    expect(receivedData.length).toEqual(2);

    subs.unsubscribe();

    tick(service.DEFAULT_REFRESH_INTERVAL);
    expect(receivedData.length).toEqual(2);
  }));

  it('should emit value with no dueTime and no refresh interval', fakeAsync(() => {
    subs = service.get(next, null, null).subscribe(observer);
    tick(service.DEFAULT_REFRESH_INTERVAL);
    expect(receivedData.length).toEqual(1);
    expect(receivedData).toEqual([true]);

    subs.unsubscribe();
  }));

  it('should emit expected values when refresh interval + no dueTime', fakeAsync(() => {
    subs = service.get(next).subscribe(observer);
    tick(service.DEFAULT_REFRESH_INTERVAL * 2);
    expect(receivedData.length).toEqual(3);
    expect(receivedData).toEqual([true, true, true]);

    subs.unsubscribe();
  }));

  it('should emit expected values when dueTime equal to refresh interval', fakeAsync(() => {
    const dueTime = 1000;
    subs = service.get(next, service.DEFAULT_REFRESH_INTERVAL, dueTime).subscribe(observer);
    tick(service.DEFAULT_REFRESH_INTERVAL * 2);
    expect(receivedData.length).toEqual(2);
    expect(receivedData).toEqual([true, true]);

    subs.unsubscribe();
  }));
});