-
-
Notifications
You must be signed in to change notification settings - Fork 76
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
add: custom retry behaviour + more retryMethods
- Loading branch information
1 parent
5d744b3
commit 12969ad
Showing
4 changed files
with
200 additions
and
32 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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,114 @@ | ||
| 'use strict' | ||
|
|
||
| const { test } = require('tap') | ||
| const Fastify = require('fastify') | ||
| const From = require('..') | ||
| const http = require('node:http') | ||
| const got = require('got') | ||
|
|
||
| function serverWithCustomError (stopAfter, statusCodeToFailOn) { | ||
| let requestCount = 0 | ||
| return http.createServer((req, res) => { | ||
| if (requestCount++ < stopAfter) { | ||
| res.statusCode = statusCodeToFailOn | ||
| res.setHeader('Content-Type', 'text/plain') | ||
| return res.end('This Service is Unavailable') | ||
| } else { | ||
| res.statusCode = 205 | ||
| res.setHeader('Content-Type', 'text/plain') | ||
| return res.end(`Hello World ${requestCount}!`) | ||
| } | ||
| }) | ||
| } | ||
|
|
||
| async function setupServer (t, fromOptions = {}, statusCodeToFailOn = 500, stopAfter = 4) { | ||
| const target = serverWithCustomError(stopAfter, statusCodeToFailOn) | ||
| await target.listen({ port: 0 }) | ||
| t.teardown(target.close.bind(target)) | ||
|
|
||
| const instance = Fastify() | ||
| instance.register(From, { | ||
| base: `http://localhost:${target.address().port}` | ||
| }) | ||
|
|
||
| instance.get('/', (request, reply) => { | ||
| reply.from(`http://localhost:${target.address().port}`, fromOptions) | ||
| }) | ||
|
|
||
| t.teardown(instance.close.bind(instance)) | ||
| await instance.listen({ port: 0 }) | ||
|
|
||
| return { | ||
| instance | ||
| } | ||
| } | ||
|
|
||
| test('a 500 status code with no custom handler should fail', async (t) => { | ||
| const { instance } = await setupServer(t) | ||
|
|
||
| try { | ||
| await got.get(`http://localhost:${instance.server.address().port}`, { retry: 0 }) | ||
| } catch (error) { | ||
| t.ok(error instanceof got.RequestError, 'should throw RequestError') | ||
| t.end() | ||
| } | ||
| }) | ||
|
|
||
| test("a server 500's with a custom handler and should revive", async (t) => { | ||
| const customRetryLogic = (req, res, registerDefaultRetry, defaultRetryAfter) => { | ||
| if (res && res.statusCode === 500 && req.method === 'GET') { | ||
| return 300 | ||
| } | ||
| return null | ||
| } | ||
|
|
||
| const { instance } = await setupServer(t, { customRetry: { handler: customRetryLogic, retries: 10 } }) | ||
|
|
||
| const res = await got.get(`http://localhost:${instance.server.address().port}`, { retry: 0 }) | ||
|
|
||
| t.equal(res.headers['content-type'], 'text/plain') | ||
| t.equal(res.statusCode, 205) | ||
| t.equal(res.body.toString(), 'Hello World 5!') | ||
| }) | ||
|
|
||
| test("a server 503's with a custom handler for 500 but the custom handler never registers the default so should fail", async (t) => { | ||
| // the key here is our customRetryHandler doesn't register the deefault handler and as a result it doesn't work | ||
| const customRetryLogic = (req, res, registerDefaultRetry, defaultRetryAfter) => { | ||
| if (res && res.statusCode === 500 && req.method === 'GET') { | ||
| return 300 | ||
| } | ||
| return null | ||
| } | ||
|
|
||
| const { instance } = await setupServer(t, { customRetry: { handler: customRetryLogic, retries: 10 } }, 503) | ||
|
|
||
| try { | ||
| await got.get(`http://localhost:${instance.server.address().port}`, { retry: 0 }) | ||
| } catch (error) { | ||
| t.equal(error.message, 'Response code 503 (Service Unavailable)') | ||
| t.end() | ||
| } | ||
| }) | ||
|
|
||
| test("a server 503's with a custom handler for 500 and the custom handler registers the default so it passes", async (t) => { | ||
| const customRetryLogic = (req, res, registerDefaultRetry, defaultRetryAfter) => { | ||
| // registering the default retry logic for non 500 errors if it occurs | ||
| if (registerDefaultRetry()) { | ||
| return defaultRetryAfter | ||
| } | ||
|
|
||
| if (res && res.statusCode === 500 && req.method === 'GET') { | ||
| return 300 | ||
| } | ||
|
|
||
| return null | ||
| } | ||
|
|
||
| const { instance } = await setupServer(t, { customRetry: { handler: customRetryLogic, retries: 10 } }, 503) | ||
|
|
||
| const res = await got.get(`http://localhost:${instance.server.address().port}`, { retry: 0 }) | ||
|
|
||
| t.equal(res.headers['content-type'], 'text/plain') | ||
| t.equal(res.statusCode, 205) | ||
| t.equal(res.body.toString(), 'Hello World 6!') | ||
| }) |
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