1. /**
  2. * Streams request headers with a timeout for hypothesis validation.
  3. * @param {XMLHttpRequest} xhr - The XMLHttpRequest object.
  4. * @param {object} expectedHeaders - An object containing the expected headers and their values.
  5. * @param {number} timeout - The timeout in milliseconds.
  6. * @returns {Promise<object>} - A promise that resolves with the expected headers if all match, or rejects with an error if the timeout is reached.
  7. */
  8. async function streamRequestHeaders(xhr, expectedHeaders, timeout) {
  9. return new Promise((resolve, reject) => {
  10. const startTime = Date.now();
  11. const headersToValidate = Object.keys(expectedHeaders);
  12. let headersReceived = {};
  14. xhr.onheaders = function(e) {
  15. //Handle header events.
  16. for (const headerName in e) {
  17. if (headersToValidate.includes(headerName)) {
  18. headersReceived[headerName] = e[headerName];
  19. }
  20. }
  21. };
  23. xhr.timeout = timeout; //Set timeout on the request
  24. xhr.onload = function() {
  25. if (Date.now() - startTime < timeout) {
  26. // Check if all expected headers are present and match.
  27. let allHeadersMatch = true;
  28. for (const headerName of headersToValidate) {
  29. if (headersReceived[headerName] !== expectedHeaders[headerName]) {
  30. allHeadersMatch = false;
  31. break;
  32. }
  33. }
  34. if (allHeadersMatch) {
  35. resolve(headersReceived);
  36. } else {
  37. reject(new Error("Request headers do not match expected headers."));
  38. }
  39. } else {
  40. reject(new Error("Request timed out."));
  41. }
  42. };
  44. xhr.onerror = function() {
  45. reject(new Error("Request failed."));
  46. };
  48. xhr.ontimeout = function() {
  49. reject(new Error("Request timed out."));
  50. };
  51. });
  52. }

Add your comment