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

[sync] remove unneeded for-comprehension

Browse source
This commit is contained in:
Paul Campbell 2019-05-11 06:25:47 +01:00
parent 218c0114c2
commit 0931f82414
1 changed files with 7 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
src/main/scala/net/kemitix/s3thorp/Sync.scala
View file

@ -4,7 +4,6 @@ import java.io.File
import java.time.Instant import java.time.Instant
import cats.effect._ import cats.effect._
import net.kemitix.s3thorp.Main.putStrLn
import net.kemitix.s3thorp.Sync.{Bucket, LocalFile, RemoteKey} import net.kemitix.s3thorp.Sync.{Bucket, LocalFile, RemoteKey}
import net.kemitix.s3thorp.awssdk.S3Client import net.kemitix.s3thorp.awssdk.S3Client
@ -20,15 +19,13 @@ class Sync(s3Client: S3Client)
override def upload(localFile: LocalFile, bucket: Bucket, remoteKey: RemoteKey) = override def upload(localFile: LocalFile, bucket: Bucket, remoteKey: RemoteKey) =
s3Client.upload(localFile, bucket, remoteKey) s3Client.upload(localFile, bucket, remoteKey)
def run(c: Config): IO[Unit] = for { def run(c: Config): IO[Unit] = {
_ <- putStrLn(s"Bucket: ${c.bucket}, Prefix: ${c.prefix}, Source: ${c.source}") println(s"Bucket: ${c.bucket}, Prefix: ${c.prefix}, Source: ${c.source}")
_ <- { streamDirectoryPaths(c.source).flatMap(
streamDirectoryPaths(c.source).flatMap( enrichWithS3MetaData(c)).flatMap(
enrichWithS3MetaData(c)).flatMap( uploadRequiredFilter(c)).flatMap(
uploadRequiredFilter(c)).flatMap( performUpload(c)).compile.drain
performUpload(c)).compile.drain }
}
} yield ()
} }