0

我们有两个端点(后端调用),它们返回不同但相关的数据类型XDataYData. 如果XData存在具有 id的实例1,则必须存在具有YData相同 id的实例1

我们为每种数据类型xFetcheryFetcher. 这些获取器在我们的 GraphQL 查询中单独使用,以从两个端点获取数据,但对于某些用例,我们希望使用特定 id 组合从它们两者检索到的数据,例如1. 这种组合可能不是简单的列表追加,如下例所示。

由于XDataYData在查询的其他部分中也被单独查询,我们不能简单地将这两个解析器合并为一个,并且尽可能避免对同一端点进行多次调用。

我为此用例创建了一个简化示例。我们如何返回一个延迟值,结合从两个 fetcher 中检索到的数据?

case class Ctx()
case class XData(id: Int, a: Seq[String], b: String)
case class YData(id: Int, a: Seq[String], c: String)
case class Data(id: Int)

val xFetcher = Fetcher((ctx: Ctx, ids: Seq[Int]) => Future {
  ids.map(id => XData(1, Seq.empty, "")) // Back end call to (endpoint X)
})(HasId(_.id))

val yFetcher = Fetcher((ctx: Ctx, ids: Seq[Int]) => Future {
  ids.map(id => YData(1, Seq.empty, "")) // Back end call to (endpoint Y)
})(HasId(_.id))

val GData = deriveObjectType[Ctx, Data](
  AddFields(
    Field("a",
      ListType(StringType),
      resolve = ctx => getA(ctx))
  )
)

def getA(ctx: Context[Ctx, Data]) = {
  val id = ctx.value.id

  // Here I should also get an instance of `YData` and return the
  // combination of the sequences `a` in both instances (xData, yData)
  val xData: XData = ??? //getDeferredXData()
  val yData: YData = ??? //getDeferredYData()
  val desiredOutput = xData.a ++ yData.a

  // I can get `a` from one instance but not both of them together
  DeferredValue({
    val xData = xFetcher.defer(id)
    // val yData = yFetcher.defer(id)
    // How can we combine both into one deferred value?
    xData
  }).mapWithErrors { data => (data.a, Vector.empty) }
}

我没怎么用过桑格利亚汽酒,所以请原谅任何与deferred resolvers或相关的不清楚的信息fetchers

4

1 回答 1

1

您的场景描述听起来与此问题非常相似:

将其他项目添加到每个请求的缓存中

它已经实现,但尚未发布。

此外,如果可以始终加载XDataYData一起加载,那么您可以为 tuple 定义一个提取器(XData, YData)。然后在解析器中,您可以从元组中提取所需的对象。像这样的东西:

DeferredValue(fetcher.defer(id)).map {case (xData, yData) ⇒ xData}
于 2018-07-27T20:04:02.933 回答