[Dns] Make resolver functional

Author: igorw

Parser.php

@@ -33,6 +33,8 @@ public function parseChunk($data, Message $message)
                 return;
             }
         }
+
+        return $message;
     }
 
     private function parseHeader(Message $message)

Resolver.php

@@ -3,16 +3,25 @@
 namespace React\Dns;
 
 use React\Dns\Model\Message;
+use React\EventLoop\LoopInterface;
 use React\Socket\Connection;
 
 class Resolver
 {
+    private $nameserver;
+    private $loop;
+
+    public function __construct($nameserver, LoopInterface $loop)
+    {
+        $this->nameserver = $nameserver;
+        $this->loop = $loop;
+    }
+
     public function resolve($domain, $callback)
     {
-        $nameserver = '8.8.8.8';
-        $query = new Query($domain, 'A', 'IN');
+        $query = new Query($domain, Message::TYPE_A, Message::CLASS_IN);
 
-        $this->query($nameserver, $query, function (Message $response) use ($callback) {
+        $this->query($this->nameserver, $query, function (Message $response) use ($callback) {
             $answer = $response->answers[array_rand($response->answers)];
             $address = $answer->data;
             $callback($address);
@@ -28,11 +37,13 @@ public function query($nameserver, Query $query, $callback)
         $request->headers->set('id', rand());
         $request->headers->set('rd', 1);
         $request->questions[] = (array) $query;
+        $request->prepare();
 
         $response = new Message();
 
-        $conn = new Connection(fopen("udp://$nameserver:53"), $this->loop);
-        $conn->on('data', function ($data) use ($conn, $response, $callback) {
+        $fd = stream_socket_client("udp://$nameserver:53");
+        $conn = new Connection($fd, $this->loop);
+        $conn->on('data', function ($data) use ($conn, $parser, $response, $callback) {
             if ($parser->parseChunk($data, $response)) {
                 $conn->end();
                 $callback($response);