src/WebBundle/Helper/ProxyHelper.php line 71

Open in your IDE?
  1. <?php
  3. namespace WebBundle\Helper;
  5. /**
  6.  * class: ProxyHelper
  7.  * ssh -p 8105 te@136.243.143.197
  8.  * -----------------------------------------------------
  9.  * Created by MihailShirnin on 05.06.2017.
  10.  * @package WebBundle\Helper
  11.  */
  12. class ProxyHelper
  13. {
  14.     /**
  15.      * Список имен серверов, для удаленной чистки кеша
  16.      * @var array
  17.      */
  18.     public static array $mirrorList = ['site1', 'site3', 'site4'];
  20.     private static array $serverList = [
  21.         'img' => [
  22.             'name' => 'сервер картинок img.tile.expert',
  23.             'host' => [
  24.                 'dev' => '35.158.222.127',
  25.                 'prod' => '35.158.222.127',
  26.             ],
  27.             'port' => '22',
  28.             'user' => 'te',
  29.             'mirror' => null,
  30.         ],
  31.         '8106' => [
  32.             'name' => 'админка 8106',
  33.             'host' => [
  34.                 'dev' => '136.243.143.197',
  35.                 'prod' => '136.243.143.197',
  36.             ],
  37.             'port' => '8106',
  38.             'user' => 'te',
  39.             'mirror' => '0',
  40.         ],
  41.     ];
  43.     public const ADMIN_SERV_ID = '8106';
  45.     private static $rsa = [
  46.         'dev' => 'd:\OSPanel\.ssh\te\id_rsa', // для консоли так /d/OSPanel/.ssh/te/id_rsa
  47.         'prod' => '/home/te/.ssh/id_rsa',
  48.     ];
  49.     public static $error = null;
  51.     /**
  52.      * @return bool
  53.      */
  54.     public static function hasError()
  55.     {
  56.         return boolval(static::$error);
  57.     }
  59.     /**
  60.      * Получаем туннель через ssh2
  61.      * @param int|string $servId указываем ID серверов по их порту
  62.      * @return null|resource
  63.      */
  64.     public static function getConnection($servId)
  65.     {
  66.         $server = static::$serverList[$servId];
  67.         $host = App::isLocEnv() ? $server['host']['dev'] : $server['host']['prod'];
  68.         $rsa = App::isLocEnv() ? static::$rsa['dev'] : static::$rsa['prod'];
  69.         $connection = ssh2_connect($host, $server['port'], ['hostkey' => 'ssh-rsa']);
  71.         if (ssh2_auth_pubkey_file($connection, $server['user'], $rsa . '.pub', $rsa, 'secret')) {
  72.             return $connection;
  73.         }
  74.         static::$error = 'Public Key Authentication Failed';
  75.         return null;
  76.     }
  78.     /**
  79.      * Отправляем SSH команду на указанный сервер
  80.      * @param $servId
  81.      * @param $command
  82.      * @return bool|null|string
  83.      */
  84.     public static function sendCommand($servId, $command)
  85.     {
  86.         $connection = static::getConnection($servId);
  88.         if ($connection) {
  89.             $command = is_array($command) ? implode('; ', $command) : $command;
  90.             $stream = ssh2_exec($connection, $command);
  91.             stream_set_blocking($stream, true);
  92.             $res = fread($stream, 4096);
  93.             fclose($stream);
  95.             return $res;
  96.         }
  98.         return null;
  99.     }
  101.     /**
  102.      * Отправляем файлы по scp
  103.      * @param $servId
  104.      * @param $from
  105.      * @param $to
  106.      * @return bool
  107.      */
  108.     public static function loadFile($servId, $from, $to)
  109.     {
  110.         // фикс для тестирования под WIN
  111.         $from = str_replace(['D:\\', 'C:\\', '\\'], ['/D/', '/C/', '/'], $from);
  112.         $to = str_replace(['D:\\', 'C:\\', '\\'], ['/D/', '/C/', '/'], $to);
  114.         $server = static::$serverList[$servId];
  117.         $host = App::isLocEnv() ? $server['host']['dev'] : $server['host']['prod'];
  118.         $rsa = App::isLocEnv() ? static::$rsa['dev'] : static::$rsa['prod'];
  120.         $command = "scp -r -P {$server['port']} -i {$rsa} {$from} {$server['user']}@{$host}:{$to}";
  122.         system($command);
  124.         return true;
  125.     }
  127.     /**
  128.      * Проверяем на ответ сервера
  129.      * @param      $link
  130.      * @param bool $self
  131.      * @return array
  132.      */
  133.     public static function getHttpCode($link, $self = false)
  134.     {
  135.         $ch = curl_init();
  136.         curl_setopt($ch, CURLOPT_URL, $link);
  138.         curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/5.0 (compatible; CrawlBot/1.0.0)');
  139.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  140.         curl_setopt($ch, CURLOPT_HEADER, true);
  141.         curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 15);
  142.         curl_setopt($ch, CURLOPT_TIMEOUT, 15);
  143.         curl_setopt($ch, CURLOPT_ENCODING, "");
  144.         curl_setopt($ch, CURLOPT_AUTOREFERER, true);
  145.         curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  146.         curl_setopt($ch, CURLOPT_MAXREDIRS, 15);
  148.         curl_exec($ch);
  149.         $info = curl_getinfo($ch);
  150.         curl_close($ch);
  152.         $code = $info['http_code'];
  153.         $url = !empty($info['redirect_url']) ? $info['redirect_url'] : null;
  155.         if ($code == 301 or $code == 302) {
  156.             if (!$self) {
  157.                 $http = self::getHttpCode($info['redirect_url'], true);
  158.                 if ($http['code'] != 200) {
  159.                     $code = $http['code'];
  160.                     $url = $http['url'];
  161.                 }
  162.             }
  164.         }
  166.         return [
  167.             'code' => $code,
  168.             'url' => $url,
  169.         ];
  170.     }
  172.     public static function getFullPathByRelative(string $relativePath): string
  173.     {
  174.         return rtrim(ROOT_DIR, DIRECTORY_SEPARATOR)
  175.             . DIRECTORY_SEPARATOR
  176.             . ltrim($relativePath, DIRECTORY_SEPARATOR);
  177.     }
  178. }