Functional Asyn Example

gistfile1.scala

  def createOrUpdateCard( profileId: ProfileId, contextName: ContextName): FutureEither[CardId] = {
    
    lazy val nowF = getAndValidateGoogleNowCredential(profileId)
    lazy val contentF = getContentFromStationService(profileId, contextName)
    lazy val contextF = ensureContextExistsOnGoogle(contextName)

    def createCard = {
      for {
        now <- nowF
        content <- contentF
        context <- contextF
        toCreate =  new Card().setContent(content)
        created <- BlockingIO.futureEither(createCardOnGoogle(toCreate, now))
      } yield created.getCardId
    }

    def updateCard = {
      val existingCard =
        for {
          now <- nowF
          context <- contextF
          card <- findCardOnGoogle(profileId, context)))
        } yield card

      for {
        now <- nowF
        card <- existingCard
        content <- contentF
        toUpdate = card.setContent(content)
        updated <- BlockingIO.futureEither(updateCard(toUpdate, now))
        updatedId <-  updated.getCardId
      } yield updatedId
    }

    updateCard orElse createCard
  }