Merge pull request #11 from rok4/develop

Correction du test d'existence d'un objet S3

Author: Dolite

CHANGELOG.md

@@ -1,3 +1,9 @@
+## 2.0.2
+
+### [Fixed]
+
+* `ProxyStorage` : le test d'existence d'un objet S3 se fait via la lecture du premier octet (le fonctionnement via préfixe n'est pas fiable).
+
 ## 2.0.0
 
 ### [Fixed]

lib/ROK4/Core/ProxyStorage.pm

@@ -99,6 +99,7 @@ my $SWIFT_TOKEN = undef;
 ### S3
 my $S3_HOST = undef;
 my $S3 = undef;
+my $S3CLIENT = undef;
 
 ####################################################################################################
 #                             Group: Controls methods                                              #
@@ -216,6 +217,13 @@ sub checkEnvironmentVariables {
             aws_secret_access_key => $ENV{ROK4_S3_SECRETKEY},
             vendor => $S3_VENDOR
         );
+
+        $S3CLIENT = Net::Amazon::S3::Client->new (
+            host => $S3_HOST,
+            aws_access_key_id => $ENV{ROK4_S3_KEY},
+            aws_secret_access_key => $ENV{ROK4_S3_SECRETKEY},
+            vendor => $S3_VENDOR
+        );
     }
 
     return TRUE;
@@ -916,15 +924,10 @@ sub isPresent {
             return FALSE;
         }
 
-        my $result = $S3->list_bucket({
-            bucket => $bucketName,
-            prefix => $objectName
-        });
+        my $object = $S3CLIENT->bucket( name => $bucketName )->object( key => $objectName );
 
-        if (! defined $result) {
-            ERROR(sprintf "Cannot request S3 storage : %s (%s)", $S3->errstr, $S3->err);
-            return FALSE;
-        } elsif (scalar(@{$result->{keys}} == 0)) {
+        eval { $object->range ("bytes=0-1")->get; };
+        if ($@) {
             return FALSE;
         } else {
             return TRUE;