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

[awssdk] Typo/rename class Throp* => Thorp*

Browse source
This commit is contained in:
Paul Campbell 2019-05-14 20:14:08 +01:00
parent 40848882f8
commit 64bf42921d
3 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/main/scala/net/kemitix/s3thorp/awssdk/S3Client.scala
View file

@ -15,7 +15,7 @@ trait S3Client {
object S3Client { object S3Client {
val defaultClient: S3Client = val defaultClient: S3Client =
new ThropS3Client( new ThorpS3Client(
S3CatsIOClient(new JavaClientWrapper {}.underlying)) S3CatsIOClient(new JavaClientWrapper {}.underlying))
} }

2
src/main/scala/net/kemitix/s3thorp/awssdk/ThropS3Client.scala → src/main/scala/net/kemitix/s3thorp/awssdk/ThorpS3Client.scala
View file

@ -6,7 +6,7 @@ import net.kemitix.s3thorp.Sync._
import software.amazon.awssdk.core.async.AsyncRequestBody import software.amazon.awssdk.core.async.AsyncRequestBody
import software.amazon.awssdk.services.s3.model.{HeadObjectRequest, PutObjectRequest} import software.amazon.awssdk.services.s3.model.{HeadObjectRequest, PutObjectRequest}
private class ThropS3Client(s3Client: S3CatsIOClient) extends S3Client { private class ThorpS3Client(s3Client: S3CatsIOClient) extends S3Client {
def objectHead(bucket: Bucket, remoteKey: RemoteKey) = { def objectHead(bucket: Bucket, remoteKey: RemoteKey) = {
val request = HeadObjectRequest.builder().bucket(bucket).key(remoteKey).build() val request = HeadObjectRequest.builder().bucket(bucket).key(remoteKey).build()

8
src/test/scala/net/kemitix/s3thorp/awssdk/S3ClientSuite.scala
View file

@ -19,7 +19,7 @@ class S3ClientSuite extends FunSpec {
describe("when underlying client response is okay") { describe("when underlying client response is okay") {
val expectedHash = "hash" val expectedHash = "hash"
val expectedLastModified = Instant.now val expectedLastModified = Instant.now
val s3Client = new ThropS3Client(new S3CatsIOClient with JavaClientWrapper { val s3Client = new ThorpS3Client(new S3CatsIOClient with JavaClientWrapper {
override def headObject(headObjectRequest: HeadObjectRequest) = override def headObject(headObjectRequest: HeadObjectRequest) =
IO(HeadObjectResponse.builder(). IO(HeadObjectResponse.builder().
eTag(expectedHash). eTag(expectedHash).
@ -32,7 +32,7 @@ class S3ClientSuite extends FunSpec {
} }
describe("when underlying client throws NoSuchKeyException") { describe("when underlying client throws NoSuchKeyException") {
val s3Client = new ThropS3Client(new S3CatsIOClient with JavaClientWrapper { val s3Client = new ThorpS3Client(new S3CatsIOClient with JavaClientWrapper {
override def headObject(headObjectRequest: HeadObjectRequest) = override def headObject(headObjectRequest: HeadObjectRequest) =
IO(throw NoSuchKeyException.builder().build()) IO(throw NoSuchKeyException.builder().build())
}) })
@ -44,11 +44,11 @@ class S3ClientSuite extends FunSpec {
} }
describe("upload") { describe("upload") {
def invoke(s3Client: ThropS3Client, localFile: LocalFile, bucket: Bucket, remoteKey: RemoteKey) = def invoke(s3Client: ThorpS3Client, localFile: LocalFile, bucket: Bucket, remoteKey: RemoteKey) =
s3Client.upload(localFile, bucket, remoteKey).unsafeRunSync s3Client.upload(localFile, bucket, remoteKey).unsafeRunSync
describe("when uploading a file") { describe("when uploading a file") {
val md5Hash = "the-md5hash" val md5Hash = "the-md5hash"
val s3Client = new ThropS3Client( val s3Client = new ThorpS3Client(
new S3CatsIOClient with JavaClientWrapper { new S3CatsIOClient with JavaClientWrapper {
override def putObject(putObjectRequest: PutObjectRequest, requestBody: RB) = override def putObject(putObjectRequest: PutObjectRequest, requestBody: RB) =
IO(PutObjectResponse.builder().eTag(md5Hash).build()) IO(PutObjectResponse.builder().eTag(md5Hash).build())