- Add Google Cloud Storage library

- Bug fixes

Author: aminyazdanpanah

README.md

@@ -69,7 +69,7 @@ $ffmpeg = Streaming\FFMpeg::create($config);
 ```
 
 ### Opening a File
-There are three ways to open a file:
+There are several ways to open a file:
 
 #### 1. From a Local Path
 You can pass a local path of video to the `open` method:
@@ -144,6 +144,23 @@ $video = $ffmpeg->fromS3($config, $bucket, $key);
 ```
 A path can also be passed to save the file on your local computer/server.
 
+
+#### 4. From Google Cloud Storage
+[Google Cloud Storage](https://console.cloud.google.com/storage) is a RESTful online file storage web service for storing and accessing data on Google Cloud Platform infrastructure. The service combines the performance and scalability of Google's cloud with advanced security and sharing capabilities. It is an Infrastructure as a Service (IaaS), comparable to Amazon S3 online storage service. Contrary to Google Drive and according to different service specifications, Google Cloud Storage appears to be more suitable for enterprises. [Learn more](https://en.wikipedia.org/wiki/Google_Storage)
+- For creating credentials, read the Cloud Storage Authentication found **[here](https://cloud.google.com/storage/docs/authentication)** or you can [create it](https://console.cloud.google.com/apis/credentials) directly.
+
+For downloading a file from Google Cloud Storage, you need to pass an associative array of config, the name of your bucket, and the name of your file in the bucket to the `fromGCS` method:
+``` php
+$config = [
+    'keyFilePath' => '/path/to/credentials.json'
+];
+$bucket = 'my_bucket';
+$name = 'my_sweetie.mp4';
+
+$video = $ffmpeg->fromGCS($config, $bucket, $name);
+```
+A path can also be passed to save the file on your local computer/server.
+
 ### DASH
 **[Dynamic Adaptive Streaming over HTTP (DASH)](https://en.wikipedia.org/wiki/Dynamic_Adaptive_Streaming_over_HTTP)**, also known as MPEG-DASH, is an adaptive bitrate streaming technique that enables high quality streaming of media content over the Internet delivered from conventional HTTP web servers.
 
@@ -270,7 +287,7 @@ $video->HLS()
 ```
 
 ### Saving Files
-There are three options to save your packaged video files:
+There are several options to save your packaged files.
 
 #### 1. To a Local Path
 You can pass a local path to the `save` method. If there was no directory in the path, then the package auto makes the directory.
@@ -352,6 +369,22 @@ A path can also be passed to save a copy of files on your local computer/server.
 ``` php
 $hls->saveToS3($config, $dest, '/var/www/media/videos/hls/test.m3u8');
 ```
+
+#### 4. TO Google Cloud Storage
+You can save and upload entire packaged video files to **[Google Cloud Storage](https://console.cloud.google.com/storage)**. For uploading files, you need to have credentials.
+``` php
+$config = [
+    'keyFilePath' => '/path/to/credentials.json'
+];
+$bucket = 'my_bucket';
+
+$dash->saveToGCS($config, $bucket)
+```
+A path can also be passed to save a copy of files on your local computer/server.
+``` php
+$hls->saveToGCS($config, $bucket, '/var/www/media/videos/hls/test.m3u8');
+```
+
 **NOTE:** You can mix opening and saving options together. For instance, you can open a file on your local computer/server and save packaged files to a Cloud (or vice versa).   
 
 ![schema](/docs/schema.gif?raw=true "schema" )

composer.json

@@ -50,6 +50,7 @@
         "php-ffmpeg/php-ffmpeg": "^0.14",
         "guzzlehttp/guzzle": "~6.0",
         "aws/aws-sdk-php": "~3.0",
+        "google/cloud-storage": "^1.14",
         "ext-openssl": "*"
     },
     "scripts": {

src/Export.php

@@ -60,12 +60,12 @@ public function save(string $path = null, $analyse = true)
             $this->getFilter()
         );
 
-        try{
+        try {
             $this->media->save(
                 $this->getFormat(),
                 $path
             );
-        }catch (ExceptionInterface $e){
+        } catch (ExceptionInterface $e) {
             throw new RuntimeException(sprintf(
                 "There was an error saving files: \n\n reason: \n %s",
                 $e->getMessage()
@@ -169,7 +169,12 @@ public function saveToCloud(
      * @return mixed
      * @throws Exception
      */
-    public function saveToS3(array $config, string $dest, string $path = null, bool $analyse = true)
+    public function saveToS3(
+        array $config,
+        string $dest,
+        string $path = null,
+        bool $analyse = true
+    )
     {
         list($results, $tmp_dir) = $this->saveToTemporaryFolder($path, $analyse);
         sleep(1);
@@ -182,6 +187,36 @@ public function saveToS3(array $config, string $dest, string $path = null, bool
         return $results;
     }
 
+    /**
+     * @param array $config
+     * @param string $bucket
+     * @param string|null $path
+     * @param array $options
+     * @param bool $userProject
+     * @param bool $analyse
+     * @return mixed
+     * @throws Exception
+     */
+    public function saveToGCS(
+        array $config,
+        string $bucket,
+        string $path = null,
+        array $options = [],
+        $userProject = false,
+        bool $analyse = true
+    )
+    {
+        list($results, $tmp_dir) = $this->saveToTemporaryFolder($path, $analyse);
+        sleep(1);
+
+        $google_cloud = new GoogleCloudStorage($config, $bucket, $userProject);
+        $google_cloud->uploadDirectory($tmp_dir, $options);
+
+        $this->moveTmpFolder($path, $tmp_dir);
+
+        return $results;
+    }
+
     /**
      * @return array
      */
@@ -215,7 +250,7 @@ private function saveToTemporaryFolder($path, $analyse)
         $basename = Helper::randomString();
 
         if (null !== $path) {
-            $basename = pathinfo($path)["basename"];
+            $basename = pathinfo($path, PATHINFO_BASENAME);
         }
 
         $tmp_dir = FileManager::tmpDir();
@@ -232,7 +267,7 @@ private function saveToTemporaryFolder($path, $analyse)
     private function moveTmpFolder(?string $path, $tmp_dir)
     {
         if (null !== $path) {
-            FileManager::moveDir($tmp_dir, pathinfo($path)["dirname"] . DIRECTORY_SEPARATOR);
+            FileManager::moveDir($tmp_dir, pathinfo($path, PATHINFO_DIRNAME) . DIRECTORY_SEPARATOR);
         } else {
             FileManager::deleteDirectory($tmp_dir);
         }

src/FFMpeg.php

@@ -87,6 +87,17 @@ public function fromS3(array $config, string $bucket, string $key, string $save_
         return $this->open($save_to, $is_tmp);
     }
 
+
+    public function fromGCS(array $config, string $bucket, string $name, string $save_to = null, $userProject = false): Media
+    {
+        list($is_tmp, $save_to) = $this->isTmp($save_to);
+
+        $google_cloud = new GoogleCloudStorage($config, $bucket, $userProject);
+        $google_cloud->download($name, $save_to);
+
+        return $this->open($save_to, $is_tmp);
+    }
+
     /**
      * @param $path
      * @return array

src/FileManager.php

@@ -190,6 +190,8 @@ public static function moveDir(string $source, string $destination)
                 unlink($source . $file);
             }
         }
+
+        static::deleteDirectory($source);
     }
 
     /**

src/GoogleCloudStorage.php

@@ -0,0 +1,56 @@
+<?php
+
+/**
+ * This file is part of the ******* package.
+ *
+ * (c) Amin Yazdanpanah <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+
+namespace Streaming;
+
+use Google\Cloud\Storage\StorageClient;
+
+class GoogleCloudStorage
+{
+    /**
+     * @var \Google\Cloud\Storage\Bucket $bucket
+     */
+    private $bucket;
+
+    /**
+     * GoogleCloudStorage constructor.
+     * @param string $bucket
+     * @param bool $userProject
+     * @param array $config
+     */
+    public function __construct(array $config, string $bucket, $userProject = false)
+    {
+        $storage = new StorageClient($config);
+        $this->bucket = $storage->bucket($bucket, $userProject);
+    }
+
+    /**
+     * @param string $dir
+     * @param array $options
+     */
+    public function uploadDirectory(string $dir, array $options = [])
+    {
+        foreach (scandir($dir) as $key => $filename) {
+            $path = $dir . DIRECTORY_SEPARATOR . $filename;
+
+            if (is_file($path)) {
+                $this->bucket->upload(fopen($path, 'r'), $options);
+            }
+        }
+    }
+
+    public function download(string $name, string $save_to)
+    {
+        return $this->bucket->object($name)
+            ->downloadToFile($save_to);
+    }
+}