Reverted some unnecessary changes.

Author: stephen-palmer

lib/server/server.js

@@ -20,9 +20,13 @@ class CacheServer {
             this._port = consts.DEFAULT_PORT;
 
         this._server = null;
-        this._mirrorConfig = options.mirror ? [].concat(options.mirror) : [];
         this._mirrors = [];
 
+        if(options.mirror) {
+            options.mirror = [].concat(options.mirror);
+            this._mirrors = options.mirror.map(m => new TransactionMirror(m, cache));
+        }
+
         this.allowIpv6 = options.allowIpv6;
         this._errCallback = null;
     }
@@ -83,11 +87,10 @@ class CacheServer {
             const cmdProc = new CommandProcessor(this.cache);
             const streamProc = new ClientStreamProcessor({clientAddress: `${socket.remoteAddress}:${socket.remotePort}`});
 
-            if(this._mirrors.length > 0) {
+            const mirrors = this._mirrors;
+            if(mirrors.length > 0) {
                 cmdProc.on('onTransactionEnd', (trx) => {
-                    this._mirrors.forEach(m => {
-                        m.queueTransaction(trx);
-                    });
+                    mirrors.forEach(m => m.queueTransaction(trx));
                 });
             }
 
@@ -111,10 +114,6 @@ class CacheServer {
             }
 
             if (this._errCallback && typeof(this._errCallback === 'function')) { this._errCallback(err); }
-        }).on('listening', () => {
-            this._mirrors = this._mirrorConfig
-                .filter(m => m && m.port && m.host)
-                .map(m => new TransactionMirror(m, this.cache));
         });
 
         return new Promise(resolve => {