Added custom_command to e.g. send "set/skimmmer" after login

Author: int2001

.env.sample

@@ -81,16 +81,20 @@ SPOT_MAX_AGE=120
 CLUSTER_ENABLED=true
 
 # Multiple DX Cluster connections (JSON array format)
-# Each cluster should have: host, port, loginPrompt, call, password, cluster (name)
+# Each cluster should have: host, port, loginPrompt, call, password, cluster (name), customCommand (optional)
 # Recommended clusters:
 #   - DXSPOTS: Reliable, fast, worldwide coverage
 #   - NC7J: Popular, good availability
 # Replace YOUR_CALLSIGN with your amateur radio callsign
+# customCommand: Optional command sent after login (e.g., "set/skimmer" for skimmer mode)
 CLUSTERS=[{"host":"dxspots.com","port":7300,"loginPrompt":"login:","call":"YOUR_CALLSIGN","password":"","cluster":"DXSPOTS"},{"host":"dxc.nc7j.com","port":7300,"loginPrompt":"login:","call":"YOUR_CALLSIGN","password":"","cluster":"NC7J"}]
 
 # Single cluster example (simpler format):
 # CLUSTERS=[{"host":"dxspots.com","port":7300,"loginPrompt":"login:","call":"YOUR_CALLSIGN","password":"","cluster":"DXSPOTS"}]
 
+# Cluster with custom command example:
+# CLUSTERS=[{"host":"dxspots.com","port":7300,"loginPrompt":"login:","call":"YOUR_CALLSIGN","password":"","cluster":"DXSPOTS","customCommand":"set/skimmer"}]
+
 # ================================================================
 # SPOT SOURCES - External Data Integration
 # ================================================================

lib/dxcluster.js

@@ -21,6 +21,7 @@ module.exports = class DXCluster extends events.EventEmitter {
       awaiting_login: false,
       awaiting_password: false,
     }
+    this.customCommand = null
     this.regex = {
       deline: /^(DX de) +([A-Z0-9/\-#]{3,}):? *(\d*.\d{1,2}) *([A-Z0-9/\-#]{3,}) +(.*\S)? +(\d{4}){1}Z *(\w{2}\d{2})?/g,
       callsign: /(((\d|[A-Z])+\/){0,2}((\d|[A-Z]){3,})(\/(\d|[A-Z])+)?(\/(\d|[A-Z])+)?){1,1}/g,
@@ -40,6 +41,9 @@ module.exports = class DXCluster extends events.EventEmitter {
         return;
       }
 
+      // Store custom command from connection options
+      this.customCommand = opts.customCommand || null
+
       this.host = opts.host || '127.0.0.1'
       this.port = opts.port || 23
 
@@ -94,21 +98,29 @@ module.exports = class DXCluster extends events.EventEmitter {
       })
 
       this.socket.on('data', (data) => {
+        const dataStr = data.toString('utf8')
+
         if(this.status.awaiting_login) {
-          if(data.toString('utf8').indexOf(loginPrompt) != -1) {
+          if(dataStr.indexOf(loginPrompt) != -1) {
             if(this.write(call)) {
               this.status.awaiting_login = false
+              // Execute custom command after login if no password required
+              if (!opts.password) {
+                this._executeCustomCommand()
+              }
             }
           }
         }
         if(this.status.awaiting_password) {
-          if(data.toString('utf8').indexOf(passPrompt) != -1) {
+          if(dataStr.indexOf(passPrompt) != -1) {
             if(this.write(opts.password)) {
               this.status.awaiting_password = false
+              // Execute custom command after password if configured
+              this._executeCustomCommand()
             }
           }
         }
-        this._parseDX(data.toString('utf8'))
+        this._parseDX(dataStr)
       })
 
       this.socket.on('close', (err) => {
@@ -146,6 +158,17 @@ module.exports = class DXCluster extends events.EventEmitter {
     return this.socket.write(str + this.ct)
   }
 
+  /**
+   * Execute custom command after authentication is complete
+   * @private
+   */
+  _executeCustomCommand() {
+    if (this.customCommand) {
+      this.write(this.customCommand)
+      this.emit('custom_command_sent', this.customCommand)
+    }
+  }
+
   /**
    * Internal method to cleanup all resources and prevent memory leaks
    * Called during connection failures, timeouts, and shutdown

lib/utils.js

@@ -164,19 +164,6 @@ function toKHz(freqMHz) {
     return NaN;
 }
 
-/**
- * Converts frequency from kHz to MHz.
- * @param {number} freqKHz - Frequency in kHz.
- * @returns {number} - Frequency in MHz, or NaN if invalid.
- */
-function toMHz(freqKHz) {
-    const khz = Number(freqKHz);
-    if (Number.isFinite(khz)) {
-        return khz / 1000; // Convert to MHz
-    }
-    return NaN;
-}
-
 /**
  * Normalizes frequency to consistent kHz format with 1 decimal place.
  * This ensures frequency consistency across all sources (DXCluster, POTA, SOTA, RBN).
@@ -228,6 +215,5 @@ module.exports = {
     sleepNow,
     getAllowedDeviation,
     toKHz,
-    toMHz,
     normalizeFrequency
 };

modules/clusters/index.js

@@ -154,6 +154,11 @@ class Clusters extends EventEmitter {
                 this.emit('spot', spot, cluster.cluster || 'cluster');
             });
 
+            // Monitor custom command execution (cleanup handled by _cleanupConnection)
+            conn.on('custom_command_sent', (command) => {
+                logConnectionState('info', cluster.host, `Custom command sent: "${command}"`);
+            });
+
             this.connections.push({ cluster, conn, clusterKey });
         } catch (e) {
             logConnectionState('error', cluster.host, 'DXCluster not reachable', e);