1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
|
<?php
declare( strict_types = 1 );
namespace MediaWiki\Http;
use GuzzleHttp\Psr7\Utils;
use LogicException;
use MWHttpRequest;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\StreamInterface;
/**
* @since 1.36
* @unstable
*
* @license GPL-2.0-or-later
*/
class MwHttpRequestToResponseInterfaceAdapter implements ResponseInterface {
/**
* @var MWHttpRequest
*/
private $mwHttpRequest;
/**
* @param MWHttpRequest $mwHttpRequest the MWHttpRequest must contain response information, i.e. must have been
* `execute`d
*/
public function __construct( MWHttpRequest $mwHttpRequest ) {
$this->validateHasResponse( $mwHttpRequest );
$this->mwHttpRequest = $mwHttpRequest;
}
public function getProtocolVersion(): string {
// @phan-suppress-previous-line PhanPluginNeverReturnMethod
// This is not accessible via MWHttpRequest, but it is set in its protected `respVersion` property.
// If this is ever needed, it can get exposed in MWHttpRequest.
throw new LogicException( __METHOD__ . ' is not implemented' );
}
public function withProtocolVersion( $version ): self {
$this->throwExceptionForBuilderMethod( __METHOD__ );
}
public function getHeaders(): array {
return $this->mwHttpRequest->getResponseHeaders();
}
public function hasHeader( $name ): bool {
return isset( $this->mwHttpRequest->getResponseHeaders()[$name] );
}
public function getHeader( $name ): array {
return $this->hasHeader( $name ) ? $this->mwHttpRequest->getResponseHeaders()[$name] : [];
}
public function getHeaderLine( $name ): string {
return $this->hasHeader( $name )
? implode( ',', $this->mwHttpRequest->getResponseHeaders()[$name] )
: '';
}
public function withHeader( $name, $value ): self {
$this->throwExceptionForBuilderMethod( __METHOD__ );
}
public function withAddedHeader( $name, $value ): self {
$this->throwExceptionForBuilderMethod( __METHOD__ );
}
public function withoutHeader( $name ): self {
$this->throwExceptionForBuilderMethod( __METHOD__ );
}
public function getBody(): StreamInterface {
return Utils::streamFor( $this->mwHttpRequest->getContent() );
}
public function withBody( StreamInterface $body ): self {
$this->throwExceptionForBuilderMethod( __METHOD__ );
}
public function getStatusCode(): int {
return $this->mwHttpRequest->getStatus();
}
public function withStatus( $code, $reasonPhrase = '' ): self {
$this->throwExceptionForBuilderMethod( __METHOD__ );
}
public function getReasonPhrase(): string {
return ''; // not exposed through MWHttpRequest, unlikely to ever be useful
}
/**
* @param string $method
* @return never
*/
private function throwExceptionForBuilderMethod( string $method ): void {
throw new LogicException( "Builder method $method is not supported." );
}
private function validateHasResponse( MWHttpRequest $mwHttpRequest ): void {
/*
* MWHttpRequest objects contain request information, but also contain response information after calling
* `execute`. The best way of determining whether a MWHttpRequest contains response information is to check
* whether its headers list is empty.
*/
if ( !$mwHttpRequest->getResponseHeaders() ) {
throw new LogicException( 'Trying to get response information from a request that was not yet executed' );
}
}
}
|
