From 232ea40be61ca3140e4dba49349bc110bd122781 Mon Sep 17 00:00:00 2001
From: Paul Campbell <pcampbell@kemitix.net>
Date: Thu, 9 May 2019 18:46:25 +0100
Subject: [PATCH] [reactives3client] add console logging

---
 .../scala/net/kemitix/s3thorp/awssdk/ReactiveS3Client.scala  | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/src/main/scala/net/kemitix/s3thorp/awssdk/ReactiveS3Client.scala b/src/main/scala/net/kemitix/s3thorp/awssdk/ReactiveS3Client.scala
index 89cc32d..c8bd113 100644
--- a/src/main/scala/net/kemitix/s3thorp/awssdk/ReactiveS3Client.scala
+++ b/src/main/scala/net/kemitix/s3thorp/awssdk/ReactiveS3Client.scala
@@ -3,6 +3,7 @@ package net.kemitix.s3thorp.awssdk
 import cats.effect.IO
 import com.github.j5ik2o.reactive.aws.s3.S3AsyncClient
 import com.github.j5ik2o.reactive.aws.s3.cats.S3CatsIOClient
+import net.kemitix.s3thorp.Main.putStrLn
 import net.kemitix.s3thorp.Sync.{Bucket, LocalFile, RemoteKey}
 import software.amazon.awssdk.core.async.AsyncRequestBody
 import software.amazon.awssdk.services.s3.model.{HeadObjectRequest, NoSuchKeyException, PutObjectRequest}
@@ -19,7 +20,9 @@ private class ReactiveS3Client extends S3Client {
       .build()
     try {
       for {
+        _ <- putStrLn(s"S3:HeadObject: $bucket : $remoteKey")
         response <- s3Client.headObject(request)
+        _ <- putStrLn(s"  -- ${response.eTag()} : ${response.lastModified()}")
       } yield Some((response.eTag(), response.lastModified()))
     } catch {
       case _: NoSuchKeyException => IO(None)
@@ -34,7 +37,9 @@ private class ReactiveS3Client extends S3Client {
     val body = AsyncRequestBody.fromFile(localFile)
     try {
       for {
+        _ <- putStrLn(s"S3:PutObject: $bucket : $remoteKey")
         _ <- s3Client.putObject(request, body)
+        _ <- putStrLn("  -- Done")
       } yield ()
     }
   }