fix all tests

This commit is contained in:
Simon Knott 2025-01-23 15:42:25 +01:00
parent 1112663f87
commit b236072cd6
No known key found for this signature in database
GPG key ID: 8CEDC00028084AEC
2 changed files with 4 additions and 3 deletions

View file

@ -19,8 +19,8 @@ import type { RootDispatcher } from './dispatcher';
import { Dispatcher, existingDispatcher } from './dispatcher';
import type * as channels from '@protocol/channels';
import { APIRequestContextDispatcher, RequestDispatcher, ResponseDispatcher, RouteDispatcher } from './networkDispatchers';
import { urlMatches } from '@isomorphic/urlMatch';
import type { Request, Response, Route } from '../network';
import { urlMatches } from '../../utils/isomorphic/urlMatch';
export class MockingProxyDispatcher extends Dispatcher<MockingProxy, channels.MockingProxyChannel, RootDispatcher> implements channels.MockingProxyChannel {
_type_MockingProxy = true;

View file

@ -81,6 +81,7 @@ export class MockingProxy extends SdkObject implements RequestContext {
const body = await collectBody(req);
const request = new Request(this, null, null, null, undefined, req.url!, '', req.method!, body, headers);
request.setRawRequestHeaders(headers);
this.emit(MockingProxy.Events.Request, request);
const route = new Route(request, {
abort: async errorCode => {
@ -135,7 +136,7 @@ export class MockingProxy extends SdkObject implements RequestContext {
const address = socket.address() as AddressInfo;
const responseBodyPromise = new ManualPromise<Buffer>();
const response = new Response(request, proxyRes.statusCode!, proxyRes.statusMessage!, headersArray(proxyRes), timings, () => responseBodyPromise, false, proxyRes.httpVersion);
response.setRawResponseHeaders(headers);
response.setRawResponseHeaders(headersArray(proxyRes));
response._securityDetailsFinished(securityDetails);
response._serverAddrFinished({ ipAddress: address.family === 'IPv6' ? `[${address.address}]` : address.address, port: address.port });
this.emit(MockingProxy.Events.Response, response);
@ -163,7 +164,7 @@ export class MockingProxy extends SdkObject implements RequestContext {
response.setTransferSize(transferSize);
response.setEncodedBodySize(encodedBodySize);
response.setResponseHeadersSize(transferSize - encodedBodySize);
this.emit(MockingProxy.Events.RequestFinished, response);
this.emit(MockingProxy.Events.RequestFinished, request);
resolve();
} catch (error) {
request._setFailureText('' + error);