5
5
namespace Kreait \Firebase \Http ;
6
6
7
7
use Beste \Json ;
8
+ use Closure ;
8
9
use Exception ;
9
10
use Fig \Http \Message \StatusCodeInterface as StatusCode ;
10
11
use GuzzleHttp \Exception \RequestException ;
11
12
use GuzzleHttp \MessageFormatter ;
12
13
use GuzzleHttp \Promise \Create ;
14
+ use GuzzleHttp \Promise \PromiseInterface ;
13
15
use GuzzleHttp \Psr7 \Query ;
14
16
use Psr \Http \Message \RequestInterface ;
15
17
use Psr \Http \Message \ResponseInterface ;
@@ -29,7 +31,7 @@ final class Middleware
29
31
*/
30
32
public static function ensureJsonSuffix (): callable
31
33
{
32
- return static fn (callable $ handler ) => static function (RequestInterface $ request , ?array $ options = null ) use ($ handler ) {
34
+ return static fn (callable $ handler ): Closure => static function (RequestInterface $ request , ?array $ options = null ) use ($ handler ) {
33
35
$ uri = $ request ->getUri ();
34
36
$ path = '/ ' .ltrim ($ uri ->getPath (), '/ ' );
35
37
@@ -47,7 +49,7 @@ public static function ensureJsonSuffix(): callable
47
49
*/
48
50
public static function addDatabaseAuthVariableOverride (?array $ override ): callable
49
51
{
50
- return static fn (callable $ handler ) => static function (RequestInterface $ request , ?array $ options = null ) use ($ handler , $ override ) {
52
+ return static fn (callable $ handler ): Closure => static function (RequestInterface $ request , ?array $ options = null ) use ($ handler , $ override ) {
51
53
$ uri = $ request ->getUri ();
52
54
53
55
$ uri = $ uri ->withQuery (Query::build (
@@ -60,16 +62,16 @@ public static function addDatabaseAuthVariableOverride(?array $override): callab
60
62
61
63
public static function log (LoggerInterface $ logger , MessageFormatter $ formatter , string $ logLevel , string $ errorLogLevel ): callable
62
64
{
63
- return static fn (callable $ handler ) => static fn ($ request , array $ options ) => $ handler ($ request , $ options )->then (
64
- static function (ResponseInterface $ response ) use ($ logger , $ request , $ formatter , $ logLevel , $ errorLogLevel ) {
65
+ return static fn (callable $ handler ): Closure => static fn ($ request , array $ options ) => $ handler ($ request , $ options )->then (
66
+ static function (ResponseInterface $ response ) use ($ logger , $ request , $ formatter , $ logLevel , $ errorLogLevel ): ResponseInterface {
65
67
$ message = $ formatter ->format ($ request , $ response );
66
68
$ messageLogLevel = $ response ->getStatusCode () >= StatusCode::STATUS_BAD_REQUEST ? $ errorLogLevel : $ logLevel ;
67
69
68
70
$ logger ->log ($ messageLogLevel , $ message );
69
71
70
72
return $ response ;
71
73
},
72
- static function (Exception $ reason ) use ($ logger , $ request , $ formatter , $ errorLogLevel ) {
74
+ static function (Exception $ reason ) use ($ logger , $ request , $ formatter , $ errorLogLevel ): PromiseInterface {
73
75
$ response = $ reason instanceof RequestException ? $ reason ->getResponse () : null ;
74
76
$ message = $ formatter ->format ($ request , $ response , $ reason );
75
77
0 commit comments