wpt: add http-response-code.any.js

Author: KhafraDev

test/wpt/runner/runner/util.mjs

@@ -126,7 +126,7 @@ export function handlePipes (code, url) {
 export function normalizeName (name) {
   return name.replace(/(\v)/g, (_, match) => {
     switch (inspect(match)) {
-      case `'\\x0B'`: return '\\x0B'
+      case '\'\\x0B\'': return '\\x0B'
       default: return match
     }
   })

test/wpt/server/routes/network-partition-key.mjs

@@ -0,0 +1,111 @@
+const stash = new Map()
+
+/**
+ * @see https://github.com/web-platform-tests/wpt/blob/master/fetch/connection-pool/resources/network-partition-key.py
+ * @param {Parameters<import('http').RequestListener>[0]} req
+ * @param {Parameters<import('http').RequestListener>[1]} res
+ * @param {URL} url
+ */
+export function route (req, res, { searchParams, port }) {
+  res.setHeader('Cache-Control', 'no-store')
+
+  const dispatch = searchParams.get('dispatch')
+  const uuid = searchParams.get('uuid')
+  const partitionId = searchParams.get('partition_id')
+
+  if (!uuid || !dispatch || !partitionId) {
+    res.statusCode = 404
+    res.end('Invalid query parameters')
+    return
+  }
+
+  let testFailed = false
+  let requestCount = 0
+  let connectionCount = 0
+
+  if (searchParams.get('nocheck_partition') !== 'True') {
+    const addressKey = `${req.socket.localAddress}|${port}`
+    const serverState = stash.get(uuid) ?? {
+      testFailed: false,
+      requestCount: 0,
+      connectionCount: 0
+    }
+
+    stash.delete(uuid)
+    requestCount = serverState.requestCount + 1
+    serverState.requestCount = requestCount
+
+    if (Object.hasOwn(serverState, addressKey)) {
+      if (serverState[addressKey] !== partitionId) {
+        serverState.testFailed = true
+      }
+    } else {
+      connectionCount = serverState.connectionCount + 1
+      serverState.connectionCount = connectionCount
+    }
+
+    serverState[addressKey] = partitionId
+    testFailed = serverState.testFailed
+    stash.set(uuid, serverState)
+  }
+
+  const origin = req.headers.origin
+  if (origin) {
+    res.setHeader('Access-Control-Allow-Origin', origin)
+    res.setHeader('Access-Control-Allow-Credentials', 'true')
+  }
+
+  if (req.method === 'OPTIONS') {
+    return handlePreflight(req, res)
+  }
+
+  if (dispatch === 'fetch_file') {
+    res.end()
+    return
+  }
+
+  if (dispatch === 'check_partition') {
+    const status = searchParams.get('status') ?? 200
+
+    if (testFailed) {
+      res.statusCode = status
+      res.end('Multiple partition IDs used on a socket')
+      return
+    }
+
+    let body = 'ok'
+    if (searchParams.get('addcounter')) {
+      body += `. Request was sent ${requestCount} times. ${connectionCount} connections were created.`
+      res.statusCode = status
+      res.end(body)
+      return
+    }
+  }
+
+  if (dispatch === 'clean_up') {
+    stash.delete(uuid)
+    res.statusCode = 200
+    if (testFailed) {
+      res.end('Test failed, but cleanup completed.')
+    } else {
+      res.end('cleanup complete')
+    }
+
+    return
+  }
+
+  res.statusCode = 404
+  res.end('Unrecognized dispatch parameter: ' + dispatch)
+}
+
+/**
+ * @param {Parameters<import('http').RequestListener>[0]} req
+ * @param {Parameters<import('http').RequestListener>[1]} res
+ */
+function handlePreflight (req, res) {
+  res.statusCode = 200
+  res.setHeader('Access-Control-Allow-Methods', 'GET')
+  res.setHeader('Access-Control-Allow-Headers', 'header-to-force-cors')
+  res.setHeader('Access-Control-Max-Age', '86400')
+  res.end('Preflight request')
+}

test/wpt/server/server.mjs

@@ -5,6 +5,7 @@ import process from 'node:process'
 import { fileURLToPath } from 'node:url'
 import { createReadStream, readFileSync } from 'node:fs'
 import { setTimeout as sleep } from 'node:timers/promises'
+import { route } from './routes/network-partition-key.mjs'
 
 const tests = fileURLToPath(join(import.meta.url, '../../tests'))
 
@@ -218,6 +219,9 @@ const server = createServer(async (req, res) => {
       res.end()
       break
     }
+    case '/fetch/connection-pool/resources/network-partition-key.py': {
+      return route(req, res, fullUrl)
+    }
     default: {
       res.statusCode = 200
       res.end('body')

test/wpt/tests/fetch/api/basic/http-response-code.any.js

@@ -0,0 +1,14 @@
+// META: global=window,worker
+// META: script=../resources/utils.js
+// META: script=/common/utils.js
+// META: script=/common/get-host-info.sub.js
+
+promise_test(async (test) => {
+  const resp = await fetch(
+    "/fetch/connection-pool/resources/network-partition-key.py?"
+    + `status=425&uuid=${token()}&partition_id=${get_host_info().ORIGIN}`
+    + `&dispatch=check_partition&addcounter=true`);
+  assert_equals(resp.status, 425);
+  const text = await resp.text();
+  assert_equals(text, "ok. Request was sent 1 times. 1 connections were created.");
+}, "Fetch on 425 response should not be retried for non TLS early data.");