13532154862

Committed 25 Feb 2025 10:24PM UTC coverage: 30.374% (+1.7%) from 28.706%

Build # 13532154862

Build Type

push

github

Committed by

web-flow

Commit Message

Update php.yml

Run Details

544 of 1791 relevant lines covered (30.37%)

9.13 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/Middleware/OutputBufferingMiddleware.php

<?php
declare(strict_types=1);

namespace Ody\Core\Middleware;

use InvalidArgumentException;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Message\StreamFactoryInterface;
use Psr\Http\Server\MiddlewareInterface;
use Psr\Http\Server\RequestHandlerInterface;
use Throwable;

use function in_array;
use function ob_end_clean;
use function ob_get_clean;
use function ob_start;

/** @api */
class OutputBufferingMiddleware implements MiddlewareInterface
{
    public const APPEND = 'append';
    public const PREPEND = 'prepend';

    protected StreamFactoryInterface $streamFactory;

    protected string $style;

    /**
     * @param string $style Either "append" or "prepend"
     */
    public function __construct(StreamFactoryInterface $streamFactory, string $style = 'append')
    {
        $this->streamFactory = $streamFactory;
        $this->style = $style;

        if (!in_array($style, [static::APPEND, static::PREPEND], true)) {
            throw new InvalidArgumentException("Invalid style `{$style}`. Must be `append` or `prepend`");
        }
    }

    /**
     * @throws Throwable
     */
    public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
    {
        try {
            ob_start();
            $response = $handler->handle($request);
            $output = ob_get_clean();
        } catch (Throwable $e) {
            ob_end_clean();
            throw $e;
        }

        if (!empty($output)) {
            if ($this->style === static::PREPEND) {
                $body = $this->streamFactory->createStream();
                $body->write($output . $response->getBody());
                $response = $response->withBody($body);
            } elseif ($this->style === static::APPEND && $response->getBody()->isWritable()) {
                $response->getBody()->write($output);
            }
        }

        return $response;
    }
}

1	<?php
2	declare(strict_types=1);
3
4	namespace Ody\Core\Middleware;
5
6	use InvalidArgumentException;
7	use Psr\Http\Message\ResponseInterface;
8	use Psr\Http\Message\ServerRequestInterface;
9	use Psr\Http\Message\StreamFactoryInterface;
10	use Psr\Http\Server\MiddlewareInterface;
11	use Psr\Http\Server\RequestHandlerInterface;
12	use Throwable;
13
14	use function in_array;
15	use function ob_end_clean;
16	use function ob_get_clean;
17	use function ob_start;
18
19	/** @api */
20	class OutputBufferingMiddleware implements MiddlewareInterface
21	{
22	public const APPEND = 'append';
23	public const PREPEND = 'prepend';
24
25	protected StreamFactoryInterface $streamFactory;
26
27	protected string $style;
28
29	/**
30	* @param string $style Either "append" or "prepend"
31	*/
32	public function __construct(StreamFactoryInterface $streamFactory, string $style = 'append')	×
33	{
34	$this->streamFactory = $streamFactory;	×
35	$this->style = $style;	×
36
37	if (!in_array($style, [static::APPEND, static::PREPEND], true)) {	×
38	throw new InvalidArgumentException("Invalid style `{$style}`. Must be `append` or `prepend`");	×
39	}
40	}
41
42	/**
43	* @throws Throwable
44	*/
45	public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface	×
46	{
47	try {
48	ob_start();	×
49	$response = $handler->handle($request);	×
50	$output = ob_get_clean();	×
51	} catch (Throwable $e) {	×
52	ob_end_clean();	×
53	throw $e;	×
54	}
55
56	if (!empty($output)) {	×
57	if ($this->style === static::PREPEND) {	×
58	$body = $this->streamFactory->createStream();	×
59	$body->write($output . $response->getBody());	×
60	$response = $response->withBody($body);	×
61	} elseif ($this->style === static::APPEND && $response->getBody()->isWritable()) {	×
62	$response->getBody()->write($output);	×
63	}
64	}
65
66	return $response;	×
67	}
68	}

IlyasDeckers / ody-core / 13532154862

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous