User:Lum Pfohl/LSL Goodies/HI-WA Occupancy Counter System/Relay Server Slave 1.5

//  _                      ______  __      _     _
// | |                     | ___ \/ _|    | |   | |
// | |    _   _ _ __ ___   | |_/ / |_ ___ | |__ | |
// | |   | | | | '_ ` _ \  |  __/|  _/ _ \| '_ \| |
// | |___| |_| | | | | | | | |   | || (_) | | | | |
// \_____/\__,_|_| |_| |_| \_|   |_| \___/|_| |_|_|


//
// Lum's Relay Server - Master
//
// Written by Lum Pfohl July 01, 2008
//
//

integer __debug = FALSE;
string __version = "1.5";

float shortScanInterval = 0.5;      // 0.5 seconds
float longScanInterval  = 10.0;      // 10.0 seconds
integer scanningShort = FALSE;

// We keep track of how many email slaves here, and which one we're going
// to use next
integer numEmailScripts = 16;
integer curEmailScript = 0;

string regionname = "";

integer nobodyCount = 0;
integer maxCount = 3;

integer countToReset = 0;
integer countToLongScan = 0;
float queryRetries = 0.0;

integer channel = 321123;
integer listenHandle = 0;

string oiPopulation = "";
string hiPopulation = "";
string waPopulation = "";

// update object to send if a client is using an older version
string invName = "HI/WA HUD 1.05";
string invVersion = "HUD01.05";

// replacement routine for llEmail(), designed to intercept
// the email request and dispatch it to one of several slave email scripts
sendMessage(string toAddress, string subject, string messageBody) {

  // marshall the email parameters to pass to the slave email scripts
  string messageToSend = toAddress + "|" + subject + "|" + messageBody;

  if (__debug) {
    llOwnerSay("linking: " + (string)curEmailScript + messageToSend);
  }

  // contact the slave script (by number - curEmailScript) and pass the marshalled message
  llMessageLinked(LINK_THIS, curEmailScript, messageToSend, NULL_KEY);

  // increment currentEmail script pointer, resetting to zero as needed
  curEmailScript = (curEmailScript + 1) % numEmailScripts;

}



default {

  state_entry() {

    llOwnerSay("Started");
    llOwnerSay("Server Key is " + (string)llGetKey());

    state active;

  }


  on_rez(integer num) {

    llResetScript();
  }
}


state active {

  state_entry() {


    // llOwnerSay("Querying server.  This may take a few moments.");
    llListen(channel, "", NULL_KEY, "");


    llSetTimerEvent(longScanInterval);
  }

  touch_start(integer num_detected) {

    llWhisper(0, "Server Key is " + (string)llGetKey());
    llWhisper(0, "Current OI = " + oiPopulation);
    llWhisper(0, "Current HI = " + hiPopulation);
    llWhisper(0, "Current WA = " + waPopulation);

    if (llGetOwner() == llDetectedKey(0)) {
      if (__debug == FALSE) {
        __debug = TRUE;
        llOwnerSay("Debug is on.");
      } else {
        __debug = FALSE;
        llOwnerSay("Debug is off.");
      }
    }
  }



  //------------------------------------------------------------------------------------
  // Every time the timer expires, check for emails
  //------------------------------------------------------------------------------------
  timer() {
    llGetNextEmail("", ""); // Check for email with any sender address and subject.
    if (__debug) {
      llOwnerSay("Timer Set");
    }


    if (scanningShort == TRUE && countToLongScan++ == 10) {
      llSetTimerEvent(longScanInterval);
      scanningShort = FALSE;
      countToLongScan = 0;
    }
  }


  listen(integer channel, string name, key id, string message) {

    if (message == "RESET") {
      llResetScript();
    }

    if (__debug) {
      llOwnerSay("Message Received");
      llOwnerSay(message);
    }

    // The message that is received from the tally server is in a CSV format.  Convert
    // this to a list so that we can iterate the elements
    list tempList = llParseString2List(message,["!"],[]);
    oiPopulation = llList2String(tempList, 0);
    hiPopulation = llList2String(tempList, 1);
    waPopulation = llList2String(tempList, 2);

    // llOwnerSay("OI: " + oiPopulation);
    // llOwnerSay("HI: " + hiPopulation);
    // llOwnerSay("WA: " + waPopulation);

    integer numElements = llGetListLength(llCSV2List(oiPopulation)) + llGetListLength(llCSV2List(hiPopulation)) + llGetListLength(llCSV2List(waPopulation));

    // Once in a while, we receive an incomplete list, presumably while results are being
    // collated on the server.  If this is the case, re-query the server
    if (numElements != 210) {
      if (__debug) {
        llOwnerSay("Invalid response received.  Ignoring...");
      }
    }

    tempList = [];
    message = "";

  }

  //------------------------------------------------------------------------------------
  // If we get an email, check for replies, and display to the client
  //------------------------------------------------------------------------------------
  email(string time, string address, string subj, string message, integer num_left) {

    llSetTimerEvent(0.0);
    countToLongScan = 0;

    if (subj == "OI Ctr") {
      // Remove the header
      message = llDeleteSubString(message, 0, llSubStringIndex(message, "\n\n") + 1);

      // Break of the message
      list notificationMessage = llParseString2List(message,["~",","],[]);

      string method = llList2String(notificationMessage, 0);
      string hudVersion = "";
      string avatarName = "";
      string avatarKey = "";

      if (llGetListLength(notificationMessage) > 2) {
        hudVersion = llToUpper(llList2String(notificationMessage, 2));
        if (llGetListLength(notificationMessage) > 3) {
          avatarName = llList2String(notificationMessage, 3);
          if (llGetListLength(notificationMessage) > 4) {
            avatarKey = llList2String(notificationMessage, 4);
          }
        }
      }
      if (__debug) {
        llOwnerSay("Hud Version = " + hudVersion);
        llOwnerSay("Avatar Name = " + avatarName);
        llOwnerSay("Avatar Key  = " + avatarKey);
      }

      if (method == "QUERY ALL") {

        // Decompose the return address (HUD UUID) from the message
        string returnAddress = llList2String(notificationMessage, 1);

        if (__debug) {
          llOwnerSay("QUERY (ALL) returnAddress = " + returnAddress);
        }
        // Send that object, the current OI + HI (HI1 - 210) population
        sendMessage(returnAddress + "@lsl.secondlife.com", "Query Response", "Update");
        // sendMessage(returnAddress + "@lsl.secondlife.com", "Query Response", oiPopulation + "," + llList2CSV(llDeleteSubList(llCSV2List(hiPopulation), 30, 79)));
        returnAddress = "";

      } else if (method == "QUERY ALL EXT") {

        // Decompose the return address (HUD UUID) from the message
        string returnAddress = llList2String(notificationMessage, 1);

        if (__debug) {
          llOwnerSay("QUERY (ALL EXT) returnAddress = " + returnAddress);
        }

        // Send that object, the current OI + HI + WA population in a !-separated format
        // If we need to send an updated HUD and an avatar key is available,
        // do so!
        if (hudVersion != "" && avatarKey != "") {
          if (llSubStringIndex(hudVersion, "HUD") != -1 && hudVersion != invVersion) {
            sendMessage(returnAddress + "@lsl.secondlife.com", "Query Response", "Update");
            llGiveInventory(avatarKey, invName);
          } else {
            sendMessage(returnAddress + "@lsl.secondlife.com", "Query Response", oiPopulation + "!" + hiPopulation + "!" + waPopulation);
          }
        } else {
          sendMessage(returnAddress + "@lsl.secondlife.com", "Query Response", oiPopulation + "!" + hiPopulation + "!" + waPopulation);
        }
        returnAddress = "";

      } else if (method == "QUERY") {

        // Decompose the return address (HUD UUID) from the message
        string returnAddress = llList2String(notificationMessage, 1);

        if (__debug) {
          llOwnerSay("QUERY (OI) returnAddress = " + returnAddress);
        }

        // Send that object, the current OI population only
        sendMessage(returnAddress + "@lsl.secondlife.com", "Query Response", "Update");
        //sendMessage(returnAddress + "@lsl.secondlife.com", "Query Response", oiPopulation);
        returnAddress = "";


      } else if (method == "QUERY HI") {

        // Decompose the return address (HUD UUID) from the message
        string returnAddress = llList2String(notificationMessage, 1);

        if (__debug) {
          llOwnerSay("QUERY (HI) returnAddress = " + returnAddress);
        }

        // Send that object, the current HI (HI1 - HI210) population
        sendMessage(returnAddress + "@lsl.secondlife.com", "Query Response", llList2CSV(llDeleteSubList(llCSV2List(hiPopulation), 30, 79)));
        returnAddress = "";

      } else if (method == "QUERY HI EXT") {

        // Decompose the return address (HUD UUID) from the message
        string returnAddress = llList2String(notificationMessage, 1);

        if (__debug) {
          llOwnerSay("QUERY (HI) returnAddress = " + returnAddress);
        }

        // Send that object, the current HI population

        sendMessage(returnAddress + "@lsl.secondlife.com", "Query Response", hiPopulation);
        returnAddress = "";

      }


      method = "";
      notificationMessage = [];

    }

    llSetTimerEvent(shortScanInterval);
    scanningShort = TRUE;

  }

  on_rez(integer num) {

    llResetScript();
  }

}