Skip to content

Commit

Permalink
fix test
Browse files Browse the repository at this point in the history
  • Loading branch information
richardm-stripe committed Dec 14, 2023
1 parent f1c52bd commit 456f6e0
Showing 1 changed file with 41 additions and 41 deletions.
82 changes: 41 additions & 41 deletions test/telemetry.spec.ts
Original file line number Diff line number Diff line change
Expand Up @@ -169,48 +169,48 @@ describe('Client Telemetry', () => {
await resource.boop('w_123');
expect(numRequests).to.equal(2);
});
});

it('Buffers metrics on concurrent requests', async () => {
let numRequests = 0;

const handle = (req, res) => {
numRequests += 1;

const telemetry = req.headers['x-stripe-client-telemetry'];

switch (numRequests) {
case 1:
case 2:
expect(telemetry).to.not.exist;
break;
case 3:
case 4:
expect(telemetry).to.exist;
expect(
JSON.parse(telemetry).last_request_metrics.request_id
).to.be.oneOf(['req_1', 'req_2']);
break;
default:
expect.fail(`Should not have reached request ${numRequests}`);
}
it('Buffers metrics on concurrent requests', async () => {
let numRequests = 0;

res.setHeader('Request-Id', `req_${numRequests}`);
res.writeHead(200, {'Content-Type': 'application/json'});
res.end('{}');
};
const {host, port} = await createTestServer(handle);
const stripe = require('../src/stripe.cjs.node.js')(
'sk_test_FEiILxKZwnmmocJDUjUNO6pa',
{
telemetry: true,
host,
port,
protocol: 'http',
}
);
const handle = (req, res) => {
numRequests += 1;

const telemetry = req.headers['x-stripe-client-telemetry'];

switch (numRequests) {
case 1:
case 2:
expect(telemetry).to.not.exist;
break;
case 3:
case 4:
expect(telemetry).to.exist;
expect(
JSON.parse(telemetry).last_request_metrics.request_id
).to.be.oneOf(['req_1', 'req_2']);
break;
default:
expect.fail(`Should not have reached request ${numRequests}`);
}

res.setHeader('Request-Id', `req_${numRequests}`);
res.writeHead(200, {'Content-Type': 'application/json'});
res.end('{}');
};
const {host, port} = await createTestServer(handle);
const stripe = require('../src/stripe.cjs.node.js')(
'sk_test_FEiILxKZwnmmocJDUjUNO6pa',
{
telemetry: true,
host,
port,
protocol: 'http',
}
);

await Promise.all([stripe.balance.retrieve(), stripe.balance.retrieve()]);
await Promise.all([stripe.balance.retrieve(), stripe.balance.retrieve()]);
expect(numRequests).to.equal(4);
await Promise.all([stripe.balance.retrieve(), stripe.balance.retrieve()]);
await Promise.all([stripe.balance.retrieve(), stripe.balance.retrieve()]);
expect(numRequests).to.equal(4);
});
});

0 comments on commit 456f6e0

Please sign in to comment.