pure-aws

Machine-generated tagless-final wrappers for the AWS SDK v2 async clients.

Each module exposes the full client API as an algebra in an arbitrary effect F[_]: Async — every CompletableFuture-returning SDK method becomes an F-returning method — plus an interpreter that builds instances (and manages the underlying client as a cats.effect.Resource).

Import

libraryDependencies += "io.laserdisc" %% "pure-sqs-tagless" % "6.6.0"

These modules are the foundation the higher-level fs2-aws-* modules are built on, but they are also useful on their own whenever you need a purely functional version of an SDK call that has no streaming wrapper.

Usage

Acquire the algebra as a Resource from the SDK client builder, then call SDK operations as F effects:

import cats.effect.*
import io.laserdisc.pure.sqs.tagless.{SqsInterpreter, SqsAsyncClientOp}
import software.amazon.awssdk.services.sqs.model.{CreateQueueRequest, SendMessageRequest}

val sqsResource: Resource[IO, SqsAsyncClientOp[IO]] =
  SqsInterpreter[IO].resource

sqsResource.use { sqs =>
  for {
    queue <- sqs.createQueue(CreateQueueRequest.builder().queueName("my-queue").build())
    _     <- sqs.sendMessage(
      SendMessageRequest.builder().queueUrl(queue.queueUrl()).messageBody("hello").build()
    )
  } yield ()
}

To configure credentials/region/endpoint, pass a builder: SqsInterpreter[IO].resource(SqsAsyncClient.builder().region(...)). When you want the raw SDK client rather than the algebra (e.g. to hand it to the KCL), use clientResource instead of resource.

The interpreters also support Kleisli-based environment passing — see PureAWS.scala for an example combining SQS and SNS both ways.

Code generation

The sources are generated from the SDK client interfaces by the taglessGen sbt task (see project/TaglessGen.scala). To regenerate after an SDK bump:

make generate-pure-aws