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
1 parent
d8462a9
commit 3538e1c
There are no files selected for viewing
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 |
|---|---|---|
| @@ -1,198 +1,149 @@ | ||
| /* eslint-disable import/first */ | ||
|
|
||
| const mockGetBySystemNumberAndCreatedTimestamp = jest.fn(); | ||
| const mockSearchByCriteria = jest.fn(); | ||
| const mockUpdateVehicle = jest.fn(); | ||
| const mockPublish = jest.fn(); | ||
| const mockSqs = jest.fn(); | ||
|
|
||
| import { handler } from '../../../src/handler/mot-update-vrm'; | ||
| import { StatusCode } from '../../../src/util/enum'; | ||
| import logger from '../../../src/util/logger'; | ||
| import updateEventMultiple from '../../resources/mot-vrm-update-event-multiple.json'; | ||
| import updateEvent from '../../resources/mot-vrm-update-event.json'; | ||
|
|
||
| jest.mock('../../../src/services/database.ts', () => ({ | ||
| searchByCriteria: mockSearchByCriteria, | ||
| updateVehicle: mockUpdateVehicle, | ||
| getBySystemNumberAndCreatedTimestamp: mockGetBySystemNumberAndCreatedTimestamp, | ||
| })); | ||
|
|
||
| jest.mock('../../../src/services/sns', () => ({ | ||
| publish: mockPublish, | ||
| })); | ||
|
|
||
| jest.mock('../../../src/services/sqs', () => ({ | ||
| addToSqs: mockSqs, | ||
| })); | ||
|
|
||
| describe('Test Mot Update Vrm Lambda Function', () => { | ||
| beforeEach(() => { | ||
| jest.resetAllMocks(); | ||
| jest.resetModules(); | ||
| }); | ||
|
|
||
| it('should log when no records are found', async () => { | ||
| mockSearchByCriteria.mockReturnValue([]); | ||
|
|
||
| const loggerSpy = jest.spyOn(logger, 'info'); | ||
|
|
||
| updateEvent.Records[0].body = JSON.stringify({ | ||
| vin: '1', | ||
| vrm: '3', | ||
| }); | ||
|
|
||
| await handler(updateEvent); | ||
|
|
||
| expect(loggerSpy).toHaveBeenCalledWith('No record found for VIN: 1'); | ||
| expect(mockPublish).not.toHaveBeenCalled(); | ||
| }); | ||
|
|
||
| it('should log when no current records are found', async () => { | ||
| mockSearchByCriteria.mockReturnValue([ | ||
| { | ||
| primaryVrm: '1', | ||
| vin: '2', | ||
| techRecord_statusCode: StatusCode.ARCHIVED, | ||
| systemNumber: '15', | ||
| }, | ||
| ]); | ||
|
|
||
| const loggerSpy = jest.spyOn(logger, 'info'); | ||
|
|
||
| updateEvent.Records[0].body = JSON.stringify({ | ||
| vin: '1', | ||
| vrm: '3', | ||
| }); | ||
|
|
||
| await handler(updateEvent); | ||
|
|
||
| expect(loggerSpy).toHaveBeenCalledWith('No current record found for VIN: 1'); | ||
| expect(mockPublish).not.toHaveBeenCalled(); | ||
| }); | ||
|
|
||
| it('should log when a current record with a duplicate VIN is found', async () => { | ||
| mockSearchByCriteria.mockReturnValue([{ | ||
| primaryVrm: '1', | ||
| vin: '2', | ||
| techRecord_statusCode: StatusCode.CURRENT, | ||
| systemNumber: '15', | ||
| }, | ||
| { | ||
| primaryVrm: '1', | ||
| vin: '2', | ||
| techRecord_statusCode: StatusCode.CURRENT, | ||
| systemNumber: '16', | ||
| }]); | ||
|
|
||
| const loggerSpy = jest.spyOn(logger, 'info'); | ||
|
|
||
| updateEvent.Records[0].body = JSON.stringify({ | ||
| vin: '1', | ||
| vrm: '3', | ||
| }); | ||
|
|
||
| await handler(updateEvent); | ||
|
|
||
| expect(loggerSpy).toHaveBeenCalledWith('Duplicate current records found for VIN 1'); | ||
| expect(mockPublish).not.toHaveBeenCalled(); | ||
| }); | ||
|
|
||
| it('should log when a current record with a duplicate VIN and VRM is found', async () => { | ||
| mockSearchByCriteria.mockReturnValue([{ | ||
| primaryVrm: '1', | ||
| vin: '2', | ||
| techRecord_statusCode: StatusCode.CURRENT, | ||
| systemNumber: '15', | ||
| }, | ||
| ]); | ||
|
|
||
| const loggerSpy = jest.spyOn(logger, 'info'); | ||
|
|
||
| updateEvent.Records[0].body = JSON.stringify({ | ||
| vin: '2', | ||
| vrm: '1', | ||
| }); | ||
|
|
||
| await handler(updateEvent); | ||
|
|
||
| expect(loggerSpy).toHaveBeenCalledWith('No update needed for VRM 1 and VIN 2'); | ||
| expect(mockPublish).not.toHaveBeenCalled(); | ||
| }); | ||
|
|
||
| it('should log when there is a current record with a matching VIN and no matching VRM', async () => { | ||
| mockSqs.mockResolvedValueOnce(undefined); | ||
| mockSearchByCriteria.mockReturnValue([{ | ||
| primaryVrm: '1', | ||
| vin: '2', | ||
| techRecord_statusCode: StatusCode.CURRENT, | ||
| systemNumber: '15', | ||
| }, | ||
| ]); | ||
|
|
||
| mockGetBySystemNumberAndCreatedTimestamp.mockResolvedValueOnce({}); | ||
| mockUpdateVehicle.mockResolvedValue(true); | ||
|
|
||
| const loggerSpy = jest.spyOn(logger, 'info'); | ||
|
|
||
| updateEvent.Records[0].body = JSON.stringify({ | ||
| vin: '2', | ||
| vrm: '3', | ||
| }); | ||
|
|
||
| await handler(updateEvent); | ||
|
|
||
| expect(loggerSpy).toHaveBeenCalledWith('Updated systemNumber 15 with VRM 3'); | ||
| expect(mockUpdateVehicle).toHaveBeenCalled(); | ||
| expect(mockPublish).toHaveBeenCalled(); | ||
| }); | ||
| }); | ||
