13481192372

Committed 23 Feb 2025 08:16AM UTC coverage: 82.956% (-0.1%) from 83.059%

Build # 13481192372

Build Type

Pull #362

github

Committed by

MrOrz

Commit Message

test(timeoutHeader): skip timeout logic in test

Pull Request Pull Request #362: Proxy read timeout mitigation

Run Details

775 of 983 branches covered (78.84%)

Branch coverage included in aggregate %.

2 of 6 new or added lines in 2 files covered. (33.33%)

1498 of 1757 relevant lines covered (85.26%)

18.89 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

33.33

/src/timeoutHeader.ts

import type { Context, Next } from 'koa';

/**
 * Creates a middleware that sends a preliminary header after a timeout
 * to keep the connection alive with Cloudflare
 * @param timeout - Timeout in milliseconds before sending the header. Default to lower than Cloudflare's Proxy Read Timeout.
 * @returns Koa middleware function
 */
export default function timeoutHeader(timeout = 90000) {
  return async (ctx: Context, next: Next): Promise<void> => {
    // Create a timer to send headers
    const timer = setTimeout(() => /* istanbul ignore next */ {
      if (!ctx.headerSent) {
        console.log(
          '[timeoutHeader] Sending preliminary header after',
          timeout,
          'ms'
        );
        ctx.set('Content-Encoding', 'identity');
        ctx.flushHeaders();
      }
    }, timeout);

    try {
      await next();
    } finally {
      clearTimeout(timer);
    }
  };
}

1	import type { Context, Next } from 'koa';
2
3	/**
4	* Creates a middleware that sends a preliminary header after a timeout
5	* to keep the connection alive with Cloudflare
6	* @param timeout - Timeout in milliseconds before sending the header. Default to lower than Cloudflare's Proxy Read Timeout.
7	* @returns Koa middleware function
8	*/
9	export default function timeoutHeader(timeout = 90000) {	1✔
10	return async (ctx: Context, next: Next): Promise<void> => {	1✔
11	// Create a timer to send headers
NEW 12	const timer = setTimeout(() => /* istanbul ignore next */ {	×
13	if (!ctx.headerSent) {
14	console.log(
15	'[timeoutHeader] Sending preliminary header after',
16	timeout,
17	'ms'
18	);
19	ctx.set('Content-Encoding', 'identity');
20	ctx.flushHeaders();
21	}
22	}, timeout);
23
NEW 24	try {	×
NEW 25	await next();	×
26	} finally {
NEW 27	clearTimeout(timer);	×
28	}
29	};
30	}

cofacts / rumors-api / 13481192372

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous