Merge pull request #3 from cspray/bug/fix-stop-intercepting-not-remove-filter

Make sure to remove filter when stop intercepting

Author: cspray

.github/workflows/ci.yml

@@ -7,18 +7,24 @@ on:
     branches: [ main ]
 
 jobs:
-  continuous-integration:
-
+  unit-testing:
     runs-on: ubuntu-latest
 
-    env:
-      XDEBUG_MODE: coverage
-
     steps:
       - uses: actions/checkout@v3
-      - name: Composer
-        uses: php-actions/composer@v6
-      - name: Tests
-        uses: php-actions/phpunit@v3
+      - name: Setup PHP
+        uses: shivammathur/setup-php@v2
         with:
-          php_extensions: "xdebug"
+          php-version: 8.2
+          extensions: xdebug
+          tools: composer:2
+      - name: Setup problem matchers for PHP
+        run: echo "::add-matcher::${{ runner.tool_cache }}/php.json"
+      - name: Setup problem matchers for PHPUnit
+        run: echo "::add-matcher::${{ runner.tool_cache }}/phpunit.json"
+      - name: Composer
+        run: composer install
+      - name: Unit Testing
+        env:
+          XDEBUG_MODE: coverage
+        run: ./vendor/bin/phpunit

src/StreamFilter.php

@@ -61,6 +61,7 @@ function() use($bufferId) : void {
                 if (!isset(self::$cache[$bufferId])) {
                     throw BufferNotFound::fromStopInterceptingMissingBuffer();
                 }
+                stream_filter_remove(self::$cache[$bufferId]['filter']);
                 unset(self::$cache[$bufferId]);
             }
         ) implements Buffer {

tests/StreamFilterTest.php

@@ -58,7 +58,6 @@ public function testRegisterAddsAppropriateFilter() : void {
         );
     }
 
-    #[RunInSeparateProcess]
     public function testInterceptAddsBuffers() : void {
         StreamFilter::register();
 
@@ -71,7 +70,6 @@ public function testInterceptAddsBuffers() : void {
         self::assertContainsEquals($buffer, $buffers);
     }
 
-    #[RunInSeparateProcess]
     public function testResetAllResetsBuffersToEmptyCollection() : void {
         StreamFilter::register();
 
@@ -87,7 +85,6 @@ public function testResetAllResetsBuffersToEmptyCollection() : void {
 
     }
 
-    #[RunInSeparateProcess]
     public function testWritingToInterceptedStreamAddedToCorrectOutput() : void {
         StreamFilter::register();
 
@@ -101,7 +98,6 @@ public function testWritingToInterceptedStreamAddedToCorrectOutput() : void {
         );
     }
 
-    #[RunInSeparateProcess]
     public function testResetIndividualBufferClearsToEmptyString() : void {
         StreamFilter::register();
 
@@ -116,7 +112,6 @@ public function testResetIndividualBufferClearsToEmptyString() : void {
         self::assertSame('', $buffer->output());
     }
 
-    #[RunInSeparateProcess]
     public function testStopInterceptingRemovesBufferedResourceFromCache() : void {
         StreamFilter::register();
 
@@ -129,7 +124,6 @@ public function testStopInterceptingRemovesBufferedResourceFromCache() : void {
         self::assertSame([], StreamFilter::buffers());
     }
 
-    #[RunInSeparateProcess]
     public function testStopInterceptingBufferIdentifierNotFoundThrowsException() : void {
         StreamFilter::register();
 
@@ -142,7 +136,6 @@ public function testStopInterceptingBufferIdentifierNotFoundThrowsException() :
         $buffer->stopIntercepting();
     }
 
-    #[RunInSeparateProcess]
     public function testOutputForBufferStoppedInterceptingThrowsException() : void {
         StreamFilter::register();
 
@@ -156,7 +149,6 @@ public function testOutputForBufferStoppedInterceptingThrowsException() : void {
         $buffer->output();
     }
 
-    #[RunInSeparateProcess]
     public function testResetForBufferNotFoundThrowsException() : void {
         StreamFilter::register();
 
@@ -170,7 +162,6 @@ public function testResetForBufferNotFoundThrowsException() : void {
         $buffer->reset();
     }
 
-    #[RunInSeparateProcess]
     public function testInterceptOptionsDefaultDoesNotHaveContentsInResource() : void {
         StreamFilter::register();
 
@@ -184,7 +175,6 @@ public function testInterceptOptionsDefaultDoesNotHaveContentsInResource() : voi
         self::assertSame('', stream_get_contents($this->resource));
     }
 
-    #[RunInSeparateProcess]
     public function testInterceptOptionsTrapDoesNotHaveContentsInResource() : void {
         StreamFilter::register();
 
@@ -198,7 +188,6 @@ public function testInterceptOptionsTrapDoesNotHaveContentsInResource() : void {
         self::assertSame('', stream_get_contents($this->resource));
     }
 
-    #[RunInSeparateProcess]
     public function testInterceptOptionsPassThruDoesHaveContentsInResource() : void {
         StreamFilter::register();
 
@@ -212,7 +201,6 @@ public function testInterceptOptionsPassThruDoesHaveContentsInResource() : void
         self::assertSame('Content written to stream', stream_get_contents($this->resource));
     }
 
-    #[RunInSeparateProcess]
     public function testInterceptOptionsFatalErrorThrowsError() : void {
         StreamFilter::register();
 
@@ -226,7 +214,6 @@ public function testInterceptOptionsFatalErrorThrowsError() : void {
         self::assertSame('', stream_get_contents($this->resource));
     }
 
-    #[RunInSeparateProcess]
     public function testWritingToSeparateStreams() : void {
         StreamFilter::register();
 
@@ -240,4 +227,18 @@ public function testWritingToSeparateStreams() : void {
         self::assertSame('stdout output', $stdout->output());
     }
 
+    public function testInterceptingStoppingAndStartingAgainDoesNotResultInNullPointer() : void {
+        StreamFilter::register();
+
+        $buffer = StreamFilter::intercept($this->resource);
+        $buffer->stopIntercepting();
+
+        $buffer = StreamFilter::intercept($this->resource);
+        fwrite($this->resource, 'Some content');
+
+        self::assertSame('Some content', $buffer->output());
+
+        $buffer->stopIntercepting();
+    }
+
 }