1 | <?php |
||
37 | class SocketPost implements RequestMethod |
||
38 | { |
||
39 | /** |
||
40 | * reCAPTCHA service host. |
||
41 | * @const string |
||
42 | */ |
||
43 | const RECAPTCHA_HOST = 'www.google.com'; |
||
44 | |||
45 | /** |
||
46 | * @const string reCAPTCHA service path |
||
47 | */ |
||
48 | const SITE_VERIFY_PATH = '/recaptcha/api/siteverify'; |
||
49 | |||
50 | /** |
||
51 | * @const string Bad request error |
||
52 | */ |
||
53 | const BAD_REQUEST = '{"success": false, "error-codes": ["invalid-request"]}'; |
||
54 | |||
55 | /** |
||
56 | * @const string Bad response error |
||
57 | */ |
||
58 | const BAD_RESPONSE = '{"success": false, "error-codes": ["invalid-response"]}'; |
||
59 | |||
60 | /** |
||
61 | * Socket to the reCAPTCHA service |
||
62 | * @var Socket |
||
63 | */ |
||
64 | private $socket; |
||
65 | |||
66 | /** |
||
67 | * Constructor |
||
68 | * |
||
69 | * @param \ReCaptcha\RequestMethod\Socket $socket optional socket, injectable for testing |
||
70 | */ |
||
71 | public function __construct(Socket $socket = null) |
||
72 | { |
||
73 | if (!is_null($socket)) { |
||
74 | $this->socket = $socket; |
||
75 | } else { |
||
76 | $this->socket = new Socket(); |
||
77 | } |
||
78 | } |
||
79 | |||
80 | /** |
||
81 | * Submit the POST request with the specified parameters. |
||
82 | * |
||
83 | * @param RequestParameters $params Request parameters |
||
84 | * @return string Body of the reCAPTCHA response |
||
85 | */ |
||
86 | public function submit(RequestParameters $params) |
||
87 | { |
||
88 | $errno = 0; |
||
89 | $errstr = ''; |
||
90 | |||
91 | if (false === $this->socket->fsockopen('ssl://' . self::RECAPTCHA_HOST, 443, $errno, $errstr, 30)) { |
||
92 | return self::BAD_REQUEST; |
||
93 | } |
||
94 | |||
95 | $content = $params->toQueryString(); |
||
96 | |||
97 | $request = "POST " . self::SITE_VERIFY_PATH . " HTTP/1.1\r\n"; |
||
98 | $request .= "Host: " . self::RECAPTCHA_HOST . "\r\n"; |
||
99 | $request .= "Content-Type: application/x-www-form-urlencoded\r\n"; |
||
100 | $request .= "Content-length: " . strlen($content) . "\r\n"; |
||
101 | $request .= "Connection: close\r\n\r\n"; |
||
102 | $request .= $content . "\r\n\r\n"; |
||
103 | |||
104 | $this->socket->fwrite($request); |
||
105 | $response = ''; |
||
106 | |||
107 | while (!$this->socket->feof()) { |
||
108 | $response .= $this->socket->fgets(4096); |
||
109 | } |
||
110 | |||
111 | $this->socket->fclose(); |
||
112 | |||
113 | if (0 !== strpos($response, 'HTTP/1.1 200 OK')) { |
||
114 | return self::BAD_RESPONSE; |
||
115 | } |
||
116 | |||
117 | $parts = preg_split("#\n\s*\n#Uis", $response); |
||
118 | |||
119 | return $parts[1]; |
||
120 | } |
||
121 | } |
||
122 |