From d5f1ccfd1dc826a2011b2eb6ed9a781285cc181d Mon Sep 17 00:00:00 2001
From: Girish Ramakrishnan <girish@forwardbias.in>
Date: Mon, 29 Sep 2014 14:34:42 -0700
Subject: [PATCH] Add mail DNS records

Part of #46
---
 config.js       |  1 +
 src/cloudron.js | 62 +++++++++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 63 insertions(+)

diff --git a/config.js b/config.js
index fcbd0ae65..7cbc8a725 100644
--- a/config.js
+++ b/config.js
@@ -44,6 +44,7 @@ config.save = function () {
     }
 
     config.nginxConfigDir = path.join(config.baseDir, 'nginx');
+    config.harakaConfigDir = path.join(config.baseDir, 'haraka');
     config.appDataRoot = path.join(config.baseDir, 'appdata');
     config.configRoot = path.join(config.baseDir, 'config');
     config.dataRoot = path.join(config.baseDir, 'data'); // TODO: rename to volumesRoot
diff --git a/src/cloudron.js b/src/cloudron.js
index 8e876395d..6e7556e0a 100644
--- a/src/cloudron.js
+++ b/src/cloudron.js
@@ -14,6 +14,7 @@ var backups = require('./backups.js'),
     fs = require('fs'),
     clientdb = require('./clientdb.js'),
     uuid = require('node-uuid'),
+    safe = require('safetydance'),
     _ = require('underscore'),
     superagent = require('superagent');
 
@@ -36,6 +37,7 @@ var RESTORE_CMD = 'sudo ' + path.join(__dirname, 'scripts/restore.sh'),
 
 var backupTimerId = null,
     announceTimerId = null,
+    addMailDnsRecordsTimerId = null,
     updater = new Updater(); // TODO: make this not an object
 
 function CloudronError(reason, info) {
@@ -67,6 +69,9 @@ function uninitialize() {
     clearTimeout(announceTimerId);
     announceTimerId = null;
 
+    clearTimeout(addMailDnsRecordsTimerId);
+    addMailDnsRecordsTimerId = null;
+
     updater.stop();
 }
 
@@ -251,6 +256,61 @@ function getCertificate(callback) {
     });
 }
 
+function sendMailDnsRecordsRequest(callback) {
+    var DKIM_SELECTOR = 'mail';
+    var DMARC_REPORT_EMAIL = 'girish@forwardbias.in';
+
+    var dkimPublicKeyFile = path.join(config.harakaConfigDir, 'dkim/' + config.fqdn + '/public');
+    var publicKey = safe.fs.readFileSync(dkimPublicKeyFile);
+
+    if (publicKey === null) return console.error('Error reading dkim public key');
+
+    // remove header, footer and new lines
+    publicKey = publicKey.split('\n').slice(1, -1).join('');
+
+    // note that dmarc requires special DNS records for external RUF and RUA
+    var records = [
+        // softfail all mails not from our IP. Note that this uses IP instead of 'a' should we use a load balancer in the future
+        { subdomain: '', type: 'SPF', value: 'v=spf1 ip4:' + getIp() + ' ~all' },
+        // t=s limits the domainkey to this domain and not it's subdomains
+        // o=- (outbound signing policy) means all are signed
+        { subdomain: DKIM_SELECTOR + '._domainkey', type: 'TXT', value: 'v=DKIM1; o=-; t=s; p=' + publicKey },
+        // DMARC requires special setup if report email id is in different domain
+        { subdomain: '_dmarc', type: 'TXT', value: 'v=DMARC1; p=none; pct=100; rua=mailto:' + DMARC_REPORT_EMAIL + '; ruf=' + DMARC_REPORT_EMAIL }
+    ];
+
+    debug('sendMailDnsRecords request:%s', JSON.stringify(records));
+
+    superagent
+        .post(config.appServerUrl + '/api/v1/subdomains')
+        .set('Accept', 'application/json')
+        .query({ token: config.token })
+        .send({ records: records })
+        .end(function (error, res) {
+            if (error) return callback(error);
+
+            debug('sendMailDnsRecords status:' + res.status);
+
+            if (res.status === 409) return callback(null); // already registered
+
+            if (res.status !== 201) return callback(new Error('Failed to add Mail DNS records: ' + res.status));
+
+            return callback(null);
+        });
+}
+
+function addMailDnsRecords() {
+    sendMailDnsRecordsRequest(function (error) {
+        if (error) {
+            console.error('Mail DNS record addition failed', error);
+            addMailDnsRecordsTimerId = setTimeout(addMailDnsRecords, 30000);
+            return;
+        }
+
+        debug('Added Mail DNS records successfully');
+    });
+}
+
 function provision(args, callback) {
     assert(typeof callback === 'function');
 
@@ -265,6 +325,8 @@ function provision(args, callback) {
 
             callback(null);
 
+            addMailDnsRecords();
+
             // now try to get the real certificate
             function getCertificateCallback(error) {
                 if (error) {