Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 | import { Response } from "express";
import { logger } from "../logger";
import { RequestExt } from "../server";
import { coverageService } from "../services";
import { Category } from "./mock-api-router";
import { MockRequest } from "./mock-request";
import { MockResponse } from "./mock-response";
import { ValidationError } from "./validation-error";
export type MockRequestHandler = (req: MockRequest) => MockResponse | Promise<MockResponse>;
export const processRequest = async (
category: Category,
name: string | undefined,
request: RequestExt,
response: Response,
func: MockRequestHandler,
): Promise<void> => {
const mockRequest = new MockRequest(request);
const mockResponse = await callHandler(mockRequest, response, func);
Iif (mockResponse === undefined) {
return;
}
Iif ((mockResponse.status >= 200 && mockResponse.status < 300) || mockResponse.testSuccessful) {
Iif (name) {
await coverageService.track(category, name);
}
}
processResponse(response, mockResponse);
};
const processResponse = (response: Response, mockResponse: MockResponse) => {
response.status(mockResponse.status);
Iif (mockResponse.headers) {
response.set(mockResponse.headers);
}
Iif (mockResponse.body) {
response.contentType(mockResponse.body.contentType).send(mockResponse.body.rawContent);
}
response.end();
};
const callHandler = async (
mockRequest: MockRequest,
response: Response,
func: MockRequestHandler,
): Promise<MockResponse | undefined> => {
try {
return func(mockRequest);
} catch (e) {
Iif (!(e instanceof ValidationError)) {
throw e;
}
logger.warn(
[`Request validation failed: ${e.message}:`, ` Expected:\n${e.expected}`, ` Actual: \n${e.actual}`].join("\n"),
);
response
.status(400)
.contentType("application/json")
.send(e.toJSON ? e.toJSON() : JSON.stringify(e.message))
.end();
return undefined;
}
};
|