如何在反应函数中使用条件和多个步骤

Question

我目前正在使用kotlin quarkus和mutiny构建一个反应式应用程序，作为反应式编程的新手，我想知道处理以下工作流的最佳方式是什么：

• 尝试在数据库中查找项目（dynamodb）
• 如果存在，则向调用者返回一个指示此的值
• 如果不存在，请调用保存服务
• 致电外部服务获取一些数据
• 使用来自外部服务的数据更新数据库中的项目
• 返回一个值，指示已创建对象

以下是我目前的代码：

fun createCard(creationOrder: CreationOrder): Uni<CardCreationResult> {
    return creationOrdersRepository.findByOrderId(creationOrder.orderId)
        .onItem().transform {item ->
            if (item != null) {
                CardCreationResult.AlreadyCreated
            } else {
                creationOrdersRepository.save(creationOrder)

                //TODO external webservice call
                
                val cardNumber = UUID.randomUUID().toString()
                creationOrdersRepository.updateCardNumberAndStatus(externalServiceCallResult)
                CardCreationResult.Created
            }
        }
}

此方法最终将由restendpoint调用。

creationOrdersRepository.save和creationOrdersRepository.updateCardNumberAndstatus返回一个CompletableFuture（我正在使用夸克斯亚马逊发电机客户端）。

这是正确的方法吗？我应该在Uni中包装保存和更新CardNumberAndstatus结果（我一直在尝试，但一直收到类型错误）？

Answer 1

我不相信你的代码能达到你的期望。如果我理解正确，您需要在发布结果之前“保存”和“更新”。因此，您需要这样的东西（在Java中，因为我的Kotlin不太好）：

return creationOrdersRepository.findByOrderId(creationOrder.orderId)
  // We will be returning a Uni as the save, update and the web service are 
  // async
  .onItem().transformToUni(item -> {
    if (item != null) {
      return Uni.createFrom().item(CardCreationResult.AlreadyCreated);
    } else {
      // Create an Uni from the save operation
      Uni<Void> save = Uni.createFrom().completionStage(() -> 
        creationOrdersRepository.save(creationOrder));
      // This uni represents the invocation of the remote service
      Uni<String> webService = callWebService();

      // we chain the operations save -> web service -> update -> Created
      return save
        .chain(webService)
        .chain(externalServiceCallResult -> 
          Uni.createFrom().completionStage(() -> creationOrdersRepository
                  .updateCardNumberAndStatus(externalServiceCallResult)
        )        
        .replaceWith(CardCreationResult.Created);
    }