JMathai\S3BucketStreamZip\S3BucketStreamZip::send()

Complexity

Conditions	3
Paths	4

Size

Total Lines	52
Code Lines	21

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	12

<?php
  public function send($filename, $params = array())
  {
    // Set default values for the optional $params argument
    if(!isset($params['expiration']))
      $params['expiration'] = '+10 minutes';

    // Initialize the ZipStream object and pass in the file name which
    //  will be what is sent in the content-disposition header.
    // This is the name of the file which will be sent to the client.
    $zip = new ZipStream\ZipStream($filename);

    // Get a list of objects from the S3 bucket. The iterator is a high
    //  level abstration that will fetch ALL of the objects without having
    //  to manually loop over responses.
    $result = $this->s3Client->getIterator('ListObjects', $this->params);

    // We loop over each object from the ListObjects call.
    foreach($result as $file)
    {
      // We need to use a command to get a request for the S3 object
      //  and then we can get the presigned URL.
      $command = $this->s3Client->getCommand('GetObject', array(
        'Bucket' => $this->params['Bucket'],
        'Key' => $file['Key']
      ));
      $signedUrl = $command->createPresignedUrl($params['expiration']);
      
      // Get the file name on S3 so we can save it to the zip file 
      //  using the same name.
      $fileName = basename($file['Key']);

      // We want to fetch the file to a file pointer so we create it here
      //  and create a curl request and store the response into the file 
      //  pointer.
      // After we've fetched the file we add the file to the zip file using
      //  the file pointer and then we close the curl request and the file 
      //  pointer.
      // Closing the file pointer removes the file.
      $fp = tmpfile();
      $ch = curl_init($signedUrl);
      curl_setopt($ch, CURLOPT_TIMEOUT, 120);
      curl_setopt($ch, CURLOPT_FILE, $fp);
      curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
      curl_exec($ch);
      curl_close($ch);
      $zip->addFileFromStream($fileName, $fp);
      fclose($fp);
    }

    // Finalize the zip file.
    $zip->finish();
  }
}