时间戳

首页 > 解决方案 > 在 Sangria 中将多个延迟值组合成一个新的延迟类型，GraphQL 实现

scala - 在 Sangria 中将多个延迟值组合成一个新的延迟类型，GraphQL 实现

问题描述

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

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

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

我为此用例创建了一个简化示例。我们如何返回一个延迟值，结合从两个 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

标签： scalagraphqlsangria

解决方案

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

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

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

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

DeferredValue(fetcher.defer(id)).map {case (xData, yData) ⇒ xData}

推荐阅读