Skip to content

Instantly share code, notes, and snippets.

@vigneshwaranr

vigneshwaranr/good-api.scala

Created February 14, 2021 08:13
Show Gist options
  • Save vigneshwaranr/d648da8e2648925a29f653b019b4c577 to your computer and use it in GitHub Desktop.
Save vigneshwaranr/d648da8e2648925a29f653b019b4c577 to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. @vigneshwaran-raveendran vigneshwaran-raveendran created this gist Feb 14, 2021.
    29 changes: 29 additions & 0 deletions good-api.scala
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,29 @@
    import scala.concurrent.ExecutionContext.Implicits.global
    import scala.concurrent.{ExecutionContext, Future}

    trait Request

    trait Response

    trait CacheService {
    def myOwnEc: ExecutionContext

    def isDuplicateRequest(request: Request): Future[Option[Request]]

    def setCacheForDeduplication(dedupedReq: Option[Request]): Future[Boolean]
    }

    trait Processor {
    def process(request: Option[Request])(implicit ec: ExecutionContext): Future[Response]
    }

    class API(cacheService: CacheService, processor: Processor) {

    def process(request: Request): Future[Response] = {
    for {
    dedupedRequest <- cacheService.isDuplicateRequest(request)
    response <- processor.process(dedupedRequest)
    _ = cacheService.setCacheForDeduplication(dedupedRequest) // now unplugged from the flow
    } yield response
    }
    }