hiro/Vulcan
1
0
Fork 0
mirror of https://github.com/vale981/Vulcan synced 2025-03-04 17:21:37 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

apollo_server2.js -> apollo_server.js

Browse source
This commit is contained in:
SachaG 2019-03-28 18:26:56 +09:00
parent 9864424d89
commit 94552b20fd
5 changed files with 3 additions and 283 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

0
packages/vulcan-lib/lib/server/apollo-server/apollo_server2.js → packages/vulcan-lib/lib/server/apollo-server/apollo_server.js
View file

2
packages/vulcan-lib/lib/server/apollo-server/index.js
View file

@ -1,4 +1,4 @@
export * from './apollo_server2';
export * from './apollo_server';
export * from './settings';
export { default as initGraphQL } from './initGraphQL';

2
packages/vulcan-lib/lib/server/apollo-server/startup.js
View file

@ -1,3 +1,3 @@
const { onStart } = require('./apollo_server2');
const { onStart } = require('./apollo_server');
// createApolloServer when server startup
Meteor.startup(onStart);

280
packages/vulcan-lib/lib/server/apollo_server.js
View file

@ -1,280 +0,0 @@
/* import { graphqlExpress, graphiqlExpress } from 'apollo-server-express';
import bodyParser from 'body-parser';
import express from 'express';
import { makeExecutableSchema } from 'graphql-tools';
import deepmerge from 'deepmerge';
import DataLoader from 'dataloader';
import { formatError } from 'apollo-errors';
import compression from 'compression';
import { Meteor } from 'meteor/meteor';
import { check } from 'meteor/check';
// import { Accounts } from 'meteor/accounts-base';
import { Engine } from 'apollo-engine';
import { GraphQLSchema } from '../modules/graphql.js';
import { Utils } from '../modules/utils.js';
import { webAppConnectHandlersUse } from './meteor_patch.js';
import { getSetting, registerSetting } from '../modules/settings.js';
import { Collections } from '../modules/collections.js';
import findByIds from '../modules/findbyids.js';
import { runCallbacks } from '../modules/callbacks.js';
import cookiesMiddleware from 'universal-cookie-express';
// import Cookies from 'universal-cookie';
import { _hashLoginToken, _tokenExpiration } from './accounts_helpers';
import { getHeaderLocale } from './intl.js';
export let executableSchema;
registerSetting('apolloEngine.logLevel', 'INFO', 'Log level (one of INFO, DEBUG, WARN, ERROR');
registerSetting('apolloServer.tracing', Meteor.isDevelopment, 'Tracing by Apollo. Default is true on development and false on prod', true);
// see https://github.com/apollographql/apollo-cache-control
const engineApiKey = getSetting('apolloEngine.apiKey');
const engineLogLevel = getSetting('apolloEngine.logLevel', 'INFO');
const engineConfig = {
apiKey: engineApiKey,
// "origins": [
// {
// "http": {
// "url": "http://localhost:3000/graphql"
// }
// }
// ],
'stores': [
{
'name': 'vulcanCache',
'inMemory': {
'cacheSize': 20000000
}
}
],
// "sessionAuth": {
// "store": "embeddedCache",
// "header": "Authorization"
// },
// "frontends": [
// {
// "host": "127.0.0.1",
// "port": 3000,
// "endpoint": "/graphql",
// "extensions": {
// "strip": []
// }
// }
// ],
'queryCache': {
'publicFullQueryStore': 'vulcanCache',
'privateFullQueryStore': 'vulcanCache'
},
// "reporting": {
// "endpointUrl": "https://engine-report.apollographql.com",
// "debugReports": true
// },
'logging': {
'level': engineLogLevel
}
};
let engine;
if (engineApiKey) {
engine = new Engine({ engineConfig });
engine.start();
}
// defaults
const defaultConfig = {
path: '/graphql',
maxAccountsCacheSizeInMB: 1,
graphiql: Meteor.isDevelopment,
graphiqlPath: '/graphiql',
graphiqlOptions: {
passHeader: "'Authorization': localStorage['Meteor.loginToken']", // eslint-disable-line quotes
},
configServer: (graphQLServer) => { },
};
const defaultOptions = {
formatError: e => ({
message: e.message,
locations: e.locations,
path: e.path,
}),
};
if (Meteor.isDevelopment) {
defaultOptions.debug = true;
}
// createApolloServer
const createApolloServer = (givenOptions = {}, givenConfig = {}) => {
const graphiqlOptions = { ...defaultConfig.graphiqlOptions, ...givenConfig.graphiqlOptions };
const config = { ...defaultConfig, ...givenConfig };
config.graphiqlOptions = graphiqlOptions;
const graphQLServer = express();
config.configServer(graphQLServer);
// Use Engine middleware
if (engineApiKey) {
graphQLServer.use(engine.expressMiddleware());
}
// cookies
graphQLServer.use(cookiesMiddleware());
// compression
graphQLServer.use(compression());
// GraphQL endpoint
graphQLServer.use(config.path, bodyParser.json({ limit: getSetting('apolloServer.jsonParserOptions.limit') }), graphqlExpress(async (req) => {
let options;
let user = null;
if (typeof givenOptions === 'function') {
options = givenOptions(req);
} else {
options = givenOptions;
}
// Merge in the defaults
options = { ...defaultOptions, ...options };
if (options.context) {
// don't mutate the context provided in options
options.context = { ...options.context };
} else {
options.context = {};
}
// enable tracing and caching
options.tracing = getSetting('apolloServer.tracing', Meteor.isDevelopment);
options.cacheControl = true;
// note: custom default resolver doesn't currently work
// see https://github.com/apollographql/apollo-server/issues/716
// options.fieldResolver = (source, args, context, info) => {
// return source[info.fieldName];
// }
// console.log('// apollo_server.js req.renderContext');
// console.log(req.renderContext);
// console.log('\n\n');
// Get the token from the header
if (req.headers.authorization) {
const token = req.headers.authorization;
check(token, String);
const hashedToken = _hashLoginToken(token);
// Get the user from the database
user = await Meteor.users.findOne(
{ 'services.resume.loginTokens.hashedToken': hashedToken },
);
if (user) {
// identify user to any server-side analytics providers
runCallbacks('events.identify', user);
const loginToken = Utils.findWhere(user.services.resume.loginTokens, { hashedToken });
const expiresAt = _tokenExpiration(loginToken.when);
const isExpired = expiresAt < new Date();
if (!isExpired) {
options.context.userId = user._id;
options.context.currentUser = user;
}
}
}
//add the headers to the context
options.context.headers = req.headers;
// merge with custom context
options.context = deepmerge(options.context, GraphQLSchema.context);
// go over context and add Dataloader to each collection
Collections.forEach(collection => {
options.context[collection.options.collectionName].loader = new DataLoader(ids => findByIds(collection, ids, options.context), { cache: true });
});
// look for headers either in renderContext (SSR) or req (normal request to the endpoint)
const headers = req.renderContext.originalHeaders || req.headers;
options.context.locale = getHeaderLocale(headers, user && user.locale);
if (headers.apikey && (headers.apikey === getSetting('vulcan.apiKey'))) {
options.context.currentUser = { isAdmin: true, isApiUser: true };
}
// console.log('// apollo_server.js isSSR?', !!req.renderContext.originalHeaders ? 'yes' : 'no');
// console.log('// apollo_server.js headers:');
// console.log(headers);
// console.log('// apollo_server.js final locale: ', options.context.locale);
// console.log('\n\n');
// add error formatting from apollo-errors
options.formatError = formatError;
return options;
}));
// Start GraphiQL if enabled
if (config.graphiql) {
graphQLServer.use(config.graphiqlPath, graphiqlExpress({ ...config.graphiqlOptions, endpointURL: config.path }));
}
// This binds the specified paths to the Express server running Apollo + GraphiQL
webAppConnectHandlersUse(Meteor.bindEnvironment(graphQLServer), {
name: 'graphQLServerMiddleware_bindEnvironment',
order: 30,
});
};
// createApolloServer when server startup
Meteor.startup(() => {
runCallbacks('graphql.init.before');
// typeDefs
const generateTypeDefs = () => [`
scalar JSON
scalar Date
${GraphQLSchema.getAdditionalSchemas()}
${GraphQLSchema.getCollectionsSchemas()}
type Query {
${GraphQLSchema.queries.map(q => (
`${q.description ? ` # ${q.description}
` : ''} ${q.query}
`)).join('\n')}
}
${GraphQLSchema.mutations.length > 0 ? `type Mutation {
${GraphQLSchema.mutations.map(m => (
`${m.description ? ` # ${m.description}
` : ''} ${m.mutation}
`)).join('\n')}
}
` : ''}
`];
const typeDefs = generateTypeDefs();
GraphQLSchema.finalSchema = typeDefs;
executableSchema = makeExecutableSchema({
typeDefs,
resolvers: GraphQLSchema.resolvers,
schemaDirectives: GraphQLSchema.directives,
});
createApolloServer({
schema: executableSchema,
});
});
*/

2
packages/vulcan-lib/test/server/apollo-server.test.js
View file

@ -1,4 +1,4 @@
import { createApolloServer } from '../../lib/server/apollo-server/apollo_server2';
import { createApolloServer } from '../../lib/server/apollo-server/apollo_server';
//import initGraphQL from '../../lib/server/apollo-server/initGraphQL';
//import { GraphQLSchema } from '../../lib/modules/graphql';
import expect from 'expect';