0

突变后，我似乎无法在我的反应前端收到 pubSub 数据

我有以下 Graphql 架构：

type SSiD {
    id: ID!
    name: String
    status: String
    hidden: Boolean
 }
type Subscription {
  SSiDAdded: SSiD
}

在我的 apolloServer 上，我像这样发送 pubSub 数据

const data = result.dataValues
data.__typename = 'SSiD'
console.log(data)
context.pubsub.publish('SSiDAdded', data)

该 console.log 将输出：

{ id: 2208,
  name: 'FooBar',
  hidden: true,
  status: 'broadcasting',
  updatedAt: 2016-10-27T22:07:09.119Z,
  createdAt: 2016-10-27T22:07:09.119Z,
  __typename: 'SSiD' }

最后在我的反应前端我有以下内容：

const query = gql`
  subscription ssidList{
    SSiDAdded{
      id
      name
      hidden
    }
  }
`
this.subscriptionObserver = this.props.client.subscribe({
  query
})
.subscribe({
  next (data) {
    console.log('The subscription data', data)
  },
  error (err) {
    console.error('Error subscription', err)
  }
})

}

在上面的console.log 订阅数据始终为空。

我是否将响应包装错了或类似的东西？

4

1 回答 1

2

这里有几件事要检查。在我的模式中，它有一些我目前在你的模式中没有看到的语法。看到: instant_message查询字符串之后的内容了吗？

const typeDefinitions = [`

type instant_message {
  id: Int
  fromID: String
  toID: String
  msgText: String
}
type Query {
  instant_message(id: Int, fromID: String, toID: String, msgText: String): [instant_message]
}
type Mutation {
  createIM(
    fromID: String!
    toID: String!
    msgText: String!
  ): instant_message
}
type Subscription {
  # Subscription fires on every comment added
  IMAdded(id: Int, fromID: String!, toID: String!): instant_message
}

schema {
  query: Query,
  mutation: Mutation
  subscription: Subscription
}

`];

我在客户端也有一些不同的语法：

subscribe(fromID, toID, updateQueryViaSubscription) {
    const SUBSCRIPTION_QUERY = gql`
      subscription getIMsViaSubscription($fromID: String!, $toID: String!){
          IMAdded(fromID:$fromID, toID: $toID){
            id,
            fromID,
            toID,
            msgText
          }
        } 
`;
    this.subscriptionObserver = this.props.client.subscribe({
        query: SUBSCRIPTION_QUERY,
        variables: { fromID: this.fromID, toID: this.toID },
    }).subscribe({
        next(data) {
            const newMsag = data.IMAdded;
            updateQueryViaSubscription((previousResult) => {
                // if it's our own mutation, we might get the subscription result
                // after the mutation result.
                // if (isDuplicateIM(newComment, previousResult.entry.comments)) {
                //     return previousResult;
                // }
                // update returns a new "immutable" list with the new comment
                // added to the front.
                return update(
                    previousResult,
                    {
                        instant_message: {
                            $push: [newMsag],
                        },
                    }
                );
            });
        },
        error(err) {
            console.error('err', err); },
    });
}

请检查并让我知道更新的代码是否消除了该错误。

更新：根据我们关于 Slack 的讨论，您发现您需要您的 executableSchema 是这样的：

const executableSchema = makeExecutableSchema({
    typeDefs: typeDefinitions,
    resolvers: Resolvers,
    connectors: Connectors,
    logger: console,
});

export default executableSchema;

这是我正在使用的解析器：

Subscription: {
    IMAdded(IMThatWasAdded) {
        var ret = IMThatWasAdded;
        return ret;
    }
}
于 2016-10-27T22:26:20.503 回答