Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
SNOW-1883649 Added manual integration test
- Loading branch information
1 parent
2dc1d95
commit e7c980c
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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,199 @@ | ||
| const assert = require('assert'); | ||
| const fs = require('fs'); | ||
| const net = require('net'); | ||
| const connParameters = require('../../authentication/connectionParameters'); | ||
| const axios = require('axios'); | ||
| const AuthTest = require('../../authentication/authTestsBaseClass'); | ||
| const WireMockRestClient = require('wiremock-rest-client').WireMockRestClient; | ||
| const { exec } = require('child_process'); | ||
| const Os = require("os"); | ||
|
|
||
|
|
||
|
|
||
| async function runWireMockAsync(port) { | ||
| let timeoutHandle; | ||
| const waitingWireMockPromise = new Promise(async (resolve, reject) => { | ||
| try { | ||
| exec(`npx wiremock --enable-browser-proxying --proxy-pass-through false --port ${port} `, (error, stdout, stderr) => { | ||
| if (error) { | ||
| console.error(`exec error: ${error}`); | ||
| return; | ||
| } | ||
| console.log(`stdout: ${stdout}`); | ||
| console.error(`stderr: ${stderr}`); | ||
| }); | ||
| const wireMock = new WireMockRestClient(`http://localhost:${port}`); | ||
| const readyWireMock = await waitForWiremockStarted(wireMock); | ||
| resolve(readyWireMock); | ||
| } catch (err) { | ||
| reject(err); | ||
| } | ||
| }); | ||
|
|
||
|
|
||
| const timeout = new Promise((resolve, reject) => | ||
| timeoutHandle = setTimeout( | ||
| () => reject('Wiremock unavailable after 26000 ms.'), | ||
| 26000)); | ||
| return Promise.race([waitingWireMockPromise, timeout]) | ||
| .then(result => { | ||
| clearTimeout(timeoutHandle); | ||
| return result; | ||
| }); | ||
| } | ||
|
|
||
| async function waitForWiremockStarted(wireMock) { | ||
| return fetch(wireMock.baseUri) | ||
| .then(async (resp) => { | ||
| if (resp.ok) { | ||
| return Promise.resolve(wireMock); | ||
| } else { | ||
| await new Promise(resolve => setTimeout(resolve, 1000)); | ||
| console.log(`Retry connection to WireMock after wrong response status: ${resp.status}`); | ||
| return await waitForWiremockStarted(wireMock); | ||
| } | ||
| }) | ||
| .catch(async (err) => { | ||
| await new Promise(resolve => setTimeout(resolve, 1000)); | ||
| console.log(`Retry connection to WireMock after error: ${err}`); | ||
| return await waitForWiremockStarted(wireMock); | ||
| }); | ||
| } | ||
|
|
||
| if (Os.platform() === 'linux') { | ||
| describe('Wiremock test', function () { | ||
| let port, wireMock; | ||
| before(async () => { | ||
| port = await getPortFree(); | ||
| wireMock = await runWireMockAsync(port); | ||
| }); | ||
| after(async () => { | ||
| await wireMock.global.shutdown(); | ||
| }); | ||
| it('Run Wiremock instance, wait, verify connection and shutdown', async function () { | ||
| assert.doesNotReject(async () => await wireMock.mappings.getAllMappings()); | ||
| }); | ||
| it('Add mappings', async function () { | ||
| const requests = JSON.parse(fs.readFileSync('wiremock/mappings/test.json', 'utf8')); | ||
| for (const mapping of requests.mappings) { | ||
| await wireMock.mappings.createMapping(mapping); | ||
| } | ||
| const mappings = await wireMock.mappings.getAllMappings(); | ||
| assert.strictEqual(mappings.mappings.length, 2); | ||
| const response = await axios.get(`http://localhost:${port}/test/authorize.html`); | ||
| assert.strictEqual(response.status, 200); | ||
| }); | ||
| }); | ||
|
|
||
| describe.only('Oauth PAT authentication', function () { | ||
| let port; | ||
| let authTest; | ||
| let wireMock; | ||
| before(async () => { | ||
| port = await getPortFree(); | ||
| wireMock = await runWireMockAsync(port); | ||
| }); | ||
| beforeEach(async () => { | ||
| authTest = new AuthTest(); | ||
| }); | ||
| afterEach(async () => { | ||
| wireMock.scenarios.resetAllScenarios(); | ||
| }); | ||
| after(async () => { | ||
| await wireMock.global.shutdown(); | ||
| }); | ||
|
|
||
|
|
||
| it('Successful flow scenario PAT as token', async function () { | ||
| await addWireMockMappingsFromFile('wiremock/mappings/pat/successful_flow.json'); | ||
| const connectionOption = {...connParameters.oauthPATOnWiremock, token: 'MOCK_TOKEN', port: port}; | ||
| authTest.createConnection(connectionOption); | ||
| await authTest.connectAsync(); | ||
| authTest.verifyNoErrorWasThrown(); | ||
| }); | ||
|
|
||
| it('Successful flow scenario PAT as password', async function () { | ||
| await addWireMockMappingsFromFile('wiremock/mappings/pat/successful_flow.json'); | ||
| const connectionOption = {...connParameters.oauthPATOnWiremock, password: 'MOCK_TOKEN', port: port}; | ||
| authTest.createConnection(connectionOption); | ||
| await authTest.connectAsync(); | ||
| authTest.verifyNoErrorWasThrown(); | ||
| }); | ||
|
|
||
| it('Invalid token', async function () { | ||
| await addWireMockMappingsFromFile('wiremock/mappings/pat/invalid_pat_token.json'); | ||
| const connectionOption = {...connParameters.oauthPATOnWiremock, token: 'INVALID_TOKEN', port: port}; | ||
| authTest.createConnection(connectionOption); | ||
| await authTest.connectAsync(); | ||
| authTest.verifyErrorWasThrown('Programmatic access token is invalid.'); | ||
| }); | ||
|
|
||
| async function addWireMockMappingsFromFile(filePath) { | ||
| const requests = JSON.parse(fs.readFileSync(filePath, 'utf8')); | ||
| for (const mapping of requests.mappings) { | ||
| await wireMock.mappings.createMapping(mapping); | ||
| } | ||
| } | ||
| }); | ||
|
|
||
| // describe('Oauth PAT authentication', function () { | ||
| // let port; | ||
| // let authTest; | ||
| // let wireMock; | ||
| // before(async () => { | ||
| // port = await getPortFree(); | ||
| // wireMock = await runWireMockAsync(port); | ||
| // }); | ||
| // beforeEach(async () => { | ||
| // authTest = new AuthTest(); | ||
| // }); | ||
| // afterEach(async () => { | ||
| // wireMock.scenarios.resetAllScenarios(); | ||
| // }); | ||
| // after(async () => { | ||
| // await wireMock.global.shutdown(); | ||
| // }); | ||
| // | ||
| // | ||
| // it('Successful flow scenario PAT as token', async function () { | ||
| // await addWireMockMappingsFromFile('wiremock/mappings/pat/successful_flow.json'); | ||
| // const connectionOption = {...connParameters.oauthPATOnWiremock, token: 'MOCK_TOKEN', port: port}; | ||
| // authTest.createConnection(connectionOption); | ||
| // await authTest.connectAsync(); | ||
| // authTest.verifyNoErrorWasThrown(); | ||
| // }); | ||
| // | ||
| // it('Successful flow scenario PAT as password', async function () { | ||
| // await addWireMockMappingsFromFile('wiremock/mappings/pat/successful_flow.json'); | ||
| // const connectionOption = {...connParameters.oauthPATOnWiremock, password: 'MOCK_TOKEN', port: port}; | ||
| // authTest.createConnection(connectionOption); | ||
| // await authTest.connectAsync(); | ||
| // authTest.verifyNoErrorWasThrown(); | ||
| // }); | ||
| // | ||
| // it('Invalid token', async function () { | ||
| // await addWireMockMappingsFromFile('wiremock/mappings/pat/invalid_pat_token.json'); | ||
| // const connectionOption = {...connParameters.oauthPATOnWiremock, token: 'INVALID_TOKEN', port: port}; | ||
| // authTest.createConnection(connectionOption); | ||
| // await authTest.connectAsync(); | ||
| // authTest.verifyErrorWasThrown('Programmatic access token is invalid.'); | ||
| // }); | ||
| // | ||
| // async function addWireMockMappingsFromFile(filePath) { | ||
| // const requests = JSON.parse(fs.readFileSync(filePath, 'utf8')); | ||
| // for (const mapping of requests.mappings) { | ||
| // await wireMock.mappings.createMapping(mapping); | ||
| // } | ||
| // } | ||
| // }); | ||
|
|
||
| async function getPortFree() { | ||
| return new Promise(res => { | ||
| const srv = net.createServer(); | ||
| srv.listen(0, () => { | ||
| const port = srv.address().port; | ||
| srv.close((err) => res(port)); | ||
| }); | ||
| }); | ||
| } | ||
| } | ||
