Files
2025-03-28 12:30:19 +11:00

143 lines
6.1 KiB
JavaScript

"use strict";
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
var __rest = (this && this.__rest) || function (s, e) {
var t = {};
for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p) && e.indexOf(p) < 0)
t[p] = s[p];
if (s != null && typeof Object.getOwnPropertySymbols === "function")
for (var i = 0, p = Object.getOwnPropertySymbols(s); i < p.length; i++) {
if (e.indexOf(p[i]) < 0 && Object.prototype.propertyIsEnumerable.call(s, p[i]))
t[p[i]] = s[p[i]];
}
return t;
};
var __importDefault = (this && this.__importDefault) || function (mod) {
return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.ApolloServer = void 0;
const express_1 = __importDefault(require("express"));
const cors_1 = __importDefault(require("cors"));
const body_parser_1 = require("body-parser");
const graphql_playground_html_1 = require("@apollographql/graphql-playground-html");
const apollo_server_core_1 = require("apollo-server-core");
const accepts_1 = __importDefault(require("accepts"));
const type_is_1 = __importDefault(require("type-is"));
const expressApollo_1 = require("./expressApollo");
var apollo_server_core_2 = require("apollo-server-core");
Object.defineProperty(exports, "GraphQLExtension", { enumerable: true, get: function () { return apollo_server_core_2.GraphQLExtension; } });
const fileUploadMiddleware = (uploadsConfig, server) => (req, res, next) => {
if (!server.disableUploads() &&
typeof apollo_server_core_1.processFileUploads === 'function' &&
type_is_1.default(req, ['multipart/form-data'])) {
apollo_server_core_1.processFileUploads(req, res, uploadsConfig)
.then(body => {
req.body = body;
next();
})
.catch(error => {
if (error.status && error.expose)
res.status(error.status);
next(apollo_server_core_1.formatApolloErrors([error], {
formatter: server.requestOptions.formatError,
debug: server.requestOptions.debug,
}));
});
}
else {
next();
}
};
class ApolloServer extends apollo_server_core_1.ApolloServerBase {
constructor(config) {
super(config);
}
createGraphQLServerOptions(req, res) {
const _super = Object.create(null, {
graphQLServerOptions: { get: () => super.graphQLServerOptions }
});
return __awaiter(this, void 0, void 0, function* () {
return _super.graphQLServerOptions.call(this, { req, res });
});
}
supportsSubscriptions() {
return true;
}
supportsUploads() {
return true;
}
applyMiddleware(_a) {
var { app } = _a, rest = __rest(_a, ["app"]);
app.use(this.getMiddleware(rest));
}
getMiddleware({ path, cors, bodyParserConfig, disableHealthCheck, onHealthCheck, } = {}) {
if (!path)
path = '/graphql';
this.ensureStarting();
const router = express_1.default.Router();
if (!disableHealthCheck) {
router.use('/.well-known/apollo/server-health', (req, res) => {
res.type('application/health+json');
if (onHealthCheck) {
onHealthCheck(req)
.then(() => {
res.json({ status: 'pass' });
})
.catch(() => {
res.status(503).json({ status: 'fail' });
});
}
else {
res.json({ status: 'pass' });
}
});
}
let uploadsMiddleware;
if (this.uploadsConfig && typeof apollo_server_core_1.processFileUploads === 'function') {
uploadsMiddleware = fileUploadMiddleware(this.uploadsConfig, this);
}
this.graphqlPath = path;
if (cors === true) {
router.use(path, cors_1.default());
}
else if (cors !== false) {
router.use(path, cors_1.default(cors));
}
if (bodyParserConfig === true) {
router.use(path, body_parser_1.json());
}
else if (bodyParserConfig !== false) {
router.use(path, body_parser_1.json(bodyParserConfig));
}
if (uploadsMiddleware) {
router.use(path, uploadsMiddleware);
}
router.use(path, (req, res, next) => {
if (this.playgroundOptions && req.method === 'GET') {
const accept = accepts_1.default(req);
const types = accept.types();
const prefersHTML = types.find((x) => x === 'text/html' || x === 'application/json') === 'text/html';
if (prefersHTML) {
const playgroundRenderPageOptions = Object.assign({ endpoint: req.originalUrl, subscriptionEndpoint: this.subscriptionsPath }, this.playgroundOptions);
res.setHeader('Content-Type', 'text/html');
const playground = graphql_playground_html_1.renderPlaygroundPage(playgroundRenderPageOptions);
res.write(playground);
res.end();
return;
}
}
return expressApollo_1.graphqlExpress(() => this.createGraphQLServerOptions(req, res))(req, res, next);
});
return router;
}
}
exports.ApolloServer = ApolloServer;
//# sourceMappingURL=ApolloServer.js.map