From fc9401f04a3aca5abb22f87ebc210de8afe11d32 Mon Sep 17 00:00:00 2001
From: marvin-borner@live.com
Date: Tue, 10 Apr 2018 21:50:16 +0200
Subject: Initial Commit

---
 assets/php/vendor/react/dns/src/Model/Message.php | 100 ++++++++++++++++++++++
 1 file changed, 100 insertions(+)
 create mode 100644 assets/php/vendor/react/dns/src/Model/Message.php

(limited to 'assets/php/vendor/react/dns/src/Model/Message.php')

diff --git a/assets/php/vendor/react/dns/src/Model/Message.php b/assets/php/vendor/react/dns/src/Model/Message.php
new file mode 100644
index 0000000..715cb1f
--- /dev/null
+++ b/assets/php/vendor/react/dns/src/Model/Message.php
@@ -0,0 +1,100 @@
+<?php
+
+namespace React\Dns\Model;
+
+use React\Dns\Query\Query;
+use React\Dns\Model\Record;
+
+class Message
+{
+    const TYPE_A = 1;
+    const TYPE_NS = 2;
+    const TYPE_CNAME = 5;
+    const TYPE_SOA = 6;
+    const TYPE_PTR = 12;
+    const TYPE_MX = 15;
+    const TYPE_TXT = 16;
+    const TYPE_AAAA = 28;
+
+    const CLASS_IN = 1;
+
+    const OPCODE_QUERY = 0;
+    const OPCODE_IQUERY = 1; // inverse query
+    const OPCODE_STATUS = 2;
+
+    const RCODE_OK = 0;
+    const RCODE_FORMAT_ERROR = 1;
+    const RCODE_SERVER_FAILURE = 2;
+    const RCODE_NAME_ERROR = 3;
+    const RCODE_NOT_IMPLEMENTED = 4;
+    const RCODE_REFUSED = 5;
+
+    /**
+     * Creates a new request message for the given query
+     *
+     * @param Query $query
+     * @return self
+     */
+    public static function createRequestForQuery(Query $query)
+    {
+        $request = new Message();
+        $request->header->set('id', self::generateId());
+        $request->header->set('rd', 1);
+        $request->questions[] = (array) $query;
+        $request->prepare();
+
+        return $request;
+    }
+
+    /**
+     * Creates a new response message for the given query with the given answer records
+     *
+     * @param Query    $query
+     * @param Record[] $answers
+     * @return self
+     */
+    public static function createResponseWithAnswersForQuery(Query $query, array $answers)
+    {
+        $response = new Message();
+        $response->header->set('id', self::generateId());
+        $response->header->set('qr', 1);
+        $response->header->set('opcode', Message::OPCODE_QUERY);
+        $response->header->set('rd', 1);
+        $response->header->set('rcode', Message::RCODE_OK);
+
+        $response->questions[] = (array) $query;
+
+        foreach ($answers as $record) {
+            $response->answers[] = $record;
+        }
+
+        $response->prepare();
+
+        return $response;
+    }
+
+    private static function generateId()
+    {
+        return mt_rand(0, 0xffff);
+    }
+
+    public $data = '';
+
+    public $header;
+    public $questions = array();
+    public $answers = array();
+    public $authority = array();
+    public $additional = array();
+
+    public $consumed = 0;
+
+    public function __construct()
+    {
+        $this->header = new HeaderBag();
+    }
+
+    public function prepare()
+    {
+        $this->header->populateCounts($this);
+    }
+}
-- 
cgit v1.2.3