/**
 * @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 {DOCUMENT} from '@angular/common';
import {ApplicationRef, Component, Injectable} from '@angular/core';
import {makeStateKey, TransferState} from '@angular/core/src/transfer_state';
import {fakeAsync, flush, TestBed} from '@angular/core/testing';
import {withBody} from '@angular/private/testing';
import {BehaviorSubject} from 'rxjs';

import {HttpClient, provideHttpClient} from '../public_api';
import {withHttpTransferCache} from '../src/transfer_cache';
import {HttpTestingController, provideHttpClientTesting} from '../testing';

describe('TransferCache', () => {
  @Component({selector: 'test-app-http', template: 'hello'})
  class SomeComponent {
  }

  describe('withHttpTransferCache', () => {
    let isStable: BehaviorSubject<boolean>;

    function makeRequestAndExpectOne(url: string, body: string): void {
      TestBed.inject(HttpClient).get(url).subscribe();
      TestBed.inject(HttpTestingController).expectOne(url).flush(body);
    }

    function makeRequestAndExpectNone(url: string): void {
      TestBed.inject(HttpClient).get(url).subscribe();
      TestBed.inject(HttpTestingController).expectNone(url);
    }

    beforeEach(withBody('<test-app-http></test-app-http>', () => {
      TestBed.resetTestingModule();
      isStable = new BehaviorSubject<boolean>(false);

      @Injectable()
      class ApplicationRefPatched extends ApplicationRef {
        override isStable = new BehaviorSubject<boolean>(false);
      }

      TestBed.configureTestingModule({
        declarations: [SomeComponent],
        providers: [
          {provide: DOCUMENT, useFactory: () => document},
          {provide: ApplicationRef, useClass: ApplicationRefPatched},
          withHttpTransferCache(),
          provideHttpClient(),
          provideHttpClientTesting(),
        ],
      });

      const appRef = TestBed.inject(ApplicationRef);
      appRef.bootstrap(SomeComponent);
      isStable = appRef.isStable as BehaviorSubject<boolean>;
    }));

    it('should store HTTP calls in cache when application is not stable', () => {
      makeRequestAndExpectOne('/test', 'foo');
      const key = makeStateKey('432906284');
      const transferState = TestBed.inject(TransferState);
      expect(transferState.get(key, null)).toEqual(jasmine.objectContaining({body: 'foo'}));
    });

    it('should stop storing HTTP calls in `TransferState` after application becomes stable',
       fakeAsync(() => {
         makeRequestAndExpectOne('/test-1', 'foo');
         makeRequestAndExpectOne('/test-2', 'buzz');

         isStable.next(true);

         flush();

         makeRequestAndExpectOne('/test-3', 'bar');

         const transferState = TestBed.inject(TransferState);
         expect(JSON.parse(transferState.toJson()) as Record<string, unknown>).toEqual({
           '3706062792': {
             'body': 'foo',
             'headers': {},
             'status': 200,
             'statusText': 'OK',
             'url': '/test-1',
             'responseType': 'json'
           },
           '3706062823': {
             'body': 'buzz',
             'headers': {},
             'status': 200,
             'statusText': 'OK',
             'url': '/test-2',
             'responseType': 'json'
           }
         });
       }));

    it(`should use calls from cache when present and application is not stable`, () => {
      makeRequestAndExpectOne('/test-1', 'foo');
      // Do the same call, this time it should served from cache.
      makeRequestAndExpectNone('/test-1');
    });

    it(`should not use calls from cache when present and application is stable`, fakeAsync(() => {
         makeRequestAndExpectOne('/test-1', 'foo');

         isStable.next(true);
         flush();
         // Do the same call, this time it should go through as application is stable.
         makeRequestAndExpectOne('/test-1', 'foo');
       }));

    it(`should differentiate calls with different parameters`, async () => {
      // make calls with different parameters. All of which should be saved in the state.
      makeRequestAndExpectOne('/test-1?foo=1', 'foo');
      makeRequestAndExpectOne('/test-1', 'foo');
      makeRequestAndExpectOne('/test-1?foo=2', 'buzz');

      makeRequestAndExpectNone('/test-1?foo=1');
      await expectAsync(TestBed.inject(HttpClient).get('/test-1?foo=1').toPromise())
          .toBeResolvedTo('foo');
    });
  });
});