Streaming and Saving Content from URL to File

rcsofttech85 · rcsofttech85 · commit 3a799eaec54c · 2023-09-03T17:55:36.000+05:30
Signed-off-by: rahul &lt;rcsofttech85@gmail.com&gt;
diff --git a/README.md b/README.md
@@ -111,3 +111,13 @@ $fileEncryptor = new FileEncryptor('movie.csv', $secret);
 $fileEncryptor->decryptFile();
 
 ```
+
+**Streaming and Saving Content from URL to File**
+
+```
+
+ $url = "https://gist.github.com/rcsofttech85/629b37d483c4796db7bdcb3704067631#file-gistfile1-txt";
+ $stream = new Stream($url, "outputFile.html");
+ $stream->startStreaming();
+
+```
diff --git a/src/Exception/StreamException.php b/src/Exception/StreamException.php
@@ -0,0 +1,14 @@
+<?php
+
+namespace rcsofttech85\FileHandler\Exception;
+
+use Exception;
+use Throwable;
+
+class StreamException extends Exception
+{
+    public function __construct($message = "could not stream file", $code = 0, Throwable $previous = null)
+    {
+        parent::__construct($message, $code, $previous);
+    }
+}
diff --git a/src/Stream.php b/src/Stream.php
@@ -0,0 +1,49 @@
+<?php
+
+namespace rcsofttech85\FileHandler;
+
+use Fiber;
+use rcsofttech85\FileHandler\Exception\StreamException;
+use Throwable;
+
+readonly class Stream
+{
+    public function __construct(public string $streamUrl, public string $outputFilename)
+    {
+    }
+
+    /**
+     * @throws StreamException
+     */
+    public function startStreaming(): void
+    {
+        $fiber = new Fiber(function ($streamUrl): void {
+            while (!feof($streamUrl)) {
+                $contents = fread($streamUrl, 100);
+                Fiber::suspend($contents);
+            }
+        });
+
+        $stream = fopen($this->streamUrl, 'r');
+        if (!$stream) {
+            throw new StreamException();
+        }
+        stream_set_blocking($stream, false);
+
+        $outputFile = fopen($this->outputFilename, 'w');
+
+        try {
+            $content = $fiber->start($stream);
+            while (!$fiber->isTerminated()) {
+                fwrite($outputFile, $content);
+
+                $content = $fiber->resume();
+            }
+        } catch (Throwable $e) {
+            throw new StreamException();
+        } finally {
+            fclose($stream);
+            fclose($outputFile);
+        }
+    }
+}
diff --git a/tests/unit/StreamTest.php b/tests/unit/StreamTest.php
@@ -0,0 +1,46 @@
+<?php
+
+namespace unit;
+
+use PHPUnit\Framework\Attributes\Test;
+use PHPUnit\Framework\TestCase;
+use rcsofttech85\FileHandler\Exception\StreamException;
+use rcsofttech85\FileHandler\Stream;
+
+class StreamTest extends TestCase
+{
+    public static function setUpBeforeClass(): void
+    {
+        parent::setUpBeforeClass();
+
+        fopen("outputFile.html", "w");
+    }
+
+    public static function tearDownAfterClass(): void
+    {
+        parent::tearDownAfterClass();
+        unlink("outputFile.html");
+    }
+
+    #[Test]
+    public function streamAndWriteToFile()
+    {
+        $url = "https://gist.github.com/rcsofttech85/629b37d483c4796db7bdcb3704067631#file-gistfile1-txt";
+        $stream = new Stream($url, "outputFile.html");
+        $stream->startStreaming();
+
+        $this->assertGreaterThan(0, filesize("outputFile.html"));
+        $this->assertStringContainsString('<!DOCTYPE html>', file_get_contents("outputFile.html"));
+        $this->assertStringContainsString('</html>', file_get_contents("outputFile.html"));
+    }
+
+    #[Test]
+    public function throwExceptionIfUrlIsInvalid()
+    {
+        $url = "https://gist.github";
+        $stream = new Stream($url, "outputFile.html");
+
+        $this->expectException(StreamException::class);
+        $stream->startStreaming();
+    }
+}
