Event Gateways - Gateway Instances

// gateways/SMSHandler.cfc
component {

  /**
   * Process incoming SMS messages
   * @cfcEvent The event object containing message data
   */
  public void function onIncomingMessage(required struct cfcEvent) {
    // Extract message data
    var senderPhone = arguments.cfcEvent.data.fromNumber;
    var messageText = arguments.cfcEvent.data.message;
    var gatewayID = arguments.cfcEvent.gatewayID;

    // Log the incoming message
    writeLog(
      file = "sms-gateway",
      type = "information",
      text = "SMS from #senderPhone#: #messageText#"
    );

    try {
      // Process the message
      processSMSCommand(senderPhone, messageText);

    } catch (any e) {
      // Log errors
      writeLog(
        file = "sms-gateway",
        type = "error",
        text = "Error processing SMS: #e.message#"
      );
    }
  }

  /**
   * Process SMS commands
   */
  private void function processSMSCommand(
    required string phone,
    required string message
  ) {
    // Parse command (e.g., "SUBSCRIBE", "STOP", "HELP")
    var command = trim(ucase(arguments.message));

    switch (command) {
      case "SUBSCRIBE":
        // Add to subscription list
        subscribeUser(arguments.phone);
        sendSMSReply(arguments.phone, "You are now subscribed!");
        break;

      case "STOP":
      case "UNSUBSCRIBE":
        // Remove from subscription list
        unsubscribeUser(arguments.phone);
        sendSMSReply(arguments.phone, "You have been unsubscribed.");
        break;

      case "HELP":
        sendSMSReply(
          arguments.phone,
          "Commands: SUBSCRIBE, STOP, HELP"
        );
        break;

      default:
        sendSMSReply(arguments.phone, "Unknown command. Reply HELP for options.");
    }
  }

  /**
   * Send SMS reply
   */
  private void function sendSMSReply(
    required string phone,
    required string message
  ) {
    // Use SendGatewayMessage to send reply
    var msgData = {
      "toNumber" = arguments.phone,
      "message" = arguments.message
    };

    sendGatewayMessage("SMS_Notifications", msgData);
  }

  private void function subscribeUser(required string phone) {
    // Database logic to add subscriber
    queryExecute(
      "INSERT INTO sms_subscribers (phone, subscribed_date) VALUES (?, ?)",
      [arguments.phone, now()],
      {datasource: "myDB"}
    );
  }

  private void function unsubscribeUser(required string phone) {
    // Database logic to remove subscriber
    queryExecute(
      "DELETE FROM sms_subscribers WHERE phone = ?",
      [arguments.phone],
      {datasource: "myDB"}
    );
  }

}

// gateways/FileProcessor.cfc
component {

  /**
   * Process file system events
   * @cfcEvent The event object containing file change data
   */
  public void function onIncomingMessage(required struct cfcEvent) {
    var changeType = arguments.cfcEvent.data.type;
    var fileName = arguments.cfcEvent.data.filename;
    var filePath = arguments.cfcEvent.data.path;

    writeLog(
      file = "file-watcher",
      type = "information",
      text = "File #changeType#: #filePath##fileName#"
    );

    // Only process file additions
    if (changeType == "ADD") {
      processNewFile(filePath, fileName);
    }
  }

  /**
   * Process newly added files
   */
  private void function processNewFile(
    required string path,
    required string filename
  ) {
    var fullPath = arguments.path & arguments.filename;

    try {
      // Read file content
      var fileContent = fileRead(fullPath);

      // Process based on file type
      if (findNoCase(".csv", arguments.filename)) {
        processCSVFile(fileContent, arguments.filename);
      }
      else if (findNoCase(".xml", arguments.filename)) {
        processXMLFile(fileContent, arguments.filename);
      }

      // Archive processed file
      archiveFile(fullPath);

    } catch (any e) {
      writeLog(
        file = "file-watcher",
        type = "error",
        text = "Error processing #arguments.filename#: #e.message#"
      );

      // Move to error directory
      moveToErrorDirectory(fullPath);
    }
  }

  private void function processCSVFile(
    required string content,
    required string filename
  ) {
    // CSV processing logic
    writeLog(
      file = "file-watcher",
      text = "Processing CSV file: #arguments.filename#"
    );
  }

  private void function processXMLFile(
    required string content,
    required string filename
  ) {
    // XML processing logic
    writeLog(
      file = "file-watcher",
      text = "Processing XML file: #arguments.filename#"
    );
  }

  private void function archiveFile(required string filePath) {
    var archivePath = expandPath("/archives/");
    fileMove(arguments.filePath, archivePath);
  }

  private void function moveToErrorDirectory(required string filePath) {
    var errorPath = expandPath("/errors/");
    fileMove(arguments.filePath, errorPath);
  }

}

// Get all gateway instances
gateways = getGatewayHelper().getGateways();
writeDump(gateways);

// Get specific gateway state
gatewayState = getGatewayHelper().getGatewayState("SMS_Notifications");
writeOutput("Gateway status: #gatewayState#");

// Start a gateway
result = getGatewayHelper().startGateway("SMS_Notifications");

// Stop a gateway
result = getGatewayHelper().stopGateway("SMS_Notifications");

// Restart a gateway
result = getGatewayHelper().restartGateway("SMS_Notifications");

// Send message via gateway
msgData = {
  "toNumber": "+15555551234",
  "message": "Hello from ColdFusion!"
};
sendGatewayMessage("SMS_Notifications", msgData);