CloudProvisioning::azureProvisioning() - Code Metrics - Inspection of "Доработал автопровижинг для Google облака." - mikopbx/Core - Measure and Improve Code Quality continuously with Scrutinizer

Passed
Push — develop ( bce914...037e9d )

by Портнов
created 2021-06-25 10:22 UTC
CloudProvisioning::azureProvisioning() A

↳ Parent: CloudProvisioning
Complexity

Conditions	4
Paths	5
Size

Total Lines	66
Code Lines	53
Duplication

Lines	0
Ratio	0 %
Importance

Changes	1
Bugs	0	Features	0
Metric	Value
eloc	53
c	1
b	0
f	0
dl	0
loc	66
rs	9.0254
cc	4
nc	5
nop	0
How to fix Long Method

<?php
/*
 * MikoPBX - free phone system for small business
 * Copyright © 2017-2021 Alexey Portnov and Nikolay Beketov
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License along with this program.
 * If not, see <https://www.gnu.org/licenses/>.
 */

namespace MikoPBX\Core\System;

use MikoPBX\Common\Models\LanInterfaces;
use MikoPBX\Common\Models\PbxSettings;
use MikoPBX\Core\System\Configs\SSHConf;

class CloudProvisioning
{
    public const PBX_SETTING_KEY = 'CloudProvisioning';
    public static function start():void
    {
        if(PbxSettings::findFirst('key="'.self::PBX_SETTING_KEY.'"')){
            // Уже отработали ранее.
            return;
        }
        $cp = new self();
        $resultProvisioning = $cp->googleProvisioning();
        if(!$resultProvisioning){
            $resultProvisioning = $cp->azureProvisioning();
        }

        $setting = PbxSettings::findFirst('key="'.self::PBX_SETTING_KEY.'"');
        if(!$setting){
            $setting = new PbxSettings();
            $setting->key = self::PBX_SETTING_KEY;
        }
        $setting->value = $resultProvisioning ? '1' : '0';
        $setting->save();
        unset($setting);
    }

    private function updateSshPassword(string $data=''):void{
        if(empty($data)){
            $data = md5(time());
        }
        $this->updatePbxSettings('SSHPassword', $data);
        $confSsh = new SSHConf();
        $confSsh->updateShellPassword();
    }

    /**
     * Обновление пароля к SSH.
     * @param $keyName
     * @param $data
     */
    private function updatePbxSettings($keyName, $data):void{
        $setting = PbxSettings::findFirst('key="'.$keyName.'"');
        if(!$setting){
            $setting = new PbxSettings();
            $setting->key = $keyName;
        }
        $setting->value = $data;
        $result = $setting->save();
        if($result){
            Util::sysLogMsg(__CLASS__, "Update $keyName ... ");
        }else{
            Util::sysLogMsg(__CLASS__, "FAIL Update $keyName ... ");
        }
        unset($setting);
    }

    /**
     * Обновление ключей ssh.
     * @param string $data
     */
    private function updateSSHKeys(string $data):void{
        if(empty($data)){
            return;
        }
        $this->updatePbxSettings('SSHAuthorizedKeys', $data);
    }

    /**
     * Обновление имени хост.
     */
    private function updateLanSettings($hostname, $extipaddr):void{
        /** @var LanInterfaces $lanData */
        $lanData = LanInterfaces::findFirst();
        if($lanData){

            if(!empty($extipaddr)){
                $lanData->extipaddr = $extipaddr;
                $lanData->topology  = 'private';
            }
            if(!empty($hostname)){
                $lanData->hostname  = $hostname;
            }
            $result = $lanData->save();
            if($result){
                Util::sysLogMsg(__CLASS__, 'Update LAN... '.$hostname.'  '. $extipaddr);
            }else{
                Util::sysLogMsg(__CLASS__, 'FAIL Update LAN... '.$hostname.'  '. $extipaddr);
            }
        }else{
            Util::sysLogMsg(__CLASS__, 'LAN not found... '.$hostname.'  '. $extipaddr);
        }
    }

    /**
     * Настройка машины для Google Claod.
     */
    public function googleProvisioning():bool
    {
        $curl    = curl_init();
        $url     = 'http://metadata.google.internal/computeMetadata/v1/instance/?recursive=true';
        curl_setopt($curl, CURLOPT_URL, $url);
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($curl, CURLOPT_TIMEOUT, 1);
        curl_setopt($curl, CURLOPT_HTTPHEADER, ['Metadata-Flavor:Google']);
        $resultRequest = curl_exec($curl);
        $http_code     = (int)curl_getinfo($curl, CURLINFO_HTTP_CODE);
        curl_close($curl);
        if($http_code === 0){
            return false;
        }
        $data = json_decode($resultRequest, true);
        $data = json_decode(/** @scrutinizer ignore-type */ $resultRequest, true);
        $this->updateSSHKeys($data['attributes']['ssh-keys']??'');

        $hostname = $data['name']??'';
        $extipaddr= $data['networkInterfaces'][0]['accessConfigs'][0]['externalIp']??'';
        $this->updateLanSettings($hostname, $extipaddr);
        $this->updateSshPassword();
        return true;
    }

    /**
     * Настройка машины для Azure Claod.
     */
    public function azureProvisioning():bool
    {
        $baseUrl = 'http://168.63.129.16/machine';
        $timeout = 4;

        $curl = curl_init();
        $url  = "{$baseUrl}?comp=goalstate";
        curl_setopt($curl, CURLOPT_URL, $url);
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($curl, CURLOPT_TIMEOUT, $timeout);
        curl_setopt($curl, CURLOPT_HTTPHEADER, ['x-ms-version: 2012-11-30']);
        $resultRequest = curl_exec($curl);
        $http_code     = (int)curl_getinfo($curl, CURLINFO_HTTP_CODE);
        curl_close($curl);

        if($http_code === 0){
            $setting = new PbxSettings();
            $setting->key = self::PBX_SETTING_KEY;
            $setting->save();
            $setting->value = '0';
            unset($setting);
            // It is not azure;
            return false;
        }

        $xml = simplexml_load_string($resultRequest);
        $xml = simplexml_load_string(/** @scrutinizer ignore-type */ $resultRequest);
        $xmlDocument = $this->getAzureXmlResponse($xml->Container->ContainerId, $xml->Container->RoleInstanceList->RoleInstance->InstanceId);
        $url="{$baseUrl}?comp=health";
        $headers = [
            'x-ms-version: 2012-11-30',
            'x-ms-agent-name: WALinuxAgent',
            'Content-Type: text/xml;charset=utf-8',
        ];

        $curl = curl_init();
        curl_setopt($curl, CURLOPT_URL, $url);
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($curl, CURLOPT_TIMEOUT, $timeout);
        curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);
        curl_setopt($curl, CURLOPT_POST, true);
        curl_setopt($curl, CURLOPT_POSTFIELDS, $xmlDocument);

        curl_exec($curl);
        $http_code     = (int)curl_getinfo($curl, CURLINFO_HTTP_CODE);
        $result = false;
        if($http_code === 200){
            $result = true;
        }
        $curl = curl_init();
        $url  = "http://169.254.169.254/metadata/instance?api-version=2020-09-01";
        curl_setopt($curl, CURLOPT_URL, $url);
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($curl, CURLOPT_TIMEOUT, $timeout);
        curl_setopt($curl, CURLOPT_HTTPHEADER, ['Metadata:true']);
        $resultRequest = curl_exec($curl);
        curl_close($curl);

        $arrKeys = [];
        $jsonData = json_decode($resultRequest, true);
        $jsonData = json_decode(/** @scrutinizer ignore-type */ $resultRequest, true);
        $publicKeys = $jsonData['compute']['publicKeys']??[];
        foreach ($publicKeys as $keeData){
            $arrKeys[]= $keeData['keyData'];
        }
        $this->updateSSHKeys(implode(PHP_EOL, $arrKeys));
        $this->updateSshPassword();
        return $result;
    }

    /**
     * Возвращает строку XML для ответа о готовкности машины.
     * @param $containerId
     * @param $instanceId
     * @return string
     */
    private function getAzureXmlResponse($containerId, $instanceId):string
    {
        return '<Health>
  <GoalStateIncarnation>1</GoalStateIncarnation>
  <Container>
    <ContainerId>'.$containerId.'</ContainerId>
    <RoleInstanceList>
      <Role>
        <InstanceId>'.$instanceId.'</InstanceId>
        <Health>
          <State>Ready</State>
        </Health>
      </Role>
    </RoleInstanceList>
  </Container>
</Health>';
    }
}
mikopbx / Core

Push — develop ( bce914...037e9d )

CloudProvisioning::azureProvisioning() A

Complexity

Size

Duplication

Importance

How to fix Long Method

Long Method

Duplication Side-by-Side

Filter issues like
