-
Notifications
You must be signed in to change notification settings - Fork 21
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
108 changed files
with
2,305 additions
and
4,564 deletions.
There are no files selected for viewing
Large diffs are not rendered by default.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,116 @@ | ||
| import { fakeAsync, TestBed, tick } from "@angular/core/testing"; | ||
|
|
||
| import { SyncService } from "./sync.service"; | ||
| import { PouchDatabase } from "./pouch-database"; | ||
| import { Database } from "./database"; | ||
| import { LoginStateSubject, SyncStateSubject } from "../session/session-type"; | ||
| import { LoginState } from "../session/session-states/login-state.enum"; | ||
| import { KeycloakAuthService } from "../session/auth/keycloak/keycloak-auth.service"; | ||
| import { HttpStatusCode } from "@angular/common/http"; | ||
| import PouchDB from "pouchdb-browser"; | ||
|
|
||
| describe("SyncService", () => { | ||
| let service: SyncService; | ||
| let loginState: LoginStateSubject; | ||
| let mockAuthService: jasmine.SpyObj<KeycloakAuthService>; | ||
|
|
||
| beforeEach(() => { | ||
| mockAuthService = jasmine.createSpyObj(["login", "addAuthHeader"]); | ||
| TestBed.configureTestingModule({ | ||
| providers: [ | ||
| { provide: KeycloakAuthService, useValue: mockAuthService }, | ||
| { provide: Database, useClass: PouchDatabase }, | ||
| LoginStateSubject, | ||
| SyncStateSubject, | ||
| ], | ||
| }); | ||
| service = TestBed.inject(SyncService); | ||
| loginState = TestBed.inject(LoginStateSubject); | ||
| }); | ||
|
|
||
| it("should be created", () => { | ||
| expect(service).toBeTruthy(); | ||
| }); | ||
|
|
||
| it("should restart the sync if it fails at one point", fakeAsync(() => { | ||
| let errorCallback, pauseCallback; | ||
| const syncHandle = { | ||
| on: (action, callback) => { | ||
| if (action === "error") { | ||
| errorCallback = callback; | ||
| } | ||
| if (action === "paused") { | ||
| pauseCallback = callback; | ||
| } | ||
| return syncHandle; | ||
| }, | ||
| cancel: () => undefined, | ||
| }; | ||
| const syncSpy = jasmine | ||
| .createSpy() | ||
| .and.returnValues(Promise.resolve("first"), syncHandle, syncHandle); | ||
| spyOn( | ||
| TestBed.inject(Database) as PouchDatabase, | ||
| "getPouchDB", | ||
| ).and.returnValue({ sync: syncSpy } as any); | ||
|
|
||
| service.startSync(); | ||
| tick(1000); | ||
|
|
||
| // error + logged in -> sync should restart | ||
| loginState.next(LoginState.LOGGED_IN); | ||
| syncSpy.calls.reset(); | ||
| errorCallback(); | ||
| expect(syncSpy).toHaveBeenCalled(); | ||
|
|
||
| // pause -> no restart required | ||
| syncSpy.calls.reset(); | ||
| pauseCallback(); | ||
| expect(syncSpy).not.toHaveBeenCalled(); | ||
|
|
||
| // logout + error -> no restart | ||
| syncSpy.calls.reset(); | ||
| loginState.next(LoginState.LOGGED_OUT); | ||
| tick(); | ||
| errorCallback(); | ||
| expect(syncSpy).not.toHaveBeenCalled(); | ||
| })); | ||
|
|
||
| it("should try auto-login if fetch fails and fetch again", async () => { | ||
| // Make sync call pass | ||
| spyOn( | ||
| TestBed.inject(Database) as PouchDatabase, | ||
| "getPouchDB", | ||
| ).and.returnValues({ sync: () => Promise.resolve() } as any); | ||
| spyOn(PouchDB, "fetch").and.returnValues( | ||
| Promise.resolve({ | ||
| status: HttpStatusCode.Unauthorized, | ||
| ok: false, | ||
| } as Response), | ||
| Promise.resolve({ status: HttpStatusCode.Ok, ok: true } as Response), | ||
| ); | ||
| // providing "valid" token on second call | ||
| let calls = 0; | ||
| mockAuthService.addAuthHeader.and.callFake((headers) => { | ||
| headers.Authorization = calls++ === 1 ? "valid" : "invalid"; | ||
| }); | ||
| mockAuthService.login.and.resolveTo(); | ||
| const initSpy = spyOn(service["remoteDatabase"], "initRemoteDB"); | ||
| await service.startSync(); | ||
| // taking fetch function from init call | ||
| const fetch = initSpy.calls.mostRecent().args[1]; | ||
|
|
||
| const url = "/db/_changes"; | ||
| const opts = { headers: {} }; | ||
| await expectAsync(fetch(url, opts)).toBeResolved(); | ||
|
|
||
| expect(PouchDB.fetch).toHaveBeenCalledTimes(2); | ||
| expect(PouchDB.fetch).toHaveBeenCalledWith(url, opts); | ||
| expect(opts.headers).toEqual({ Authorization: "valid" }); | ||
| expect(mockAuthService.login).toHaveBeenCalled(); | ||
| expect(mockAuthService.addAuthHeader).toHaveBeenCalledTimes(2); | ||
|
|
||
| // prevent live sync call | ||
| service["cancelLiveSync"](); | ||
| }); | ||
| }); |
Oops, something went wrong.