WIP

Author: ardalanamini

index.js

@@ -1,24 +1,31 @@
-const Server = require('./lib/server')
-const Connection = require('./lib/connection')
+const Server = require("./lib/server");
+const Connection = require("./lib/connection");
 
-exports.Server = Server
-exports.Connection = Connection
+exports.Server = Server;
 
-exports.createServer = function (opts, onconnection) {
-  if (typeof opts === 'function') return exports.createServer(null, opts)
-  const server = new Server(opts)
-  if (onconnection) server.on('connection', onconnection)
-  return server
-}
+exports.Connection = Connection;
 
-exports.connect = function (port, host, opts) {
-  if (typeof host !== 'string' && host) return exports.connect(port, null, host)
-  if (!opts) opts = {}
+exports.createServer = function createServer(opts, onconnection) {
+  if (typeof opts === "function") return exports.createServer(undefined, opts);
 
-  var connection = new Connection()
+  const server = new Server(opts);
 
-  if (opts.allowHalfOpen) connection.allowHalfOpen = true
-  connection._connect(port, host || '127.0.0.1')
+  if (onconnection) server.on("connection", onconnection);
 
-  return connection
-}
+  return server;
+};
+
+exports.connect = function connect(port, host, opts) {
+  if (typeof host !== "string" && host)
+    return exports.connect(port, null, host);
+
+  if (!opts) opts = {};
+
+  var connection = new Connection();
+
+  if (opts.allowHalfOpen) connection.allowHalfOpen = true;
+
+  connection._connect(port, host || "127.0.0.1");
+
+  return connection;
+};

lib/Request.js

@@ -0,0 +1,29 @@
+class Request {
+  constructor(handle) {
+    this.callback = null;
+    this.buffer = null;
+    this.buffers = null;
+    this.length = 0;
+    this.lengths = null;
+    this.handle = handle ? Buffer.alloc(handle) : null;
+  }
+
+  donev(err) {
+    const cb = this.callback;
+    const buffers = this.buffers;
+    const lengths = this.lengths;
+
+    this.callback = this.buffers = this.lengths = null;
+    cb(err, buffers, lengths);
+  }
+
+  done(err, len) {
+    const cb = this.callback;
+    const buf = this.buffer;
+
+    this.callback = this.buffer = null;
+    cb(err, buf, len);
+  }
+}
+
+module.exports = Request;

lib/connection.js

@@ -2,7 +2,7 @@ const binding = require("./binding");
 const events = require("events");
 const unordered = require("unordered-set");
 const RequestQueue = require("./queue");
-const lookup = require("./lookup");
+const { lookup } = require("dns");
 
 const EMPTY = Buffer.alloc(0);
 

lib/lookup.js

@@ -1,3 +1,5 @@
+const Request = require("./Request");
+
 class RequestQueue {
   constructor(size, handle) {
     this.size = size;
@@ -47,32 +49,4 @@ class RequestQueue {
   }
 }
 
-class Request {
-  constructor(handle) {
-    this.callback = null;
-    this.buffer = null;
-    this.buffers = null;
-    this.length = 0;
-    this.lengths = null;
-    this.handle = handle ? Buffer.alloc(handle) : null;
-  }
-
-  donev(err) {
-    const cb = this.callback;
-    const buffers = this.buffers;
-    const lengths = this.lengths;
-
-    this.callback = this.buffers = this.lengths = null;
-    cb(err, buffers, lengths);
-  }
-
-  done(err, len) {
-    const cb = this.callback;
-    const buf = this.buffer;
-
-    this.callback = this.buffer = null;
-    cb(err, buf, len);
-  }
-}
-
 module.exports = RequestQueue;

lib/queue.js

@@ -1,13 +1,12 @@
 const binding = require("./binding");
 const Connection = require("./connection");
-const lookup = require("./lookup");
+const { lookup } = require("dns");
 const events = require("events");
 const semver = require("semver");
 const os = require("os");
 
 class Server extends events.EventEmitter {
-  constructor(opts) {
-    if (!opts) opts = {};
+  constructor(opts = {}) {
     super();
 
     this.connections = [];