Fixing wrong variable name

Fixing error
Adding stream interface
2018-12-03 09:04:40 +01:00 · 2018-12-03 08:58:37 +01:00 · 2018-12-03 08:52:54 +01:00 · 2018-12-03 08:30:42 +01:00 · 2018-12-03 08:29:00 +01:00 · 2018-12-03 08:21:19 +01:00
31 changed files with 4364 additions and 1142 deletions
--- a/.drone.yml
+++ b/.drone.yml
@ -0,0 +1,8 @@
+pipeline:
+  core:
+    image: node
+    commands:
+      - node --version && npm --version
+      - npm install
+      - npm run build
+      - npm test
--- a/.editorconfig
+++ b/.editorconfig
@ -0,0 +1,9 @@
+root = true
+
+[*]
+indent_style = space
+indent_size = 3
+end_of_line = lf
+charset = utf-8
+trim_trailing_whitespace = true
+insert_final_newline = false
--- a/.gitignore
+++ b/.gitignore
@ -1,4 +1,4 @@
 node_modules
-yarn.lock
 *.pcapng
 *.bin
+lib/
--- a/.travis.yml
+++ b/.travis.yml
@ -0,0 +1,3 @@
+language: node_js
+node_js:
+    - "lts/*"
--- a/Readme.md
+++ b/Readme.md
@ -0,0 +1,32 @@
+# NodeName-Core
+This repository is part of the NodeName Project, a simple to use and very flexible Nameserver implementation for NodeJS.
+
+## What does this NodeName-Core contain?
+
+NodeName-Core is responsible for several things:
+
+- parsing incoming DNS requests
+- serializing outgoing answers
+- providing storage backend API definition
+
+## API
+
+``` JavaScript
+   const Core = new DnsCore();
+   Core.addStorage(new AnyStoragePlugin(options), timeout?);
+   // One or multiple storage plugins
+   // All Storage engines are requested at the same time all their results will be processed
+   // Optionally an timeout can be defined after wich this storage engine will be ignored
+   // If no others answer an error is returned in Response
+
+   Core.addMonitoring(new MonitoringPlugin(options));
+   // Async called Monmitoring plugin.
+
+   Core.addListener(new ListenetPlugin(options));
+
+   // The question plugin can handle on or more Questions and needs to
+   // make shure, that it creates the desired output. It is responsible
+   // for handeling the question and optionally add additional questions
+   // to be resolved.
+   Core.addQuestionHandler(new QuestionPlugin(options));
+```
--- a/lib/listener.d.ts
+++ b/lib/listener.d.ts
@ -1,7 +0,0 @@
-import { Request } from "./request";
-export default class Listener {
-    private udp;
-    private tcp;
-    constructor(type: "udp" | "tcp", onRequest: (request: Request) => any, port: number, host?: string);
-    close(): void;
-}
--- a/lib/listener.js
+++ b/lib/listener.js
@ -1,69 +0,0 @@
-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-const net = require("net");
-const dgram = require("dgram");
-const request_1 = require("./request");
-class Listener {
-    constructor(type, onRequest, port, host = "0.0.0.0") {
-        switch (type) {
-            case "udp":
-                this.udp = dgram.createSocket("udp4");
-                this.udp.on("listening", () => {
-                    console.log(`UDP Server Listening on ${port}`);
-                });
-                this.udp.on("message", (message, remote) => {
-                    let request = new request_1.Request(message, (data) => {
-                        // console.log("sending:", new Request(data, (a) => 0));
-                        this.udp.send(data, remote.port, remote.address);
-                    });
-                    onRequest(request);
-                });
-                this.udp.bind(port, host);
-                break;
-            case "tcp":
-                console.log("Not correct implemented");
-                this.tcp = net.createServer((socket) => {
-                    let length;
-                    let got = 0;
-                    let message = undefined;
-                    socket.on("data", (data) => {
-                        let offset = 0;
-                        if (!message) {
-                            length = data.readUInt16BE(0);
-                            if (length > 2048)
-                                return socket.destroy(); //Requests with more that 2k are ignored
-                            message = Buffer.alloc(length);
-                            offset = 2;
-                        }
-                        let read = (data.length - offset) > (length - got) ? (length - got) : (data.length - offset);
-                        data.copy(message, got, offset, read + offset);
-                        got += read;
-                        //ToDo don't ignore probably following requests
-                        if (got >= length) {
-                            let request = new request_1.Request(message, (data) => {
-                                socket.write(data);
-                            });
-                            got = 0;
-                            message = undefined;
-                            length = 0;
-                            onRequest(request);
-                        }
-                    });
-                });
-                this.tcp.listen(port, host);
-                break;
-            default:
-                throw new Error("Unknown socket type");
-        }
-    }
-    close() {
-        if (this.udp) {
-            this.udp.close();
-        }
-        else {
-            this.tcp.close();
-        }
-    }
-}
-exports.default = Listener;
-//# sourceMappingURL=listener.js.map
--- a/lib/listener.js.map
+++ b/lib/listener.js.map
@ -1 +0,0 @@
-{"version":3,"file":"listener.js","sourceRoot":"","sources":["../src/listener.ts"],"names":[],"mappings":";;AAAA,2BAA0B;AAC1B,+BAA+B;AAC/B,uCAAoC;AAEpC;IAGG,YAAY,IAAmB,EAAE,SAAoC,EAAE,IAAY,EAAE,OAAe,SAAS;QAC1G,QAAQ,IAAI,EAAE;YACX,KAAK,KAAK;gBACP,IAAI,CAAC,GAAG,GAAG,KAAK,CAAC,YAAY,CAAC,MAAM,CAAC,CAAA;gBACrC,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,WAAW,EAAE,GAAG,EAAE;oBAC3B,OAAO,CAAC,GAAG,CAAC,2BAA2B,IAAI,EAAE,CAAC,CAAA;gBACjD,CAAC,CAAC,CAAA;gBAEF,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,SAAS,EAAE,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;oBACxC,IAAI,OAAO,GAAG,IAAI,iBAAO,CAAC,OAAO,EAAE,CAAC,IAAI,EAAE,EAAE;wBACzC,wDAAwD;wBACxD,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,IAAI,EAAE,MAAM,CAAC,IAAI,EAAE,MAAM,CAAC,OAAO,CAAC,CAAA;oBACnD,CAAC,CAAC,CAAA;oBACF,SAAS,CAAC,OAAO,CAAC,CAAC;gBACtB,CAAC,CAAC,CAAA;gBAEF,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,IAAI,EAAE,IAAI,CAAC,CAAA;gBACzB,MAAM;YACT,KAAK,KAAK;gBACP,OAAO,CAAC,GAAG,CAAC,yBAAyB,CAAC,CAAA;gBACtC,IAAI,CAAC,GAAG,GAAG,GAAG,CAAC,YAAY,CAAC,CAAC,MAAM,EAAE,EAAE;oBACpC,IAAI,MAAc,CAAC;oBACnB,IAAI,GAAG,GAAW,CAAC,CAAC;oBACpB,IAAI,OAAO,GAAG,SAAS,CAAC;oBACxB,MAAM,CAAC,EAAE,CAAC,MAAM,EAAE,CAAC,IAAI,EAAE,EAAE;wBACxB,IAAI,MAAM,GAAG,CAAC,CAAC;wBACf,IAAI,CAAC,OAAO,EAAE;4BACX,MAAM,GAAG,IAAI,CAAC,YAAY,CAAC,CAAC,CAAC,CAAC;4BAC9B,IAAI,MAAM,GAAG,IAAI;gCAAE,OAAO,MAAM,CAAC,OAAO,EAAE,CAAC,CAAC,wCAAwC;4BACpF,OAAO,GAAG,MAAM,CAAC,KAAK,CAAC,MAAM,CAAC,CAAC;4BAC/B,MAAM,GAAG,CAAC,CAAC;yBACb;wBAED,IAAI,IAAI,GAAG,CAAC,IAAI,CAAC,MAAM,GAAG,MAAM,CAAC,GAAG,CAAC,MAAM,GAAG,GAAG,CAAC,CAAC,CAAC,CAAC,CAAC,MAAM,GAAG,GAAG,CAAC,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,MAAM,GAAG,MAAM,CAAC,CAAC;wBAC7F,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,GAAG,EAAE,MAAM,EAAE,IAAI,GAAG,MAAM,CAAC,CAAA;wBAC9C,GAAG,IAAI,IAAI,CAAC;wBACZ,+CAA+C;wBAC/C,IAAI,GAAG,IAAI,MAAM,EAAE;4BAChB,IAAI,OAAO,GAAG,IAAI,iBAAO,CAAC,OAAO,EAAE,CAAC,IAAI,EAAE,EAAE;gCACzC,MAAM,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;4BACtB,CAAC,CAAC,CAAA;4BACF,GAAG,GAAG,CAAC,CAAC;4BACR,OAAO,GAAG,SAAS,CAAC;4BACpB,MAAM,GAAG,CAAC,CAAC;4BACX,SAAS,CAAC,OAAO,CAAC,CAAC;yBACrB;oBACJ,CAAC,CAAC,CAAC;gBACN,CAAC,CAAC,CAAC;gBACH,IAAI,CAAC,GAAG,CAAC,MAAM,CAAC,IAAI,EAAE,IAAI,CAAC,CAAC;gBAC5B,MAAM;YACT;gBACG,MAAM,IAAI,KAAK,CAAC,qBAAqB,CAAC,CAAA;SAC3C;IACJ,CAAC;IAED,KAAK;QACF,IAAI,IAAI,CAAC,GAAG,EAAE;YACX,IAAI,CAAC,GAAG,CAAC,KAAK,EAAE,CAAC;SACnB;aAAM;YACJ,IAAI,CAAC,GAAG,CAAC,KAAK,EAAE,CAAC;SACnB;IACJ,CAAC;CACH;AAjED,2BAiEC"}
--- a/lib/request.d.ts
+++ b/lib/request.d.ts
@ -1,126 +0,0 @@
-/// <reference types="node" />
-import { Message, MessageHeader, MessageQuestion, MessageRecourceRecord, ErrorCodes } from "./types";
-export declare enum QueryTypes {
-    /**
-     * IPv4 address
-     */
-    A = 1,
-    /**
-     * Nameserver
-     */
-    NS = 2,
-    /**
-     * Obsolete
-     */
-    MD = 3,
-    /**
-     * Obsolete
-     */
-    MF = 4,
-    /**
-     * Alias
-     */
-    CNAME = 5,
-    /**
-     * Start of authority
-     */
-    SOA = 6,
-    /**
-     * Experimental
-     */
-    MB = 7,
-    /**
-     * Experimental
-     */
-    MG = 8,
-    /**
-     * Experimental
-     */
-    MR = 9,
-    /**
-     * Experimental
-     */
-    NULL = 10,
-    /**
-     * Service description
-     */
-    WKS = 11,
-    /**
-     * Reverse entry (inaddr.arpa)
-     */
-    PTR = 12,
-    /**
-     * Host information
-     */
-    HINFO = 13,
-    /**
-     * Mailbox / Mail-list information
-     */
-    MINFO = 14,
-    /**
-     * Mail exchange
-     */
-    MX = 15,
-    /**
-     * Text strings
-     */
-    TXT = 16,
-    /**
-     * IPv6 address
-     */
-    AAAA = 28,
-    /**
-     * SRV records
-     */
-    SRV = 33,
-    /**
-     * Request to transfer entire zone
-     */
-    AXFR = 252,
-    /**
-     * Request for mailbox related records
-     */
-    MAILA = 254,
-    /**
-     * Request for mail agend RRs
-     */
-    MAILB = 253,
-    /**
-     * Any class
-     */
-    ANY = 255,
-}
-export declare function SerializeName(name: string): Buffer;
-export declare class Request implements Message {
-    private sendCallback;
-    private _header;
-    readonly header: MessageHeader;
-    private _questions;
-    readonly questions: MessageQuestion[];
-    answers: RecourceRecord[];
-    authorities: RecourceRecord[];
-    additionals: RecourceRecord[];
-    constructor(packet: Buffer, sendCallback: (packet: Buffer) => any);
-    error(error: ErrorCodes): void;
-    noRecursion(): void;
-    send(): void;
-    serialize(truncate?: boolean, rcode?: 0 | 1 | 2 | 3 | 4 | 5): Buffer;
-    private serializeHeader();
-    private serializeQuestion(question);
-    private serializeResourceRecord(record);
-}
-export declare class RecourceRecord implements MessageRecourceRecord {
-    /**
-     * This value can be set to identify if specific record is already set
-     */
-    Identifier: string;
-    NAME: string;
-    private _TYPE;
-    TYPE: number;
-    private _CLASS;
-    CLASS: number;
-    private _TTL;
-    TTL: number;
-    RDATA: Buffer;
-    readonly RDLENGTH: number;
-}
--- a/lib/request.js
+++ b/lib/request.js
@ -1,316 +0,0 @@
-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-const binary_parser_1 = require("binary-parser");
-const types_1 = require("./types");
-const MAX_LABEL_SIZE = 63;
-var QueryTypes;
-(function (QueryTypes) {
-    /**
-     * IPv4 address
-     */
-    QueryTypes[QueryTypes["A"] = 1] = "A";
-    /**
-     * Nameserver
-     */
-    QueryTypes[QueryTypes["NS"] = 2] = "NS";
-    /**
-     * Obsolete
-     */
-    QueryTypes[QueryTypes["MD"] = 3] = "MD";
-    /**
-     * Obsolete
-     */
-    QueryTypes[QueryTypes["MF"] = 4] = "MF";
-    /**
-     * Alias
-     */
-    QueryTypes[QueryTypes["CNAME"] = 5] = "CNAME";
-    /**
-     * Start of authority
-     */
-    QueryTypes[QueryTypes["SOA"] = 6] = "SOA";
-    /**
-     * Experimental
-     */
-    QueryTypes[QueryTypes["MB"] = 7] = "MB";
-    /**
-     * Experimental
-     */
-    QueryTypes[QueryTypes["MG"] = 8] = "MG";
-    /**
-     * Experimental
-     */
-    QueryTypes[QueryTypes["MR"] = 9] = "MR";
-    /**
-     * Experimental
-     */
-    QueryTypes[QueryTypes["NULL"] = 10] = "NULL";
-    /**
-     * Service description
-     */
-    QueryTypes[QueryTypes["WKS"] = 11] = "WKS";
-    /**
-     * Reverse entry (inaddr.arpa)
-     */
-    QueryTypes[QueryTypes["PTR"] = 12] = "PTR";
-    /**
-     * Host information
-     */
-    QueryTypes[QueryTypes["HINFO"] = 13] = "HINFO";
-    /**
-     * Mailbox / Mail-list information
-     */
-    QueryTypes[QueryTypes["MINFO"] = 14] = "MINFO";
-    /**
-     * Mail exchange
-     */
-    QueryTypes[QueryTypes["MX"] = 15] = "MX";
-    /**
-     * Text strings
-     */
-    QueryTypes[QueryTypes["TXT"] = 16] = "TXT";
-    /**
-     * IPv6 address
-     */
-    QueryTypes[QueryTypes["AAAA"] = 28] = "AAAA";
-    /**
-     * SRV records
-     */
-    QueryTypes[QueryTypes["SRV"] = 33] = "SRV";
-    /**
-     * Request to transfer entire zone
-     */
-    QueryTypes[QueryTypes["AXFR"] = 252] = "AXFR";
-    /**
-     * Request for mailbox related records
-     */
-    QueryTypes[QueryTypes["MAILA"] = 254] = "MAILA";
-    /**
-     * Request for mail agend RRs
-     */
-    QueryTypes[QueryTypes["MAILB"] = 253] = "MAILB";
-    /**
-     * Any class
-     */
-    QueryTypes[QueryTypes["ANY"] = 255] = "ANY";
-})(QueryTypes = exports.QueryTypes || (exports.QueryTypes = {}));
-const headerParser = new binary_parser_1.Parser()
-    .endianess("big")
-    .uint16("ID")
-    .bit1("QR")
-    .bit4("OPCODE")
-    .bit1("AA")
-    .bit1("TC")
-    .bit1("RD")
-    .bit1("RA")
-    .bit1("Z")
-    .bit1("AD")
-    .bit1("CD")
-    .bit4("RCODE")
-    .uint16("QDCOUNT")
-    .uint16("ANCOUNT")
-    .uint16("NSCOUNT")
-    .uint16("ARCOUNT");
-const labelParser = new binary_parser_1.Parser()
-    .endianess("big")
-    .uint8("dataLength")
-    .string("name", {
-    length: "dataLength",
-    encoding: "ascii"
-});
-const questionParser = new binary_parser_1.Parser()
-    .endianess("big")
-    .array("QNAME", {
-    type: labelParser,
-    readUntil: (item, buffer) => {
-        if (item.dataLength <= 0)
-            return true;
-    },
-    formatter: (value) => {
-        return value.map(e => e.name).join(".").slice(0, -1);
-    }
-})
-    .uint16("QTYPE")
-    .uint16("QCLASS");
-function parseQuestions(count, packet) {
-    return new binary_parser_1.Parser()
-        .endianess("big")
-        .array("questions", {
-        type: questionParser,
-        length: count
-    }).parse(packet).questions;
-}
-function SerializeName(name) {
-    let length = 0;
-    let parts = name.split(".");
-    parts.forEach(e => {
-        // Length of part and byte that holds the length information
-        if (e.length > MAX_LABEL_SIZE)
-            throw new Error("Label to large");
-        length += e.length + 1;
-    });
-    length += 1; //Adding last 0 length octet
-    let data = Buffer.alloc(length);
-    let offset = 0;
-    parts.forEach(e => {
-        data.writeUInt8(e.length, offset);
-        offset++;
-        data.write(e, offset, e.length);
-        offset += e.length;
-    });
-    data.writeUInt8(0, offset);
-    return data;
-}
-exports.SerializeName = SerializeName;
-class Request {
-    constructor(packet, sendCallback) {
-        this.sendCallback = sendCallback;
-        this.answers = [];
-        this.authorities = [];
-        this.additionals = [];
-        let headerData = Buffer.alloc(12);
-        packet.copy(headerData, 0, 0, 12);
-        let bodyData = Buffer.alloc(packet.length - 12);
-        packet.copy(bodyData, 0, 12, packet.length);
-        this._header = headerParser.parse(headerData);
-        this._header.AD = 0;
-        this._header.RCODE = types_1.ErrorCodes.NoError;
-        this._header.RA = this._header.RD;
-        this._questions = parseQuestions(this._header.QDCOUNT, bodyData);
-    }
-    get header() {
-        return Object.assign({}, this._header);
-    }
-    get questions() {
-        return this._questions.map(e => e);
-    }
-    error(error) {
-        if (this._header.RCODE === types_1.ErrorCodes.NoError)
-            this._header.RCODE = error;
-    }
-    noRecursion() {
-        this._header.RA = 0;
-    }
-    send() {
-        this.sendCallback(this.serialize());
-    }
-    serialize(truncate = false, rcode = 0) {
-        this._header.AA = 1;
-        this._header.ANCOUNT = this.answers.length;
-        this._header.ARCOUNT = this.additionals.length;
-        this._header.NSCOUNT = this.authorities.length;
-        this._header.QR = 1;
-        this._header.RCODE = rcode;
-        let questions = this.questions.map(this.serializeQuestion, this);
-        let answers = this.answers.map(this.serializeResourceRecord, this);
-        let authority = this.authorities.map(this.serializeResourceRecord, this);
-        let additional = this.additionals.map(this.serializeResourceRecord, this);
-        let questionsByteLength = 0;
-        questions.forEach(e => questionsByteLength += e.length);
-        let answersByteLength = 0;
-        answers.forEach(e => answersByteLength += e.length);
-        let authorityByteLength = 0;
-        authority.forEach(e => authorityByteLength += e.length);
-        let additionalByteLength = 0;
-        additional.forEach(e => additionalByteLength += e.length);
-        let length = 12 + questionsByteLength + answersByteLength + authorityByteLength + additionalByteLength; //Header is always 12 byte large
-        if (truncate && length > 512) {
-            this._header.TC = 1;
-            //Buffer will ignore data that exeeds the max buffer length
-            length = 512;
-        }
-        let header = this.serializeHeader();
-        let data = Buffer.alloc(length);
-        let offset = 0;
-        let append = (buffer) => {
-            buffer.copy(data, offset, 0, buffer.length);
-            offset += buffer.length;
-        };
-        append(header);
-        questions.forEach(append);
-        answers.forEach(append);
-        authority.forEach(append);
-        additional.forEach(append);
-        return data;
-    }
-    serializeHeader() {
-        let header = this.header;
-        let data = Buffer.alloc(12);
-        data.writeUInt16BE(header.ID, 0);
-        var f = 0x0000;
-        f = f | (header.QR << 15);
-        f = f | (header.OPCODE << 11);
-        f = f | (header.AA << 10);
-        f = f | (header.TC << 9);
-        f = f | (header.RD << 8);
-        f = f | (header.RA << 7);
-        f = f | (header.Z << 6);
-        f = f | (header.AD << 5);
-        f = f | (header.CD << 4);
-        f = f | header.RCODE;
-        data.writeUInt16BE(f, 2);
-        data.writeUInt16BE(header.QDCOUNT, 4);
-        data.writeUInt16BE(header.ANCOUNT, 6);
-        data.writeUInt16BE(header.NSCOUNT, 8);
-        data.writeUInt16BE(header.ARCOUNT, 10);
-        return data;
-    }
-    serializeQuestion(question) {
-        let qname = SerializeName(question.QNAME);
-        let data = Buffer.alloc(qname.length + 4);
-        qname.copy(data, 0, 0, qname.length);
-        let offset = qname.length;
-        data.writeUInt16BE(question.QTYPE, offset);
-        offset += 2;
-        data.writeUInt16BE(question.QCLASS, offset);
-        return data;
-    }
-    serializeResourceRecord(record) {
-        // TODO: Implement compression
-        let name = SerializeName(record.NAME);
-        let data = Buffer.alloc(name.length + 10 + record.RDLENGTH); // For TYPE, CLASS, TTL, RLENGTH
-        name.copy(data, 0, 0, name.length);
-        let offset = name.length;
-        data.writeUInt16BE(record.TYPE, offset);
-        offset += 2;
-        data.writeUInt16BE(record.CLASS, offset);
-        offset += 2;
-        data.writeUInt32BE(record.TTL, offset);
-        offset += 4;
-        data.writeUInt16BE(record.RDLENGTH, offset);
-        offset += 2;
-        record.RDATA.copy(data, offset, 0, record.RDLENGTH);
-        return data;
-    }
-}
-exports.Request = Request;
-class RecourceRecord {
-    set TYPE(value) {
-        if (value < 0 || value > 65535)
-            throw new TypeError("TYPE Range: 0 - 65.535");
-        this._TYPE = value;
-    }
-    get TYPE() {
-        return this._TYPE;
-    }
-    set CLASS(value) {
-        if (value < 0 || value > 65535)
-            throw new TypeError("CLASS Range: 0 - 65.535");
-        this._CLASS = value;
-    }
-    get CLASS() {
-        return this._CLASS;
-    }
-    set TTL(value) {
-        if (value < 0 || value > 4294967295)
-            throw new TypeError("TTL Range: 0 - 4.294.967.295");
-    }
-    get TTL() {
-        return this._TTL;
-    }
-    get RDLENGTH() {
-        return this.RDATA.length;
-    }
-}
-exports.RecourceRecord = RecourceRecord;
-//# sourceMappingURL=request.js.map
--- a/lib/request.js.map
+++ b/lib/request.js.map
--- a/lib/test.js
+++ b/lib/test.js
@ -1,6 +0,0 @@
-// const t = `71 15 01 00 00 01 00 00 00 00 00 00 02 64 63 08 73 65 72 76 69 63 65 73 0c 76 69 73 75 61 6c 73 74 75 64 69 6f 03 63 6f 6d 00 00 01 00 01`.split(" ").join("");
-// // const tp = Buffer.from(t, "hex")
-// // // import Parse from "./index";
-// // import * as util from "util";
-// // console.log(util.inspect(Parse(tp), false, 20, true));
-//# sourceMappingURL=test.js.map
--- a/lib/test.js.map
+++ b/lib/test.js.map
@ -1 +0,0 @@
-{"version":3,"file":"test.js","sourceRoot":"","sources":["../src/test.ts"],"names":[],"mappings":"AAAA,6KAA6K;AAC7K,sCAAsC;AACtC,qCAAqC;AACrC,mCAAmC;AACnC,4DAA4D"}
--- a/lib/types.d.ts
+++ b/lib/types.d.ts
@ -1,178 +0,0 @@
-/// <reference types="node" />
-export declare enum ErrorCodes {
-    /**
-     * No error
-     */
-    NoError = 0,
-    /**
-     * Format error - unable to interpret query
-     */
-    FormatError = 1,
-    /**
-     * Server failure - internal problem
-     */
-    ServerFailure = 2,
-    /**
-     * Name error - Only for authorative name server, domain name of query does not exist
-     */
-    NameError = 3,
-    /**
-     * Not implemented - Request not supported
-     */
-    NotImplemented = 4,
-    /**
-     * Refused - Nameserver refuses request
-     */
-    Refused = 5,
-}
-export interface MessageHeader {
-    /**
-     *  A 16 bit identifier assigned by the program that
-     *  generates any kind of query.  This identifier is copied
-     *  the corresponding reply and can be used by the requester
-     *  to match up replies to outstanding queries.
-     */
-    ID: number;
-    /**
-     * Defines if query or response
-     */
-    QR: 0 | 1;
-    /**
-     * 4 Bit code, that defines type of query.
-     * 0 Standard query
-     * 1 Inverse query
-     * 2 Server status request
-     * 3-15 reserved for future use
-     */
-    OPCODE: number;
-    /**
-     * Authorative Answer - only valid in responses and
-     * specifies that the responding name server is an
-     * authority for the domain name in question section
-     */
-    AA: 0 | 1;
-    /**
-     * Truncation - specifies that his message was truncated doe to
-     * length grater than permitted on the transaction channel
-     *
-     * WARNING: NOT IMPLEMENTED IN THIS APPLICATION
-     */
-    TC: 0 | 1;
-    /**
-     * Recursion Desired - set in query and copied to response
-     * if is set, directs name server to pursue the query recursively
-     *
-     * WARNING: NOT IMPLEMENTED IN THIS APPLICATION
-     */
-    RD: 0 | 1;
-    /**
-     * Recursion Available - will be cleared in response to
-     * show the client that recursion is not available
-     */
-    RA: 0 | 1;
-    /**
-     * Reserved for future usage, must be 0 in all queries
-     */
-    Z: 0;
-    AD: 0 | 1;
-    CD: 0 | 1;
-    /**
-     * Response Code - 4 bit field is part of response
-     *
-     * 0 No error condition
-     * 1 Format error - unable to interpret query
-     * 2 Server failure - internal problem
-     * 3 Name error - Only for authorative name server, domain name of query does not exist
-     * 4 Not implemented - Request not supported
-     * 5 Refused - Nameserver refuses request
-     * 6-15 Reserved for future usage
-     */
-    RCODE: ErrorCodes;
-    /**
-     * Number of entries in question section
-     * uint16
-     */
-    QDCOUNT: number;
-    /**
-     * Number of entries in answer section
-     * uint16
-     */
-    ANCOUNT: number;
-    /**
-     * Number of resource records in authority records section
-     * uint16
-     */
-    NSCOUNT: number;
-    /**
-     * Number of resource records in additional records section
-     * uint16
-     */
-    ARCOUNT: number;
-}
-export interface MessageQuestion {
-    /**
-     * Domain name represented as sequence of labels
-     * Each label consists of a length octed followed
-     * by that number of octeds
-     */
-    QNAME: string;
-    /**
-     * Two octed code wich specifies the type of the query.
-     */
-    QTYPE: number;
-    /**
-     * Two octed code that specifies the class of the Query
-     * IS for internet
-     * WARNING: ONLY IN IS SUPPORTED BY THIS APPLICATION
-     */
-    QCLASS: number;
-}
-export interface MessageRecourceRecord {
-    /**
-     * Domain name to wich resource record pertains
-     */
-    NAME: string;
-    /**
-     * Two octets containing TT type code.
-     * Specifies meaning of data in RDATA field
-     *
-     * uint16
-     */
-    TYPE: number;
-    /**
-     * Two octets specifying class of RDATA field
-     *
-     * uint16
-     */
-    CLASS: number;
-    /**
-     * Specifies Time Interval (in seconds) that the record
-     * may be cached before discarded.
-     * Zero values are not cached
-     *
-     * uint32
-     */
-    TTL: number;
-    /**
-     * Length of RDATA field
-     *
-     * uint16
-     */
-    RDLENGTH: number;
-    /**
-     * a variable length string of ectets taht describes
-     * the resource. The format is defined by TYPE and CLASS
-     * field.
-     *
-     * If TYPE is A and CLASS is IN, RDATA is a 4 octet
-     * ARPA internet address.
-     */
-    RDATA: Buffer;
-}
-export interface Message {
-    header: MessageHeader;
-    questions: MessageQuestion[];
-    answers: MessageRecourceRecord[];
-    authorities: MessageRecourceRecord[];
-    additionals: MessageRecourceRecord[];
-}
--- a/lib/types.js
+++ b/lib/types.js
@ -1,38 +0,0 @@
-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-// 0 No error condition
-//    * 1 Format error - unable to interpret query
-//       * 2 Server failure - internal problem
-//          * 3 Name error - Only for authorative name server, domain name of query does not exist
-//             * 4 Not implemented - Request not supported
-//                * 5 Refused - Nameserver refuses request
-//    * 6 - 15 Reserved for future usage
-//       * 
-var ErrorCodes;
-(function (ErrorCodes) {
-    /**
-     * No error
-     */
-    ErrorCodes[ErrorCodes["NoError"] = 0] = "NoError";
-    /**
-     * Format error - unable to interpret query
-     */
-    ErrorCodes[ErrorCodes["FormatError"] = 1] = "FormatError";
-    /**
-     * Server failure - internal problem
-     */
-    ErrorCodes[ErrorCodes["ServerFailure"] = 2] = "ServerFailure";
-    /**
-     * Name error - Only for authorative name server, domain name of query does not exist
-     */
-    ErrorCodes[ErrorCodes["NameError"] = 3] = "NameError";
-    /**
-     * Not implemented - Request not supported
-     */
-    ErrorCodes[ErrorCodes["NotImplemented"] = 4] = "NotImplemented";
-    /**
-     * Refused - Nameserver refuses request
-     */
-    ErrorCodes[ErrorCodes["Refused"] = 5] = "Refused";
-})(ErrorCodes = exports.ErrorCodes || (exports.ErrorCodes = {}));
-//# sourceMappingURL=types.js.map
--- a/lib/types.js.map
+++ b/lib/types.js.map
@ -1 +0,0 @@
-{"version":3,"file":"types.js","sourceRoot":"","sources":["../src/types.ts"],"names":[],"mappings":";;AACA,uBAAuB;AACvB,kDAAkD;AAClD,8CAA8C;AAC9C,kGAAkG;AAClG,0DAA0D;AAC1D,0DAA0D;AAC1D,wCAAwC;AACxC,WAAW;AACX,IAAY,UA8BX;AA9BD,WAAY,UAAU;IACnB;;OAEG;IACH,iDAAW,CAAA;IAEX;;OAEG;IACH,yDAAW,CAAA;IAEX;;OAEG;IACH,6DAAa,CAAA;IAEb;;OAEG;IACH,qDAAS,CAAA;IAET;;OAEG;IACH,+DAAc,CAAA;IAEd;;OAEG;IACH,iDAAO,CAAA;AACV,CAAC,EA9BW,UAAU,GAAV,kBAAU,KAAV,kBAAU,QA8BrB"}
--- a/package-lock.json
+++ b/package-lock.json
--- a/package.json
+++ b/package.json
@ -1,22 +1,32 @@
 {
   "name": "nodename-core",
-   "version": "0.1.10",
-   "main": "lib/listener.js",
-   "types": "lib/listener.d.ts",
+   "version": "0.3.2",
+   "main": "lib/index.js",
+   "types": "lib/index.d.ts",
   "author": "Fabian Stamm <dev@fabianstamm.de>",
   "license": "MIT",
   "scripts": {
      "build": "tsc",
      "watch": "tsc --watch",
-      "test": "nodemon lib/test.js"
+      "prepublish": "tsc",
+      "install": "tsc",
+      "test": "mocha src/test.ts --require ts-node/register",
+      "testwatch": "mocha src/test.ts --require ts-node/register --watch --watch-extensions ts"
   },
   "devDependencies": {
      "@types/binary-parser": "^1.3.0",
-      "@types/node": "^10.0.8",
-      "nodemon": "^1.17.4",
-      "typescript": "^2.8.3"
+      "@types/chai": "^4.1.7",
+      "@types/lru-cache": "^4.1.1",
+      "@types/mocha": "^5.2.5",
+      "@types/node": "^10.12.11",
+      "chai": "^4.2.0",
+      "mocha": "^5.2.0",
+      "nodemon": "^1.18.7",
+      "ts-node": "^7.0.1",
+      "typescript": "^3.2.1"
   },
   "dependencies": {
-      "binary-parser": "^1.3.2"
+      "binary-parser": "^1.3.2",
+      "lru-cache": "^5.1.1"
   }
 }
--- a/src/benchmark.ts
+++ b/src/benchmark.ts
@ -0,0 +1,171 @@
+import { Request, parseInput } from "./request";
+import { RDATARecord, RecourceRecord } from "./record";
+import { MonitoringPlugin, QuestionPlugin, DnsCore, AnswerHandler, ListenerPlugin, StoragePlugin, Record } from "./core";
+import assert = require("assert");
+import { RecordTypes } from "./types";
+import { Question } from "./question";
+
+function fromHex(data: string) {
+   return Buffer.from(data.replace(/\s/g, ""), "hex");
+}
+
+const itr = 100000;
+console.log("All tests x" + itr);
+
+let reqData = fromHex("E835 0100 0001 0000 0000 0000 07 6578616D706c65 03636F6D 00 0001 0001");
+console.time("input parser")
+for (let i = 0; i < itr; i++) {
+   parseInput(reqData);
+}
+console.timeEnd("input parser")
+
+console.time("complete")
+for (let i = 0; i < itr; i++) {
+   let request = new Request(reqData, "")
+   let rr = new RDATARecord()
+   rr.CLASS = 1
+   rr.NAME = "example.com"
+   rr.TTL = 1600
+   rr.TYPE = 1
+   rr.RDATA = fromHex("0A 00 00 01")
+   request.addAnswer(rr)
+   request.serialize()
+}
+console.timeEnd("complete")
+
+console.time("complete 10 answers")
+for (let i = 0; i < itr; i++) {
+   let request = new Request(reqData, "")
+   let rr = new RDATARecord()
+   rr.CLASS = 1
+   rr.NAME = "example.com"
+   rr.TTL = 1600
+   rr.TYPE = 1
+   rr.RDATA = fromHex("0A 00 00 01")
+   for (let i = 0; i < 10; i++) request.addAnswer(rr);
+   request.serialize()
+}
+console.timeEnd("complete 10 answers")
+
+class TestMonitoringPlugin implements MonitoringPlugin {
+   constructor() { }
+   async init(core) { }
+   priority = 0
+   onRequest(domain, hostname, type) { }
+}
+
+class ARR extends RecourceRecord {
+   TYPE = RecordTypes.A
+
+   constructor(domain: string, ip: string) {
+      super();
+      this.NAME = domain
+      this.TTL = 1600
+      let data = Buffer.alloc(4)
+      let idx = 0;
+      ip.split(".").forEach(e => {
+         data.writeUInt8(Number(e), idx);
+         idx++;
+      })
+      this.dataLock = () => {
+         return {
+            length: 4,
+            serialize: (buffer, offset) => {
+               data.copy(buffer, offset);
+               return offset + 4;
+            }
+         }
+      };
+   }
+}
+
+class TestQuestionPlugin implements QuestionPlugin {
+   private Core: DnsCore
+   question_types = [RecordTypes.A]
+   priority = 0
+   async init(core) {
+      this.Core = core;
+   }
+
+   async handleQuestion(question: Question, request: AnswerHandler, next: () => void) {
+      assert(this.question_types.find(e => e === <any>question.QTYPE), "Handler was called with not supported question type")
+      let parts = question.QNAME.split(".")
+      let domain = parts.splice(-2, 2).join(".")
+      let hostname = parts.join(".");
+      hostname = hostname !== "" ? hostname : "*"
+      let records = await this.Core.storageManager.getRecords(domain, hostname, question.QTYPE)
+      records.forEach(e => request.addAnswer(new ARR(question.QNAME, e.value)));
+   }
+}
+
+class TestListenerPlugin implements ListenerPlugin {
+   async init(core) { }
+   priority = 0;
+   callback: (data: Buffer, sender: string, max_size?: number) => Promise<Buffer>;
+   registerCallback(callback) {
+      this.callback = callback;
+   }
+
+   sendRequest(message: Buffer) {
+      return this.callback(message, "localhost")
+   }
+}
+
+
+class TestStoragePlugin implements StoragePlugin {
+   re: Record = { domain: "example.com", hostname: "test", type: RecordTypes.A, value: "10.0.0.1", ttl: 1600 }
+
+   constructor(record?: Record, private count: number = 1) {
+      if (record)
+         this.re = record;
+   }
+
+   priority = 0
+   no_cache = false
+   record_types = [RecordTypes.A]
+   isResponsible(domain: string) {
+      // console.log("Is responsible")
+      return true
+   }
+
+   async init(core) { }
+
+   async getRecords(domain, hostname, type) {
+      if (domain !== this.re.domain || hostname !== this.re.hostname || type != this.re.type) return undefined;
+      let r = [];
+      for (let i = 0; i < this.count; i++) {
+         r.push(this.re);
+      }
+      return r;
+   }
+
+   async getAllRecordsForDomain(domain) {
+      if (domain !== this.re.domain) return undefined;
+      return [this.re];
+   }
+}
+
+let core = new DnsCore();
+
+let listener = new TestListenerPlugin();
+core.addListener(listener)
+core.addMonitoring(new TestMonitoringPlugin());
+core.addQuestion(new TestQuestionPlugin())
+
+let storage = new TestStoragePlugin({
+   domain: "example.com",
+   hostname: "test",
+   type: RecordTypes.A,
+   ttl: 500,
+   value: "10.0.0.1"
+}, 3)
+core.addStorage(storage);
+
+core.start().then(async () => {
+   let reqData = fromHex("E835 0100 0001 0000 0000 0000 04 74657374 07 6578616D706c65 03 636F6D 00 0001 0001");
+   console.time("core handler");
+   for (let i = 0; i < itr; i++) {
+      await listener.sendRequest(reqData)
+   }
+   console.timeEnd("core handler");
+});
--- a/src/core.ts
+++ b/src/core.ts
@ -0,0 +1,323 @@
+import { Request } from "./request";
+import { RecordTypes } from "./types";
+import * as LRU from "lru-cache";
+import { Writable } from "stream";
+import { Question } from "./question";
+import { RecourceRecord } from "./record";
+
+// export class AnswerSteam extends Writable {
+
+// }
+
+export interface Record {
+   type: RecordTypes
+   domain: string
+   hostname: string
+   value: string
+   ttl: number
+   priority?: number
+   additional?: string
+}
+
+export interface Plugin {
+   /**
+    * This sets the priority of this Plugin.
+    *
+    * The lower the value, the higher priority.
+    * It is recommended to make this value changeable over the cosntructor options field.
+    */
+   priority: number
+
+   init(core: DnsCore): Promise<void>
+}
+
+export type ListenerCallback =
+   ((data: Buffer, sender: string, max_size?: number) => Promise<Buffer>) |
+   ((data: Buffer, sender: string, answer: Writable) => Promise<void>)
+
+export interface ListenerPlugin extends Plugin {
+   /**
+    * This method is for registering a callback that is called
+    * when packet is received and ready for parsing.
+    * The function returns the Answer data. Errors shouldn't be possible
+    * by this function
+    */
+   registerCallback(callback: ListenerCallback): void
+}
+
+export class ListenerManager {
+   private _listener: ListenerPlugin[] = []
+
+   add(listener: ListenerPlugin) {
+      this._listener.push(listener)
+   }
+
+   setup(core: DnsCore) {
+      return Promise.all(this._listener.map(e => e.init(core)))
+   }
+
+   registerCallback(callback: ListenerCallback) {
+      this._listener.forEach(e => e.registerCallback(callback))
+   }
+}
+
+export interface MonitoringPlugin extends Plugin {
+   onRequest(domain: string, hostname: string, type: RecordTypes, additionalInformations): void
+}
+
+export class MonitoringManager {
+   private _monitoring: MonitoringPlugin[] = []
+
+   add(monitoring: MonitoringPlugin) {
+      this._monitoring.push(monitoring)
+   }
+
+   setup(core: DnsCore) {
+      return Promise.all(this._monitoring.map(e => e.init(core)))
+   }
+
+   onRequest(domain: string, hostname: string, type: RecordTypes, additionalInformations) {
+      this._monitoring.forEach(e => e.onRequest(domain, hostname, type, additionalInformations))
+   }
+}
+
+export interface StoragePlugin extends Plugin {
+   /**
+    * Here you can define wich record types this storage plugin is capable of.
+    */
+   record_types: RecordTypes[]
+
+   /**
+    * Disables record caching for this Storage
+    */
+   no_cache: boolean;
+
+   /**
+    * Returns if storage plugin is responsible for this domain.
+    * This check is synchroneus because it should be quick.
+    *
+    * @param domain The domain for check
+    */
+   isResponsible(domain: string): boolean
+   getRecords(domain: string, hostname: string, type: RecordTypes): Promise<Record[] | undefined>
+   getAllRecordsForDomain(domain: string): Promise<Record[]>
+}
+
+type SortedStorage = {
+   [P in keyof any]: StoragePlugin[] | undefined
+}
+
+const cacheoptions: LRU.Options = {
+   length: () => 1,
+   max: 500,
+   maxAge: 10 * 60 * 1000
+}
+
+class RecordCache {
+   private cache = new LRU<string, Record[]>(cacheoptions);
+
+   getRecords(domain: string, hostname: string, type: RecordTypes) {
+      let key = `${domain};;${hostname};;${RecordTypes[type]}`;
+      let rec = this.cache.get(key)
+      if (!rec) {
+         return undefined;
+      }
+      return rec;
+   }
+
+   addRecords(domain: string, hostname: string, type: RecordTypes, records: Record[], ttl: number) {
+      let key = `${domain};;${hostname};;${RecordTypes[type]}`;
+      this.cache.set(key, records, ttl);
+   }
+}
+
+export class StorageManager {
+   private _storages: StoragePlugin[] = []
+   private _sorted: SortedStorage;
+   private _cache = new RecordCache();
+
+   add(storage: StoragePlugin) {
+      this._storages.push(storage)
+   }
+
+   private presort() {
+      this._storages = this._storages.sort((e1, e2) => e1.priority - e2.priority)
+      this._sorted = <any>{}
+      for (let key in RecordTypes) {
+         let key_n = Number(key)
+         if (key_n !== Number.NaN) {
+            //The _storages list is sorted with priority.
+            this._sorted[key_n] = this._storages.filter(e => e.record_types.find(t => t === key_n) !== undefined)
+         }
+      }
+   }
+
+   setup(core: DnsCore) {
+      this.presort()
+      return Promise.all(this._storages.map(e => e.init(core)))
+   }
+
+   async getAllRecordsForDomain(domain: string) {
+      return this._storages.find(e => e.isResponsible(domain)).getAllRecordsForDomain(domain);
+   }
+
+   async getRecords(domain: string, hostname: string, type: RecordTypes) {
+      // First check if record is cached. Since the dns entries should not chacnge quickly
+      // using the cach for quicker response times is the way to go.
+      let records = this._cache.getRecords(domain, hostname, type);
+      if (records) return records;
+
+      let storages = this._sorted[type].filter(s => s.isResponsible(domain));
+      if (!storages || storages.length <= 0) return undefined
+
+      let nocache = false;
+      for (let storage of storages) {
+         nocache = storage.no_cache || nocache;
+         records = await storage.getRecords(domain, hostname, type)
+         if (records) {
+            if (storage.no_cache) this._cache.addRecords(domain, hostname, type, records, records.length <= 0 ? 3600 : records[0].ttl)
+            return records;
+         }
+      }
+
+      // If any of the checked storage engines that is
+      // responsible for the domain has the noCache flag,
+      // caching will be disabled for all.
+      if (!nocache)
+         this._cache.addRecords(domain, hostname, type, [], 0);
+      return [];
+   }
+}
+
+export interface AnswerHandler {
+   addQuestion: (question: Question) => void;
+   addAnswer: (record: RecourceRecord) => void;
+   addAdditional: (record: RecourceRecord) => void;
+   addAutority: (record: RecourceRecord) => void
+}
+
+export interface QuestionPlugin extends Plugin {
+   /**
+    * This field defines wich question types this plugin is capable of handling.
+    */
+   question_types: RecordTypes[];
+   init(core: DnsCore): Promise<void>
+
+   /**
+    *
+    * @param question The question this plugin should solve
+    * @param request This gives the plugin access to relevant
+    *  functions for queing depending questions or adding answers etc.
+    * @param next This function should be called if the plugin is not able to resolve
+    *  the request. This will trigger other handlers.
+    */
+   handleQuestion(question: Question, request: AnswerHandler, next: () => void): Promise<void>
+}
+
+export class QuestionManager {
+   private _questions: QuestionPlugin[] = [];
+   private _sorted = <any>{};
+   add(question: QuestionPlugin) {
+      this._questions.push(question);
+   }
+
+   private sort() {
+      this._questions = this._questions.sort((e1, e2) => e1.priority - e2.priority);
+      this._sorted = {};
+      for (let key in RecordTypes) {
+         let key_n = Number(key)
+         if (key_n !== Number.NaN) {
+            this._sorted[key_n] = this._questions.filter(e => e.question_types.find(t => t === key_n) !== undefined)
+         }
+      }
+   }
+
+   setup(core: DnsCore) {
+      this.sort();
+      return Promise.all(this._questions.map(e => e.init(core)))
+   }
+
+   async handleQuestion(question: Question, request: AnswerHandler) {
+      let handlers: QuestionPlugin[] = this._sorted[question.QTYPE];
+      if (!handlers || handlers.length <= 0) return;
+      let index = 0;
+      while (index < handlers.length) {
+         let i = index;
+         await handlers[i].handleQuestion(question, request, () => {
+            index++;
+         })
+         if (i === index) break;
+      }
+   }
+}
+
+export class DnsCore {
+   storageManager: StorageManager;
+   addStorage(plugin: StoragePlugin) {
+      this.storageManager.add(plugin);
+   }
+   monitoringManager: MonitoringManager;
+   addMonitoring(plugin: MonitoringPlugin) {
+      this.monitoringManager.add(plugin);
+   }
+   listenerManager: ListenerManager;
+   addListener(plugin: ListenerPlugin) {
+      this.listenerManager.add(plugin);
+   }
+
+   questionManager: QuestionManager;
+   addQuestion(plugin: QuestionPlugin) {
+      this.questionManager.add(plugin);
+   }
+
+   constructor() {
+      this.listenerManager = new ListenerManager()
+      this.monitoringManager = new MonitoringManager()
+      this.storageManager = new StorageManager()
+      this.questionManager = new QuestionManager()
+   }
+
+   async start() {
+      await this.storageManager.setup(this);
+      await this.monitoringManager.setup(this);
+      await this.listenerManager.setup(this);
+      await this.questionManager.setup(this);
+      this.listenerManager.registerCallback(this.onMessage.bind(this));
+   }
+
+   private onMessage: ListenerCallback = async (data: Buffer, sender: string, r) => {
+      let max_size = 128 * 1024;
+      let stream = true;
+      if (!r || typeof r === "number") {
+         max_size = r;
+         stream = false;
+      }
+      let request = new Request(data, sender, max_size);
+      let questionqueue: Promise<void>[] = [];
+      let handleQuestion = question => {
+         let prom = this.questionManager.handleQuestion(question, {
+            addAdditional: record => {
+               request.addAdditionals(record)
+            },
+            addAnswer: record => {
+               request.addAnswer(record);
+            },
+            addAutority: record => {
+               request.addAuthorities(record);
+            },
+            addQuestion: question => {
+               handleQuestion(question)
+            }
+         })
+         questionqueue.push(prom);
+      }
+      request.questions.map(q => handleQuestion(q));
+      await Promise.all(questionqueue);
+      let res = request.serialize();
+      if (stream) {
+         (<Writable>r).write(res);
+      } else {
+         return res;
+      }
+   }
+}
--- a/src/header.ts
+++ b/src/header.ts
@ -0,0 +1,75 @@
+import { IMessageHeader, ErrorCodes } from "./types";
+import { Serializeable } from "./serializeable";
+
+export class Header implements IMessageHeader, Serializeable {
+   ID: number;
+   QR: 0 | 1;
+   OPCODE: number
+   AA: 0 | 1;
+   TC: 0 | 1;
+   RD: 0 | 1;
+   RA: 0 | 1;
+   Z: 0 | 1;
+   AD: 0 | 1;
+   CD: 0 | 1;
+   RCODE: ErrorCodes;
+   QDCOUNT: number;
+   ANCOUNT: number;
+   NSCOUNT: number;
+   ARCOUNT: number;
+
+   constructor(header: IMessageHeader) {
+      for (let k in header) {
+         this[k] = header[k];
+      }
+   }
+
+   lock() {
+      var f = 0x0000;
+      f = f | (this.QR << 15);
+      f = f | (this.OPCODE << 11);
+      f = f | (this.AA << 10);
+      f = f | (this.TC << 9);
+      f = f | (this.RD << 8);
+      f = f | (this.RA << 7);
+      f = f | (this.Z << 6);
+      f = f | (this.AD << 5);
+      f = f | (this.CD << 4);
+      f = f | this.RCODE;
+
+      let id = this.ID;
+      let qdc = this.QDCOUNT;
+      let anc = this.ANCOUNT;
+      let nsc = this.NSCOUNT;
+      let arc = this.ARCOUNT;
+      return {
+         length: 12,
+         serialize: (buffer: Buffer, offset: number) => {
+            buffer.writeUInt16BE(id, offset);
+            offset += 2;
+            buffer.writeUInt16BE(f, offset);
+            offset += 2;
+            buffer.writeUInt16BE(qdc, offset);
+            offset += 2;
+            buffer.writeUInt16BE(anc, offset);
+            offset += 2;
+            buffer.writeUInt16BE(nsc, offset);
+            offset += 2;
+            buffer.writeUInt16BE(arc, offset);
+            return offset + 2;
+         }
+      }
+   }
+
+   // serialize() {
+   //    let data = Buffer.alloc(12);
+   //    data.writeUInt16BE(this.ID, 0);
+
+   //    data.writeUInt16BE(f, 2);
+   //    data.writeUInt16BE(this.QDCOUNT, 4)
+   //    data.writeUInt16BE(this.ANCOUNT, 6)
+   //    data.writeUInt16BE(this.NSCOUNT, 8)
+   //    data.writeUInt16BE(this.ARCOUNT, 10)
+   //    return data;
+   // }
+}
--- a/src/index.ts
+++ b/src/index.ts
@ -0,0 +1,4 @@
+export { DnsCore, ListenerPlugin, MonitoringPlugin, StoragePlugin, QuestionPlugin, AnswerHandler, Record } from "./core"
+export { RecourceRecord, RDATARecord } from "./record"
+export { Request } from "./request"
+export { Label } from "./label"
--- a/src/label.ts
+++ b/src/label.ts
@ -0,0 +1,60 @@
+import { Serializeable } from "./serializeable";
+
+const MAX_LABEL_SIZE = 63;
+
+export class Label implements Serializeable {
+   constructor(public name?: string) { }
+
+   public lock() {
+      let parts = this.name.split(".");
+      let length = 0;
+      parts.forEach(e => {
+         if (e.length > MAX_LABEL_SIZE) throw new Error("Label to large");
+         length += e.length + 1;
+      })
+
+      length += 1;
+      return {
+         length: length,
+         serialize: (buffer: Buffer, offset: number) => {
+            parts.forEach(e => {
+               buffer.writeUInt8(e.length, offset)
+               offset++
+               buffer.write(e, offset, e.length)
+               offset += e.length
+            })
+            buffer.writeUInt8(0, offset);
+            offset += 1;
+            return offset;
+         }
+      }
+   }
+
+   // set name(name: string) {
+   //    if (name != this._name) {
+   //       let length = 0;
+   //       let parts = name.split(".")
+   //       parts.forEach(e => {
+   //          if (e.length > MAX_LABEL_SIZE) throw new Error("Label to large");
+   //          length += e.length + 1;
+   //       })
+
+   //       length += 1; //Adding last 0 length octet
+   //       this._length = length;
+   //       this._name_parts = parts;
+   //       this._name = name;
+   //    }
+   // }
+
+   // get name() {
+   //    return this._name;
+   // }
+
+   // get length() {
+   //    return this._length;
+   // }
+
+   // serialize(buffer: Buffer, offset: number) {
+
+   // }
+}
--- a/src/listener.ts
+++ b/src/listener.ts
@ -1,70 +0,0 @@
-import * as net from "net"
-import * as dgram from "dgram";
-import { Request } from "./request";
-import { PassThrough } from "stream";
-export default class Listener {
-   private udp: dgram.Socket
-   private tcp: net.Server
-   constructor(type: "udp" | "tcp", onRequest: (request: Request) => any, port: number, host: string = "0.0.0.0") {
-      switch (type) {
-         case "udp":
-            this.udp = dgram.createSocket("udp4")
-            this.udp.on("listening", () => {
-               console.log(`UDP Server Listening on ${port}`)
-            })
-
-            this.udp.on("message", (message, remote) => {
-               let request = new Request(message, (data) => {
-                  // console.log("sending:", new Request(data, (a) => 0));
-                  this.udp.send(data, remote.port, remote.address)
-               })
-               onRequest(request);
-            })
-
-            this.udp.bind(port, host)
-            break;
-         case "tcp":
-            console.log("Not correct implemented")
-            this.tcp = net.createServer((socket) => {
-               let length: number;
-               let got: number = 0;
-               let message = undefined;
-               socket.on("data", (data) => {
-                  let offset = 0;
-                  if (!message) {
-                     length = data.readUInt16BE(0);
-                     if (length > 2048) return socket.destroy(); //Requests with more that 2k are ignored
-                     message = Buffer.alloc(length);
-                     offset = 2;
-                  }
-
-                  let read = (data.length - offset) > (length - got) ? (length - got) : (data.length - offset);
-                  data.copy(message, got, offset, read + offset)
-                  got += read;
-                  //ToDo don't ignore probably following requests
-                  if (got >= length) {
-                     let request = new Request(message, (data) => {
-                        socket.write(data);
-                     })
-                     got = 0;
-                     message = undefined;
-                     length = 0;
-                     onRequest(request);
-                  }
-               });
-            });
-            this.tcp.listen(port, host);
-            break;
-         default:
-            throw new Error("Unknown socket type")
-      }
-   }
-
-   close() {
-      if (this.udp) {
-         this.udp.close();
-      } else {
-         this.tcp.close();
-      }
-   }
-}
--- a/lib/test.d.ts
+++ b/lib/test.d.ts
--- a/src/question.ts
+++ b/src/question.ts
@ -0,0 +1,37 @@
+import { IMessageQuestion } from "./types";
+import { Label } from "./label";
+import { Serializeable } from "./serializeable";
+
+export class Question implements IMessageQuestion, Serializeable {
+   private _QNAME = new Label();
+   get QNAME() { return this._QNAME.name };
+
+   _QTYPE: number;
+   get QTYPE() { return this._QTYPE };
+
+   _QCLASS: number;
+   get QCLASS() { return this._QCLASS };
+
+   constructor(question: IMessageQuestion) {
+      this._QCLASS = question.QCLASS;
+      this._QTYPE = question.QTYPE;
+      this._QNAME.name = question.QNAME;
+   }
+
+   lock() {
+      let name = this._QNAME.lock();
+      let type = this._QTYPE;
+      let cl = this._QCLASS;
+      return {
+         length: name.length + 4,
+         serialize: (buffer: Buffer, offset: number) => {
+            offset = name.serialize(buffer, offset);
+            buffer.writeUInt16BE(type, offset);
+            offset += 2;
+            buffer.writeUInt16BE(cl, offset);
+            offset += 2;
+            return offset;
+         }
+      }
+   }
+}
--- a/src/record.ts
+++ b/src/record.ts
@ -0,0 +1,92 @@
+import { Serializeable, Serializer } from "./serializeable";
+import { MessageRecourceRecord } from "./types";
+import { Label } from "./label";
+
+export class RecourceRecord implements Partial<MessageRecourceRecord>, Serializeable {
+   /**
+    * This value can be set to identify if specific record is already set
+    */
+   public Identifier: string;
+
+   private _NAME = new Label();
+   public get NAME() { return this._NAME.name };
+   public set NAME(name) { this._NAME.name = name };
+
+   private _TYPE: number;
+   public get TYPE() { return this._TYPE }
+   public set TYPE(value) {
+      if (value < 0 || value > 65535) throw new TypeError("TYPE Range: 0 - 65.535")
+      this._TYPE = value;
+   }
+
+   private _CLASS: number = 1;
+   public get CLASS() { return this._CLASS }
+   public set CLASS(value) {
+      if (value < 0 || value > 65535) throw new TypeError("CLASS Range: 0 - 65.535")
+      this._CLASS = value;
+   }
+
+   private _TTL: number;
+   public get TTL() { return this._TTL }
+   public set TTL(value) {
+      if (value < 0 || value > 4294967295) throw new TypeError("TTL Range: 0 - 4.294.967.295")
+      this._TTL = value;
+   }
+
+   constructor(data?: Partial<MessageRecourceRecord>) {
+      if (data) {
+         for (let key in data) {
+            this[key] = data[key];
+         }
+      }
+   }
+
+   protected dataLock?: () => Serializer;
+
+   public lock() {
+      if (!this.dataLock) return {
+         length: 0,
+         serialize: (buffer: Buffer, offset: number) => offset
+      }
+
+      let name = this._NAME.lock();
+      let type = this.TYPE;
+      let cl = this.CLASS;
+      let ttl = this.TTL;
+      let data = this.dataLock();
+      let length = name.length + 2 + 2 + 4 + 2 + data.length;
+      return {
+         length: length,
+         serialize: (buffer: Buffer, offset: number) => {
+            offset = name.serialize(buffer, offset);
+            buffer.writeUInt16BE(type, offset)
+            offset += 2
+            buffer.writeUInt16BE(cl, offset)
+            offset += 2
+            buffer.writeUInt32BE(ttl, offset)
+            offset += 4
+            buffer.writeUInt16BE(data.length, offset)
+            offset += 2
+            return data.serialize(buffer, offset);
+         }
+      }
+   }
+}
+
+export class RDATARecord extends RecourceRecord {
+   public RDATA: Buffer;
+
+   get RDLENGTH() {
+      return this.RDATA.length;
+   }
+
+   dataLock = () => {
+      return {
+         length: this.RDATA.length,
+         serialize: (buffer: Buffer, offset: number) => {
+            this.RDATA.copy(buffer, offset);
+            return offset + this.RDATA.length;
+         }
+      }
+   }
+}
--- a/src/request.ts
+++ b/src/request.ts
@ -1,121 +1,11 @@
 import { Parser } from "binary-parser"
-import { Message, MessageHeader, MessageQuestion, MessageRecourceRecord, ErrorCodes } from "./types"
+import { IMessageHeader, IMessageQuestion, MessageRecourceRecord, ErrorCodes } from "./types"
+import { Serializer, Serializeable } from "./serializeable";
+import { Question } from "./question";
+import { RecourceRecord } from "./record";
+import { Header } from "./header";

-const MAX_LABEL_SIZE = 63;
-
-export enum QueryTypes {
-   /**
-    * IPv4 address
-    */
-   A = 0x01,
-
-   /**
-    * Nameserver
-    */
-   NS = 0x02,   // nameserver
-
-   /**
-    * Obsolete
-    */
-   MD = 0x03,   // obsolete
-
-   /**
-    * Obsolete
-    */
-   MF = 0x04,   // obsolete
-
-   /**
-    * Alias
-    */
-   CNAME = 0x05,   // alias
-
-   /**
-    * Start of authority
-    */
-   SOA = 0x06,   // start of authority
-
-   /**
-    * Experimental
-    */
-   MB = 0x07,   // experimental
-
-   /**
-    * Experimental
-    */
-   MG = 0x08,   // experimental
-
-   /**
-    * Experimental
-    */
-   MR = 0x09,   // experimental
-
-   /**
-    * Experimental
-    */
-   NULL = 0x0A,   // experimental null RR
-
-   /**
-    * Service description
-    */
-   WKS = 0x0B,   // service description
-
-   /**
-    * Reverse entry (inaddr.arpa)
-    */
-   PTR = 0x0C,   // reverse entry (inaddr.arpa)
-
-   /**
-    * Host information
-    */
-   HINFO = 0x0D,   // host information
-
-   /**
-    * Mailbox / Mail-list information
-    */
-   MINFO = 0x0E,   // mailbox or mail list information
-
-   /**
-    * Mail exchange
-    */
-   MX = 0x0F,   // mail exchange
-
-   /**
-    * Text strings
-    */
-   TXT = 0x10,   // text strings
-
-   /**
-    * IPv6 address
-    */
-   AAAA = 0x1C,   // ipv6 address
-
-   /**
-    * SRV records
-    */
-   SRV = 0x21,   // srv records
-
-   /**
-    * Request to transfer entire zone
-    */
-   AXFR = 0xFC,   // request to transfer entire zone
-
-   /**
-    * Request for mailbox related records
-    */
-   MAILA = 0xFE,   // request for mailbox related records
-
-   /**
-    * Request for mail agend RRs
-    */
-   MAILB = 0xFD,   // request for mail agent RRs
-
-   /**
-    * Any class
-    */
-   ANY = 0xFF,   // any class
-}
-
-const headerParser = new Parser()
+export const headerParser: Parser = new Parser()
   .endianess("big")
   .uint16("ID")
   .bit1("QR")
@ -133,7 +23,7 @@ const headerParser = new Parser()
   .uint16("NSCOUNT")
   .uint16("ARCOUNT")

-const labelParser = new Parser()
+export const labelParser = new Parser()
   .endianess("big")
   .uint8("dataLength")
   .string("name", {
@ -141,7 +31,7 @@ const labelParser = new Parser()
      encoding: "ascii"
   })

-const questionParser = new Parser()
+export const questionParser = new Parser()
   .endianess("big")
   .array("QNAME", {
      type: labelParser,
@ -156,64 +46,54 @@ const questionParser = new Parser()
   .uint16("QTYPE")
   .uint16("QCLASS")

-function parseQuestions(count: number, packet: Buffer): MessageQuestion[] {
-   return <any>new Parser()
-      .endianess("big")
-      .array("questions", {
-         type: questionParser,
-         length: count
-      }).parse(packet).questions;
-}

-export function SerializeName(name: string) {
-   let length = 0;
-   let parts = name.split(".");
-   parts.forEach(e => {
-      // Length of part and byte that holds the length information
-      if (e.length > MAX_LABEL_SIZE) throw new Error("Label to large");
-      length += e.length + 1;
+const packetParser = new Parser()
+   .endianess("big")
+   .nest("header", { type: headerParser })
+   .array("questions", {
+      type: questionParser,
+      length: "header.QDCOUNT"
   })

-   length += 1; //Adding last 0 length octet
-   let data = Buffer.alloc(length);
-   let offset = 0;
-   parts.forEach(e => {
-      data.writeUInt8(e.length, offset)
-      offset++
-      data.write(e, offset, e.length)
-      offset += e.length
-   })
-   data.writeUInt8(0, offset);
-   return data;
+export function parseInput(data: Buffer): { header: IMessageHeader, questions: IMessageQuestion[] } {
+   let res = packetParser.parse(data);
+   return <any>res;
 }

-export class Request implements Message {
-   private _header: MessageHeader;
+export class Request {
+   private _header: Header;
   get header() {
-      return Object.assign({}, this._header);
+      return { ...this._header };
   }

-   private _questions: MessageQuestion[];
+   private _questions: Question[];
   get questions() {
-      return this._questions.map(e => e);
+      return this._questions.map(e => new Question(e));
   }

-   answers: RecourceRecord[] = [];
-   authorities: RecourceRecord[] = [];
-   additionals: RecourceRecord[] = [];
+   private _answers: Serializer[] = [];
+   addAnswer(rr: RecourceRecord) {
+      this._answers.push(rr.lock())
+   }

-   constructor(packet: Buffer, private sendCallback: (packet: Buffer) => any) {
-      let headerData = Buffer.alloc(12);
-      packet.copy(headerData, 0, 0, 12);
-      let bodyData = Buffer.alloc(packet.length - 12);
-      packet.copy(bodyData, 0, 12, packet.length);
+   private _authorities: Serializer[] = [];
+   addAuthorities(rr: RecourceRecord) {
+      this._authorities.push(rr.lock())
+   }

-      this._header = <any>headerParser.parse(headerData);
+   private _additionals: Serializer[] = [];
+   addAdditionals(rr: RecourceRecord) {
+      this._additionals.push(rr.lock())
+   }
+
+   constructor(packet: Buffer, public sender: string, private max_size = 0) {
+      let parsed = parseInput(packet);
+
+      this._header = new Header(parsed.header);
      this._header.AD = 0;
      this._header.RCODE = ErrorCodes.NoError;
      this._header.RA = this._header.RD;
-
-      this._questions = parseQuestions(this._header.QDCOUNT, bodyData);
+      this._questions = parsed.questions.map(e => new Question(e));
   }

   error(error: ErrorCodes) {
@ -225,54 +105,41 @@ export class Request implements Message {
      this._header.RA = 0;
   }

-   send() {
-      this.sendCallback(this.serialize());
-   }
-
-   serialize(truncate: boolean = false, rcode: 0 | 1 | 2 | 3 | 4 | 5 = 0) {
+   serialize() {
      this._header.AA = 1;
-      this._header.ANCOUNT = this.answers.length;
-      this._header.ARCOUNT = this.additionals.length;
-      this._header.NSCOUNT = this.authorities.length;
+      this._header.ANCOUNT = this._answers.length;
+      this._header.ARCOUNT = this._additionals.length;
+      this._header.NSCOUNT = this._authorities.length;
      this._header.QR = 1;
-      this._header.RCODE = rcode;

-      let questions = this.questions.map(this.serializeQuestion, this)
-      let answers = this.answers.map(this.serializeResourceRecord, this)
-      let authority = this.authorities.map(this.serializeResourceRecord, this)
-      let additional = this.additionals.map(this.serializeResourceRecord, this)
+      let header = this._header.lock();
+      let questions = this._questions.map(e => e.lock())
+      let answers = this._answers;
+      let authority = this._authorities;
+      let additional = this._additionals;

-      let questionsByteLength = 0;
-      questions.forEach(e => questionsByteLength += e.length);
+      let length = header.length;
+      questions.forEach(e => length += e.length);
+      answers.forEach(e => length += e.length)
+      authority.forEach(e => length += e.length)
+      additional.forEach(e => length += e.length)

-      let answersByteLength = 0;
-      answers.forEach(e => answersByteLength += e.length)
-
-      let authorityByteLength = 0;
-      authority.forEach(e => authorityByteLength += e.length)
-
-      let additionalByteLength = 0;
-      additional.forEach(e => additionalByteLength += e.length)
-
-      let length = 12 + questionsByteLength + answersByteLength + authorityByteLength + additionalByteLength; //Header is always 12 byte large
-
-      if (truncate && length > 512) {
+      if (this.max_size && length > this.max_size) {
         this._header.TC = 1;

-         //Buffer will ignore data that exeeds the max buffer length
-         length = 512;
+         //Will ignore data, that exceeds length
+         length = this.max_size;
      }

-      let header = this.serializeHeader()

      let data = Buffer.alloc(length)
      let offset = 0;

-      let append = (buffer: Buffer) => {
-         buffer.copy(data, offset, 0, buffer.length)
-         offset += buffer.length;
+      let append = (ser: Serializer) => {
+         if (offset <= length) {
+            offset = ser.serialize(data, offset);
+         }
      }
-
      append(header)
      questions.forEach(append)
      answers.forEach(append)
@ -280,100 +147,4 @@ export class Request implements Message {
      additional.forEach(append)
      return data;
   }
-
-   private serializeHeader() {
-      let header = this.header;
-      let data = Buffer.alloc(12);
-      data.writeUInt16BE(header.ID, 0);
-      var f = 0x0000;
-      f = f | (header.QR << 15);
-      f = f | (header.OPCODE << 11);
-      f = f | (header.AA << 10);
-      f = f | (header.TC << 9);
-      f = f | (header.RD << 8);
-      f = f | (header.RA << 7);
-      f = f | (header.Z << 6);
-      f = f | (header.AD << 5);
-      f = f | (header.CD << 4);
-      f = f | header.RCODE;
-      data.writeUInt16BE(f, 2);
-
-      data.writeUInt16BE(header.QDCOUNT, 4)
-      data.writeUInt16BE(header.ANCOUNT, 6)
-      data.writeUInt16BE(header.NSCOUNT, 8)
-      data.writeUInt16BE(header.ARCOUNT, 10)
-      return data;
-   }
-
-   private serializeQuestion(question: MessageQuestion) {
-      let qname = SerializeName(question.QNAME);
-      let data = Buffer.alloc(qname.length + 4);
-      qname.copy(data, 0, 0, qname.length);
-      let offset = qname.length;
-      data.writeUInt16BE(question.QTYPE, offset);
-      offset += 2;
-      data.writeUInt16BE(question.QCLASS, offset);
-      return data;
-   }
-
-   private serializeResourceRecord(record: MessageRecourceRecord) {
-      // TODO: Implement compression
-      let name = SerializeName(record.NAME);
-      let data = Buffer.alloc(name.length + 10 + record.RDLENGTH) // For TYPE, CLASS, TTL, RLENGTH
-      name.copy(data, 0, 0, name.length);
-      let offset = name.length;
-      data.writeUInt16BE(record.TYPE, offset)
-      offset += 2
-      data.writeUInt16BE(record.CLASS, offset)
-      offset += 2
-      data.writeUInt32BE(record.TTL, offset)
-      offset += 4
-      data.writeUInt16BE(record.RDLENGTH, offset)
-      offset += 2
-      record.RDATA.copy(data, offset, 0, record.RDLENGTH)
-      return data;
-   }
-}
-
-export class RecourceRecord implements MessageRecourceRecord {
-   /**
-    * This value can be set to identify if specific record is already set
-    */
-   Identifier: string;
-
-   NAME: string
-   private _TYPE: number;
-   set TYPE(value) {
-      if (value < 0 || value > 65535) throw new TypeError("TYPE Range: 0 - 65.535")
-      this._TYPE = value;
-   }
-
-   get TYPE() {
-      return this._TYPE;
-   }
-
-   private _CLASS: number;
-   set CLASS(value) {
-      if (value < 0 || value > 65535) throw new TypeError("CLASS Range: 0 - 65.535")
-      this._CLASS = value;
-   }
-
-   get CLASS() {
-      return this._CLASS;
-   }
-
-   private _TTL: number;
-   set TTL(value) {
-      if (value < 0 || value > 4294967295) throw new TypeError("TTL Range: 0 - 4.294.967.295")
-   }
-
-   get TTL() {
-      return this._TTL;
-   }
-
-   RDATA: Buffer;
-
-   get RDLENGTH() {
-      return this.RDATA.length;
-   }
 }
--- a/src/serializeable.ts
+++ b/src/serializeable.ts
@ -0,0 +1,19 @@
+export interface Serializer {
+   /**
+       *
+       * @param buffer Buffer to write to (should be capable to hold this.length)
+       * @param offset The offset at wich to start writing
+       * @returns The new offset (should be equal to original offset + this.length)
+       */
+   serialize(buffer: Buffer, offset: number): number;
+
+   /**
+    * Returns length of serialized data
+    * @readonly
+    */
+   length: number;
+}
+
+export interface Serializeable {
+   lock(): Serializer;
+}
--- a/src/test.ts
+++ b/src/test.ts
@ -1,5 +1,518 @@
-// const t = `71 15 01 00 00 01 00 00 00 00 00 00 02 64 63 08 73 65 72 76 69 63 65 73 0c 76 69 73 75 61 6c 73 74 75 64 69 6f 03 63 6f 6d 00 00 01 00 01`.split(" ").join("");
-// // const tp = Buffer.from(t, "hex")
-// // // import Parse from "./index";
-// // import * as util from "util";
-// // console.log(util.inspect(Parse(tp), false, 20, true));
+import { assert } from "chai";
+
+import { parseInput, Request, questionParser, headerParser } from "./request"
+import { IMessageHeader, RecordTypes } from "./types";
+import { RDATARecord, RecourceRecord } from "./record";
+import { Question } from "./question";
+import { Header } from "./header";
+
+function fromHex(data: string) {
+   return Buffer.from(data.replace(/\s/g, ""), "hex");
+}
+
+describe("parser", function () {
+   describe("header", function () {
+      describe("header parser", function () {
+         let should_templ: IMessageHeader = {
+            ID: 0, QR: 0, OPCODE: 0, AA: 0, TC: 0, RD: 0, RA: 0, Z: 0, AD: 0, CD: 0, RCODE: 0, QDCOUNT: 0, ANCOUNT: 0, ARCOUNT: 0, NSCOUNT: 0
+         }
+
+         let tests: { name: string, data: string, fields: Partial<IMessageHeader> }[] = [
+            {
+               name: "Testing ID field",
+               data: "0001 0000 0000 0000 0000 0000",
+               fields: {
+                  ID: 1
+               }
+            },
+            {
+               name: "Testing ID field with max value",
+               data: "FFFF 0000 0000 0000 0000 0000",
+               fields: {
+                  ID: 65535
+               }
+            },
+            {
+               name: "Testing QR field",
+               data: "0000 8000 0000 0000 0000 0000",
+               fields: {
+                  QR: 1
+               }
+            },
+            {
+               name: "Testing OPCODE field value 2",
+               data: "0000 1000 0000 0000 0000 0000",
+               fields: {
+                  OPCODE: 2
+               }
+            },
+            {
+               name: "Testing OPCODE field value 1",
+               data: "0000 0800 0000 0000 0000 0000",
+               fields: {
+                  OPCODE: 1
+               }
+            },
+            {
+               name: "Testing AA field",
+               data: "0000 0400 0000 0000 0000 0000",
+               fields: {
+                  AA: 1
+               }
+            },
+            {
+               name: "Testing TC field",
+               data: "0000 0200 0000 0000 0000 0000",
+               fields: {
+                  TC: 1
+               }
+            },
+            {
+               name: "Testing RD field",
+               data: "0000 0100 0000 0000 0000 0000",
+               fields: {
+                  RD: 1
+               }
+            },
+            {
+               name: "Testing RCODE field",
+               data: "0000 0002 0000 0000 0000 0000",
+               fields: {
+                  RCODE: 2
+               }
+            },
+            {
+               name: "Testing QDCOUNT field max value",
+               data: "0000 0000 FFFF 0000 0000 0000",
+               fields: {
+                  QDCOUNT: 65535
+               }
+            },
+            {
+               name: "Testing ANCOUNT field max value",
+               data: "0000 0000 0000 FFFF 0000 0000",
+               fields: {
+                  ANCOUNT: 65535
+               }
+            },
+            {
+               name: "Testing NSCOUNT field max value",
+               data: "0000 0000 0000 0000 FFFF 0000",
+               fields: {
+                  NSCOUNT: 65535
+               }
+            },
+            {
+               name: "Testing ARCOUNT field max value",
+               data: "0000 0000 0000 0000 0000 FFFF",
+               fields: {
+                  ARCOUNT: 65535
+               }
+            },
+            {
+               name: "Testing all Flags and Values max",
+               data: "FFFF FFFF FFFF FFFF FFFF FFFF",
+               fields: {
+                  ID: 65535, QR: 1, OPCODE: 15, AA: 1, TC: 1, RD: 1, RA: 1, Z: 1, AD: 1, CD: 1, RCODE: 15, QDCOUNT: 65535, ANCOUNT: 65535, NSCOUNT: 65535, ARCOUNT: 65535
+               }
+            }
+         ]
+         tests.forEach(function (e) {
+            it(e.name, function () {
+               let testdata = fromHex(e.data)
+               let should: IMessageHeader = { ...should_templ, ...e.fields }
+               let header = <any>headerParser.parse(testdata);
+               assert.hasAllKeys(header, Object.keys(should), "Parsed header is missing some fields")
+               assert.deepEqual(header, should, "Parsed header has not expected values!")
+            })
+         })
+      })
+
+      describe("header serializer", function () {
+         let empty_header: IMessageHeader = {
+            ID: 0, QR: 0, OPCODE: 0, AA: 0, TC: 0, RD: 0, RA: 0, Z: 0, AD: 0, CD: 0, RCODE: 0, QDCOUNT: 0, ANCOUNT: 0, ARCOUNT: 0, NSCOUNT: 0
+         }
+         let tests: { name: string, result: string, values: Partial<IMessageHeader> }[] = [
+            {
+               name: "Fill header with 0s",
+               result: "0000 0000 0000 0000 0000 0000",
+               values: {}
+            },
+            {
+               name: "Set header id to 5",
+               result: "0005 0000 0000 0000 0000 0000",
+               values: {
+                  ID: 5
+               }
+            },
+            {
+               name: "Set QR",
+               result: "0000 8000 0000 0000 0000 0000",
+               values: {
+                  QR: 1
+               }
+            },
+            {
+               name: "Set OPCODE",
+               result: "0000 7800 0000 0000 0000 0000",
+               values: {
+                  OPCODE: 15
+               }
+            },
+            {
+               name: "Set AA",
+               result: "0000 0400 0000 0000 0000 0000",
+               values: {
+                  AA: 1
+               }
+            },
+            {
+               name: "Set TC",
+               result: "0000 0200 0000 0000 0000 0000",
+               values: {
+                  TC: 1
+               }
+            },
+            {
+               name: "Set RD",
+               result: "0000 0100 0000 0000 0000 0000",
+               values: {
+                  RD: 1
+               }
+            },
+            {
+               name: "Set RA",
+               result: "0000 0080 0000 0000 0000 0000",
+               values: {
+                  RA: 1
+               }
+            },
+            {
+               name: "Set Z",
+               result: "0000 0040 0000 0000 0000 0000",
+               values: {
+                  Z: 1
+               }
+            },
+            {
+               name: "Set AD",
+               result: "0000 0020 0000 0000 0000 0000",
+               values: {
+                  AD: 1
+               }
+            },
+            {
+               name: "Set CD",
+               result: "0000 0010 0000 0000 0000 0000",
+               values: {
+                  CD: 1
+               }
+            },
+            {
+               name: "Set RCODE",
+               result: "0000 000F 0000 0000 0000 0000",
+               values: {
+                  RCODE: 15
+               }
+            },
+            {
+               name: "Set QDCOUNT",
+               result: "0000 0000 FFFF 0000 0000 0000",
+               values: {
+                  QDCOUNT: 65535
+               }
+            },
+            {
+               name: "Set ANCOUNT",
+               result: "0000 0000 0000 FFFF 0000 0000",
+               values: {
+                  ANCOUNT: 65535
+               }
+            },
+            {
+               name: "Set NSCOUNT",
+               result: "0000 0000 0000 0000 FFFF 0000",
+               values: {
+                  NSCOUNT: 65535
+               }
+            },
+            {
+               name: "Set ARCOUNT",
+               result: "0000 0000 0000 0000 0000 FFFF",
+               values: {
+                  ARCOUNT: 65535
+               }
+            },
+         ]
+
+         tests.forEach(function (e) {
+            it(e.name, function () {
+               let header = Object.assign({}, empty_header, e.values)
+               let slz = new Header(header).lock();
+               assert.equal(slz.length, 12, "Header returns wrong length");
+               let res = Buffer.alloc(slz.length);
+               assert.equal(slz.serialize(res, 0), 12, "Header returns wrong offset");
+               assert.equal(res.toString("hex"), e.result.replace(/\s/g, "").toLowerCase(), "Header serialization failed");
+            })
+         })
+      })
+   })
+
+   describe("question", function () {
+      let questionData = fromHex("0474 6573 7407 6578 616d 706c 6503 636f 6d00 0001 0001")
+      let questionObj = {
+         QNAME: "test.example.com",
+         QTYPE: RecordTypes.A,
+         QCLASS: 1
+      }
+      it("check question parser with one question", function () {
+
+         let res = questionParser.parse(questionData)
+
+         assert.deepEqual(res, questionObj, "Question parser does not parse input correctly")
+      })
+
+      it("check question serialization", function () {
+         let slz = new Question(questionObj).lock()
+         assert.equal(slz.length, 22, "Question serializer returns wrong length")
+         let res = Buffer.alloc(slz.length);
+         assert.equal(slz.serialize(res, 0), 22, "Question serializer returns wrong offset")
+         assert.equal(res.toString("hex"), questionData.toString("hex"), "Query serializer does not serialite correctly");
+      })
+   })
+
+   it("parse valid request", () => {
+      let should = {
+         header: { ID: 59445, QR: 0, OPCODE: 0, AA: 0, TC: 0, RD: 1, RA: 0, Z: 0, AD: 0, CD: 0, RCODE: 0, QDCOUNT: 1, ANCOUNT: 0, NSCOUNT: 0, ARCOUNT: 0 },
+         questions: [{ QNAME: 'example.com', QTYPE: 1, QCLASS: 1 }]
+      }
+      let data = fromHex("E835 0100 0001 0000 0000 0000 07 6578616D706c65 03636F6D 00 0001 0001");
+      let res = parseInput(data);
+      assert.deepEqual(res, should);
+   })
+
+
+   it("recource record serialization", function () {
+      let should = "07 6578616D706C65 03 636f6D 00 0001 0001 00000640 0004 0A000001"
+      let rr = new RDATARecord()
+      rr.CLASS = 1
+      rr.NAME = "example.com"
+      rr.TTL = 1600
+      rr.TYPE = 1
+      rr.RDATA = fromHex("0A 00 00 01")
+      let srl = rr.lock();
+      let res = Buffer.alloc(srl.length);
+      srl.serialize(res, 0);
+      assert.equal(res.toString("hex"), should.replace(/\s/g, "").toLowerCase(), "Serialization not working properly")
+   })
+
+   it("recource record constructor value assign", function () {
+      let should = "07 6578616D706C65 03 636f6D 00 0001 0001 00000640 0004 0A000001"
+      let rr = new RDATARecord({
+         CLASS: 1,
+         NAME: "example.com",
+         TTL: 1600,
+         TYPE: 1,
+         RDATA: fromHex("0A 00 00 01")
+      })
+      let srl = rr.lock();
+      assert.equal(srl.length, 27, "Record serializer returns wrong length")
+      let res = Buffer.alloc(srl.length);
+      assert.equal(srl.serialize(res, 0), 27, "Record serializer returns wrong offset")
+      assert.equal(res.toString("hex"), should.replace(/\s/g, "").toLowerCase(), "Record serialization not working properly")
+   })
+
+   it("full response serialization", function () {
+      let reqData = fromHex("E835 0100 0001 0000 0000 0000 07 6578616D706c65 03636F6D 00 0001 0001");
+      let should = "E835 8580 0001000100000000 076578616D706C6503636F6D0000010001 07 6578616D706C65 03 636F6D 00 0001 0001 0000 0640 0004 0A000001"
+      let request = new Request(reqData, "")
+      let rr = new RDATARecord()
+      rr.CLASS = 1
+      rr.NAME = "example.com"
+      rr.TTL = 1600
+      rr.TYPE = 1
+      rr.RDATA = fromHex("0A 00 00 01")
+      request.addAnswer(rr);
+      let data = request.serialize()
+      assert.equal(data.toString("hex"), should.replace(/\s/g, "").toLowerCase(), "Whole packet serialization failed")
+   })
+})
+
+import { DnsCore, StoragePlugin, Record, MonitoringPlugin, QuestionPlugin, AnswerHandler, ListenerPlugin } from "./core"
+
+describe("DNS Core", function () {
+   it("Initialization", () => {
+      let core = new DnsCore();
+      assert.exists(core, "Core constructor working")
+   })
+
+   it("Adding fake plugins and initialize", () => {
+      let core = new DnsCore();
+
+      core.addListener({
+         init: async (c) => { assert.exists(c, "Core not defined on Plugin init") },
+         priority: 0,
+         registerCallback: () => { }
+      })
+
+      core.addMonitoring({
+         init: async (c) => { assert.exists(c, "Core not defined on Plugin init") },
+         priority: 0,
+         onRequest: () => { }
+      })
+
+      core.addQuestion({
+         init: async (c) => { assert.exists(c, "Core not defined on Plugin init") },
+         question_types: [RecordTypes.A],
+         priority: 0,
+         handleQuestion: async () => { },
+      })
+
+      core.addStorage({
+         getAllRecordsForDomain: async () => undefined,
+         getRecords: async () => undefined,
+         init: async (c) => { assert.exists(c, "Core not defined on Plugin init") },
+         isResponsible: () => true,
+         no_cache: false,
+         priority: 0,
+         record_types: [RecordTypes.A]
+      })
+
+      return core.start();
+   })
+
+   it("Test Request flow", async function () {
+      let core = new DnsCore();
+
+      let listener = new TestListenerPlugin();
+      core.addListener(listener)
+
+      let monitoring = new TestMonitoringPlugin({
+         domain: "example.com",
+         hostname: "test",
+         type: "A"
+      });
+      core.addMonitoring(monitoring)
+
+
+      let question = new TestQuestionPlugin();
+      core.addQuestion(question)
+
+      let storage = new TestStoragePlugin({
+         domain: "example.com",
+         hostname: "test",
+         type: RecordTypes.A,
+         ttl: 500,
+         value: "10.0.0.1"
+      })
+      core.addStorage(storage);
+
+      await core.start();
+
+      let reqData = fromHex("E835 0100 0001 0000 0000 0000 04 74657374 07 6578616D706c65 03 636F6D 00 0001 0001");
+      let should = "E835 8580 0001000100000000 04 74657374 076578616D706C6503636F6D0000010001 04 74657374 07 6578616D706C65 03 636F6D 00 0001 0001 0000 0640 0004 0A000001"
+      let resData = await listener.sendRequest(reqData)
+
+      assert.equal(resData.toString("hex"), should.replace(/\s/g, "").toLowerCase(), "Whole packet serialization failed")
+   })
+})
+
+class TestStoragePlugin implements StoragePlugin {
+   re: Record = { domain: "example.com", hostname: "test", type: RecordTypes.A, value: "10.0.0.1", ttl: 1600 }
+
+   constructor(record?: Record) {
+      if (record)
+         this.re = record;
+   }
+
+   priority = 0
+   no_cache = false
+   record_types = [RecordTypes.A]
+   isResponsible(domain: string) {
+      // console.log("Is responsible")
+      return true
+   }
+
+   async init(core) { assert.exists(core, "TestStoragePlugin init no core object") }
+
+   async getRecords(domain, hostname, type) {
+      if (domain !== this.re.domain || hostname !== this.re.hostname || type != this.re.type) return undefined;
+      return [this.re];
+   }
+
+   async getAllRecordsForDomain(domain) {
+      if (domain !== this.re.domain) return undefined;
+      return [this.re];
+   }
+}
+
+class TestMonitoringPlugin implements MonitoringPlugin {
+   constructor(private should: { domain: string, hostname: string, type: string }) { }
+
+   async init(core) { assert.exists(core, "TestMonitoringPlugin init no core object") }
+   priority = 0
+   onRequest(domain, hostname, type) {
+      assert.equal(this.should.domain, domain, "Domain value wrong")
+      assert.equal(this.should.hostname, hostname, "Domain value wrong")
+      assert.equal(this.should.type, type, "Domain value wrong")
+   }
+}
+
+class ARR extends RecourceRecord {
+   TYPE = RecordTypes.A
+
+   constructor(domain: string, ip: string) {
+      super();
+      this.NAME = domain
+      this.TTL = 1600
+      let data = Buffer.alloc(4)
+      let idx = 0;
+      ip.split(".").forEach(e => {
+         data.writeUInt8(Number(e), idx);
+         idx++;
+      })
+      this.dataLock = () => {
+         return {
+            length: 4,
+            serialize: (buffer, offset) => {
+               data.copy(buffer, offset);
+               return offset + 4;
+            }
+         }
+      };
+      // this.RDATA = data;
+   }
+}
+
+class TestQuestionPlugin implements QuestionPlugin {
+   private Core: DnsCore
+   question_types = [RecordTypes.A]
+   priority = 0
+   async init(core) {
+      assert.exists(core, "TestQuestionPlugin init no core object")
+      this.Core = core;
+   }
+
+   async handleQuestion(question: Question, request: AnswerHandler, next: () => void) {
+      assert(this.question_types.find(e => e === <any>question.QTYPE), "Handler was called with not supported questin type")
+      let parts = question.QNAME.split(".")
+      let domain = parts.splice(-2, 2).join(".")
+      let hostname = parts.join(".");
+      hostname = hostname !== "" ? hostname : "*"
+      let records = await this.Core.storageManager.getRecords(domain, hostname, question.QTYPE)
+      records.forEach(e => request.addAnswer(new ARR(question.QNAME, e.value)));
+   }
+}
+
+class TestListenerPlugin implements ListenerPlugin {
+   async init(core) { assert.exists(core, "TestListenerPlugin init no core object") }
+   priority = 0;
+   callback: (data: Buffer, sender: string, max_size?: number) => Promise<Buffer>;
+   registerCallback(callback) {
+      this.callback = callback;
+   }
+
+   sendRequest(message: Buffer) {
+      return this.callback(message, "localhost")
+   }
+}
--- a/src/types.ts
+++ b/src/types.ts
@ -1,12 +1,3 @@
-
-// 0 No error condition
-//    * 1 Format error - unable to interpret query
-//       * 2 Server failure - internal problem
-//          * 3 Name error - Only for authorative name server, domain name of query does not exist
-//             * 4 Not implemented - Request not supported
-//                * 5 Refused - Nameserver refuses request
-//    * 6 - 15 Reserved for future usage
-//       * 
 export enum ErrorCodes {
   /**
    * No error
@ -39,7 +30,119 @@ export enum ErrorCodes {
   Refused
 }

-export interface MessageHeader {
+export enum RecordTypes {
+   /**
+    * IPv4 address
+    */
+   A = 0x01,
+
+   /**
+    * Nameserver
+    */
+   NS = 0x02,   // nameserver
+
+   /**
+    * Obsolete
+    */
+   MD = 0x03,   // obsolete
+
+   /**
+    * Obsolete
+    */
+   MF = 0x04,   // obsolete
+
+   /**
+    * Alias
+    */
+   CNAME = 0x05,   // alias
+
+   /**
+    * Start of authority
+    */
+   SOA = 0x06,   // start of authority
+
+   /**
+    * Experimental
+    */
+   MB = 0x07,   // experimental
+
+   /**
+    * Experimental
+    */
+   MG = 0x08,   // experimental
+
+   /**
+    * Experimental
+    */
+   MR = 0x09,   // experimental
+
+   /**
+    * Experimental
+    */
+   NULL = 0x0A,   // experimental null RR
+
+   /**
+    * Service description
+    */
+   WKS = 0x0B,   // service description
+
+   /**
+    * Reverse entry (inaddr.arpa)
+    */
+   PTR = 0x0C,   // reverse entry (inaddr.arpa)
+
+   /**
+    * Host information
+    */
+   HINFO = 0x0D,   // host information
+
+   /**
+    * Mailbox / Mail-list information
+    */
+   MINFO = 0x0E,   // mailbox or mail list information
+
+   /**
+    * Mail exchange
+    */
+   MX = 0x0F,   // mail exchange
+
+   /**
+    * Text strings
+    */
+   TXT = 0x10,   // text strings
+
+   /**
+    * IPv6 address
+    */
+   AAAA = 0x1C,   // ipv6 address
+
+   /**
+    * SRV records
+    */
+   SRV = 0x21,   // srv records
+
+   /**
+    * Request to transfer entire zone
+    */
+   AXFR = 0xFC,   // request to transfer entire zone
+
+   /**
+    * Request for mailbox related records
+    */
+   MAILA = 0xFE,   // request for mailbox related records
+
+   /**
+    * Request for mail agend RRs
+    */
+   MAILB = 0xFD,   // request for mail agent RRs
+
+   /**
+    * Any class
+    */
+   ANY = 0xFF,   // any class
+}
+
+export interface IMessageHeader {
   /**
    *  A 16 bit identifier assigned by the program that
    *  generates any kind of query.  This identifier is copied
@ -93,7 +196,7 @@ export interface MessageHeader {
   /**
    * Reserved for future usage, must be 0 in all queries
    */
-   Z: 0;
+   Z: 0 | 1;

   AD: 0 | 1;

@ -136,7 +239,7 @@ export interface MessageHeader {
    */
   ARCOUNT: number;
 }
-export interface MessageQuestion {
+export interface IMessageQuestion {
   /**
    * Domain name represented as sequence of labels
    * Each label consists of a length octed followed
@ -151,14 +254,13 @@ export interface MessageQuestion {

   /**
    * Two octed code that specifies the class of the Query
-    * IS for internet
-    * WARNING: ONLY IN IS SUPPORTED BY THIS APPLICATION
+    * IN for internet
    */
   QCLASS: number;
 }
 export interface MessageRecourceRecord {
   /**
-    * Domain name to wich resource record pertains
+    * Domain name to wich resource record points
    */
   NAME: string;

@ -194,7 +296,7 @@ export interface MessageRecourceRecord {
   RDLENGTH: number;

   /**
-    * a variable length string of ectets taht describes
+    * a variable length string of octets that describes
    * the resource. The format is defined by TYPE and CLASS
    * field.
    *
@ -203,10 +305,3 @@ export interface MessageRecourceRecord {
    */
   RDATA: Buffer;
 }
-export interface Message {
-   header: MessageHeader;
-   questions: MessageQuestion[];
-   answers: MessageRecourceRecord[];
-   authorities: MessageRecourceRecord[];
-   additionals: MessageRecourceRecord[];
-}
Author	SHA1	Message	Date
Fabian Stamm	07047ee8cb	Fixing wrong variable name All checks were successful the build was successful Details continuous-integration/drone/push Build is passing Details continuous-integration/drone Build is passing Details	2018-12-03 09:04:40 +01:00
Fabian Stamm	7d9ad57f52	Fixing error Some checks failed the build failed Details	2018-12-03 08:58:37 +01:00
Fabian Stamm	55354c2381	Adding stream interface Some checks failed the build failed Details	2018-12-03 08:52:54 +01:00
Fabian Stamm	da5285ac9b	Adding new naming to test and benchmark All checks were successful the build was successful Details	2018-12-03 08:30:42 +01:00
Fabian Stamm	d16f8c3d8a	Normalizing names of plugin properties Some checks failed the build failed Details	2018-12-03 08:29:00 +01:00
Fabian Stamm	ccee8ae5da	Version bump All checks were successful the build was successful Details	2018-12-03 08:21:19 +01:00
Fabian Stamm	172855b8cf	Adding typscript compilation at install level for usage with repository All checks were successful the build was successful Details	2018-12-03 08:20:14 +01:00
Fabian Stamm	07e2dff29f	Optimizing export All checks were successful the build was successful Details	2018-12-03 07:59:29 +01:00
Fabian Stamm	5bf7af6565	Add request flow handler All checks were successful the build was successful Details	2018-12-03 07:54:37 +01:00
Fabian Stamm	69094524d1	Rewriting of backend All checks were successful the build was successful Details	2018-11-30 21:48:27 +01:00
Fabian Stamm	e8dcf31461	Adding index.ts for bundling request and type All checks were successful the build was successful Details	2018-05-19 16:59:44 +02:00
Fabian Stamm	23c27c3c4f	Removing listener for export in different Module All checks were successful the build was successful Details	2018-05-19 16:10:42 +02:00
Fabian Stamm	2b318d47aa	Removing old code	2018-05-19 16:10:16 +02:00
Fabian Stamm	9d3d9f8a80	Adding parameter for easy initialization to RecourceRecord constructor. All checks were successful the build was successful Details	2018-05-17 18:46:50 +02:00
Fabian Stamm	43f4cf358d	adding experimental udp6 support All checks were successful the build was successful Details	2018-05-17 13:54:18 +02:00
Fabian Stamm	25131a2d4b	adding version output to drone All checks were successful the build was successful Details	2018-05-17 13:50:23 +02:00
Fabian Stamm	64f9ef3f87	Add travis CI and adding yarn.lock to tracked files All checks were successful the build was successful Details	2018-05-17 13:31:17 +02:00
Fabian Stamm	6db8d58539	Adding drone.io CI config All checks were successful the build was successful Details	2018-05-17 11:09:22 +02:00
Fabian Stamm	6dad6c5d56	Adding tests	2018-05-17 10:02:17 +02:00
Fabian Stamm	4e3cf05d29	Refactoring and adding Question class	2018-05-17 10:01:56 +02:00
Fabian Stamm	a34cd4bac2	Removing port choice on listener Listening ports are now fixed to 53 on udp and tcp	2018-05-17 09:57:51 +02:00
Fabian Stamm	c57260e11b	Adding .editorconfig	2018-05-17 09:31:48 +02:00
				`@ -1 +0,0 @@`
				{"version":3,"file":"listener.js","sourceRoot":"","sources":["../src/listener.ts"],"names":[],"mappings":";;AAAA,2BAA0B;AAC1B,+BAA+B;AAC/B,uCAAoC;AAEpC;IAGG,YAAY,IAAmB,EAAE,SAAoC,EAAE,IAAY,EAAE,OAAe,SAAS;QAC1G,QAAQ,IAAI,EAAE;YACX,KAAK,KAAK;gBACP,IAAI,CAAC,GAAG,GAAG,KAAK,CAAC,YAAY,CAAC,MAAM,CAAC,CAAA;gBACrC,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,WAAW,EAAE,GAAG,EAAE;oBAC3B,OAAO,CAAC,GAAG,CAAC,2BAA2B,IAAI,EAAE,CAAC,CAAA;gBACjD,CAAC,CAAC,CAAA;gBAEF,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,SAAS,EAAE,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;oBACxC,IAAI,OAAO,GAAG,IAAI,iBAAO,CAAC,OAAO,EAAE,CAAC,IAAI,EAAE,EAAE;wBACzC,wDAAwD;wBACxD,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,IAAI,EAAE,MAAM,CAAC,IAAI,EAAE,MAAM,CAAC,OAAO,CAAC,CAAA;oBACnD,CAAC,CAAC,CAAA;oBACF,SAAS,CAAC,OAAO,CAAC,CAAC;gBACtB,CAAC,CAAC,CAAA;gBAEF,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,IAAI,EAAE,IAAI,CAAC,CAAA;gBACzB,MAAM;YACT,KAAK,KAAK;gBACP,OAAO,CAAC,GAAG,CAAC,yBAAyB,CAAC,CAAA;gBACtC,IAAI,CAAC,GAAG,GAAG,GAAG,CAAC,YAAY,CAAC,CAAC,MAAM,EAAE,EAAE;oBACpC,IAAI,MAAc,CAAC;oBACnB,IAAI,GAAG,GAAW,CAAC,CAAC;oBACpB,IAAI,OAAO,GAAG,SAAS,CAAC;oBACxB,MAAM,CAAC,EAAE,CAAC,MAAM,EAAE,CAAC,IAAI,EAAE,EAAE;wBACxB,IAAI,MAAM,GAAG,CAAC,CAAC;wBACf,IAAI,CAAC,OAAO,EAAE;4BACX,MAAM,GAAG,IAAI,CAAC,YAAY,CAAC,CAAC,CAAC,CAAC;4BAC9B,IAAI,MAAM,GAAG,IAAI;gCAAE,OAAO,MAAM,CAAC,OAAO,EAAE,CAAC,CAAC,wCAAwC;4BACpF,OAAO,GAAG,MAAM,CAAC,KAAK,CAAC,MAAM,CAAC,CAAC;4BAC/B,MAAM,GAAG,CAAC,CAAC;yBACb;wBAED,IAAI,IAAI,GAAG,CAAC,IAAI,CAAC,MAAM,GAAG,MAAM,CAAC,GAAG,CAAC,MAAM,GAAG,GAAG,CAAC,CAAC,CAAC,CAAC,CAAC,MAAM,GAAG,GAAG,CAAC,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,MAAM,GAAG,MAAM,CAAC,CAAC;wBAC7F,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,GAAG,EAAE,MAAM,EAAE,IAAI,GAAG,MAAM,CAAC,CAAA;wBAC9C,GAAG,IAAI,IAAI,CAAC;wBACZ,+CAA+C;wBAC/C,IAAI,GAAG,IAAI,MAAM,EAAE;4BAChB,IAAI,OAAO,GAAG,IAAI,iBAAO,CAAC,OAAO,EAAE,CAAC,IAAI,EAAE,EAAE;gCACzC,MAAM,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;4BACtB,CAAC,CAAC,CAAA;4BACF,GAAG,GAAG,CAAC,CAAC;4BACR,OAAO,GAAG,SAAS,CAAC;4BACpB,MAAM,GAAG,CAAC,CAAC;4BACX,SAAS,CAAC,OAAO,CAAC,CAAC;yBACrB;oBACJ,CAAC,CAAC,CAAC;gBACN,CAAC,CAAC,CAAC;gBACH,IAAI,CAAC,GAAG,CAAC,MAAM,CAAC,IAAI,EAAE,IAAI,CAAC,CAAC;gBAC5B,MAAM;YACT;gBACG,MAAM,IAAI,KAAK,CAAC,qBAAqB,CAAC,CAAA;SAC3C;IACJ,CAAC;IAED,KAAK;QACF,IAAI,IAAI,CAAC,GAAG,EAAE;YACX,IAAI,CAAC,GAAG,CAAC,KAAK,EAAE,CAAC;SACnB;aAAM;YACJ,IAAI,CAAC,GAAG,CAAC,KAAK,EAAE,CAAC;SACnB;IACJ,CAAC;CACH;AAjED,2BAiEC"}
				`@ -1 +0,0 @@`
				`{"version":3,"file":"test.js","sourceRoot":"","sources":["../src/test.ts"],"names":[],"mappings":"AAAA,6KAA6K;AAC7K,sCAAsC;AACtC,qCAAqC;AACrC,mCAAmC;AACnC,4DAA4D"}`
				`@ -1 +0,0 @@`
				`{"version":3,"file":"types.js","sourceRoot":"","sources":["../src/types.ts"],"names":[],"mappings":";;AACA,uBAAuB;AACvB,kDAAkD;AAClD,8CAA8C;AAC9C,kGAAkG;AAClG,0DAA0D;AAC1D,0DAA0D;AAC1D,wCAAwC;AACxC,WAAW;AACX,IAAY,UA8BX;AA9BD,WAAY,UAAU;IACnB;;OAEG;IACH,iDAAW,CAAA;IAEX;;OAEG;IACH,yDAAW,CAAA;IAEX;;OAEG;IACH,6DAAa,CAAA;IAEb;;OAEG;IACH,qDAAS,CAAA;IAET;;OAEG;IACH,+DAAc,CAAA;IAEd;;OAEG;IACH,iDAAO,CAAA;AACV,CAAC,EA9BW,UAAU,GAAV,kBAAU,KAAV,kBAAU,QA8BrB"}`