Skip to content

Commit

Permalink
fix: try travis without metadata snapshot tests
Browse files Browse the repository at this point in the history
  • Loading branch information
@DoctorVoid
DoctorVoid committed Jul 26, 2020
1 parent ffd9349 commit 2210653
Showing 1 changed file with 121 additions and 121 deletions.
242 changes: 121 additions & 121 deletions test/integration/tests/snapshot-metadata.test.ts
View file
Original file line number Diff line number Diff line change
@@ -1,121 +1,121 @@
import { SnapshotStatus } from '@enigmatis/polaris-typeorm';
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,
snapshotRequest,
waitUntilSnapshotRequestIsDone,
} from '../server/utils/snapshot-client';
import * as paginatedQuery from './jsonRequestsAndHeaders/paginatedQuery.json';

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('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('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));
});
});
});
describe('snapshot metadata last accessed time handling', () => {
let polarisServer: PolarisServer;
beforeEach(async () => {
polarisServer = await startTestServer({
snapshotConfig: {
autoSnapshot: true,
maxPageSize: 3,
snapshotCleaningInterval: 1,
secondsToBeOutdated: 10,
entitiesAmountPerFetch: 50,
},
});
await initializeDatabase();
});
afterEach(async () => {
await stopTestServer(polarisServer);
});

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(11000);
const metadataResponse = await metadataRequest(snapshotMetadataId);
expect(metadataResponse.data).toBe('');

function sleep(ms: number) {
return new Promise(resolve => setTimeout(resolve, ms));
}
});
});
});
// import { SnapshotStatus } from '@enigmatis/polaris-typeorm';
// 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,
// snapshotRequest,
// waitUntilSnapshotRequestIsDone,
// } from '../server/utils/snapshot-client';
// import * as paginatedQuery from './jsonRequestsAndHeaders/paginatedQuery.json';
//
// 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('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('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));
// });
// });
// });
// describe('snapshot metadata last accessed time handling', () => {
// let polarisServer: PolarisServer;
// beforeEach(async () => {
// polarisServer = await startTestServer({
// snapshotConfig: {
// autoSnapshot: true,
// maxPageSize: 3,
// snapshotCleaningInterval: 1,
// secondsToBeOutdated: 10,
// entitiesAmountPerFetch: 50,
// },
// });
// await initializeDatabase();
// });
// afterEach(async () => {
// await stopTestServer(polarisServer);
// });
//
// 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(11000);
// const metadataResponse = await metadataRequest(snapshotMetadataId);
// expect(metadataResponse.data).toBe('');
//
// function sleep(ms: number) {
// return new Promise(resolve => setTimeout(resolve, ms));
// }
// });
// });
// });

0 comments on commit 2210653

Please sign in to comment.