forked from helyOSFramework/helyos_core
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request helyOSFramework#74 from helyOSFramework/refactorin…
…g/new_reponse_parameter Refactoring/alternative microservice response parameter for assignment order
- Loading branch information
Showing
9 changed files
with
376 additions
and
57 deletions.
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
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,69 @@ | ||
| // What is being tested: | ||
| // Same than test 01 but the mission will failed because microservice produces wrong | ||
| // assignment format. | ||
|
|
||
|
|
||
| process.env.TEST_NUMBER = 18; | ||
| console.log("starting test 18"); | ||
|
|
||
|
|
||
| let helyosApplication; | ||
|
|
||
| describe('18 Two Consecutive Assignments', () => { | ||
|
|
||
| it('Agent is reserved', async () => { | ||
| helyosApplication = await getHelyOSClientInstance(); | ||
| await helyosApplication.createNewMission('driving_release', ['Ab34069fc5-fdgs-434b-b87e-f19c5435113', | ||
| 'Bb34069fc5-fdgs-434b-b87e-f19c5435113']); | ||
| const result = await helyosApplication.waitAgentStatus(1, 'ready'); | ||
| expect(result).toEqual('ready'); | ||
| }); | ||
|
|
||
| it('Microservice is ready', async () => { | ||
| const result = await helyosApplication.waitMicroserviceStatus(1, 'ready'); | ||
| expect(result).toEqual('ready'); | ||
| }); | ||
|
|
||
| it('One Assignment starts and other waits', async () => { | ||
| const result1 = await helyosApplication.waitAssignmentStatuses(1, ['executing', 'not_ready_to_dispatch']); | ||
| const result2 = await helyosApplication.waitAssignmentStatuses(2, ['executing', 'not_ready_to_dispatch']); | ||
| const result = result1 === 'executing' && result2 === 'not_ready_to_dispatch' || result2 === 'executing' && result1 === 'not_ready_to_dispatch'; | ||
| expect(result).toEqual(true); | ||
| }); | ||
|
|
||
| it('One assignment is completed and the other runs', async () => { | ||
| const result1 = await helyosApplication.waitAssignmentStatuses(1, ['completed', 'executing']); | ||
| const result2 = await helyosApplication.waitAssignmentStatuses(2, ['completed', 'executing']); | ||
| const result = result1 === 'executing' && result2 === 'completed' || result2 === 'executing' && result1 === 'completed'; | ||
| expect(result).toEqual(true); | ||
|
|
||
| }); | ||
|
|
||
|
|
||
| it(' 2 Assignments are completed', async () => { | ||
| const result1 = await helyosApplication.waitAssignmentStatus(1, 'completed'); | ||
| const result2 = await helyosApplication.waitAssignmentStatus(2, 'completed'); | ||
| expect(result1).toEqual('completed'); | ||
| expect(result2).toEqual('completed'); | ||
| }); | ||
|
|
||
|
|
||
| it('Agent is free', async () => { | ||
| const result1 = await helyosApplication.waitAgentStatus(1, 'free'); | ||
| const result2 = await helyosApplication.waitAgentStatus(2, 'free'); | ||
| expect(result1).toEqual('free'); | ||
| expect(result2).toEqual('free'); | ||
| }); | ||
|
|
||
| it('Check 1 x Reserves/ 1 x Releases sent to the agent 1', async () => { | ||
| const logs = await helyosApplication.getAgentRelatedLogs('Ab34069fc5-fdgs-434b-b87e-f19c5435113'); | ||
| const reservationsSent = logs.filter(log => log.msg.includes('Sending reserve')).length; | ||
| const cancelationsSent = logs.filter(log => log.msg.includes('Sending cancel')).length; | ||
| const releasesSent = logs.filter(log => log.msg.includes('Sending release')).length; | ||
|
|
||
| expect(reservationsSent).toEqual(1); | ||
| expect(cancelationsSent).toEqual(0); | ||
| expect(releasesSent).toEqual(1); | ||
| }); | ||
|
|
||
| }); |
Oops, something went wrong.