From d0a04126a0015dfe53b9ba9f6f1c00a67fa08b12 Mon Sep 17 00:00:00 2001
From: Scala Steward <43047562+scala-steward@users.noreply.github.com>
Date: Tue, 21 Nov 2023 18:37:13 +0100
Subject: [PATCH] Update cloudwatch, dynamodb, kinesis, s3, sns, ... to 2.21.21
 (#1120)

* Update cloudwatch, dynamodb, kinesis, s3, sns, ... to 2.21.21

* upgrade the localstack version
explicitly create and delete kinesis stream for tests

---------

Co-authored-by: mergify[bot] <37929162+mergify[bot]@users.noreply.github.com>
Co-authored-by: dmytro.obodowsky <dmytro.obodowsky@disney.com>
---
 docker-compose.yml                                           | 2 +-
 .../src/test/scala/fs2/aws/kinesis/NewLocalStackSuite.scala  | 5 ++++-
 project/Dependencies.scala                                   | 2 +-
 project/build.sbt                                            | 2 +-
 4 files changed, 7 insertions(+), 4 deletions(-)

diff --git a/docker-compose.yml b/docker-compose.yml
index 32a8882e..0091899b 100644
--- a/docker-compose.yml
+++ b/docker-compose.yml
@@ -22,7 +22,7 @@ services:
       exit 0;
       "
   localstack:
-    image: localstack/localstack:1.2.0
+    image: localstack/localstack:3
     ports:
       - 4566:4566
     environment:
diff --git a/fs2-aws-kinesis/src/test/scala/fs2/aws/kinesis/NewLocalStackSuite.scala b/fs2-aws-kinesis/src/test/scala/fs2/aws/kinesis/NewLocalStackSuite.scala
index fa771a00..7ad271b4 100644
--- a/fs2-aws-kinesis/src/test/scala/fs2/aws/kinesis/NewLocalStackSuite.scala
+++ b/fs2-aws-kinesis/src/test/scala/fs2/aws/kinesis/NewLocalStackSuite.scala
@@ -90,7 +90,7 @@ class NewLocalStackSuite extends AnyFlatSpec with Matchers with ScalaFutures {
 
     val data = List("foo", "bar", "baz")
 
-    val test = kAlgebraResource(kac, dac, cac).use { case (_, kAlgebra) =>
+    val test = kAlgebraResource(kac, dac, cac).use { case (ki, kAlgebra) =>
       for {
         _ <- Stream
           .emits(data)
@@ -207,6 +207,9 @@ class NewLocalStackSuite extends AnyFlatSpec with Matchers with ScalaFutures {
       k <- i.KinesisAsyncClientResource(kac)
       kinesisInterpreter = i.create(k)
       kAlgebra           = Kinesis.create[IO](k, d, c)
+      _ <- Resource.make(
+        kinesisInterpreter.createStream(CreateStreamRequest.builder().streamName("test").build())
+      )(_ => kinesisInterpreter.deleteStream(DeleteStreamRequest.builder().streamName("test").build()).void)
     } yield kinesisInterpreter -> kAlgebra
 
 }
diff --git a/project/Dependencies.scala b/project/Dependencies.scala
index 6d69a10b..34bf33e3 100644
--- a/project/Dependencies.scala
+++ b/project/Dependencies.scala
@@ -5,7 +5,7 @@ import sbt.{Def, _}
 object Dependencies {
 
   object V {
-    val AwsSdk           = "2.21.15"
+    val AwsSdk           = "2.21.21"
     val Circe            = "0.14.5"
     val Munit            = "0.7.29"
     val Fs2              = "3.9.3"
diff --git a/project/build.sbt b/project/build.sbt
index 5c32dee5..59c613c6 100644
--- a/project/build.sbt
+++ b/project/build.sbt
@@ -1,5 +1,5 @@
 // Required for the freegen definition in ../build.sbt
-val AwsSdk = "2.21.15"
+val AwsSdk = "2.21.21"
 
 libraryDependencies += "software.amazon.awssdk" % "sqs"        % AwsSdk
 libraryDependencies += "software.amazon.awssdk" % "s3"         % AwsSdk