@@ -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 | } |
@@ -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', __DIR__.'/example.com.json']); |
|
6 | +$jsonResolver = new yswery\DNS\Resolver\JsonResolver([__DIR__ . '/record.json', __DIR__ . '/example.com.json']); |
|
7 | 7 | |
8 | 8 | // System resolver acting as a fallback to the JsonResolver |
9 | 9 | $systemResolver = new yswery\DNS\Resolver\SystemResolver(); |