Skip to content

Commit

Permalink
fix: updated tests
Browse files Browse the repository at this point in the history
  • Loading branch information
@DoctorVoid
DoctorVoid committed Jul 26, 2020
1 parent 27a89cd commit a30a664
Show file tree
Hide file tree
Showing 2 changed files with 92 additions and 90 deletions.
40 changes: 40 additions & 0 deletions test/integration/tests/snapshot-metadata-cleaning.test.ts
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,40 @@
import { PolarisServer } from '../../../src';
import { initializeDatabase } from '../server/dal/data-initalizer';
import { startTestServer, stopTestServer } from '../server/test-server';
import { graphqlRawRequest } from '../server/utils/graphql-client';
import { metadataRequest, waitUntilSnapshotRequestIsDone } from '../server/utils/snapshot-client';
import * as paginatedQuery from './jsonRequestsAndHeaders/paginatedQuery.json';

let polarisServer: PolarisServer;
beforeEach(async () => {
polarisServer = await startTestServer({
snapshotConfig: {
autoSnapshot: true,
maxPageSize: 3,
snapshotCleaningInterval: 1,
secondsToBeOutdated: 4,
entitiesAmountPerFetch: 50,
},
});
await initializeDatabase();
});
afterEach(async () => {
await stopTestServer(polarisServer);
});

describe('snapshot metadata cleaned every interval', () => {
it('should remove expired metadata', async () => {
const paginatedResult = await graphqlRawRequest(paginatedQuery.request, {
...paginatedQuery.headers,
});
const snapshotMetadataId = paginatedResult.extensions.snapResponse.snapshotMetadataId;
await waitUntilSnapshotRequestIsDone(snapshotMetadataId, 500);
await sleep(5000);
const metadataResponse = await metadataRequest(snapshotMetadataId);
expect(metadataResponse.data).toBe('');

function sleep(ms: number) {
return new Promise(resolve => setTimeout(resolve, ms));
}
});
});
142 changes: 52 additions & 90 deletions test/integration/tests/snapshot-metadata.test.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -10,112 +10,74 @@ import {
} from '../server/utils/snapshot-client';
import * as paginatedQuery from './jsonRequestsAndHeaders/paginatedQuery.json';

let polarisServer: PolarisServer;
beforeEach(async () => {
polarisServer = await startTestServer({
snapshotConfig: {
autoSnapshot: true,
maxPageSize: 3,
snapshotCleaningInterval: 60,
secondsToBeOutdated: 60,
entitiesAmountPerFetch: 50,
},
});
await initializeDatabase();
});
afterEach(async () => {
await stopTestServer(polarisServer);
});

describe('snapshot metadata is generated running snapshot pagination', () => {
describe('snapshot cleanup every minute', () => {
let polarisServer: PolarisServer;
beforeEach(async () => {
polarisServer = await startTestServer({
snapshotConfig: {
autoSnapshot: true,
maxPageSize: 3,
snapshotCleaningInterval: 60,
secondsToBeOutdated: 60,
entitiesAmountPerFetch: 50,
},
});
await initializeDatabase();
});
afterEach(async () => {
await stopTestServer(polarisServer);
});
describe('snapshot metadata is returned upon request', () => {
it('will generate metadata and return it when requested', async () => {
const paginatedResult = await graphqlRawRequest(paginatedQuery.request, {
...paginatedQuery.headers,
});
const snapshotMetadataId =
paginatedResult.extensions.snapResponse.snapshotMetadataId;
await waitUntilSnapshotRequestIsDone(snapshotMetadataId, 500);
const snapshotMetadata: any = (await metadataRequest(snapshotMetadataId)).data;
expect(snapshotMetadata.id).toBe(snapshotMetadataId);
expect(snapshotMetadata.pagesCount).toBe(2);
expect(snapshotMetadata.status).toBe(SnapshotStatus.DONE);
describe('snapshot metadata is returned upon request', () => {
it('will generate metadata and return it when requested', async () => {
const paginatedResult = await graphqlRawRequest(paginatedQuery.request, {
...paginatedQuery.headers,
});
const snapshotMetadataId = paginatedResult.extensions.snapResponse.snapshotMetadataId;
await waitUntilSnapshotRequestIsDone(snapshotMetadataId, 500);
const snapshotMetadata: any = (await metadataRequest(snapshotMetadataId)).data;
expect(snapshotMetadata.id).toBe(snapshotMetadataId);
expect(snapshotMetadata.pagesCount).toBe(2);
expect(snapshotMetadata.status).toBe(SnapshotStatus.DONE);
});
});

describe('page generation will occur even after initial request ends', () => {
it('returns IN_PROGRESS as status if pagination not ended yet', async () => {
const paginatedResult = await graphqlRawRequest(paginatedQuery.request, {
...paginatedQuery.headers,
});
const snapshotMetadataId =
paginatedResult.extensions.snapResponse.snapshotMetadataId;
const snapshotMetadata: any = (await metadataRequest(snapshotMetadataId)).data;
await waitUntilSnapshotRequestIsDone(snapshotMetadataId, 500);
expect(snapshotMetadata.status).toBe(SnapshotStatus.IN_PROGRESS);
});

it('not completed pages will return status in_progress', async () => {
const paginatedResult = await graphqlRawRequest(paginatedQuery.request, {
...paginatedQuery.headers,
});
const secondPageId = paginatedResult.extensions.snapResponse.pagesIds[1];
const snapshotMetadataId =
paginatedResult.extensions.snapResponse.snapshotMetadataId;
const snapshotPage: any = (await snapshotRequest(secondPageId)).data;
await waitUntilSnapshotRequestIsDone(snapshotMetadataId, 500);
expect(snapshotPage.status).toBe(SnapshotStatus.IN_PROGRESS);
describe('page generation will occur even after initial request ends', () => {
it('returns IN_PROGRESS as status if pagination not ended yet', async () => {
const paginatedResult = await graphqlRawRequest(paginatedQuery.request, {
...paginatedQuery.headers,
});
const snapshotMetadataId = paginatedResult.extensions.snapResponse.snapshotMetadataId;
const snapshotMetadata: any = (await metadataRequest(snapshotMetadataId)).data;
await waitUntilSnapshotRequestIsDone(snapshotMetadataId, 500);
expect(snapshotMetadata.status).toBe(SnapshotStatus.IN_PROGRESS);
});

describe('snapshot metadata request', () => {
it('should update metadata last accessed time each access', async () => {
const paginatedResult = await graphqlRawRequest(paginatedQuery.request, {
...paginatedQuery.headers,
});
const snapshotMetadataId =
paginatedResult.extensions.snapResponse.snapshotMetadataId;
await waitUntilSnapshotRequestIsDone(snapshotMetadataId, 500);
const firstSnapshotMetadataRequest = await metadataRequest(snapshotMetadataId);

const secondSnapshotMetadataRequest = await metadataRequest(snapshotMetadataId);
expect(
Date.parse(secondSnapshotMetadataRequest.data.lastAccessedTime),
).toBeGreaterThan(Date.parse(firstSnapshotMetadataRequest.data.lastAccessedTime));
it('not completed pages will return status in_progress', async () => {
const paginatedResult = await graphqlRawRequest(paginatedQuery.request, {
...paginatedQuery.headers,
});
const secondPageId = paginatedResult.extensions.snapResponse.pagesIds[1];
const snapshotMetadataId = paginatedResult.extensions.snapResponse.snapshotMetadataId;
const snapshotPage: any = (await snapshotRequest(secondPageId)).data;
await waitUntilSnapshotRequestIsDone(snapshotMetadataId, 500);
expect(snapshotPage.status).toBe(SnapshotStatus.IN_PROGRESS);
});
});
describe('snapshot metadata last accessed time handling', () => {
let polarisServer: PolarisServer;
beforeEach(async () => {
polarisServer = await startTestServer({
snapshotConfig: {
autoSnapshot: true,
maxPageSize: 3,
snapshotCleaningInterval: 1,
secondsToBeOutdated: 4,
entitiesAmountPerFetch: 50,
},
});
await initializeDatabase();
});
afterEach(async () => {
await stopTestServer(polarisServer);
});

it('should remove expired metadata', async () => {
describe('snapshot metadata request', () => {
it('should update metadata last accessed time each access', async () => {
const paginatedResult = await graphqlRawRequest(paginatedQuery.request, {
...paginatedQuery.headers,
});
const snapshotMetadataId = paginatedResult.extensions.snapResponse.snapshotMetadataId;
await waitUntilSnapshotRequestIsDone(snapshotMetadataId, 500);
await sleep(5000);
const metadataResponse = await metadataRequest(snapshotMetadataId);
expect(metadataResponse.data).toBe('');
const firstSnapshotMetadataRequest = await metadataRequest(snapshotMetadataId);

function sleep(ms: number) {
return new Promise(resolve => setTimeout(resolve, ms));
}
const secondSnapshotMetadataRequest = await metadataRequest(snapshotMetadataId);
expect(Date.parse(secondSnapshotMetadataRequest.data.lastAccessedTime)).toBeGreaterThan(
Date.parse(firstSnapshotMetadataRequest.data.lastAccessedTime),
);
});
});
});
});

0 comments on commit a30a664

Please sign in to comment.