Подписки не работают на Apollo Server Express - PullRequest
Новая
       16

Подписки не работают на Apollo Server Express

0 голосов
/ 27 апреля 2020

Я хотел добавить подписку на мой уже работающий сервер apollo с express, но не могу подключиться даже с игровой площадкой. Я получаю эту ошибку с детской площадки 

"error": "Could not connect to websocket endpoint ws://localhost:4000/graphql. Please check if the endpoint url is correct."

С firefox и chrome Я получаю похожие ошибки 

Firefox can’t establish a connection to the server at ws://localhost:4000/graphql

Это мое приложение. js мой основной файл. 

const express = require('express');
const mongoose = require('mongoose');
const { ApolloServer } = require('apollo-server-express');

const cors = require('cors');
const session = require('express-session');
const Keycloak = require('keycloak-connect');

const { typeDefs } = require('./graphql/Schema');
const { resolvers } = require('./graphql/Resolvers');
const { userTypeDefs, userResolvers } = require('./graphql/User');
const { campusTypeDefs, campusResolvers } = require('./graphql/Campus');
const { profileTypeDefs, profileResolvers } = require('./graphql/Profile');
const { notificationTypeDefs, notificationResolvers } = require('./graphql/Notification');
const { rideTypeDefs, rideResolvers } = require('./graphql/Ride');

const app = express();
app.use(i18n.init);
const keycloak = new Keycloak({
  memoryStore
}, 'keycloak.json');

app.use('/graphql', keycloak.middleware());

const server = new ApolloServer({
  typeDefs: [KeycloakTypeDefs, typeDefs, rideTypeDefs, userTypeDefs, campusTypeDefs, profileTypeDefs, notificationTypeDefs],
  schemaDirectives: KeycloakSchemaDirectives,
  cors: cors(corsOptions),
  resolvers: [resolvers, rideResolvers, userResolvers, campusResolvers, profileResolvers, notificationResolvers],
  context: ({ req, connection }) => {
    console.log(connection);
    return { kauth: new KeycloakContext({ req }) };
  },
  subscriptions: {
    onConnect: async (connectionParams, webSocket) => {
      console.log("xxx");
      console.log(connectionParams);
      if (connectionParams.authToken) {
        return validateToken(connectionParams.authToken)
          .then(findUser(connectionParams.authToken))
          .then(user => {
            return {
              currentUser: user,
            };
          });
      }

      throw new Error('Missing auth token!');
    },
  }
});

server.applyMiddleware({ app });
server.installSubscriptionHandlers(app);

mongoose.connect(
  'mongodb://deaventon:mapache@localhost:27017/deaventon')
  .then(result => {
    app.listen(4000);
  })
  .catch(err => console.log(err));

В соответствии с некоторым примером должно быть достаточно server.installSubscriptionHandlers, в некоторых других случаях они не используют его. Но я думаю, что это связано с apollo-server- express, обычно это используют примеры с apollo-server- express. Когда я делаю console.log () для соединения, я получаю неопределенное от этого, даже с запросом от сокетных соединений. Я вижу запрос req или socket. Я никогда ничего не получаю в функции subscription.onConnect, она явно не вызывается, потому что она никогда не стабилизирует соединение. Если я создаю console.log из контекста в req var, я получаю что-то вроде 

IncomingMessage {
  _readableState: ReadableState {
    objectMode: false,
    highWaterMark: 16384,
    buffer: BufferList { head: null, tail: null, length: 0 },
    length: 0,
    pipes: null,
    pipesCount: 0,
    flowing: null,
    ended: true,
    endEmitted: false,
    reading: false,
    sync: true,
    needReadable: false,
    emittedReadable: false,
    readableListening: false,
    resumeScheduled: false,
    emitClose: true,
    autoDestroy: false,
    destroyed: false,
    defaultEncoding: 'utf8',
    awaitDrain: 0,
    readingMore: true,
    decoder: null,
    encoding: null,
    [Symbol(kPaused)]: null
  },
  readable: true,
  _events: [Object: null prototype] {
    end: [Function: resetHeadersTimeoutOnReqEnd]
  },
  _eventsCount: 1,
  _maxListeners: undefined,
  socket: Socket {
    connecting: false,
    _hadError: false,
    _parent: null,
    _host: null,
    _readableState: ReadableState {
      objectMode: false,
      highWaterMark: 16384,
      buffer: BufferList { head: null, tail: null, length: 0 },
      length: 0,
      pipes: null,
      pipesCount: 0,
      flowing: true,

Похоже, что он даже не проверяет подписки.

...