我的 Apollo Server 的订阅不起作用：无法读取未定义的属性“标题”

Question

我尝试将它与上下文连接一起使用，并将订阅参数添加到 Apollo Server 中，但它不起作用。我是第一次使用 Apollo 服务器订阅，我不知道错误是在服务器配置中还是在解析器中。我在查询或突变中没有问题，问题是订阅。

这是我的 index.js：

    import express from 'express';

    import { createServer } from 'http';

    import { ApolloServer } from 'apollo-server-express';

    import { typeDefs } from './data/schema';

    import { resolvers } from './data/resolvers';

    import cors from 'cors';

    import jwt from 'jsonwebtoken';

    const bodyParser = require('body-parser');

    const PORT = process.env.PORT ||  4004;

    const app = express();

    app.use(bodyParser.json());

    app.use(cors());

    const server = new ApolloServer({

          typeDefs,

          resolvers,

          context: async({req, connection}) => {

            console.log("Context connection", connection)  

            const token = req.headers['authorization'];

              if(connection){

                return connection.context;

              } else {

                if(token !== "null"){

                    try{

                      //validate user in client.

                      const currentUser = await jwt.verify(token, process.env.SECRET);

              //add user to request

              req.currentUser = currentUser;

              return {

                  currentUser

              }   

            }catch(err){

                return "";

            }

      }

    } 

  },

  subscriptions: {

    path: "/subscriptions",

    onConnect: async (connectionParams, webSocket, context) => {

      console.log(`Subscription client connected using Apollo server's built-in SubscriptionServer.`)

    },

    onDisconnect: async (webSocket, context) => {

      console.log(`Subscription client disconnected.`)

    }

   }

});

我的突变：

    mutation {

      pushNotification(label:"My septh notification") {

        label

      }

    }

我的查询：

    query {

      notifications {

        label

      }

    }

我的订阅：

    subscription {

      newNotification {

        label

      }

    }

错误是：

{

       "error": {

         "message": "Cannot read property 'headers' of undefined"

        }

 }

Answer 1

您可以在上下文回调时检查 jwt 令牌server = new ApolloServer({  schema: schema ,  graphiql: true ,  context:({req, connection} )=>    if connection      token = connection.context["x-access-token"]      decoded = await LoginService.verify token #verify by jwt      if decoded == null        throw new Error("auth required")      return connection.context    headers = req.headers    token = headers["x-access-token"]    decoded = await LoginService.verify token #verify by jwt    return authed: decoded != null})

Answer 2

我只是这样做解决它：const server = new ApolloServer({      typeDefs,      resolvers,      context: async ({ req, connection }) => {        if (connection) {         // check connection for metadata         return connection.context;        } else {         // check from req         const token = req.headers.authorization        if(token !== "null"){          try{          //validate user in client.          const currentUser = await jwt.verify(token, process.env.SECRET);          //add user to request          req.currentUser = currentUser;          return {              currentUser          }           }catch(err){            return "";                }             }         }       },    });