Improve startup time and logging

Author: tylermenezes

src/plugins/log.js

@@ -0,0 +1,57 @@
+import syslog from 'syslog-client';
+
+const logger = syslog.createClient(process.env.SYSLOG_HOST, {
+  port: process.env.SYSLOG_PORT,
+  syslogHostname: `gql`,
+});
+
+export default {
+  requestDidStart({ schemaHash, context: { req } }) {
+    const ip = req.headers['x-forwarded-for'] || req.socket.remoteAddress;
+
+    return {
+      validationDidStart({ source, queryHash, request }) {
+        logger.log([
+          queryHash,
+          ip,
+          `QUERY`,
+          `"${source?.split(`\n`).filter((line) => Boolean(line.trim())).join(' ').replace(/"/g, `'`)}"`,
+          schemaHash,
+        ].join(' '));
+        if (request?.variables) {
+          logger.log([
+            queryHash,
+            ip,
+            `QUERY_VARIABLES`,
+            `"${JSON.stringify(request.variables)}"`,
+            schemaHash,
+          ].join(' '));
+        }
+        return (errs) => {
+          (errs || []).forEach((e) => {
+            logger.log([
+              queryHash,
+              ip,
+              `PARSE_ERROR`,
+              `"${e?.toString().split(`\n`).join('; ')}"`,
+              `"${e?.stack?.split(`\n`).join('; ')}"`
+            ].join(' '));
+          });
+        }
+      },
+
+      didEncounterErrors({ queryHash, errors }) {
+        console.log(errors);
+        (errors || []).forEach((e) => {
+          logger.log([
+            queryHash,
+            ip,
+            `EXEC_ERROR`,
+            `"${e?.toString().split(`\n`).join('; ')}"`,
+            `"${e?.stack?.split(`\n`).join('; ')}"`
+          ].join(' '));
+        });
+      }
+    }
+  },
+}

src/remotes/advisors.js

@@ -2,6 +2,7 @@ import { wrapSchema, introspectSchema } from '@graphql-tools/wrap';
 import makeRemoteTransport from '../remoteTransport';
 
 export default async function createAdvisorsSchema(uri) {
+  console.log(` * advisors(${uri})`);
   const { executor, subscriber } = makeRemoteTransport(uri);
   const schema = wrapSchema({
     schema: await introspectSchema(executor),

src/remotes/calendar.js

@@ -1,7 +1,8 @@
 import { loadSchema } from '@graphql-tools/load';
 import { UrlLoader } from '@graphql-tools/url-loader';
 
-export default async function createDiscordPostsSchema(uri) {
+export default async function createCalendarSchema(uri) {
+  console.log(` * calendar(${uri})`);
   const schema = await loadSchema(uri, { loaders: [new UrlLoader()] });
   return {
     schema,

src/remotes/clear.js

@@ -61,6 +61,7 @@ function getConnectionResolvers(prefix, schemas) {
 
 
 export default async function createClearSchema(uri) {
+  console.log(` * clear(${uri})`);
   const { executor, subscriber } = makeRemoteTransport(uri);
   const schema = wrapSchema({
     schema: await introspectSchema(executor),

src/remotes/contentful.js

@@ -78,6 +78,7 @@ function getConnectionResolvers(prefix, schemas) {
 }
 
 export default async function createContentfulSchema(space, token) {
+  console.log(` * contentful(${space})`);
   const schema = await loadSchema(
     `https://graphql.contentful.com/content/v1/spaces/${space}`,
     {

src/remotes/discordPosts.js

@@ -35,6 +35,7 @@ function getConnectionResolvers(prefix, schemas) {
 }
 
 export default async function createDiscordPostsSchema(uri) {
+  console.log(` * discordPosts(${uri})`);
   const schema = await loadSchema(uri, { loaders: [new UrlLoader()] });
   return {
     schema,

src/remotes/labs.js

@@ -49,6 +49,7 @@ function getConnectionResolvers(prefix, schemas) {
 }
 
 export default async function createLabsSchema(uri) {
+  console.log(` * labs(${uri})`);
   const { executor, subscriber } = makeRemoteTransport(uri);
   const schema = wrapSchema({
     schema: await introspectSchema(executor),

src/remotes/learn.js

@@ -206,6 +206,7 @@ function getConnectionResolvers(prefix, schemas) {
 
 
 export default async function createShowcaseSchema(uri, wsUri) {
+  console.log(` * showcase(${uri})`);
   const { executor, subscriber } = makeRemoteTransport(uri, wsUri);
   const schema = wrapSchema({
     schema: await introspectSchema(executor),

src/remotes/showcase.js

@@ -43,6 +43,7 @@ function getConnectionResolvers(prefix, schemas) {
 }
 
 export default async function createWordpressSchema(uri) {
+  console.log(` * wordpress(${uri})`);
   const schema = await loadSchema(uri, { loaders: [new UrlLoader()] });
   return {
     schema,