阿波罗服务器订阅嵌套在一个类型中

Question

我正在尝试获得在Apollo Server 2中进行订阅的解析器。订阅在它是顶级字段时工作（即直接在Subscription根目录下的schema下）。

但是，如果订阅包含在另一个type中，我总是在客户端的websocket连接上得到错误Subscription field must return Async Iterable. Received: undefined - 从不执行服务器的解析器。

即此架构有效：

type Subscription {
  postAdded: Post
}

但这个没有：

type Subscription {
  post: PostSubscription
}

type PostSubscription {
  postAdded: Post
}

我的第二个案例的解析器看起来像这样，但我尝试了一堆不同的变化而没有成功：

Subscription: {
  post: () => ({
    PostSubscription: {}
  })
},
PostSubscription: {
  postAdded: {
    subscribe: () => pubSub.asyncIterator(['postAdded'])
  }
}

Answer 1

错误消息表示您的解析器

    Subscription: {
      post: () => ({
        PostSubscription: {} // This needs to return AsyncIterator
      })
    },

如果我理解正确，你想在帖子下订阅postAdded，postDeleted，postUpdated，这三个。我知道你想尝试在同一模型下命名它们，这有助于组织更好。但它有一些问题，我稍后会解释。

一句话建议：最好将这3个字段直接放在根订阅字段下。

不是说你做不到，但如果你真的想要，假设你正在订阅

    Subscription{
      post{
         postAdded: Post
         postDeleted: Post
         postUpdated(id:Int!): Post
      }
    }

然后三个嵌套字段都“共享”相同的通道。

然后你需要做几件事

1. post的订阅函数返回async迭代器，而不是postAdd，而是post字段。

    Subscription: {
        post: {
            subscription: () =>  pubSub.asyncIterator(['postChannel'])
        }
    }

2. 然后在变异函数中，后突变（添加，更新，删除），你需要弄清楚要发送给客户端的内容。

这样的事情

    Mutation{
       createPost: (_,args,context,info)=>{
          const createdObject = // do create
          pubsub.publish("postChannel", {
             post:{
                // do not do postUpdate, postDelete, because there's nothing updated, deleted
                postAdded:createdObject
             }
          })
       }
    }

这将使您想要的工作，但这有几个问题。 1.任何时候发生任何更新/创建/删除，都会通知客户端。这可能会给客户提供不正确的信息。像这样如果客户订阅

subscription{
    post{
        postAdded
    }
}

然后，当其他人更新帖子时，客户端会得到这样的响应

response = {
    subscription:{
        postAdded:null
    }
}

对于postAdd，可以忽略null。但对于postUpdate来说肯定会有问题。想象一下用户订阅

subscribe{
    post{
        postUpdate(id:1)
    }
}

然后有人添加帖子，客户端将始终收到通知，因为这三个事件共享同一个频道。然后他会收到

response = {
    subscription:{
        postUpdated:null
    }
}

然后，如果您正在使用apollo客户端，它将从缓存中删除post：1，因为它会认为post是null。

由于这些问题，强烈建议创建多个渠道，最好是每个模型三个渠道。并创建三个根级别订阅而不是嵌套它们。

对于最低工作订阅，我会将您重定向到我演示订阅https://github.com/hansololai/apollo_subscription_boilerplate的git-repo