kemitix/thorp
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

[reactives3client] handle key not found

Browse source
This commit is contained in:
Paul Campbell 2019-05-09 07:41:50 +01:00
parent 7af4004c75
commit 4e2729ae26
1 changed files with 9 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/main/scala/net/kemitix/s3thorp/ReactiveS3Client.scala
View file

@ -1,8 +1,9 @@
package net.kemitix.s3thorp package net.kemitix.s3thorp
import cats.effect.IO
import com.github.j5ik2o.reactive.aws.s3.S3AsyncClient import com.github.j5ik2o.reactive.aws.s3.S3AsyncClient
import com.github.j5ik2o.reactive.aws.s3.cats.S3CatsIOClient import com.github.j5ik2o.reactive.aws.s3.cats.S3CatsIOClient
import software.amazon.awssdk.services.s3.model.HeadObjectRequest import software.amazon.awssdk.services.s3.model.{HeadObjectRequest, NoSuchKeyException}
import software.amazon.awssdk.services.s3.{S3AsyncClient => JavaS3AsyncClient} import software.amazon.awssdk.services.s3.{S3AsyncClient => JavaS3AsyncClient}
class ReactiveS3Client extends S3Client { class ReactiveS3Client extends S3Client {
@ -14,9 +15,12 @@ class ReactiveS3Client extends S3Client {
.bucket(bucket) .bucket(bucket)
.key(key) .key(key)
.build() .build()
for { try {
response <- s3Client.headObject(request) for {
// TODO catch 404 error when key doesn't exist response <- s3Client.headObject(request)
} yield Some((response.eTag(), response.lastModified())) } yield Some((response.eTag(), response.lastModified()))
} catch {
case _: NoSuchKeyException => IO(None)
}
} }
} }