cfmgrv4/app/Services/Cloudflare/ZoneService.php

<?php

namespace App\Services\Cloudflare;

use App\Entities\Cloudflare\AccountEntity;
use App\Entities\Cloudflare\ZoneEntity;
use App\Models\Cloudflare\ZoneModel;
use App\Services\MyLogService;
use App\Traits\MylogTrait;

class ZoneService extends CloudflareService
{
    use MylogTrait;
    private ?AccountEntity $_parent_entity = null;
    private ?ZoneModel $_model = null;
    private array $_setting_fields = [
        'development_mode' => 'off',
        'ipv6' => 'off',
        'security_level' => 'medium',
        'ssl' => 'flexible',
        'always_use_https' => 'off'
    ];

    public function __construct()
    {
        parent::__construct("Zone", class_path: "Zone");
    }

    private function getParentEntity(): AccountEntity
    {
        if ($this->_parent_entity === null) {
            throw new \Exception(__FUNCTION__ . "에서 부모정보가 없습니다.");
        }
        return $this->_parent_entity;
    }

    private function setParentEntity(AccountEntity $parent_entity): void
    {
        $this->_parent_entity = $parent_entity;
        $auth_entity = $this->getAuthModel()->getEntityByPK($this->getParentEntity()->getParent());
        if ($auth_entity === null) {
            throw new \Exception("해당 계정정보를 찾을수 없습니다.");
        }
        $this->setAuthEntity($auth_entity);
    }

    public function getModel(): ZoneModel
    {
        if ($this->_model === null) {
            $this->_model = new ZoneModel();
        }
        return $this->_model;
    }

    protected function getArrayByResult(\stdClass $result, array $formDatas = []): array
    {
        // log_message("debug",  var_export($result, true));
        $formDatas[ZoneModel::PK] = $result->id;
        $formDatas[ZoneModel::PARENT] = $result->account->id;
        $formDatas[ZoneModel::TITLE] = $result->name;
        $formDatas['status'] = $result->status;
        //$formDatas['type'] = $result->type; // full 이게있는데 뭔지 잘모름
        $formDatas['name_servers'] = 'none';
        if (isset($result->name_servers)) {
            $formDatas['name_servers'] = is_array($result->name_servers) ?
                implode(',', $result->name_servers) : $result->name_servers;
        }
        $formDatas['original_name_servers'] = 'none';
        if (isset($result->original_name_servers)) {
            $formDatas['original_name_servers'] = is_array($result->original_name_servers) ?
                implode(',', $result->original_name_servers) : $result->original_name_servers;
        }
        // $formDatas['updated_at'] = $result->modified_on;
        $formDatas['updated_at'] = date("Y-m-d H:i:s");
        $formDatas['created_at'] = $result->created_on;
        $formDatas['plan'] = $result->plan->name;
        // log_message("debug", var_export($formDatas, true));
        return $formDatas;
    }

    //Cfzone에서 가져온 값을 zone에 setting
    private function getCFSetting(string $uid, array $formDatas = []): array
    {
        $response = $this->getMySocket()->get('zones/' . $uid . '/settings');
        $body = json_decode($response->getBody());
        // log_message("debug", var_export($body, true));
        foreach ($body->result as $result) {
            if (in_array($result->id, array_keys($this->_setting_fields))) {
                $formDatas[($result->id === 'ssl') ? 'ssl_mode' : $result->id] = $result->value;
            }
        }
        // log_message("debug", var_export($cf, return: true));
        return $formDatas;
    }

    private function setCFSetting(string $uid, string $field, string $value): string
    {
        $field = ($field === 'ssl_mode') ? 'ssl' : $field;
        $response = $this->getMySocket()->patch('zones/' . $uid . '/settings/' . $field, ['value' => $value]);
        $body = json_decode($response->getBody());
        //최종 결과값은 body->result->id='필드명',body->result->value='on/off'이런식으로 받음
        MyLogService::add("debug", __FUNCTION__ . "에서 {$field}:{$body->result->value}을 설정하였습니다.");
        return $body->result->value;
    }

    public function create(AccountEntity $parent_entity, string $domain, bool $jump_start = false): ZoneEntity
    {
        //부모데이터정의
        $this->setParentEntity($parent_entity);
        //Socket용
        //도메인생성을 위해 Cloudflare에 전송
        $datas    = [
            'accountId'  => $this->getParentEntity()->getPK(),
            'name'       => $domain,
            'jump_start' => $jump_start,
        ];
        $response = $this->getMySocket()->post('zones/', $datas);
        $body     = json_decode($response->getBody());
        $formDatas = $this->getArrayByResult($body->result);
        //Zone Setting Fields: ipv6 , development_mode , security_level
        foreach ($this->_setting_fields as $field => $default) {
            $formDatas[$field] = $this->setCFSetting($formDatas[ZoneModel::PK], $field, $default);
        }
        //DB생성
        $entity = $this->getModel()->create($formDatas);
        // log_message("debug", $this->getModel()->getLastQuery());
        //생성값 formDatas Log남기기
        $this->add_MylogTrait(__FUNCTION__, $formDatas, $entity);
        return $entity;
    }

    public function modify(AccountEntity $parent_entity, ZoneEntity $entity, array $formDatas): ZoneEntity
    {
        //부모데이터정의
        $this->setParentEntity($parent_entity);
        //Zone Setting Fields: ipv6 , development_mode , security_level
        foreach ($formDatas as $field => $value) {
            $formDatas[$field] = $this->setCFSetting($entity->getPK(), $field, $value);
        }
        //변경전 entity 값, 변경값 formDatas Log남기기
        $this->add_MylogTrait(__FUNCTION__, $formDatas, $entity);
        //DB수정
        $entity = $this->getModel()->modify($entity, $formDatas);
        // log_message("debug", $this->getModel()->getLastQuery());
        return $entity;
    }

    public function delete(AccountEntity $parent_entity, ZoneEntity $entity): ZoneEntity
    {
        //부모데이터정의
        $this->setParentEntity($parent_entity);
        $this->getMySocket()->delete("zones/{$entity->getPK()}");
        //DB삭제
        $this->getModel()->delete($entity->getPK());
        //삭제전 entity 값 Log남기기
        $this->add_MylogTrait(__FUNCTION__, [], $entity);
        // log_message("debug", $this->getModel()->getLastQuery());
        return $entity;
    }

    public function sync(AccountEntity $parent_entity, ZoneEntity $entity): ZoneEntity
    {
        $this->setParentEntity($parent_entity);
        $response = $this->getMySocket()->get("zones/{$entity->getPK()}");
        $body = json_decode($response->getBody());
        $formDatas = $this->getArrayByResult($body->result);
        // log_message("debug", var_export($formDatas, true));
        $formDatas = $this->getCFSetting($formDatas[ZoneModel::PK], $formDatas);
        // log_message("debug", var_export($formDatas, true));
        $entity = $this->getModel()->modify($entity, $formDatas);
        // log_message("debug", $this->getModel()->getLastQuery());
        return $entity;
    }

    public function expired(AccountEntity $parent_entity, ZoneEntity $entity): ZoneEntity
    {
        $this->setParentEntity($parent_entity);
        $response  = $this->getMySocket()->get("accounts/{$entity->getParent()}/registrar/domains/{$entity->getTitle()}");
        $body = json_decode($response->getBody());
        $formDatas = ['expire_date', $body->result->expires_at];
        // log_message("debug", var_export($formDatas, true));
        $entity = $this->getModel()->modify($entity, $formDatas);
        // log_message("debug", $this->getModel()->getLastQuery());
        return $entity;
    }

    //Reload
    public function reload(AccountEntity $parent_entity): array
    {
        //부모데이터정의
        $this->setParentEntity($parent_entity);
        log_message("notice", "\n-----------Account {$this->getParentEntity()->getTitle()}의 Zone처리 시작-----------");
        $entities = [];
        try {
            $results = $this->reload_procedure("zones");
            $cnt = 1;
            $total = count($results);
            if ($total > 0) {
                foreach ($results as $result) {
                    if (!is_object($result) || get_class($result) !== 'stdClass') {
                        log_message("error", "Zone: result is not a stdClass:\n" . var_export($result, true) . "\n");
                        continue;
                    }
                    if (isset($result->status) && $result->status === 'active') {
                        $formDatas = $this->getArrayByResult($result);
                        // $formDatas = $this->getCFSetting($formDatas[ZoneModel::PK], $formDatas);
                        $entity = $this->getModel()->modify(new ZoneEntity(), $formDatas);
                        log_message("debug", "{$cnt}/{$total} => {$entity->getTitle()} Zone 처리,[{$this->getMySocket()::$_request}]");
                        $entities[$entity->getPK()] = $entity;
                        $cnt++;
                    } else {
                        log_message("error", "Zone is abnormal status:\n" . var_export($result, true) . "\n");
                    }
                }
                //부모키를 기준으로 CF에 존재하지 않는 데이터 삭제용
                $this->getModel()->where(ZoneModel::PARENT, $this->getParentEntity()->getPK());
                $this->getModel()->whereNotIn(ZoneModel::PK, array_keys($entities));
                $this->getModel()->delete();
                // log_message("debug", $this->getModel()->getLastQuery());
            }
        } catch (\Exception $e) {
            log_message("error", $e->getMessage());
            throw new \Exception($e->getMessage());
        }
        log_message("notice", "\n----------Account {$this->getParentEntity()->getTitle()}의 Zone 처리[" . count($entities) . "개] 완료-----------");
        return $entities;
    }
}