Skip to content

Commit

Permalink
[backend] Update counters (#issue/4911)
Browse files Browse the repository at this point in the history
  • Loading branch information
Goumies committed Nov 23, 2023
1 parent 7274c83 commit ad3b0cb
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -20,25 +20,25 @@ describe('Raw streams tests', () => {
expect(createEventsByTypes['marking-definition'].length).toBe(12);
expect(createEventsByTypes['external-reference'].length).toBe(17);
expect(createEventsByTypes.label.length).toBe(15);
expect(createEventsByTypes.identity.length).toBe(28);
expect(createEventsByTypes.identity.length).toBe(30);
expect(createEventsByTypes.relationship.length).toBe(126);
expect(createEventsByTypes.indicator.length).toBe(30);
expect(createEventsByTypes['attack-pattern'].length).toBe(7);
expect(createEventsByTypes.report.length).toBe(14);
expect(createEventsByTypes.tool.length).toBe(2);
expect(createEventsByTypes.vocabulary.length).toBe(330); // 328 created at init + 2 created in tests
expect(createEventsByTypes.vulnerability.length).toBe(7);
expect(createEvents.length).toBe(692);
expect(createEvents.length).toBe(694);
for (let createIndex = 0; createIndex < createEvents.length; createIndex += 1) {
const { data: insideData, origin, type } = createEvents[createIndex];
expect(origin).toBeDefined();
checkStreamGenericContent(type, insideData);
}
// 02 - CHECK UPDATE EVENTS
const updateEvents = events.filter((e) => e.type === EVENT_TYPE_UPDATE);
expect(updateEvents.length).toBe(129);
expect(updateEvents.length).toBe(131);
const updateEventsByTypes = R.groupBy((e) => e.data.data.type, updateEvents);
expect(updateEventsByTypes.report.length).toBe(3);
expect(updateEventsByTypes.report.length).toBe(5);
for (let updateIndex = 0; updateIndex < updateEvents.length; updateIndex += 1) {
const event = updateEvents[updateIndex];
const { data: insideData, origin, type } = event;
Expand All @@ -51,7 +51,7 @@ describe('Raw streams tests', () => {
}
// 03 - CHECK DELETE EVENTS
const deleteEvents = events.filter((e) => e.type === EVENT_TYPE_DELETE);
expect(deleteEvents.length).toBe(75);
expect(deleteEvents.length).toBe(77);
// const deleteEventsByTypes = R.groupBy((e) => e.data.data.type, deleteEvents);
for (let delIndex = 0; delIndex < deleteEvents.length; delIndex += 1) {
const { data: insideData, origin, type } = deleteEvents[delIndex];
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ export const checkPreSyncContent = async () => {
const initObjectAggregation = await elAggregationCount(testContext, ADMIN_USER, READ_DATA_INDICES, { types: ['Stix-Object'], field: 'entity_type' });
const objectMap = new Map(initObjectAggregation.map((i) => [i.label, i.value]));
expect(objectMap.get('Indicator')).toEqual(28);
expect(objectMap.get('Malware')).toEqual(27);
expect(objectMap.get('Malware')).toEqual(28);
expect(objectMap.get('Label')).toEqual(13);
expect(objectMap.get('Vocabulary')).toEqual(330);
// Relations
Expand Down

0 comments on commit ad3b0cb

Please sign in to comment.