@@ -1,9 +1,9 @@ |
||
| 1 | 1 | <?php |
| 2 | 2 | |
| 3 | -require_once __DIR__.'/../vendor/autoload.php'; |
|
| 3 | +require_once __DIR__ . '/../vendor/autoload.php'; |
|
| 4 | 4 | |
| 5 | 5 | // JsonResolver created and provided with path to file with json dns records |
| 6 | -$jsonResolver = new yswery\DNS\Resolver\JsonResolver([__DIR__.'/record.json']); |
|
| 6 | +$jsonResolver = new yswery\DNS\Resolver\JsonResolver([__DIR__ . '/record.json']); |
|
| 7 | 7 | |
| 8 | 8 | // System resolver acting as a fallback to the JsonResolver |
| 9 | 9 | $systemResolver = new yswery\DNS\Resolver\SystemResolver(); |
@@ -73,7 +73,7 @@ |
||
| 73 | 73 | $this->loop = \React\EventLoop\Factory::create(); |
| 74 | 74 | $factory = new \React\Datagram\Factory($this->loop); |
| 75 | 75 | |
| 76 | - $factory->createServer($this->ip.':'.$this->port)->then(function (Socket $server) { |
|
| 76 | + $factory->createServer($this->ip . ':' . $this->port)->then(function(Socket $server) { |
|
| 77 | 77 | $this->dispatcher->dispatch(Events::SERVER_START, new ServerStartEvent($server)); |
| 78 | 78 | $server->on('message', [$this, 'onMessage']); |
| 79 | 79 | }); |
@@ -170,9 +170,9 @@ |
||
| 170 | 170 | if (is_array($this->rdata)) { |
| 171 | 171 | $rdata = '('; |
| 172 | 172 | foreach ($this->rdata as $key => $value) { |
| 173 | - $rdata .= $key.': '.$value.', '; |
|
| 173 | + $rdata .= $key . ': ' . $value . ', '; |
|
| 174 | 174 | } |
| 175 | - $rdata = rtrim($rdata, ', ').')'; |
|
| 175 | + $rdata = rtrim($rdata, ', ') . ')'; |
|
| 176 | 176 | } else { |
| 177 | 177 | $rdata = $this->rdata; |
| 178 | 178 | } |
@@ -44,19 +44,19 @@ |
||
| 44 | 44 | public function onQueryReceive(QueryReceiveEvent $event): void |
| 45 | 45 | { |
| 46 | 46 | foreach ($event->getMessage()->getQuestions() as $question) { |
| 47 | - $this->log(LogLevel::INFO, 'Query: '.$question); |
|
| 47 | + $this->log(LogLevel::INFO, 'Query: ' . $question); |
|
| 48 | 48 | } |
| 49 | 49 | } |
| 50 | 50 | |
| 51 | 51 | public function onQueryResponse(QueryResponseEvent $event): void |
| 52 | 52 | { |
| 53 | 53 | foreach ($event->getMessage()->getAnswers() as $answer) { |
| 54 | - $this->log(LogLevel::INFO, 'Answer: '.$answer); |
|
| 54 | + $this->log(LogLevel::INFO, 'Answer: ' . $answer); |
|
| 55 | 55 | } |
| 56 | 56 | } |
| 57 | 57 | |
| 58 | 58 | public function log($level, $message, array $context = []) |
| 59 | 59 | { |
| 60 | - echo sprintf('[%s] %s: %s'.PHP_EOL, date('c'), $level, $message); |
|
| 60 | + echo sprintf('[%s] %s: %s' . PHP_EOL, date('c'), $level, $message); |
|
| 61 | 61 | } |
| 62 | 62 | } |
@@ -22,10 +22,10 @@ discard block |
||
| 22 | 22 | public static function encodeMessage(Message $message): string |
| 23 | 23 | { |
| 24 | 24 | return |
| 25 | - self::encodeHeader($message->getHeader()). |
|
| 26 | - self::encodeResourceRecords($message->getQuestions()). |
|
| 27 | - self::encodeResourceRecords($message->getAnswers()). |
|
| 28 | - self::encodeResourceRecords($message->getAuthoritatives()). |
|
| 25 | + self::encodeHeader($message->getHeader()) . |
|
| 26 | + self::encodeResourceRecords($message->getQuestions()) . |
|
| 27 | + self::encodeResourceRecords($message->getAnswers()) . |
|
| 28 | + self::encodeResourceRecords($message->getAuthoritatives()) . |
|
| 29 | 29 | self::encodeResourceRecords($message->getAdditionals()); |
| 30 | 30 | } |
| 31 | 31 | |
@@ -42,11 +42,11 @@ discard block |
||
| 42 | 42 | return chr(0); |
| 43 | 43 | } |
| 44 | 44 | |
| 45 | - $domain = rtrim($domain, '.').'.'; |
|
| 45 | + $domain = rtrim($domain, '.') . '.'; |
|
| 46 | 46 | $res = ''; |
| 47 | 47 | |
| 48 | 48 | foreach (explode('.', $domain) as $label) { |
| 49 | - $res .= chr(strlen($label)).$label; |
|
| 49 | + $res .= chr(strlen($label)) . $label; |
|
| 50 | 50 | } |
| 51 | 51 | |
| 52 | 52 | return $res; |
@@ -77,13 +77,13 @@ discard block |
||
| 77 | 77 | case RecordTypeEnum::TYPE_SOA: |
| 78 | 78 | return self::encodeSOA($rdata); |
| 79 | 79 | case RecordTypeEnum::TYPE_MX: |
| 80 | - return pack('n', (int) $rdata['preference']).self::encodeDomainName($rdata['exchange']); |
|
| 80 | + return pack('n', (int) $rdata['preference']) . self::encodeDomainName($rdata['exchange']); |
|
| 81 | 81 | case RecordTypeEnum::TYPE_TXT: |
| 82 | 82 | $rdata = substr($rdata, 0, 255); |
| 83 | 83 | |
| 84 | - return chr(strlen($rdata)).$rdata; |
|
| 84 | + return chr(strlen($rdata)) . $rdata; |
|
| 85 | 85 | case RecordTypeEnum::TYPE_SRV: |
| 86 | - return pack('nnn', (int) $rdata['priority'], (int) $rdata['weight'], (int) $rdata['port']). |
|
| 86 | + return pack('nnn', (int) $rdata['priority'], (int) $rdata['weight'], (int) $rdata['port']) . |
|
| 87 | 87 | self::encodeDomainName($rdata['target']); |
| 88 | 88 | case RecordTypeEnum::TYPE_AXFR: |
| 89 | 89 | case RecordTypeEnum::TYPE_ANY: |
@@ -167,8 +167,8 @@ discard block |
||
| 167 | 167 | private static function encodeSOA(array $soa): string |
| 168 | 168 | { |
| 169 | 169 | return |
| 170 | - self::encodeDomainName($soa['mname']). |
|
| 171 | - self::encodeDomainName($soa['rname']). |
|
| 170 | + self::encodeDomainName($soa['mname']) . |
|
| 171 | + self::encodeDomainName($soa['rname']) . |
|
| 172 | 172 | pack( |
| 173 | 173 | 'NNNNN', |
| 174 | 174 | $soa['serial'], |
@@ -48,7 +48,7 @@ |
||
| 48 | 48 | |
| 49 | 49 | $domainName = ''; |
| 50 | 50 | while (0 !== $len) { |
| 51 | - $domainName .= substr($string, $offset, $len).'.'; |
|
| 51 | + $domainName .= substr($string, $offset, $len) . '.'; |
|
| 52 | 52 | $offset += $len; |
| 53 | 53 | $len = ord($string[$offset]); |
| 54 | 54 | ++$offset; |
@@ -76,7 +76,7 @@ discard block |
||
| 76 | 76 | */ |
| 77 | 77 | public function isWildcardDomain(string $domain): bool |
| 78 | 78 | { |
| 79 | - $domain = rtrim($domain, '.').'.'; |
|
| 79 | + $domain = rtrim($domain, '.') . '.'; |
|
| 80 | 80 | $pattern = '/^\*\.(?:[a-zA-Z0-9\-\_]+\.)*$/'; |
| 81 | 81 | |
| 82 | 82 | return (bool) preg_match($pattern, $domain); |
@@ -170,7 +170,7 @@ discard block |
||
| 170 | 170 | } |
| 171 | 171 | |
| 172 | 172 | if ('.' !== substr($name, -1, 1)) { |
| 173 | - return $name.'.'.$parent; |
|
| 173 | + return $name . '.' . $parent; |
|
| 174 | 174 | } |
| 175 | 175 | |
| 176 | 176 | return $name; |
@@ -49,7 +49,7 @@ discard block |
||
| 49 | 49 | */ |
| 50 | 50 | protected function processZone(array $zone): array |
| 51 | 51 | { |
| 52 | - $parent = rtrim($zone['domain'], '.').'.'; |
|
| 52 | + $parent = rtrim($zone['domain'], '.') . '.'; |
|
| 53 | 53 | $defaultTtl = $zone['default-ttl']; |
| 54 | 54 | $rrs = $zone['resource-records']; |
| 55 | 55 | $resourceRecords = []; |
@@ -78,7 +78,7 @@ discard block |
||
| 78 | 78 | */ |
| 79 | 79 | protected function isLegacyFormat(array $zone): bool |
| 80 | 80 | { |
| 81 | - $keys = array_map(function ($value) { |
|
| 81 | + $keys = array_map(function($value) { |
|
| 82 | 82 | return strtolower($value); |
| 83 | 83 | }, array_keys($zone)); |
| 84 | 84 | |
@@ -96,7 +96,7 @@ discard block |
||
| 96 | 96 | { |
| 97 | 97 | $resourceRecords = []; |
| 98 | 98 | foreach ($zones as $domain => $types) { |
| 99 | - $domain = rtrim($domain, '.').'.'; |
|
| 99 | + $domain = rtrim($domain, '.') . '.'; |
|
| 100 | 100 | foreach ($types as $type => $data) { |
| 101 | 101 | $data = (array) $data; |
| 102 | 102 | $type = RecordTypeEnum::getTypeFromName($type); |
@@ -149,7 +149,7 @@ |
||
| 149 | 149 | */ |
| 150 | 150 | private function IANA2PHP(int $type): int |
| 151 | 151 | { |
| 152 | - $constantName = 'DNS_'.RecordTypeEnum::getName($type); |
|
| 152 | + $constantName = 'DNS_' . RecordTypeEnum::getName($type); |
|
| 153 | 153 | if (!defined($constantName)) { |
| 154 | 154 | throw new UnsupportedTypeException(sprintf('Record type "%d" is not a supported type.', $type)); |
| 155 | 155 | } |