Exists API

Author: tib

Package.resolved

@@ -68,6 +68,16 @@ struct LiquidAwsS3Storage: FileStorage {
     func delete(key: String) -> EventLoopFuture<Void> {
         s3.deleteObject(S3.DeleteObjectRequest(bucket: bucket, key: key)).map { _ in }
     }
+
+    func exists(key: String) -> EventLoopFuture<Bool> {
+        s3.getObject(S3.GetObjectRequest(bucket: bucket, key: key)).map { _ in true }.flatMapError { err -> EventLoopFuture<Bool> in
+            if let err = err as? SotoS3.S3ErrorType, err == SotoS3.S3ErrorType.noSuchKey {
+                return s3.eventLoopGroup.next().makeSucceededFuture(false)
+            }
+            return s3.eventLoopGroup.next().makeFailedFuture(err)
+        }
+    }
+
 }
 
 

Sources/LiquidAwsS3Driver/LiquidAwsS3Storage.swift

@@ -103,6 +103,19 @@ final class LiquidAwsS3DriverTests: XCTestCase {
         let res = try fs.list(key: "dir02").wait()
         XCTAssertEqual(res, ["dir03", "test-01.txt"])
     }
+    
+    func testExists() throws {
+        let fs = try createTestStorage()
+
+        let key1 = "non-existing-thing"
+        let exists1 = try fs.exists(key: key1).wait()
+        XCTAssertFalse(exists1)
+        
+        let key2 = "my/dir"
+        _ = try fs.createDirectory(key: key2).wait()
+        let exists2 = try fs.exists(key: key2).wait()
+        XCTAssertTrue(exists2)
+    }
 
     /*
     func testUploadWithCustomEndpoint() throws {