[ticket/13358] Add file_downloader as replacement for get_remote_file

PHPBB3-13358

phpBB/config/services.yml

@@ -109,6 +109,11 @@ services:
     filesystem:
         class: phpbb\filesystem
 
+    file_downloader:
+        class: phpbb\file_downloader
+        arguments:
+            - @user
+
     http_kernel:
         class: Symfony\Component\HttpKernel\HttpKernel
         arguments:

phpBB/phpbb/file_downloader.php

@@ -0,0 +1,137 @@
+<?php
+/**
+*
+* This file is part of the phpBB Forum Software package.
+*
+* @copyright (c) phpBB Limited <https://www.phpbb.com>
+* @license GNU General Public License, version 2 (GPL-2.0)
+*
+* For full copyright and license information, please see
+* the docs/CREDITS.txt file.
+*
+*/
+
+namespace phpbb;
+
+class file_downloader
+{
+	/** @var \phpbb\user */
+	protected $user;
+
+	/** @var string Error string */
+	public $error_string = '';
+
+	/** @var int Error number */
+	public $error_number = 0;
+
+	/**
+	 * Constructor
+	 *
+	 * @param \phpbb\user $user phpBB user object
+	 */
+	public function __construct(user $user)
+	{
+		$this->user = $user;
+	}
+
+	/**
+	 * Retrieve contents from remotely stored file
+	 *
+	 * @param string	$host			File host
+	 * @param string	$directory		Directory file is in
+	 * @param string	$filename		Filename of file to retrieve
+	 * @param int		$port			Port to connect to; default: 80
+	 * @param int		$timeout		Connection timeout in seconds; default: 6
+	 *
+	 * @return mixed File data as string if file can be read and there is no
+	 *			timeout, false if there were errors or the connection timed out
+	 */
+	function get($host, $directory, $filename, $port = 80, $timeout = 6)
+	{
+		if ($socket = @fsockopen($host, $port, $this->error_number, $this->error_string, $timeout))
+		{
+			@fputs($socket, "GET $directory/$filename HTTP/1.0\r\n");
+			@fputs($socket, "HOST: $host\r\n");
+			@fputs($socket, "Connection: close\r\n\r\n");
+
+			$timer_stop = time() + $timeout;
+			stream_set_timeout($socket, $timeout);
+
+			$file_info = '';
+			$get_info = false;
+
+			while (!@feof($socket))
+			{
+				if ($get_info)
+				{
+					$file_info .= @fread($socket, 1024);
+				}
+				else
+				{
+					$line = @fgets($socket, 1024);
+					if ($line == "\r\n")
+					{
+						$get_info = true;
+					}
+					else if (stripos($line, '404 not found') !== false)
+					{
+						$this->error_string = $this->user->lang('FILE_NOT_FOUND', $filename);
+						return false;
+					}
+				}
+
+				$stream_meta_data = stream_get_meta_data($socket);
+
+				if (!empty($stream_meta_data['timed_out']) || time() >= $timer_stop)
+				{
+					$this->error_string = $this->user->lang['FSOCK_TIMEOUT'];
+					return false;
+				}
+			}
+			@fclose($socket);
+		}
+		else
+		{
+			if ($this->error_string)
+			{
+				$this->error_string = utf8_convert_message($this->error_string);
+				return false;
+			}
+			else
+			{
+				$this->error_string = $this->user->lang['FSOCK_DISABLED'];
+				return false;
+			}
+		}
+
+		return $file_info;
+	}
+
+	/**
+	 * Set error string
+	 *
+	 * @param string $error_string Error string
+	 *
+	 * @return self
+	 */
+	public function set_error_string(&$error_string)
+	{
+		$this->error_string = &$error_string;
+
+		return $this;
+	}
+
+	/**
+	 * Set error number
+	 *
+	 * @param int $error_number Error number
+	 *
+	 * @return self
+	 */
+	public function set_error_number(&$error_number)
+	{
+		$this->error_number = &$error_number;
+
+		return $this;
+	}
+}