[s3metadataenricher] enrich with metadata when remote doesn't exists returns file to upload
This commit is contained in:
parent
e75b2a4892
commit
65c1915d53
1 changed files with 13 additions and 4 deletions
|
@ -40,20 +40,29 @@ class S3MetaDataEnricherSuite extends FunSpec {
|
||||||
}
|
}
|
||||||
|
|
||||||
describe("enrich with metadata") {
|
describe("enrich with metadata") {
|
||||||
|
val local = "localFile"
|
||||||
|
val localFile = new File(sourcePath + local)
|
||||||
describe("when remote exists") {
|
describe("when remote exists") {
|
||||||
val hash = "hash"
|
val hash = "hash"
|
||||||
val lastModified = Instant.now()
|
val lastModified = Instant.now()
|
||||||
new S3MetaDataEnricher {
|
new S3MetaDataEnricher {
|
||||||
override def objectHead(bucket: String, key: String) = IO(Some((hash, lastModified)))
|
override def objectHead(bucket: String, key: String) = IO(Some((hash, lastModified)))
|
||||||
it("returns metadata") {
|
it("returns metadata") {
|
||||||
val local = "localFile"
|
|
||||||
val localFile = new File(sourcePath + local)
|
|
||||||
val expectedMetadata = S3MetaData(localFile, s"$prefix/$local", hash, lastModified)
|
val expectedMetadata = S3MetaData(localFile, s"$prefix/$local", hash, lastModified)
|
||||||
|
|
||||||
val result: Either[File, S3MetaData] =
|
val result = enrichWithS3MetaData(config)(localFile).compile.toList.unsafeRunSync().head
|
||||||
enrichWithS3MetaData(config)(localFile).compile.toList.unsafeRunSync().head
|
|
||||||
assertResult(Right(expectedMetadata))(result)
|
assertResult(Right(expectedMetadata))(result)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
describe("when remote doesn't exist") {
|
||||||
|
new S3MetaDataEnricher {
|
||||||
|
override def objectHead(bucket: String, key: String) = IO(None)
|
||||||
|
it("returns file to upload") {
|
||||||
|
val result = enrichWithS3MetaData(config)(localFile).compile.toList.unsafeRunSync().head
|
||||||
|
assertResult(Left(localFile))(result)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue