535 lines
15 KiB
Plaintext
535 lines
15 KiB
Plaintext
|
/* The URL of the prim-dns webservice. */
|
||
|
|
string prim_dns_api = "https://annapuddles.com/prim-dns/alias";
|
||
|
|
|
||
|
|
/* The alias registered on the prim-dns service. If blank, the object key will be used. */
|
||
|
|
string prim_dns_alias;
|
||
|
|
|
||
|
|
/* The authorization string used to update the URL alias */
|
||
|
|
string prim_dns_auth;
|
||
|
|
|
||
|
|
/* How often in seconds the server statistics text should be updated. 0 will disable status text completely. */
|
||
|
|
float status_update_interval = 1;
|
||
|
|
|
||
|
|
/* Whether to use a secure (https) or insecure (http) URL. */
|
||
|
|
integer use_secure_url = FALSE;
|
||
|
|
|
||
|
|
/* Whether to automatically start the server, or wait for a signal from a script. */
|
||
|
|
integer auto_start = TRUE;
|
||
|
|
|
||
|
|
/* The actual temporary prim URL assigned by llRequestURL */
|
||
|
|
string temporary_url;
|
||
|
|
|
||
|
|
/* The current line of the config notecard that is being read. */
|
||
|
|
integer config_notecard_line;
|
||
|
|
|
||
|
|
/* ID of the config notecard dataserver query. */
|
||
|
|
key config_notecard_query_id;
|
||
|
|
|
||
|
|
/* ID of the prim-dns HTTP request. */
|
||
|
|
key prim_dns_request_id;
|
||
|
|
|
||
|
|
/* Channel which dialogs will use. */
|
||
|
|
integer dialog_channel = -872;
|
||
|
|
|
||
|
|
/* Listener for dialogs. */
|
||
|
|
integer dialog_listener;
|
||
|
|
|
||
|
|
/* Send a JSON-RPC-like message to linked prims. */
|
||
|
|
json_link_message(integer link, string method, list params)
|
||
|
|
{
|
||
|
|
llMessageLinked(link, 0, llList2Json(JSON_OBJECT, ["method", method, "params", llList2Json(JSON_OBJECT, params)]), NULL_KEY);
|
||
|
|
}
|
||
|
|
|
||
|
|
/* Request a URL, either secure or insecure based on the use_secure_url setting. */
|
||
|
|
start_url_request()
|
||
|
|
{
|
||
|
|
if (use_secure_url)
|
||
|
|
{
|
||
|
|
llRequestSecureURL();
|
||
|
|
}
|
||
|
|
else
|
||
|
|
{
|
||
|
|
llRequestURL();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* Convert a time in seconds to a human-readable string. */
|
||
|
|
string time_to_string(float time)
|
||
|
|
{
|
||
|
|
integer t = (integer) time;
|
||
|
|
|
||
|
|
integer weeks = t / 604800;
|
||
|
|
integer days = (t / 86400) % 7;
|
||
|
|
integer hours = (t / 3600) % 24;
|
||
|
|
integer minutes = (t / 60) % 60;
|
||
|
|
integer seconds = t % 60;
|
||
|
|
|
||
|
|
list parts;
|
||
|
|
|
||
|
|
if (weeks > 0)
|
||
|
|
{
|
||
|
|
parts += (string) weeks + " weeks";
|
||
|
|
}
|
||
|
|
if (days > 0)
|
||
|
|
{
|
||
|
|
parts += (string) days + " days";
|
||
|
|
}
|
||
|
|
if (hours > 0)
|
||
|
|
{
|
||
|
|
parts += (string) hours + " hours";
|
||
|
|
}
|
||
|
|
if (minutes > 0)
|
||
|
|
{
|
||
|
|
parts += (string) minutes + " minutes";
|
||
|
|
}
|
||
|
|
if (seconds > 0)
|
||
|
|
{
|
||
|
|
parts += (string) seconds + " seconds";
|
||
|
|
}
|
||
|
|
|
||
|
|
return llDumpList2String(parts, ", ");
|
||
|
|
}
|
||
|
|
|
||
|
|
/* Change settings based on config file name. */
|
||
|
|
change_setting(string setting, string value)
|
||
|
|
{
|
||
|
|
if (setting == "api")
|
||
|
|
{
|
||
|
|
prim_dns_api = value;
|
||
|
|
}
|
||
|
|
else if (setting == "alias")
|
||
|
|
{
|
||
|
|
prim_dns_alias = value;
|
||
|
|
}
|
||
|
|
else if (setting == "auth")
|
||
|
|
{
|
||
|
|
prim_dns_auth = value;
|
||
|
|
}
|
||
|
|
else if (setting == "secure_url")
|
||
|
|
{
|
||
|
|
use_secure_url = (integer) value;
|
||
|
|
}
|
||
|
|
else if (setting == "status_update_interval")
|
||
|
|
{
|
||
|
|
status_update_interval = (float) value;
|
||
|
|
}
|
||
|
|
else if (setting == "auto_start")
|
||
|
|
{
|
||
|
|
auto_start = (integer) value;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
default
|
||
|
|
{
|
||
|
|
state_entry()
|
||
|
|
{
|
||
|
|
llSetText("Touch to start", <1, 1, 1>, 1);
|
||
|
|
}
|
||
|
|
|
||
|
|
touch_end(integer detected)
|
||
|
|
{
|
||
|
|
if (llDetectedKey(0) != llGetOwner())
|
||
|
|
{
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
state read_configuration;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* In the read_configuration state, the server settings are initialized by reading the config notecard. */
|
||
|
|
state read_configuration
|
||
|
|
{
|
||
|
|
state_entry()
|
||
|
|
{
|
||
|
|
llSetText("Reading configuration...", <1, 1, 1>, 1);
|
||
|
|
|
||
|
|
/* If the config notecard doesn't exist, abort. */
|
||
|
|
if (llGetInventoryType("config") != INVENTORY_NOTECARD)
|
||
|
|
{
|
||
|
|
state startup;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* Reset these saved settings to their default values. */
|
||
|
|
prim_dns_alias = "";
|
||
|
|
prim_dns_auth = "";
|
||
|
|
|
||
|
|
/* Reset the notecard line counter to 0. */
|
||
|
|
config_notecard_line = 0;
|
||
|
|
|
||
|
|
/* Read the first line of the notecard. */
|
||
|
|
config_notecard_query_id = llGetNotecardLine("config", config_notecard_line++);
|
||
|
|
}
|
||
|
|
|
||
|
|
/* Read each line of the config notecard. */
|
||
|
|
dataserver(key query_id, string data)
|
||
|
|
{
|
||
|
|
/* Ignore dataserver events from other scripts. */
|
||
|
|
if (query_id != config_notecard_query_id)
|
||
|
|
{
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* If there are no more lines to read, stop. */
|
||
|
|
if (data == EOF)
|
||
|
|
{
|
||
|
|
state startup;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* Ignore lines that start with #, treating them as comments */
|
||
|
|
if (llGetSubString(data, 0, 1) != "#")
|
||
|
|
{
|
||
|
|
list parts = llParseStringKeepNulls(data, [" = "], []);
|
||
|
|
|
||
|
|
if (llGetListLength(parts) == 2)
|
||
|
|
{
|
||
|
|
string setting = llList2String(parts, 0);
|
||
|
|
string value = llList2String(parts, 1);
|
||
|
|
|
||
|
|
change_setting(setting, value);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* Read the next line */
|
||
|
|
config_notecard_query_id = llGetNotecardLine("config", config_notecard_line++);
|
||
|
|
}
|
||
|
|
|
||
|
|
state_exit()
|
||
|
|
{
|
||
|
|
llSetText("", ZERO_VECTOR, 0);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* In the startup state, the script will wait to receive the "start" message from another script. */
|
||
|
|
state startup
|
||
|
|
{
|
||
|
|
state_entry()
|
||
|
|
{
|
||
|
|
llSetText("Waiting for startup...", <1, 1, 1>, 1);
|
||
|
|
|
||
|
|
json_link_message(LINK_THIS, "prim-dns:startup", []);
|
||
|
|
|
||
|
|
if (auto_start)
|
||
|
|
{
|
||
|
|
state request_url;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
changed(integer change)
|
||
|
|
{
|
||
|
|
if (change & CHANGED_INVENTORY)
|
||
|
|
{
|
||
|
|
state read_configuration;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
link_message(integer sender, integer num, string str, key id)
|
||
|
|
{
|
||
|
|
string method = llJsonGetValue(str, ["method"]);
|
||
|
|
|
||
|
|
if (method == "prim-dns:start")
|
||
|
|
{
|
||
|
|
state request_url;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* Present an options menu on touch. */
|
||
|
|
touch_start(integer detected)
|
||
|
|
{
|
||
|
|
key toucher = llDetectedKey(0);
|
||
|
|
llListenRemove(dialog_listener);
|
||
|
|
dialog_listener = llListen(dialog_channel, "", toucher, "");
|
||
|
|
llDialog(toucher, "What would you like to do?", ["reboot", "shutdown", "cancel"], dialog_channel);
|
||
|
|
}
|
||
|
|
|
||
|
|
/* Handle the response from the options menu. */
|
||
|
|
listen(integer channel, string name, key id, string message)
|
||
|
|
{
|
||
|
|
llListenRemove(dialog_listener);
|
||
|
|
|
||
|
|
if (message == "reboot")
|
||
|
|
{
|
||
|
|
state read_configuration;
|
||
|
|
}
|
||
|
|
else if (message == "shutdown")
|
||
|
|
{
|
||
|
|
state default;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
state_exit()
|
||
|
|
{
|
||
|
|
llSetText("", ZERO_VECTOR, 0);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* In the request_url state, the script requests a URL, and registers it with the prim-dns service. */
|
||
|
|
state request_url
|
||
|
|
{
|
||
|
|
state_entry()
|
||
|
|
{
|
||
|
|
llSetText("Requesting URL...", <1, 1, 1>, 1);
|
||
|
|
|
||
|
|
/* Release any current temporary URL in use. */
|
||
|
|
llReleaseURL(temporary_url);
|
||
|
|
|
||
|
|
/* Request a new URL. */
|
||
|
|
start_url_request();
|
||
|
|
}
|
||
|
|
|
||
|
|
/* Handle HTTP requests made to this prim. */
|
||
|
|
http_request(key request_id, string method, string body)
|
||
|
|
{
|
||
|
|
/* If the SecondLife server granted the script a URL, it will send an HTTP request to the prim with the URL */
|
||
|
|
if (method == URL_REQUEST_GRANTED)
|
||
|
|
{
|
||
|
|
temporary_url = body;
|
||
|
|
llOwnerSay("URL request granted: " + temporary_url);
|
||
|
|
|
||
|
|
/* Use the obtained temporary URL and auth string to update the permanent URL alias */
|
||
|
|
|
||
|
|
/* Create the headers for the request. */
|
||
|
|
list headers = [
|
||
|
|
HTTP_METHOD, "POST",
|
||
|
|
HTTP_MIMETYPE, "application/json",
|
||
|
|
HTTP_CUSTOM_HEADER, "Authorization", prim_dns_auth
|
||
|
|
];
|
||
|
|
|
||
|
|
string name;
|
||
|
|
|
||
|
|
/* If no name is given for the alias, use the object's key. */
|
||
|
|
if (prim_dns_alias == "")
|
||
|
|
{
|
||
|
|
name = llGetKey();
|
||
|
|
}
|
||
|
|
else
|
||
|
|
{
|
||
|
|
name = prim_dns_alias;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* Create the body data for the request. */
|
||
|
|
list body = [
|
||
|
|
"name", name,
|
||
|
|
"url", temporary_url
|
||
|
|
];
|
||
|
|
|
||
|
|
/* Make the request to the prim-dns webservice. */
|
||
|
|
prim_dns_request_id = llHTTPRequest(prim_dns_api, headers, llList2Json(JSON_OBJECT, body));
|
||
|
|
}
|
||
|
|
/* If for some reason the SecondLife server denied the request, display the reason */
|
||
|
|
else if (method == URL_REQUEST_DENIED)
|
||
|
|
{
|
||
|
|
llOwnerSay("URL request denied: " + body);
|
||
|
|
|
||
|
|
llSetTimerEvent(10);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* Handle the response from the prim-dns webservice */
|
||
|
|
http_response(key request_id, integer status, list metadata, string body)
|
||
|
|
{
|
||
|
|
/* Ignore HTTP responses triggered by other scripts. */
|
||
|
|
if (request_id != prim_dns_request_id)
|
||
|
|
{
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* If we received a successful response from the webservice... */
|
||
|
|
if (status == 200)
|
||
|
|
{
|
||
|
|
string auth = llJsonGetValue(body, ["auth"]);
|
||
|
|
|
||
|
|
/* If not auth string is returned in the response, then we must be updating an existing alias. */
|
||
|
|
if (auth == JSON_INVALID)
|
||
|
|
{
|
||
|
|
llOwnerSay("Server URL updated successfully for " + llJsonGetValue(body, ["endpoint"]));
|
||
|
|
}
|
||
|
|
/* If an auth string is returned, this must be a new alias. */
|
||
|
|
else
|
||
|
|
{
|
||
|
|
llOwnerSay("Server URL registered successfully at " + llJsonGetValue(body, ["endpoint"]));
|
||
|
|
llOwnerSay("****************************************\nCOPY THIS LINE INTO THE config NOTECARD:\n\nauth = " + llJsonGetValue(body, ["auth"]) + "\n\n****************************************");
|
||
|
|
}
|
||
|
|
|
||
|
|
state main;
|
||
|
|
}
|
||
|
|
/* If the webservice responded with an error, display it */
|
||
|
|
else
|
||
|
|
{
|
||
|
|
llOwnerSay("Registration failed: [" + (string) status + "] " + llJsonGetValue(body, ["error"]));
|
||
|
|
|
||
|
|
llSetTimerEvent(10);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* Reboot automatically if no URL can be obtained. */
|
||
|
|
timer()
|
||
|
|
{
|
||
|
|
state read_configuration;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* Present an options menu on touch. */
|
||
|
|
touch_start(integer detected)
|
||
|
|
{
|
||
|
|
key toucher = llDetectedKey(0);
|
||
|
|
llListenRemove(dialog_listener);
|
||
|
|
dialog_listener = llListen(dialog_channel, "", toucher, "");
|
||
|
|
llDialog(toucher, "What would you like to do?", ["reboot", "shutdown", "cancel"], dialog_channel);
|
||
|
|
}
|
||
|
|
|
||
|
|
/* Handle the response from the options menu. */
|
||
|
|
listen(integer channel, string name, key id, string message)
|
||
|
|
{
|
||
|
|
llListenRemove(dialog_listener);
|
||
|
|
|
||
|
|
if (message == "reboot")
|
||
|
|
{
|
||
|
|
state read_configuration;
|
||
|
|
}
|
||
|
|
else if (message == "shutdown")
|
||
|
|
{
|
||
|
|
state default;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
state_exit()
|
||
|
|
{
|
||
|
|
llSetTimerEvent(0);
|
||
|
|
llSetText("", ZERO_VECTOR, 0);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* In the main state, handle normal requests. */
|
||
|
|
state main
|
||
|
|
{
|
||
|
|
state_entry()
|
||
|
|
{
|
||
|
|
llResetTime();
|
||
|
|
llSetText("Ready!", <1, 1, 1>, 1);
|
||
|
|
if (status_update_interval > 0)
|
||
|
|
{
|
||
|
|
llSetTimerEvent(status_update_interval);
|
||
|
|
}
|
||
|
|
else
|
||
|
|
{
|
||
|
|
llSetTimerEvent(1);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* Update the server statistics text. */
|
||
|
|
timer()
|
||
|
|
{
|
||
|
|
if (status_update_interval == 0)
|
||
|
|
{
|
||
|
|
llSetText("", ZERO_VECTOR, 0);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
string stats;
|
||
|
|
|
||
|
|
integer used_mem = llGetUsedMemory();
|
||
|
|
integer mem_limit = llGetMemoryLimit();
|
||
|
|
float mem_ratio = (float) used_mem / (float) mem_limit;
|
||
|
|
integer percent_mem = (integer) (mem_ratio * 100);
|
||
|
|
|
||
|
|
stats += "Uptime: " + time_to_string(llGetTime()) + "\n";
|
||
|
|
|
||
|
|
stats += "Memory Used: " + (string) percent_mem + "% (" + (string) (used_mem / 1024) + " KiB / " + (string) (mem_limit / 1024) + " KiB)";
|
||
|
|
|
||
|
|
llSetText(stats, <1, 1, 1>, 1);
|
||
|
|
}
|
||
|
|
|
||
|
|
state_exit()
|
||
|
|
{
|
||
|
|
llSetText("", ZERO_VECTOR, 0);
|
||
|
|
llSetTimerEvent(0);
|
||
|
|
}
|
||
|
|
|
||
|
|
/* If the object is de-rezzed and then rezzed again, we must request a new URL */
|
||
|
|
on_rez(integer param)
|
||
|
|
{
|
||
|
|
/* When rezzed, the object has a new key, so if the key is used as the alias, a new auth is required. */
|
||
|
|
if (prim_dns_alias == "")
|
||
|
|
{
|
||
|
|
prim_dns_auth = "";
|
||
|
|
}
|
||
|
|
|
||
|
|
state request_url;
|
||
|
|
}
|
||
|
|
|
||
|
|
changed(integer change)
|
||
|
|
{
|
||
|
|
/* If the inventory changes (for example, after updating the config notecard), re-initialize. */
|
||
|
|
if (change & CHANGED_INVENTORY)
|
||
|
|
{
|
||
|
|
state read_configuration;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* If the prim changes regions or the region the prim is in restarts, we must request a new URL */
|
||
|
|
if (change & (CHANGED_REGION | CHANGED_REGION_START))
|
||
|
|
{
|
||
|
|
state request_url;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* Pass the request data to linked prims in a JSON-RPC message. */
|
||
|
|
http_request(key request_id, string method, string body)
|
||
|
|
{
|
||
|
|
json_link_message(LINK_THIS, "prim-dns:request", ["request-id", request_id, "method", method, "body", body]);
|
||
|
|
}
|
||
|
|
|
||
|
|
/* Process JSON-RPC messages from linked prims. */
|
||
|
|
link_message(integer sender, integer num, string str, key id)
|
||
|
|
{
|
||
|
|
string method = llJsonGetValue(str, ["method"]);
|
||
|
|
|
||
|
|
if (method == "prim-dns:set-content-type")
|
||
|
|
{
|
||
|
|
key request_id = (key) llJsonGetValue(str, ["params", "request-id"]);
|
||
|
|
integer content_type = (integer) llJsonGetValue(str, ["params", "content-type"]);
|
||
|
|
|
||
|
|
llSetContentType(request_id, content_type);
|
||
|
|
}
|
||
|
|
else if (method == "prim-dns:response")
|
||
|
|
{
|
||
|
|
key request_id = (key) llJsonGetValue(str, ["params", "request-id"]);
|
||
|
|
integer status = (integer) llJsonGetValue(str, ["params", "status"]);
|
||
|
|
string body = llJsonGetValue(str, ["params", "body"]);
|
||
|
|
|
||
|
|
llHTTPResponse(request_id, status, body);
|
||
|
|
}
|
||
|
|
else if (method == "prim-dns:reboot")
|
||
|
|
{
|
||
|
|
state read_configuration;
|
||
|
|
}
|
||
|
|
else if (method == "prim-dns:shutdown")
|
||
|
|
{
|
||
|
|
state default;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* Present an options menu on touch. */
|
||
|
|
touch_start(integer detected)
|
||
|
|
{
|
||
|
|
key toucher = llDetectedKey(0);
|
||
|
|
llListenRemove(dialog_listener);
|
||
|
|
dialog_listener = llListen(dialog_channel, "", toucher, "");
|
||
|
|
llDialog(toucher, "What would you like to do?", ["reboot", "shutdown", "cancel"], dialog_channel);
|
||
|
|
}
|
||
|
|
|
||
|
|
/* Handle the response from the options menu. */
|
||
|
|
listen(integer channel, string name, key id, string message)
|
||
|
|
{
|
||
|
|
llListenRemove(dialog_listener);
|
||
|
|
|
||
|
|
if (message == "reboot")
|
||
|
|
{
|
||
|
|
state read_configuration;
|
||
|
|
}
|
||
|
|
else if (message == "shutdown")
|
||
|
|
{
|
||
|
|
state default;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|