182 lines
7.7 KiB
PHP
182 lines
7.7 KiB
PHP
<?php
|
|
|
|
namespace App\Libraries\MySocket\Cloudflare;
|
|
|
|
use App\Models\Cloudflare\ZoneModel;
|
|
use App\Libraries\MySocket\CloudflareSocket;
|
|
use App\Entities\Cloudflare\ZoneEntity;
|
|
use App\Entities\Cloudflare\AuthEntity;
|
|
use App\Entities\Cloudflare\AccountEntity;
|
|
|
|
class ZoneSocket extends CloudflareSocket
|
|
{
|
|
private $_model = null;
|
|
private $_account_entity = null;
|
|
public function __construct(AccountEntity $account_entity)
|
|
{
|
|
$this->_account_entity = $account_entity;
|
|
$auth_entity = $this->getAuthModel()->getEntityByPK($this->_account_entity->getParent());
|
|
if ($auth_entity === null) {
|
|
throw new \Exception("해당 계정정보를 찾을수 없습니다.");
|
|
}
|
|
parent::__construct($auth_entity);
|
|
}
|
|
protected function getModel(): ZoneModel
|
|
{
|
|
if ($this->_model === null) {
|
|
$this->_model = new ZoneModel();
|
|
}
|
|
return $this->_model;
|
|
}
|
|
protected function getArrayByResult($result, array $formDatas = []): array
|
|
{
|
|
$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;
|
|
return $formDatas;
|
|
}
|
|
//Cfzone에서 가져온 값을 zone에 setting
|
|
protected function getCFSetting(ZoneEntity $entity): ZoneEntity
|
|
{
|
|
$cf = $this->getClient()->patch('zones/' . $entity->getPK() . '/settings/');
|
|
$cf = json_decode($cf->getBody());
|
|
if (!$cf->success) {
|
|
throw new \Exception("Zone:" . __FUNCTION__ . "에서 실패:\n" . var_export($cf, true));
|
|
}
|
|
foreach ($cf->result as $cf) {
|
|
switch ($cf->id) {
|
|
case 'development_mode':
|
|
$entity->development_mode = $cf->value;
|
|
break;
|
|
case 'ipv6':
|
|
$entity->ipv6 = $cf->value;
|
|
break;
|
|
case 'security_level':
|
|
$entity->security_level = $cf->value;
|
|
break;
|
|
}
|
|
}
|
|
return $entity;
|
|
}
|
|
protected function setCFSetting(ZoneEntity $entity, string $field, string $value): ZoneEntity
|
|
{
|
|
$cf = $this->getClient()->patch('zones/' . $entity->getPK() . '/settings/' . $field, array('value' => $value));
|
|
$cf = json_decode($cf->getBody());
|
|
if (!$cf->success || $cf->result->id !== $field) {
|
|
throw new \Exception("Zone:" . __FUNCTION__ . "에서 {$field}->{$value} 변경실패:\n" . var_export($cf, true));
|
|
}
|
|
//최종 결과값은 body->result->id='필드명',body->result->value='on/off'이런식으로 받음
|
|
return $cf->result->value;
|
|
}
|
|
public function create(string $domain, bool $jump_start = false): ZoneEntity
|
|
{
|
|
//Socket용
|
|
//도메인생성을 위해 Cloudflare에 전송
|
|
$cf = $this->getClient()->post('zones/', [
|
|
'accountId' => $this->_account_entity->getPK(),
|
|
'name' => $domain,
|
|
'jump_start' => $jump_start,
|
|
]);
|
|
$cf = json_decode($cf->getBody());
|
|
if (!$cf->success) {
|
|
throw new \Exception("Zone:" . __FUNCTION__ . "에서 실패:\n" . var_export($cf, true));
|
|
}
|
|
//DB생성
|
|
$formDatas = $this->getArrayByResult($cf->result);
|
|
$entity = $this->getModel()->create($formDatas);
|
|
|
|
//초기화값 추가셋팅 ipv6 , development_mode , security_level
|
|
$formDatas = [];
|
|
$formDatas['ipv6'] = $this->setCFSetting($entity, 'ipv6', 'off');
|
|
$formDatas['development_mode'] = $this->setCFSetting($entity, 'development_mode', 'off');
|
|
$formDatas['security_level'] = $this->setCFSetting($entity, 'security_level', 'medium');
|
|
//DB수정
|
|
return $this->getModel()->modify($entity, $formDatas);
|
|
}
|
|
public function modify(ZoneEntity $entity, array $formDatas): ZoneEntity
|
|
{
|
|
//modify,toggle,batchjob 사용 셋팅 ipv6 , //development_mode , //security_level
|
|
$formDatas = [];
|
|
foreach ($formDatas as $field => $value) {
|
|
$formDatas[$field] = $this->setCFSetting($entity, $field, $value);
|
|
}
|
|
//DB수정
|
|
return $this->getModel()->modify($entity, $formDatas);
|
|
}
|
|
public function delete(ZoneEntity $entity): void
|
|
{
|
|
$cf = $this->getClient()->delete('zones/' . $entity->getPK());
|
|
$cf = json_decode($cf->getBody());
|
|
if (!$cf->success) {
|
|
throw new \Exception("Zone:" . __FUNCTION__ . "에서 실패:\n" . var_export($cf, true));
|
|
}
|
|
//DB삭제
|
|
$this->getModel()->where(ZoneModel::PK, $entity->getPK());
|
|
$this->getModel()->delete();
|
|
}
|
|
public function sync(ZoneEntity $entity): void
|
|
{
|
|
//기존 Sync형태
|
|
// $cf = $this->getClient()->get('zones/' . $entity->getPK());
|
|
// $cf = json_decode($cf->getBody());
|
|
// if (!$cf->success) {
|
|
// throw new \Exception("Zone:" . __FUNCTION__ . "에서 실패:\n" . var_export($cf, true));
|
|
// }
|
|
// log_message("notice", "Zone:" . __FUNCTION__ . "=> 작업을 완료하였습니다.");
|
|
// return new ZoneEntity($this->getArrayByResult($cf->result));
|
|
//Async형태
|
|
$promise = $this->getClient()->getAsync("zones/{$entity->getPK()}");
|
|
$promise->then(
|
|
onFulfilled: function ($response) use ($entity): ZoneEntity {
|
|
$record = json_decode($response->getBody(), true)['result'];
|
|
//DB수정
|
|
return $this->getModel()->modify($entity, $this->getArrayByResult($record));
|
|
},
|
|
onRejected: function ($error) {
|
|
log_message('error', 'Failed to fetch DNS records: ' . $error->getMessage());
|
|
// throw new \Exception('Failed to fetch DNS records: ' . $error->getMessage());
|
|
}
|
|
);
|
|
$promise->wait();
|
|
}
|
|
//Reload
|
|
public function reload(): void
|
|
{
|
|
log_message("notice", "-----{$this->_account_entity->getTitle()} 처리 시작-----");
|
|
$entity_uids = [];
|
|
$results = $this->reload_procedure('zones');
|
|
foreach ($results as $result) {
|
|
$formDatas = $this->getArrayByResult($result);
|
|
$entity = $this->getModel()->modify($this->getModel()->getEntity(), $formDatas);
|
|
$entity_uids[] = $entity->getPK();
|
|
}
|
|
//부모키를 기준으로 CF에 존재하지 않는 데이터 삭제용
|
|
$this->getModel()->where(ZoneModel::PARENT, $this->_account_entity);
|
|
$this->getModel()->whereNotIn(ZoneModel::PK, $entity_uids);
|
|
$this->getModel()->delete();
|
|
log_message("notice", "-----{$this->_account_entity->getTitle()} 처리[" . count($results) . "개] 완료-----");
|
|
}
|
|
}
|