<?php
/**
- * @copyright Copyright (C) 2010-2021, the Friendica project
+ * @copyright Copyright (C) 2010-2022, the Friendica project
*
* @license GNU AGPL version 3 or any later version
*
*/
class HTTPInputData
{
- public static function process()
+ /** @var array The $_SERVER variable */
+ protected $server;
+
+ public function __construct(array $server)
{
- $content_parts = explode(';', $_SERVER['CONTENT_TYPE'] ?? 'application/x-www-form-urlencoded');
+ $this->server = $server;
+ }
+
+ /**
+ * Process the PHP input stream and creates an array with its content
+ *
+ * @return array|array[]
+ */
+ public function process(): array
+ {
+ $content_parts = explode(';', $this->server['CONTENT_TYPE'] ?? 'application/x-www-form-urlencoded');
$boundary = '';
$encoding = '';
}
if ($content_type == 'multipart/form-data') {
- return self::fetchFromMultipart($boundary);
+ return $this->fetchFromMultipart($boundary);
}
// can be handled by built in PHP functionality
- $content = file_get_contents('php://input');
+ $content = static::getPhpInputContent();
- $variables = json_decode($content);
+ $variables = json_decode($content, true);
if (empty($variables)) {
parse_str($content, $variables);
return ['variables' => $variables, 'files' => []];
}
- private static function fetchFromMultipart(string $boundary)
+ private function fetchFromMultipart(string $boundary): array
{
$result = ['variables' => [], 'files' => []];
- $stream = fopen('php://input', 'rb');
+ $stream = static::getPhpInputStream();
$sanity = fgets($stream, strlen($boundary) + 5);
continue;
}
- $result = self::parseRawHeader($stream, $raw_headers, $boundary, $result);
+ $result = $this->parseRawHeader($stream, $raw_headers, $boundary, $result);
$raw_headers = '';
}
return $result;
}
- private static function parseRawHeader($stream, string $raw_headers, string $boundary, array $result)
+ private function parseRawHeader($stream, string $raw_headers, string $boundary, array $result)
{
$variables = $result['variables'];
$files = $result['files'];
if (strpos($header, ':') === false) {
continue;
}
- list($name, $value) = explode(':', $header, 2);
+ [$name, $value] = explode(':', $header, 2);
$headers[strtolower($name)] = ltrim($value, ' ');
}
$filename = $matches[4] ?? '';
if (!empty($filename)) {
- $files[$name] = self::fetchFileData($stream, $boundary, $headers, $filename);
+ $files[$name] = static::fetchFileData($stream, $boundary, $headers, $filename);
return ['variables' => $variables, 'files' => $files];
} else {
- $variables = self::fetchVariables($stream, $boundary, $name, $variables);
+ $variables = $this->fetchVariables($stream, $boundary, $headers, $name, $variables);
}
return ['variables' => $variables, 'files' => $files];
}
- private static function fetchFileData($stream, string $boundary, array $headers, string $filename)
+ protected function fetchFileData($stream, string $boundary, array $headers, string $filename)
{
$error = UPLOAD_ERR_OK;
if ($fileHandle === false) {
$error = UPLOAD_ERR_CANT_WRITE;
} else {
- $lastLine = NULL;
+ $lastLine = null;
while (($chunk = fgets($stream, 8096)) !== false && strpos($chunk, $boundary) !== 0) {
- if ($lastLine !== NULL) {
- if (fwrite($fileHandle, $lastLine) === false) {
+ if ($lastLine !== null) {
+ if (!fwrite($fileHandle, $lastLine)) {
$error = UPLOAD_ERR_CANT_WRITE;
break;
}
$lastLine = $chunk;
}
- if ($lastLine !== NULL && $error !== UPLOAD_ERR_CANT_WRITE) {
- if (fwrite($fileHandle, rtrim($lastLine, "\r\n")) === false) {
+ if ($lastLine !== null && $error !== UPLOAD_ERR_CANT_WRITE) {
+ if (!fwrite($fileHandle, rtrim($lastLine, "\r\n"))) {
$error = UPLOAD_ERR_CANT_WRITE;
}
}
];
}
- private static function fetchVariables($stream, string $boundary, string $name, array $variables)
+ private function fetchVariables($stream, string $boundary, array $headers, string $name, array $variables)
{
$fullValue = '';
- $lastLine = NULL;
+ $lastLine = null;
while (($chunk = fgets($stream)) !== false && strpos($chunk, $boundary) !== 0) {
- if ($lastLine !== NULL) {
+ if ($lastLine !== null) {
$fullValue .= $lastLine;
}
$lastLine = $chunk;
}
- if ($lastLine !== NULL) {
+ if ($lastLine !== null) {
$fullValue .= rtrim($lastLine, "\r\n");
}
$tmp = [];
parse_str($fullValue, $tmp);
- return self::expandVariables(explode('[', $name), $variables, $tmp);
+ return $this->expandVariables(explode('[', $name), $variables, $tmp);
}
- private static function expandVariables(array $names, $variables, array $values)
+ private function expandVariables(array $names, $variables, array $values)
{
if (!is_array($variables)) {
return $values;
if ($name === '') {
$variables[] = reset($values);
} elseif (isset($variables[$name]) && isset($values[$name])) {
- $variables[$name] = self::expandVariables($names, $variables[$name], $values[$name]);
+ $variables[$name] = $this->expandVariables($names, $variables[$name], $values[$name]);
} elseif (isset($values[$name])) {
$variables[$name] = $values[$name];
}
return $variables;
}
+
+ /**
+ * Returns the current PHP input stream
+ * Mainly used for test doubling
+ *
+ * @return false|resource
+ */
+ protected function getPhpInputStream()
+ {
+ return fopen('php://input', 'rb');
+ }
+
+ /**
+ * Returns the content of the current PHP input
+ * Mainly used for test doubling
+ *
+ * @return false|string
+ */
+ protected function getPhpInputContent()
+ {
+ return file_get_contents('php://input');
+ }
}
-?>