test: added esm test for tedious #2253
There are no files selected for viewing
This file contains hidden or 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 hidden or 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 hidden or 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 hidden or 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,148 @@ | ||
| /* | ||
| * (c) Copyright IBM Corp. 2025 | ||
| */ | ||
|
|
||
| /* eslint-disable no-console */ | ||
|
|
||
| // NOTE: c8 bug https://github.com/bcoe/c8/issues/166 | ||
| process.on('SIGTERM', () => { | ||
| process.disconnect(); | ||
| process.exit(0); | ||
| }); | ||
|
|
||
| import express from 'express'; | ||
| import fs from 'fs'; | ||
| import bodyParser from 'body-parser'; | ||
| import { createRequire } from 'module'; | ||
| import { fileURLToPath } from 'url'; | ||
| import { dirname, resolve } from 'path'; | ||
| import testUtil from '../../../../core/test/test_util/index.js'; | ||
| import getAppPort from '../../test_util/app-port.js'; | ||
| const port = getAppPort(); | ||
| const isCI = testUtil.isCI; | ||
| import tedious from 'tedious'; | ||
| const __filename = fileURLToPath(import.meta.url); | ||
| const __dirname = dirname(__filename); | ||
| const require = createRequire(import.meta.url); | ||
| const tediousPath = require.resolve('tedious'); | ||
| const expectedLocalPath = resolve(__dirname, 'node_modules', 'tedious'); | ||
| if (!tediousPath.includes(expectedLocalPath)) { | ||
| throw new Error( | ||
| `tedious must be loaded from local node_modules. Expected path containing: ${expectedLocalPath}, but got: ${tediousPath}` | ||
| ); | ||
| } | ||
|
|
||
| const Connection = tedious.Connection; | ||
| const Request = tedious.Request; | ||
| const app = express(); | ||
|
|
||
| app.use(bodyParser.json()); | ||
|
|
||
| // Locally: | ||
| // To obtain the credentials for the Azure SQL Database, you can find them in 1password. Search for | ||
| // "Team Node.js: Azure SQL credentials", download the file and copy this to your CMD line: | ||
| // export AZURE_SQL_CONFIG=~/Downloads/nodejs-tracer-azure-sql-server.json | ||
| if (!isCI() && !process.env.AZURE_SQL_CONFIG) { | ||
| throw new Error('Please set the env variable `AZURE_SQL_CONFIG`.'); | ||
| } | ||
|
|
||
| const azureConfig = process.env.AZURE_SQL_CONFIG | ||
| ? JSON.parse(fs.readFileSync(process.env.AZURE_SQL_CONFIG, 'utf-8')) | ||
| : null; | ||
|
|
||
| const config = { | ||
| server: azureConfig?.AZURE_SQL_SERVER || process.env.AZURE_SQL_SERVER, | ||
| authentication: { | ||
| type: 'default', | ||
| options: { | ||
| userName: azureConfig?.AZURE_SQL_USERNAME || process.env.AZURE_SQL_USERNAME, | ||
| password: azureConfig?.AZURE_SQL_PWD || process.env.AZURE_SQL_PWD | ||
| } | ||
| }, | ||
| options: { | ||
| database: azureConfig?.AZURE_SQL_DATABASE || process.env.AZURE_SQL_DATABASE, | ||
| connectTimeout: 30000 | ||
| } | ||
| }; | ||
|
|
||
| let connected = false; | ||
| let connection; | ||
|
|
||
| const retryDelay = 30000; | ||
| const maxRetries = 2; | ||
| let currentRetry = 0; | ||
|
|
||
| (function connectWithRetry() { | ||
| if (connection) { | ||
| connection.close(); | ||
| } | ||
| connection = new Connection(config); | ||
| connection.connect(); | ||
|
|
||
| connection.on('connect', err => { | ||
| if (err) { | ||
| console.warn('Connection error', err); | ||
| if (currentRetry < maxRetries) { | ||
| currentRetry++; | ||
| console.warn(`Retrying connection after ${retryDelay} ms (Retry ${currentRetry}/${maxRetries})`); | ||
| setTimeout(connectWithRetry, retryDelay); | ||
| } else { | ||
| console.error('Maximum retries reached. Unable to establish a connection.'); | ||
| connection.close(); | ||
| } | ||
| } else { | ||
| connected = true; | ||
| console.warn('Connected to the database'); | ||
| } | ||
| }); | ||
| })(); | ||
|
|
||
| const executeStatement = (query, isBatch, res) => { | ||
| const request = new Request(query, error => { | ||
| if (error) { | ||
| console.error('Error on executeStatement.', error); | ||
| res.status(500).send('Internal Server Error'); | ||
| } | ||
| }); | ||
|
|
||
| request.on('requestCompleted', () => { | ||
| res.send('OK'); | ||
| }); | ||
|
|
||
| if (isBatch) { | ||
| connection.execSqlBatch(request); | ||
| } else { | ||
| connection.execSql(request); | ||
| } | ||
| }; | ||
|
|
||
| app.get('/', (req, res) => { | ||
| if (!connected) { | ||
| res.sendStatus(500); | ||
| } else { | ||
| res.sendStatus(200); | ||
| } | ||
| }); | ||
|
|
||
| app.get('/packages', (req, res) => { | ||
| const query = 'SELECT * FROM packages'; | ||
| executeStatement(query, false, res); | ||
| }); | ||
|
|
||
| app.delete('/packages', (req, res) => { | ||
| const id = 11; | ||
| const query = `DELETE FROM packages WHERE id = ${id}`; | ||
| executeStatement(query, false, res); | ||
| }); | ||
|
|
||
| app.post('/packages/batch', (req, res) => { | ||
| const batchQuery = ` | ||
| INSERT INTO packages (id, name, version) VALUES (11, 'BatchPackage1', 1); | ||
| INSERT INTO packages (id, name, version) VALUES (11, 'BatchPackage2', 2); | ||
| `; | ||
| executeStatement(batchQuery, true, res); | ||
| }); | ||
| app.listen(port, () => { | ||
| // eslint-disable-next-line no-console | ||
| console.warn(`Listening on port: ${port}`); | ||
| }); |
This file contains hidden or 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
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Otel integration has its complete own testing space (we dont use anything from outside). Offering a way to specify the esm handler inside the otel app space.