Merge pull request #8 from TehSatoshi3/master

Solves #5 and internal issues.

Author: jonaharagon

node_modules/mongoose/node_modules/mongodb/node_modules/mongodb-core/node_modules/require_optional/.npmignore renamed to .gitignore

@@ -2,32 +2,63 @@
 logs
 *.log
 npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
 
 # Runtime data
 pids
 *.pid
 *.seed
+*.pid.lock
 
 # Directory for instrumented libs generated by jscoverage/JSCover
 lib-cov
 
 # Coverage directory used by tools like istanbul
 coverage
 
+# nyc test coverage
+.nyc_output
+
 # Grunt intermediate storage (http://gruntjs.com/creating-plugins#storing-task-files)
 .grunt
 
+# Bower dependency directory (https://bower.io/)
+bower_components
+
 # node-waf configuration
 .lock-wscript
 
 # Compiled binary addons (http://nodejs.org/api/addons.html)
 build/Release
 
-# Dependency directory
-node_modules
+# Dependency directories
+node_modules/
+jspm_packages/
+
+# Typescript v1 declaration files
+typings/
 
 # Optional npm cache directory
 .npm
 
+# Optional eslint cache
+.eslintcache
+
 # Optional REPL history
 .node_repl_history
+
+# Output of 'npm pack'
+*.tgz
+
+# Yarn Integrity file
+.yarn-integrity
+
+# dotenv environment variables file
+.env
+
+# Config file
+config.json
+
+# MongoDB
+data

README.md

@@ -0,0 +1,36 @@
+# cesium
+A domain registry system, coded in Node.js
+
+## Usage
+1. Install nodejs, MySQL server, MongoDB.
+2. Run `npm install`
+3. Prepare the database
+	* Install PowerDNS (or run `mysql -u [username] -p [password] -D [name of the database] < _schema_test.sql`)
+	* Run `mysql -u [username] -p [password] -D [name of the database] < _schema_extra.sql`
+4. Set up the config
+5. Run `node app.js`
+6. Voilà! 
+
+## Configuration file
+The example file is `config.json.example`.
+
+### Web --web--
+| key | value type | details |
+| --- | --- | --- |
+| port | integer | the port on which the Express server should run on |
+
+### Database --database--
+_(MySQL connection)_ 
+
+| key | value type | details |
+| --- | --- | --- |
+| host | string | the host of the MySQL server |
+| user | string | the username of the MySQL server |
+| password | string | the password of the MySQL server |
+| database | string | the name of the database |
+
+## TODO
+- Fix all issues
+- Restructure the project
+- Clean the mess
+

_schema_extra.sql

@@ -0,0 +1,9 @@
+# Courtesy of @theos-space
+CREATE TABLE user_to_domain (
+  id                    INT AUTO_INCREMENT,
+  user                  VARCHAR(255),
+  domain                VARCHAR(255),
+  nameserver            VARCHAR(255),
+  PRIMARY KEY (id)
+) Engine=InnoDB;
+

_schema_pdns.sql

@@ -0,0 +1,90 @@
+CREATE TABLE domains (
+  id                    INT AUTO_INCREMENT,
+  name                  VARCHAR(255) NOT NULL,
+  master                VARCHAR(128) DEFAULT NULL,
+  last_check            INT DEFAULT NULL,
+  type                  VARCHAR(6) NOT NULL,
+  notified_serial       INT DEFAULT NULL,
+  account               VARCHAR(40) DEFAULT NULL,
+  PRIMARY KEY (id)
+) Engine=InnoDB;
+
+CREATE UNIQUE INDEX name_index ON domains(name);
+
+
+CREATE TABLE records (
+  id                    INT AUTO_INCREMENT,
+  domain_id             INT DEFAULT NULL,
+  name                  VARCHAR(255) DEFAULT NULL,
+  type                  VARCHAR(10) DEFAULT NULL,
+  content               VARCHAR(64000) DEFAULT NULL,
+  ttl                   INT DEFAULT NULL,
+  prio                  INT DEFAULT NULL,
+  change_date           INT DEFAULT NULL,
+  disabled              TINYINT(1) DEFAULT 0,
+  ordername             VARCHAR(255) BINARY DEFAULT NULL,
+  auth                  TINYINT(1) DEFAULT 1,
+  PRIMARY KEY (id)
+) Engine=InnoDB;
+
+CREATE INDEX nametype_index ON records(name,type);
+CREATE INDEX domain_id ON records(domain_id);
+CREATE INDEX recordorder ON records (domain_id, ordername);
+
+
+CREATE TABLE supermasters (
+  ip                    VARCHAR(64) NOT NULL,
+  nameserver            VARCHAR(255) NOT NULL,
+  account               VARCHAR(40) NOT NULL,
+  PRIMARY KEY (ip, nameserver)
+) Engine=InnoDB;
+
+
+CREATE TABLE comments (
+  id                    INT AUTO_INCREMENT,
+  domain_id             INT NOT NULL,
+  name                  VARCHAR(255) NOT NULL,
+  type                  VARCHAR(10) NOT NULL,
+  modified_at           INT NOT NULL,
+  account               VARCHAR(40) NOT NULL,
+  comment               VARCHAR(64000) NOT NULL,
+  PRIMARY KEY (id)
+) Engine=InnoDB;
+
+CREATE INDEX comments_domain_id_idx ON comments (domain_id);
+CREATE INDEX comments_name_type_idx ON comments (name, type);
+CREATE INDEX comments_order_idx ON comments (domain_id, modified_at);
+
+
+CREATE TABLE domainmetadata (
+  id                    INT AUTO_INCREMENT,
+  domain_id             INT NOT NULL,
+  kind                  VARCHAR(32),
+  content               TEXT,
+  PRIMARY KEY (id)
+) Engine=InnoDB;
+
+CREATE INDEX domainmetadata_idx ON domainmetadata (domain_id, kind);
+
+
+CREATE TABLE cryptokeys (
+  id                    INT AUTO_INCREMENT,
+  domain_id             INT NOT NULL,
+  flags                 INT NOT NULL,
+  active                BOOL,
+  content               TEXT,
+  PRIMARY KEY(id)
+) Engine=InnoDB;
+
+CREATE INDEX domainidindex ON cryptokeys(domain_id);
+
+
+CREATE TABLE tsigkeys (
+  id                    INT AUTO_INCREMENT,
+  name                  VARCHAR(255),
+  algorithm             VARCHAR(50),
+  secret                VARCHAR(255),
+  PRIMARY KEY (id)
+) Engine=InnoDB;
+
+CREATE UNIQUE INDEX namealgoindex ON tsigkeys(name, algorithm);

app.js

@@ -11,6 +11,7 @@ var LocalStrategy = require('passport-local').Strategy;
 
 var routes = require('./routes/index');
 var users = require('./routes/users');
+var webConfig = require('./config.json').web;
 
 var app = express();
 
@@ -35,6 +36,9 @@ app.use(express.static(path.join(__dirname, 'public')));
 
 
 app.use('/', routes);
+var listener = app.listen(webConfig.port, function(){
+    console.log('Listening on port ' + listener.address().port); //Listening on port 8888
+});
 
 // passport config
 var Account = require('./models/account');

bin/www

@@ -0,0 +1,11 @@
+{
+	"web": {
+		"port": 80
+	},
+	"database": {
+    	"host"     : "localhost",
+    	"user"     : "root",
+    	"password" : "",
+    	"database" : "pdns"
+	}
+}

config.json.example

@@ -0,0 +1,54 @@
+// This is in replacement of @theospace code
+
+var databaseConfig = require('../config.json').database;
+var mysql = require('mysql');
+var databaseConn = mysql.createConnection(databaseConfig);
+
+var database = {};
+
+database.checkIfDomainValid = function(domainName) {
+	return /(?=^.{4,253}$)(^((?!-)[a-zA-Z0-9-]{0,62}[a-zA-Z0-9]\.)+[a-zA-Z]{1,63}$)/.test(domainName)
+}
+
+database.checkIfDomainExists = function(domainName, callback) {
+	if (database.checkIfDomainValid(domainName)) {
+		var query = 'SELECT * FROM `records` WHERE `name` = ?';
+		databaseConn.query(query, [domainName], function (error, result, fields) {
+			if (result.length > 0)
+				callback(true, null);
+			else
+				callback(false, null);
+		});
+	} else {
+		callback(false, new Error('The given domain name is not valid.'));
+	}
+};
+
+database.registerDomain = function(user, domainName, nameserver) {
+	if (!database.checkIfDomainValid(domainName))
+		throw new Error('The given domain name is not valid.');
+
+	var dateTime = Date.now();
+	var timestamp = Math.floor(dateTime / 1000);
+
+	databaseConn.query('INSERT INTO `user_to_domain` (`user`, `domain`, `nameserver`) VALUES (?, ?, ?);', [user.username, domainName, nameserver], function (error, results, fields) {if (error) throw error;});
+	databaseConn.query('INSERT INTO `records` (`id`, `domain_id`, `name`, `type`, `content`, `ttl`, `prio`, `change_date`, `disabled`, `ordername`, `auth`) VALUES (NULL, \'17\', ?, \'NS\', ?, \'86400\', \'0\', ?, \'0\', NULL, \'1\');',
+		[domainName, nameserver, timestamp], function (error, results, fields) {if (error) throw error;});
+};
+
+database.getAllUserDomain = function(user, callback) {
+	databaseConn.query('SELECT `domain`, `nameserver` FROM `user_to_domain` WHERE `user` = ?', [user.username], function (error, rows, fields) {
+		callback(error, rows, fields);
+	});
+};
+
+database.updateNameServer = function(user, nameserver, domain) {
+	databaseConn.query('SELECT * FROM `user_to_domain` WHERE `user` = ? AND `domain` = ?', [user.username, domain], function(err, res, fields) {
+		if (res.length > 0){
+			databaseConn.query('UPDATE `user_to_domain` SET `nameserver`= ? WHERE `domain` = ?;', [nameserver, domain], function (error, results, fields) {if (error) throw error;});
+    		databaseConn.query('UPDATE `records` SET `content` = ? WHERE `records`.`name` = ?', [nameserver, domain], function (error, results, fields) {if (error) throw error;});
+		}
+	});
+};
+
+module.exports = database;