Fix getS3Service() method

pydio · Dec 8, 2017 · c63bc35 · c63bc35
1 parent 10406ae
commit c63bc35
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 5 deletions.
diff --git a/core/src/plugins/access.s3/S3AccessDriver.php b/core/src/plugins/access.s3/S3AccessDriver.php
@@ -92,18 +92,19 @@ protected function initRepository(ContextInterface $contextInterface)
     }
 
     /**
+     * @param ContextInterface $ctx
      * @return S3Client
      */
-    public function getS3Service(){
-        return $this->s3Client;
+    public function getS3Service(ContextInterface $ctx){
+        return S3AccessWrapper::getClientForContext($ctx);
     }
 
     /**
      * @param AJXP_Node $node
      * @return int
      */
     public function directoryUsage(AJXP_Node $node){
-        $client = $this->getS3Service();
+        $client = $this->getS3Service($node->getContext());
         $bucket = $node->getRepository()->getContextOption($node->getContext(), "CONTAINER"); //(isSet($repositoryResolvedOptions["CONTAINER"])?$repositoryResolvedOptions["CONTAINER"]:$this->repository->getOption("CONTAINER"));
         $path   = rtrim($node->getRepository()->getContextOption($node->getContext(), "PATH"), "/").$node->getPath(); //(isSet($repositoryResolvedOptions["PATH"])?$repositoryResolvedOptions["PATH"]:"");
         $objects = $client->getIterator('ListObjects', array(

diff --git a/core/src/plugins/access.s3/S3AccessWrapper.php b/core/src/plugins/access.s3/S3AccessWrapper.php
@@ -72,7 +72,7 @@ public static function getResolvedOptionsForNode($node)
      * @param boolean $registerStream
      * @return S3Client
      */
-    protected static function getClientForContext(ContextInterface $ctx, $registerStream = true)
+    public static function getClientForContext(ContextInterface $ctx, $registerStream = true)
     {
         $repoObject = $ctx->getRepository();
         if (!isSet(self::$clients[$repoObject->getId()])) {

diff --git a/core/src/plugins/metastore.s3/S3MetaStore.php b/core/src/plugins/metastore.s3/S3MetaStore.php
@@ -66,12 +66,13 @@ protected function getUserId($node)
     }
 
     /**
+     * @param ContextInterface $ctx
      * @return \aws\S3\S3Client
      */
     protected function getAwsService(ContextInterface $ctx)
     {
         if(method_exists($ctx->getRepository()->getDriverInstance($ctx), "getS3Service")){
-            return $ctx->getRepository()->getDriverInstance($ctx)->getS3Service();
+            return $ctx->getRepository()->getDriverInstance($ctx)->getS3Service($ctx);
         }
         return null;
     }