From 04b5d4eded873df7a32c0c584cef13a9de4b0771 Mon Sep 17 00:00:00 2001 From: Paul Campbell Date: Tue, 7 May 2019 22:14:56 +0100 Subject: [PATCH] [s3metadataenricher] extend S3Client --- src/main/scala/net/kemitix/s3thorp/S3MetaDataEnricher.scala | 2 +- src/main/scala/net/kemitix/s3thorp/Sync.scala | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/src/main/scala/net/kemitix/s3thorp/S3MetaDataEnricher.scala b/src/main/scala/net/kemitix/s3thorp/S3MetaDataEnricher.scala index 69ac9b0..071f26d 100644 --- a/src/main/scala/net/kemitix/s3thorp/S3MetaDataEnricher.scala +++ b/src/main/scala/net/kemitix/s3thorp/S3MetaDataEnricher.scala @@ -6,7 +6,7 @@ import fs2.Stream import cats.effect.IO import Main.putStrLn -trait S3MetaDataEnricher { +trait S3MetaDataEnricher extends S3Client { def enrichWithS3MetaData: Path => Stream[IO, S3MetaData] = path => Stream.eval(for { diff --git a/src/main/scala/net/kemitix/s3thorp/Sync.scala b/src/main/scala/net/kemitix/s3thorp/Sync.scala index 85a57da..8b7b96e 100644 --- a/src/main/scala/net/kemitix/s3thorp/Sync.scala +++ b/src/main/scala/net/kemitix/s3thorp/Sync.scala @@ -37,4 +37,6 @@ object Sync extends LocalFileStream with S3MetaDataEnricher { // upload p = Promise[Unit]() } yield p) + + override def objectHead(bucket: String, key: String): (Hash, LastModified) = ??? }