import { provideHttpClient } from '@angular/common/http';
import { HttpTestingController, provideHttpClientTesting } from '@angular/common/http/testing';
import { TestBed } from '@angular/core/testing';
import { API_CONFIG } from './app.constants';
import { ApiError, ApiService } from './api.service';
import { SessionService } from './session.service';

describe('ApiService', () => {
  let api: ApiService;
  let http: HttpTestingController;
  let sessionToken = '';

  beforeEach(() => {
    sessionToken = '';
    TestBed.configureTestingModule({ providers: [provideHttpClient(), provideHttpClientTesting(), { provide: SessionService, useValue: { token: () => sessionToken } }] });
    api = TestBed.inject(ApiService);
    http = TestBed.inject(HttpTestingController);
  });

  afterEach(() => http.verify());

  it('routes migrated actions through the cloud gateway and parses JSON result strings', () => {
    let actual: unknown;
    api.get('node_list', { cpage: 1 }).subscribe((response) => actual = response.result);
    const request = http.expectOne(API_CONFIG.cloudFunctionUrl);
    expect(request.request.method).toBe('POST');
    expect(request.request.headers.get('X-Parse-Application-Id')).toBe(API_CONFIG.parseAppId);
    expect(request.request.body).toEqual({ params: { action: 'node_list', cpage: 1 } });
    request.flush({ retcode: 0, result: '[{"ID":1}]' });
    expect(actual).toEqual([{ ID: 1 }]);
  });

  it('keeps not-yet-migrated actions on the legacy gateway', () => {
    api.get('order_list', { cpage: 2 }).subscribe();
    const request = http.expectOne((candidate) => candidate.url.includes(API_CONFIG.endpoint) && candidate.urlWithParams.includes('action=order_list'));
    expect(request.request.method).toBe('GET');
    expect(request.request.params.get('cpage')).toBe('2');
    request.flush({ retcode: 0, result: [] });
  });

  it('nests reserved id parameters inside params', () => {
    api.get('node_get', { id: 81 }).subscribe();
    const request = http.expectOne(API_CONFIG.cloudFunctionUrl);
    expect(request.request.body).toEqual({ params: { action: 'node_get', id: 81 } });
    request.flush({ retcode: 0, result: { id: 81 } });
  });

  it('keeps private addon content without a Parse session and product queries on the legacy gateway', () => {
    api.get('content_list', { modelId: 56, myfield2: 'UserId=42' }).subscribe();
    api.get('product_list', { cpage: 1 }).subscribe();
    const content = http.expectOne((candidate) => candidate.urlWithParams.includes('action=content_list'));
    const products = http.expectOne((candidate) => candidate.urlWithParams.includes('action=product_list'));
    expect(content.request.url).toContain(API_CONFIG.endpoint);
    expect(products.request.url).toContain(API_CONFIG.endpoint);
    content.flush({ retcode: 0, result: [] });
    products.flush({ retcode: 0, result: [] });
  });

  it('routes supported private addon content with a Parse session', () => {
    sessionToken = 'r:session-token';
    api.get('content_list', { modelId: 56, myfield2: 'UserId=42|dqrq=20260818' }).subscribe();
    const request = http.expectOne(API_CONFIG.cloudFunctionUrl);
    expect(request.request.body).toEqual({ token: 'r:session-token', params: { action: 'content_list', modelId: 56, myfield2: 'UserId=42|dqrq=20260818' } });
    request.flush({ retcode: 0, result: [] });
  });

  it('routes verified learning detail reads with a Parse session', () => {
    sessionToken = 'r:session-token';
    api.get('e_record_detail', { id: 931 }).subscribe();
    const request = http.expectOne(API_CONFIG.cloudFunctionUrl);
    expect(request.request.body).toEqual({ token: 'r:session-token', params: { action: 'e_record_detail', id: 931 } });
    request.flush({ retcode: 0, result: [{ GeneralID: 149, detail: [{ Title: 'beautiful' }] }] });
  });

  it('routes course word progress reads with a Parse session', () => {
    sessionToken = 'r:session-token';
    api.get('e_ck_list', { uid: 58, nids: '40,41' }).subscribe();
    const request = http.expectOne(API_CONFIG.cloudFunctionUrl);
    expect(request.request.body).toEqual({ token: 'r:session-token', params: { action: 'e_ck_list', uid: 58, nids: '40,41' } });
    request.flush({ retcode: 0, result: [{ GeneralID: 2505, w_learned: 7 }] });
  });

  it('routes team member, team statistics, and coach student reads with a Parse session', () => {
    sessionToken = 'r:session-token';
    api.get('user_list', { puid: 58, cpage: 1 }).subscribe();
    api.get('user_dept', { uid: 58 }).subscribe();
    api.get('e_user_list', { cpage: 1 }).subscribe();
    const [members, statistics, students] = http.match(API_CONFIG.cloudFunctionUrl);
    expect(members.request.body).toEqual({ token: 'r:session-token', params: { action: 'user_list', puid: 58, cpage: 1 } });
    expect(statistics.request.body).toEqual({ token: 'r:session-token', params: { action: 'user_dept', uid: 58 } });
    expect(students.request.body).toEqual({ token: 'r:session-token', params: { action: 'e_user_list', cpage: 1 } });
    members.flush({ retcode: 0, result: [] });
    statistics.flush({ retcode: 0, result: { childs: 0, v0: 0 } });
    students.flush({ retcode: 0, result: [] });
  });

  it('routes typed virtual-currency history reads with a Parse session', () => {
    sessionToken = 'r:session-token';
    api.get('user_point_list', { uid: 58, stype: 3, cpage: 1 }).subscribe();
    const request = http.expectOne(API_CONFIG.cloudFunctionUrl);
    expect(request.request.body).toEqual({ token: 'r:session-token', params: { action: 'user_point_list', uid: 58, stype: 3, cpage: 1 } });
    request.flush({ retcode: 0, result: [{ ExpHisID: 1, score: 2 }] });
  });

  it('routes legacy model-based feedback submissions with a Parse session', () => {
    sessionToken = 'r:session-token';
    const model = JSON.stringify({ UserID: 58, Title: '小树 反馈的意见', TContent: '请假一天', Cateid: 22 });
    api.post('guestbook_add', { model }).subscribe();
    const request = http.expectOne(API_CONFIG.cloudFunctionUrl);
    expect(request.request.body).toEqual({ token: 'r:session-token', params: { action: 'guestbook_add', model } });
    request.flush({ retcode: 0, result: { GID: 1, TContent: '请假一天' } });
  });

  it('routes learning word state writes with a Parse session', () => {
    sessionToken = 'r:session-token';
    api.post('e_add_words', { uid: 58, wordsId: '2505,2503', kcid: 16, ifnew: 1 }).subscribe();
    const request = http.expectOne(API_CONFIG.cloudFunctionUrl);
    expect(request.request.body).toEqual({ token: 'r:session-token', params: { action: 'e_add_words', uid: 58, wordsId: '2505,2503', kcid: 16, ifnew: 1 } });
    request.flush({ retcode: 0, result: { affected: 2, newWordState: 1 } });
  });

  it('routes study record upserts with a Parse session', () => {
    sessionToken = 'r:session-token';
    api.post('stu_record_update_v2', { orderId: 918, uid: 23, addon: '{"xxqs":[]}' }).subscribe();
    const request = http.expectOne(API_CONFIG.cloudFunctionUrl);
    expect(request.request.body).toEqual({ token: 'r:session-token', params: { action: 'stu_record_update_v2', orderId: 918, uid: 23, addon: '{"xxqs":[]}' } });
    request.flush({ retcode: 0, result: { GeneralID: 123456, created: true } });
  });

  it('routes scheduled study record creation with a Parse session', () => {
    sessionToken = 'r:session-token';
    api.post('content_add_zt', { content: '{"ModelID":56}', addon: '{"UserID":23,"xxqs":"[]"}' }).subscribe();
    const request = http.expectOne(API_CONFIG.cloudFunctionUrl);
    expect(request.request.body).toEqual({ token: 'r:session-token', params: { action: 'content_add_zt', content: '{"ModelID":56}', addon: '{"UserID":23,"xxqs":"[]"}' } });
    request.flush({ retcode: 0, result: '123456' });
  });

  it('routes normalized content updates with a Parse session', () => {
    sessionToken = 'r:session-token';
    api.post('content_update', { content: '{"GeneralID":123456}', addon: '{"learned":2}' }).subscribe();
    const request = http.expectOne(API_CONFIG.cloudFunctionUrl);
    expect(request.request.body).toEqual({ token: 'r:session-token', params: { action: 'content_update', content: '{"GeneralID":123456}', addon: '{"learned":2}' } });
    request.flush({ retcode: 0, result: '123456' });
  });

  it('routes normalized content creation with a Parse session', () => {
    sessionToken = 'r:session-token';
    api.post('content_add', { content: '{"ModelID":61,"nodeId":389}', addon: '{"UserID":23,"df":8}' }).subscribe();
    const request = http.expectOne(API_CONFIG.cloudFunctionUrl);
    expect(request.request.body).toEqual({ token: 'r:session-token', params: { action: 'content_add', content: '{"ModelID":61,"nodeId":389}', addon: '{"UserID":23,"df":8}' } });
    request.flush({ retcode: 0, result: '123456' });
  });

  it('routes appointment statistics with a Parse session', () => {
    sessionToken = 'r:session-token';
    api.post('e_order_tongji', { uid: 23 }).subscribe();
    const request = http.expectOne(API_CONFIG.cloudFunctionUrl);
    expect(request.request.body).toEqual({ token: 'r:session-token', params: { action: 'e_order_tongji', uid: 23 } });
    request.flush({ retcode: 0, result: { t30: '1', t_shichang: '0.5', t_total: '1' } });
  });

  it('routes complete appointment transitions with a Parse session', () => {
    sessionToken = 'r:session-token';
    api.post('e_order_update_v2', { uid: 23, status: 11, content: '{"GeneralID":918}' }).subscribe();
    const request = http.expectOne(API_CONFIG.cloudFunctionUrl);
    expect(request.request.body).toEqual({ token: 'r:session-token', params: { action: 'e_order_update_v2', uid: 23, status: 11, content: '{"GeneralID":918}' } });
    request.flush({ retcode: 0, result: { GeneralID: '918', status: 11, reviewCount: 15, periodDeducted: true } });
  });

  it('keeps learning detail reads on legacy until a real Parse session exists', () => {
    sessionToken = 'legacy-session';
    api.get('e_words_list', { uid: 58 }).subscribe();
    const request = http.expectOne((candidate) => candidate.urlWithParams.includes('action=e_words_list'));
    expect(request.request.url).toContain(API_CONFIG.endpoint);
    request.flush({ retcode: 0, result: [] });
  });

  it('routes public vocabulary addon content without a session', () => {
    api.get('content_list', { modelId: 52, nid: 327 }).subscribe();
    const request = http.expectOne(API_CONFIG.cloudFunctionUrl);
    expect(request.request.body).toEqual({ params: { action: 'content_list', modelId: 52, nid: 327 } });
    request.flush({ retcode: 0, result: [] });
  });

  it('turns retcode -1 responses into ApiError', () => {
    let actual: unknown;
    api.post('user_login_passwd', {}).subscribe({ error: (error) => actual = error });
    http.expectOne(API_CONFIG.cloudFunctionUrl).flush({ retcode: -1, retmsg: '账号或密码错误', result: null }, { status: 401, statusText: 'Unauthorized' });
    http.expectOne((candidate) => candidate.urlWithParams.includes('action=user_login_passwd')).flush({ retcode: -1, retmsg: '登录失败', result: null });
    expect(actual instanceof ApiError).toBeTrue();
    expect((actual as ApiError).message).toBe('登录失败');
  });

  it('keeps a successful password login on the cloud response', () => {
    let actual: unknown;
    api.post('user_login_passwd', { name: 'tree', passwd: 'password' }).subscribe((response) => actual = response.result);
    http.expectOne(API_CONFIG.cloudFunctionUrl).flush({ retcode: 0, result: { userId: 42, sessionToken: 'r:token' } });
    http.expectNone((candidate) => candidate.url.includes(API_CONFIG.endpoint));
    expect(actual).toEqual({ userId: 42, sessionToken: 'r:token' });
  });
});