corrade-lsl-templates – Diff between revs 39 and 40

Subversion Repositories:

?pathlinks?

Rev 39 – Details – Blame – Last modification – View Log

     list a = llParseStringKeepNulls(data, ["&", "="], []);
     integer i = llListFindList(llList2ListStrided(a, 0, -1, 2), [ k ]);
     if(i != -1) return llList2String(a, 2*i+1);
     return "";
+}
 ///////////////////////////////////////////////////////////////////////////
-//    Copyright (C) 2013 Wizardry and Steamworks - License: CC BY 2.0    //
+//    Copyright (C) 2013 Wizardry and Steamworks - License: GNU GPLv3    //
 ///////////////////////////////////////////////////////////////////////////
 string wasKeyValueEncode(list data) {
     list k = llList2ListStrided(data, 0, -1, 2);
     list v = llList2ListStrided(llDeleteSubList(data, 0, 0), 0, -1, 2);
     data = [];
     } while(llGetListLength(k) != 0);
     return llDumpList2String(data, "&");
+}
 ///////////////////////////////////////////////////////////////////////////
-//    Copyright (C) 2015 Wizardry and Steamworks - License: CC BY 2.0    //
+//    Copyright (C) 2015 Wizardry and Steamworks - License: GNU GPLv3    //
 ///////////////////////////////////////////////////////////////////////////
 // escapes a string in conformance with RFC1738
 string wasURLEscape(string i) {
     string o = "";
     } while(i != "");
     return o;
+}
 ///////////////////////////////////////////////////////////////////////////
-//    Copyright (C) 2015 Wizardry and Steamworks - License: CC BY 2.0    //
+//    Copyright (C) 2015 Wizardry and Steamworks - License: GNU GPLv3    //
 ///////////////////////////////////////////////////////////////////////////
 // unescapes a string in conformance with RFC1738
 string wasURLUnescape(string i) {
     return llUnescapeURL(
+        )
     );
+}
 ///////////////////////////////////////////////////////////////////////////
-//    Copyright (C) 2015 Wizardry and Steamworks - License: CC BY 2.0    //
+//    Copyright (C) 2015 Wizardry and Steamworks - License: GNU GPLv3    //
 ///////////////////////////////////////////////////////////////////////////
 list wasCSVToList(string csv) {
     list l = [];
     list s = [];
     } while(csv != "");
     // postcondition: length(s) = 0
     return l + m;
+}
+///////////////////////////////////////////////////////////////////////////
+//    Copyright (C) 2015 Wizardry and Steamworks - License: CC BY 2.0    //
+///////////////////////////////////////////////////////////////////////////
+string wasListToCSV(list l) {
+    list v = [];
+    do {
+        string a = llDumpList2String(
+            llParseStringKeepNulls(
+                llList2String(
+                    l,
+                ),
+                ["\""],
+                []
+            ),
+            "\"\""
+        );
+        if(llParseStringKeepNulls(
+            a,
+            [" ", ",", "\n", "\""], []
+            ) !=
+            (list) a
+        ) a = "\"" + a + "\"";
+        v += a;
+        l = llDeleteSubList(l, 0, 0);
+    } while(l != []);
+    return llDumpList2String(v, ",");
+}
+///////////////////////////////////////////////////////////////////////////
+//                  SQL STATEMENT DEFINITIONS                            //
+///////////////////////////////////////////////////////////////////////////
+string SQL_INSERT_VISITOR = "INSERT OR REPLACE INTO visitors (firstname, lastname, lastseen, time, memory) VALUES(:firstname, :lastname, :time, COALESCE((SELECT time FROM visitors WHERE firstname=:firstname AND lastname=:lastname), 0) + 1, :memory)";
+string SQL_CREATE_TABLE = "CREATE TABLE IF NOT EXISTS visitors ('firstname' TEXT NOT NULL, 'lastname' TEXT NOT NULL, 'lastseen' TEXT NOT NULL, 'time' INTEGER NOT NULL, 'memory' INTEGER NOT NULL, PRIMARY KEY ('firstname', 'lastname'))";
+string SQL_COUNT_VISITORS = "SELECT COUNT(*) AS 'Visits', AVG(time) AS 'Time', AVG(memory) AS 'Memory' FROM visitors";
+string SQL_SELECT_VISITOR = "SELECT * FROM visitors ORDER BY lastseen DESC LIMIT 1 OFFSET :offset";
+string SQL_DROP_TABLE = "DROP TABLE IF EXISTS visitors";
+///////////////////////////////////////////////////////////////////////////
 // corrade data
 key CORRADE = NULL_KEY;
 string GROUP = "";
 // for notecard reading
 integer line = 0;
 // key-value data will be read into this list
+list tuples = [];
+list agents = [];
-list tuples = [];
+string agentName = "";
         // DEBUG
         llOwnerSay("Detecting if Corrade is online...");
         llSetTimerEvent(5);
+    }
     timer() {
-        llRequestAgentData((key)CORRADE, DATA_ONLINE);
+        llRequestAgentData(CORRADE, DATA_ONLINE);
+    }
     dataserver(key id, string data) {
         if(data != "1") {
             // DEBUG
             llOwnerSay("Corrade is not online, sleeping...");
 state initialize {
     state_entry() {
         // DEBUG
         llOwnerSay("Creating the database if it does not exist...");
         llInstantMessage(
-            (key)CORRADE,
+            CORRADE,
             wasKeyValueEncode(
+                [
                     "command", "database",
                     "group", wasURLEscape(GROUP),
                     "password", wasURLEscape(PASSWORD),
-                    "SQL", wasURLEscape(
+                    "SQL", wasURLEscape(SQL_CREATE_TABLE),
-                        "CREATE TABLE IF NOT EXISTS visitors (
-                            'firstname' TEXT NOT NULL,
-                            'lastname' TEXT NOT NULL,
-                            'lastseen' TEXT NOT NULL,
-                            'time' INTEGER NOT NULL,
-                            'memory' INTEGER NOT NULL,
-                            PRIMARY KEY ('firstname', 'lastname')
-                        )"
-                    ),
                     "callback", wasURLEscape(callback)
+                ]
+            )
         );
         // alarm 60
         llOwnerSay("Timeout creating table...");
         llResetScript();
+    }
     http_request(key id, string method, string body) {
         llHTTPResponse(id, 200, "OK");
-        if(wasKeyValueGet("command", body) != "database") return;
+        if(wasKeyValueGet("command", body) == "database") {
-        if(wasKeyValueGet("success", body) != "True") {
+            integer success = wasKeyValueGet("success", body) == "True";
+            if(!success) {
-            // DEBUG
+                // DEBUG
-            llOwnerSay("Failed to create the table: " +
+                llOwnerSay("Failed to create the table: " +
-                wasURLUnescape(
+                    wasURLUnescape(
-                    wasKeyValueGet(
+                        wasKeyValueGet(
-                        "error",
+                            "error",
-                        body
+                            body
+                        )
+                    )
-                )
+                );
+                return;
-            );
+            }
-            return;
+            // DEBUG
+            llOwnerSay("Table created...");
+            state show;
+        }
+    }
+    link_message(integer sender_num, integer num, string str, key id) {
+        if(str == "reset") {
+            state reset;
+        }
-        // DEBUG
-        llOwnerSay("Table created...");
-        state show;
+    }
     on_rez(integer num) {
         llResetScript();
+    }
     changed(integer change) {
 state show {
     state_entry() {
         // DEBUG
         llOwnerSay("Updating display with the number of recorded visitors...");
         llInstantMessage(
-            (key)CORRADE,
+            CORRADE,
             wasKeyValueEncode(
+                [
                     "command", "database",
                     "group", wasURLEscape(GROUP),
                     "password", wasURLEscape(PASSWORD),
-                    "SQL", wasURLEscape(
+                    "SQL", wasURLEscape(SQL_COUNT_VISITORS),
-                        "SELECT
-                            COUNT(*) AS 'Visits',
-                            AVG(time) AS 'Time',
-                            AVG(memory) AS 'Memory'
-                        FROM visitors"
-                    ),
                     "callback", wasURLEscape(callback)
+                ]
+            )
         );
         // alarm 60
         llOwnerSay("Timeout reading rows from visitors table...");
         llResetScript();
+    }
     http_request(key id, string method, string body) {
         llHTTPResponse(id, 200, "OK");
-        if(wasKeyValueGet("command", body) != "database") return;
+        if(wasKeyValueGet("command", body) == "database") {
-        if(wasKeyValueGet("success", body) != "True") {
+            integer success = wasKeyValueGet("success", body) == "True";
+            if(!success) {
-            // DEBUG
+                // DEBUG
-            llOwnerSay("Failed to enumerate visitors: " +
+                llOwnerSay("Failed to enumerate visitors: " +
+                    wasURLUnescape(
+                        wasKeyValueGet(
+                            "error",
+                            body
+                        )
+                    )
+                );
+                llResetScript();
+            }
+            list data = wasCSVToList(
                 wasURLUnescape(
                     wasKeyValueGet(
-                        "error",
+                        "data",
                         body
+                    )
+                )
             );
-            llResetScript();
-        }
-        list data = wasCSVToList(
-            wasURLUnescape(
+            // DEBUG
-                wasKeyValueGet(
-                    "data",
+            //llOwnerSay("Data: " + llDumpList2String(data, ","));
-                    body
-                )
-            )
-        );
-        integer visits = llList2Integer(
+            integer visits = llList2Integer(
-            data,
-            llListFindList(
                 data,
-                (list)"Visits"
+                llListFindList(
-            ) + 1
+                    data,
-        );
+                    (list)"Visits"
-        integer time = llList2Integer(
+                ) + 1
-            data,
+            );
-            llListFindList(
+            integer time = llList2Integer(
                 data,
-                (list)"Time"
+                llListFindList(
-            ) + 1
+                    data,
-        );
+                    (list)"Time"
-        integer memory = llList2Integer(
+                ) + 1
-            data,
+            );
-            llListFindList(
+            integer memory = llList2Integer(
                 data,
+                llListFindList(
+                    data,
-                (list)"Memory"
+                    (list)"Memory"
-            ) + 1
+                ) + 1
-        );
+            );
+            // Send message to xyz script.
-        llMessageLinked(LINK_ROOT, 204000, "V:" + (string)visits, "0");
+            llMessageLinked(LINK_ROOT, 204000, "V:" + (string)visits, "0");
-        llMessageLinked(LINK_ROOT, 204000, "T:" + (string)time + "m", "1");
+            llMessageLinked(LINK_ROOT, 204000, "T:" + (string)time + "m", "1");
-        llMessageLinked(LINK_ROOT, 204000, "M:" + (string)memory + "k", "2");
+            llMessageLinked(LINK_ROOT, 204000, "M:" + (string)memory + "k", "2");
+            // Get the list of agents.
+            agents = llGetAgentList(AGENT_LIST_REGION, []);
-        state scan;
+            state insert_trampoline;
+        }
+    }
     link_message(integer sender_num, integer num, string str, key id) {
         if(str == "reset")
             state reset;
         if(str == "display") {
     state_exit() {
         llSetTimerEvent(0);
+    }
+}
-state scan {
+state insert_trampoline {
-    state_entry() {
-        // DEBUG
-        llOwnerSay("Scanning for visitors...");
-        // Scan for visitors every 60 seconds.
+    state_entry() {
-        llSetTimerEvent(60);
+        llSetTimerEvent(1);
+    }
-    timer() {
-        // Check if Corrade is online.
-        llRequestAgentData((key)CORRADE, DATA_ONLINE);
-        // Get agents
-        list as = llGetAgentList(AGENT_LIST_REGION, []);
-        do {
-            key a = llList2Key(as, 0);
-            as = llDeleteSubList(as, 0, 0);
-            list name = llParseString2List(llKey2Name(a), [" "], []);
-            if(llGetListLength(name) != 2) return;
-            string fn = llList2String(name, 0);
-            string ln = llList2String(name, 1);
-            // The command sent to Corrade responsible for adding a visitor
-            // or updating the data for the visitor in case the visitor is
-            // already entered into the visitors table. This is performed
-            // with an INSER OR REPLACE sqlite command given the first name
-            // and the last name of the avatar are unique primary keys.
-            llInstantMessage(
-                (key)CORRADE,
-                wasKeyValueEncode(
-                    [
-                        "command", "database",
-                        "group", wasURLEscape(GROUP),
-                        "password", wasURLEscape(PASSWORD),
-                        "SQL", wasURLEscape(
-                            "INSERT OR REPLACE INTO visitors (
-                                firstname,
-                                lastname,
-                                lastseen,
-                                time,
-                                memory
-                            ) VALUES(
-                                '" + fn + "', '" +  ln + "', '" + llGetTimestamp() + "',
-                                COALESCE(
-                                    (
-                                        SELECT time FROM visitors WHERE
-                                            firstname='" + fn + "' AND lastname='" + ln + "'
-                                    ) + 1
-                                    ,
-                                ), " +
-                                (string)(
-                                    (integer)(
-                                        llList2Float(
-                                            llGetObjectDetails(
-                                                a,
-                                                [OBJECT_SCRIPT_MEMORY]
-                                            ),
-                                        )
-                                        /
-/*in kib, to mib 1048576*/
-                                    )
-                                ) +
-                            ")"
-                        )
-                    ]
-                )
-            );
-        } while(llGetListLength(as));
+    timer() {
-        state show;
+        state insert;
+    }
     link_message(integer sender_num, integer num, string str, key id) {
         if(str == "reset")
             state reset;
         if(str == "display") {
             line = 0;
             state display;
+        }
+    }
+    on_rez(integer num) {
+        llResetScript();
     }
+    changed(integer change) {
+        if((change & CHANGED_INVENTORY) || (change & CHANGED_REGION_START)) {
+            llResetScript();
+        }
+    }
+    state_exit() {
+        llSetTimerEvent(0);
+    }
+}
+state insert {
+    state_entry() {
+        // Once the list is empty, go back to display.
+        if(llGetListLength(agents) == 0) {
+            state show;
+        }
+        key agent = llList2Key(agents, 0);
+        agents = llDeleteSubList(agents, 0, 0);
+        list name = llParseString2List(llKey2Name(agent), [" "], []);
-    dataserver(key id, string data) {
+        if(llGetListLength(name) != 2) {
+            return;
+        }
+        string firstname = llList2String(name, 0);
+        string lastname = llList2String(name, 1);
+        agentName = firstname + " " + lastname;
+        string memory = (string)(
+            (integer)(
+                llList2Float(
+                    llGetObjectDetails(
+                        agent,
+                        [OBJECT_SCRIPT_MEMORY]
+                    ),
+                )
+                /
+/*in kib, to mib 1048576*/
+            )
-        if(data == "1") return;
+        );
+        // DEBUG
+        //llOwnerSay("Memory: " + memory);
+        // The command sent to Corrade responsible for adding a visitor
+        // or updating the data for the visitor in case the visitor is
+        // already entered into the visitors table. This is performed
+        // with an INSER OR REPLACE sqlite command given the first name
+        // and the last name of the avatar are unique primary keys.
+        llInstantMessage(
+            CORRADE,
+            wasKeyValueEncode(
+                [
+                    "command", "database",
+                    "group", wasURLEscape(GROUP),
+                    "password", wasURLEscape(PASSWORD),
+                    "SQL", wasURLEscape(SQL_INSERT_VISITOR),
+                    "data", wasListToCSV(
+                        [
+                            "firstname",
+                            firstname,
+                            "lastname",
+                            lastname,
+                            "time",
+                            llGetTimestamp(),
+                            "memory",
+                            memory
+                        ]
+                    ),
+                    "callback", wasURLEscape(callback)
+                ]
+            )
+        );
+        // Command timeout.
+        llSetTimerEvent(60);
+    }
+    http_request(key id, string method, string body) {
+        llHTTPResponse(id, 200, "OK");
+        // DEBUG
+        //llOwnerSay(wasURLUnescape(body));
+        if(wasKeyValueGet("command", body) == "database") {
+            integer success = wasKeyValueGet("success", body) == "True";
+            if(!success) {
+                // DEBUG
+                llOwnerSay("Failed to insert visitor " + agentName + " due to: " +
+                    wasURLUnescape(
+                        wasKeyValueGet(
+                            "error",
+                            body
+                        )
+                    )
+                );
+                state insert_trampoline;
+            }
+            // DEBUG
+            llOwnerSay("Processed visitor named " + agentName + "...");
+            state insert_trampoline;
+        }
+    }
+    timer() {
         // DEBUG
+        llOwnerSay("Inserting visitors has timed out, resetting...");
+        state insert_trampoline;
-        llOwnerSay("Corrade is not online, sleeping...");
+    }
+    link_message(integer sender_num, integer num, string str, key id) {
-        // Switch to detect loop and wait there for Corrade to come online.
+        if(str == "reset") {
+            state reset;
+        }
+        if(str == "display") {
+            line = 0;
+            state display;
         state detect;
+    }
     on_rez(integer num) {
         llResetScript();
+    }
+}
 state display {
     state_entry() {
         llInstantMessage(
-            (key)CORRADE,
+            CORRADE,
             wasKeyValueEncode(
+                [
                     "command", "database",
                     "group", wasURLEscape(GROUP),
                     "password", wasURLEscape(PASSWORD),
-                    "SQL", wasURLEscape(
+                    "SQL", wasURLEscape(SQL_SELECT_VISITOR),
-                        "SELECT * FROM visitors
+                    "data", wasListToCSV(
-                            ORDER BY lastseen DESC
+                        [
-                            LIMIT 1
+                            "offset",
+                            (string)line
                             OFFSET " + (string)line
                     ),
                     "callback", wasURLEscape(callback)
+                ]
+            )
+        );
         );
         // alarm 60
         llSetTimerEvent(60);
+    }
     http_request(key id, string method, string body) {
+        llHTTPResponse(id, 200, "OK");
-        llHTTPResponse(id, 200, "OK");
-        if(wasKeyValueGet("command", body) != "database") return;
+        if(wasKeyValueGet("command", body) == "database") {
+            integer success = wasKeyValueGet("success", body) == "True";
-        if(wasKeyValueGet("success", body) != "True") {
+            if(!success) {
-            // DEBUG
+                // DEBUG
-            llOwnerSay("Failed to query the table: " +
+                llOwnerSay("Failed to query the visitors table: " +
-                wasURLUnescape(
+                    wasURLUnescape(
-                    wasKeyValueGet(
+                        wasKeyValueGet(
-                        "error",
+                            "error",
+                            body
                         body
+                    )
+                );
+                return;
+            }
+            // Grab the data key if it exists.
+            string dataKey = wasURLUnescape(
+                wasKeyValueGet(
+                    "data",
                     body
+                )
-            );
-            return;
-        }
-        // Grab the data key if it exists.
-        string dataKey = wasURLUnescape(
-            wasKeyValueGet(
-                "data",
-                body
-            )
-        );
-        // We got no more rows, so switch back to scanning.
-        if(dataKey == "")
-            state scan;
-        list data = wasCSVToList(dataKey);
+            );
-        string firstname = llList2String(
+            // We got no more rows, so switch back to scanning.
+            if(dataKey == "")
+                state show;
+            list data = wasCSVToList(dataKey);
             data,
-            llListFindList(
+            string firstname = llList2String(
                 data,
-                (list)"firstname"
+                llListFindList(
-            ) + 1
+                    data,
-        );
+                    (list)"firstname"
-        string lastname = llList2String(
+                ) + 1
-            data,
+            );
-            llListFindList(
+            string lastname = llList2String(
                 data,
-                (list)"lastname"
+                llListFindList(
-            ) + 1
+                    data,
-        );
+                    (list)"lastname"
-        string lastseen = llList2String(
+                ) + 1
-            data,
+            );
+            string lastseen = llList2String(
+                data,
-            llListFindList(
+                llListFindList(
-                data,
+                    data,
-                (list)"lastseen"
+                    (list)"lastseen"
-            ) + 1
+                ) + 1
-        );
+            );
+            llOwnerSay(firstname + " " + lastname + " @ " + lastseen);
-        llOwnerSay(firstname + " " + lastname + " @ " + lastseen);
+            state display_trampoline;
         state display_trampoline;
     }
     link_message(integer sender_num, integer num, string str, key id) {
+        if(str == "reset") {
+            state reset;
+        }
+        // If the display button is pressed again, go back to the display and stop.
+        if(str == "display") {
-        if(str == "reset")
+            state show;
             state reset;
+    }
     timer() {
         // DEBUG
 state reset {
     state_entry() {
         // DEBUG
         llOwnerSay("Resetting all visitors...");
         llInstantMessage(
-            (key)CORRADE,
+            CORRADE,
             wasKeyValueEncode(
+                [
                     "command", "database",
                     "group", wasURLEscape(GROUP),
                     "password", wasURLEscape(PASSWORD),
-                    "SQL", "DROP TABLE visitors",
+                    "SQL", wasURLEscape(SQL_DROP_TABLE),
                     "callback", wasURLEscape(callback)
+                ]
+            )
         );
         // alarm 60
         llSetTimerEvent(60);
+    }
     timer() {
         // DEBUG
         llOwnerSay("Timeout deleting database...");
         llResetScript();
+    }
     http_request(key id, string method, string body) {
         llHTTPResponse(id, 200, "OK");
-        if(wasKeyValueGet("command", body) != "database") return;
+        if(wasKeyValueGet("command", body) == "database") {
-        if(wasKeyValueGet("success", body) != "True") {
+            integer success = wasKeyValueGet("success", body) == "True";
+            if(!success) {
-            // DEBUG
+                // DEBUG
-            llOwnerSay("Failed to drop the visitors table: " +
+                llOwnerSay("Failed to drop the visitors table: " +
-                wasURLUnescape(
+                    wasURLUnescape(
-                    wasKeyValueGet(
+                        wasKeyValueGet(
-                        "error",
+                            "error",
-                        body
+                            body
+                        )
+                    )
-                )
+                );
+                llResetScript();
-            );
+            }
+            // DEBUG
+            llOwnerSay("Table dropped...");
             llResetScript();
+        }
-        // DEBUG
-        llOwnerSay("Table dropped...");
-        llResetScript();
+    }
     on_rez(integer num) {
         llResetScript();
+    }
     changed(integer change) {