//////////// //SECURITY// //////////// #define TOPIC_SPAM_DELAY 2 //2 ticks is about 2/10ths of a second; it was 4 ticks, but that caused too many clicks to be lost due to lag #define UPLOAD_LIMIT 10485760 //Restricts client uploads to the server to 10MB //Boosted this thing. What's the worst that can happen? #define MIN_CLIENT_VERSION 0 //Just an ambiguously low version for now, I don't want to suddenly stop people playing. //I would just like the code ready should it ever need to be used. /* When somebody clicks a link in game, this Topic is called first. It does the stuff in this proc and then is redirected to the Topic() proc for the src=[0xWhatever] (if specified in the link). ie locate(hsrc).Topic() Such links can be spoofed. Because of this certain things MUST be considered whenever adding a Topic() for something: - Can it be fed harmful values which could cause runtimes? - Is the Topic call an admin-only thing? - If so, does it have checks to see if the person who called it (usr.client) is an admin? - Are the processes being called by Topic() particularly laggy? - If so, is there any protection against somebody spam-clicking a link? If you have any questions about this stuff feel free to ask. ~Carn */ /client/Topic(href, href_list, hsrc) if(!usr || usr != mob) //stops us calling Topic for somebody else's client. Also helps prevent usr=null return //Reduces spamming of links by dropping calls that happen during the delay period if(next_allowed_topic_time > world.time) return next_allowed_topic_time = world.time + TOPIC_SPAM_DELAY //search the href for script injection if( findtext(href,"You are no longer able to use this, it's been more then 10 minutes since an admin on Discord has responded to you" return if(mute_discord) usr << "" return cmd_admin_discord_pm(href_list["discord_msg"]) return //Logs all hrefs if(config && config.log_hrefs && href_logfile) href_logfile << "[time2text(world.timeofday,"hh:mm")] [src] (usr:[usr]) || [hsrc ? "[hsrc] " : ""][href]
" switch(href_list["_src_"]) if("holder") hsrc = holder if("usr") hsrc = mob if("prefs") return prefs.process_link(usr,href_list) if("vars") return view_var_Topic(href,href_list,hsrc) if(href_list["warnacknowledge"]) var/queryid = text2num(href_list["warnacknowledge"]) warnings_acknowledge(queryid) if(href_list["warnview"]) warnings_check() if(href_list["linkingrequest"]) if (!config.webint_url) return if (!href_list["linkingaction"]) return var/request_id = text2num(href_list["linkingrequest"]) establish_db_connection(dbcon) if (!dbcon.IsConnected()) src << "\red Action failed! Database link could not be established!" return var/DBQuery/check_query = dbcon.NewQuery("SELECT player_ckey, status FROM ss13_player_linking WHERE id = :id") check_query.Execute(list(":id" = request_id)) if (!check_query.NextRow()) src << "\red No request found!" return if (ckey(check_query.item[1]) != ckey || check_query.item[2] != "new") src << "\red Request authentication failed!" return var/query_contents = "" var/list/query_details = list(":new_status", ":id") var/feedback_message = "" switch (href_list["linkingaction"]) if ("accept") query_contents = "UPDATE ss13_player_linking SET status = :new_status, updated_at = NOW() WHERE id = :id" query_details[":new_status"] = "confirmed" query_details[":id"] = request_id feedback_message = "Account successfully linked!" if ("deny") query_contents = "UPDATE ss13_player_linking SET status = :new_status, deleted_at = NOW() WHERE id = :id" query_details[":new_status"] = "rejected" query_details[":id"] = request_id feedback_message = "Link request rejected!" else src << "\red Invalid command sent." return var/DBQuery/update_query = dbcon.NewQuery(query_contents) update_query.Execute(query_details) if (href_list["linkingaction"] == "accept" && alert("To complete the process, you have to visit the website. Do you want to do so now?",,"Yes","No") == "Yes") process_webint_link("interface/user/link") src << feedback_message check_linking_requests() return if (href_list["routeWebInt"]) process_webint_link(href_list["routeWebInt"], href_list["routeAttributes"]) return // JSlink switch. if (href_list["JSlink"]) switch (href_list["JSlink"]) if ("warnings") src.warnings_check() if ("linking") src.check_linking_requests() if ("dismiss") if (href_list["notification"]) var/datum/client_notification/a = locate(href_list["notification"]) if (a && isnull(a.gcDestroyed)) a.dismiss() if ("github") if (!config.githuburl) src << "Github URL not set in the config. Unable to open the site." else if (alert("This will open the issue tracker in your browser. Are you sure?",, "Yes", "No") == "Yes") src << link(config.githuburl) if ("forums") src.forum() if ("wiki") src.wiki() if ("webint") src.open_webint() if ("logie") if (config.sql_stats && href_list["ie_data"]) var/list/data = json_decode(href_list["ie_data"]) data["_ckey"] = src.ckey if (data.len != 7) return if (!establish_db_connection(dbcon)) return var/DBQuery/query = dbcon.NewQuery("INSERT INTO ss13_stats_ie (ckey, IsIE, IsEdge, EdgeHtmlVersion, TrueVersion, ActingVersion, CompatibilityMode, DateUpdated) VALUES (_ckey, _IsIE, _IsEdge, _EdgeHtmlVersion, _TrueVersion, _ActingVersion, _CompatibilityMode, NOW()) ON DUPLICATE KEY UPDATE IsIE = VALUES(IsIe), IsEdge = VALUES(IsEdge), EdgeHtmlVersion = VALUES(EdgeHtmlVersion), TrueVersion = VALUES(TrueVersion), ActingVersion = VALUES(ActingVersion), CompatibilityMode = VALUES(CompatibilityMode), DateUpdated = NOW()") query.Execute(data) if ("greeting") if (server_greeting) server_greeting.handle_call(href_list, src) return // Antag contest shit if (href_list["contest_action"] && config.antag_contest_enabled) src.process_contest_topic(href_list) return ..() //redirect to hsrc.() /client/proc/handle_spam_prevention(var/message, var/mute_type) if(config.automute_on && !holder && src.last_message == message) src.last_message_count++ if(src.last_message_count >= SPAM_TRIGGER_AUTOMUTE) src << "\red You have exceeded the spam filter limit for identical messages. An auto-mute was applied." cmd_admin_mute(src.mob, mute_type, 1) return 1 if(src.last_message_count >= SPAM_TRIGGER_WARNING) src << "\red You are nearing the spam filter limit for identical messages." return 0 else last_message = message src.last_message_count = 0 return 0 //This stops files larger than UPLOAD_LIMIT being sent from client to server via input(), client.Import() etc. /client/AllowUpload(filename, filelength) if(filelength > UPLOAD_LIMIT) src << "Error: AllowUpload(): File Upload too large. Upload Limit: [UPLOAD_LIMIT/1024]KiB." return 0 /* //Don't need this at the moment. But it's here if it's needed later. //Helps prevent multiple files being uploaded at once. Or right after eachother. var/time_to_wait = fileaccess_timer - world.time if(time_to_wait > 0) src << "Error: AllowUpload(): Spam prevention. Please wait [round(time_to_wait/10)] seconds." return 0 fileaccess_timer = world.time + FTPDELAY */ return 1 /////////// //CONNECT// /////////// /client/New(TopicData) TopicData = null //Prevent calls to client.Topic from connect if(!(connection in list("seeker", "web"))) //Invalid connection type. return null if(byond_version < MIN_CLIENT_VERSION) //Out of date client. return null if(!config.guests_allowed && IsGuestKey(key)) alert(src,"This server doesn't allow guest accounts to play. Please go to http://www.byond.com/ and register for a key.","Guest","OK") del(src) return // Change the way they should download resources. if(config.resource_urls) src.preload_rsc = pick(config.resource_urls) else src.preload_rsc = 1 // If config.resource_urls is not set, preload like normal. src << "\red If the title screen is black, resources are still downloading. Please be patient until the title screen appears." clients += src directory[ckey] = src //Admin Authorisation holder = admin_datums[ckey] if(holder) admins += src holder.owner = src log_client_to_db() //preferences datum - also holds some persistant data for the client (because we may as well keep these datums to a minimum) prefs = preferences_datums[ckey] if(!prefs) prefs = new /datum/preferences(src) preferences_datums[ckey] = prefs prefs.gather_notifications(src) prefs.last_ip = address //these are gonna be used for banning prefs.last_id = computer_id //these are gonna be used for banning . = ..() //calls mob.Login() if (byond_version < config.client_error_version) src << "Your version of BYOND is too old!" src << config.client_error_message src << "Your version: [byond_version]." src << "Required version: [config.client_error_version] or later." src << "Visit http://www.byond.com/download/ to get the latest version of BYOND." if (holder) src << "Admins get a free pass. However, please update your BYOND as soon as possible. Certain things may cause crashes if you play with your present version." else del(src) return 0 if( (world.address == address || !address) && !host ) host = key world.update_status() if(holder) add_admin_verbs() // Forcibly enable hardware-accelerated graphics, as we need them for the lighting overlays. // (but turn them off first, since sometimes BYOND doesn't turn them on properly otherwise) spawn(5) // And wait a half-second, since it sounds like you can do this too fast. if(src) winset(src, null, "command=\".configure graphics-hwmode off\"") sleep(2) // wait a bit more, possibly fixes hardware mode not re-activating right winset(src, null, "command=\".configure graphics-hwmode on\"") send_resources() nanomanager.send_resources(src) // Server greeting shenanigans. if (server_greeting.find_outdated_info(src, 1)) server_greeting.display_to_client(src) // Check code/modules/admin/verbs/antag-ooc.dm for definition add_aooc_if_necessary() ////////////// //DISCONNECT// ////////////// /client/Del() if(holder) holder.owner = null admins -= src directory -= ckey clients -= src return ..() // here because it's similar to below // Returns null if no DB connection can be established, or -1 if the requested key was not found in the database /proc/get_player_age(key) establish_db_connection(dbcon) if(!dbcon.IsConnected()) return null var/sql_ckey = sql_sanitize_text(ckey(key)) var/DBQuery/query = dbcon.NewQuery("SELECT datediff(Now(),firstseen) as age FROM ss13_player WHERE ckey = '[sql_ckey]'") query.Execute() if(query.NextRow()) return text2num(query.item[1]) else return -1 /client/proc/log_client_to_db() if ( IsGuestKey(src.key) ) return establish_db_connection(dbcon) if(!dbcon.IsConnected()) return var/sql_ckey = sql_sanitize_text(src.ckey) var/DBQuery/query = dbcon.NewQuery("SELECT id, datediff(Now(),firstseen) as age, whitelist_status, migration_status FROM ss13_player WHERE ckey = '[sql_ckey]'") query.Execute() var/sql_id = 0 player_age = 0 // New players won't have an entry so knowing we have a connection we set this to zero to be updated if their is a record. while(query.NextRow()) sql_id = query.item[1] player_age = text2num(query.item[2]) whitelist_status = text2num(query.item[3]) need_saves_migrated = text2num(query.item[4]) break var/DBQuery/query_ip = dbcon.NewQuery("SELECT ckey FROM ss13_player WHERE ip = '[address]'") query_ip.Execute() related_accounts_ip = "" while(query_ip.NextRow()) related_accounts_ip += "[query_ip.item[1]], " break var/DBQuery/query_cid = dbcon.NewQuery("SELECT ckey FROM ss13_player WHERE computerid = '[computer_id]'") query_cid.Execute() related_accounts_cid = "" while(query_cid.NextRow()) related_accounts_cid += "[query_cid.item[1]], " break //Just the standard check to see if it's actually a number if(sql_id) if(istext(sql_id)) sql_id = text2num(sql_id) if(!isnum(sql_id)) return var/admin_rank = "Player" if(src.holder) admin_rank = src.holder.rank var/sql_ip = sql_sanitize_text(src.address) var/sql_computerid = sql_sanitize_text(src.computer_id) var/sql_admin_rank = sql_sanitize_text(admin_rank) if(sql_id) //Player already identified previously, we need to just update the 'lastseen', 'ip' and 'computer_id' variables var/DBQuery/query_update = dbcon.NewQuery("UPDATE ss13_player SET lastseen = Now(), ip = '[sql_ip]', computerid = '[sql_computerid]', lastadminrank = '[sql_admin_rank]' WHERE id = [sql_id]") query_update.Execute() else //New player!! Need to insert all the stuff var/DBQuery/query_insert = dbcon.NewQuery("INSERT INTO ss13_player (id, ckey, firstseen, lastseen, ip, computerid, lastadminrank) VALUES (null, '[sql_ckey]', Now(), Now(), '[sql_ip]', '[sql_computerid]', '[sql_admin_rank]')") query_insert.Execute() //Logging player access var/serverip = "[world.internet_address]:[world.port]" var/DBQuery/query_accesslog = dbcon.NewQuery("INSERT INTO `ss13_connection_log`(`id`,`datetime`,`serverip`,`ckey`,`ip`,`computerid`) VALUES(null,Now(),'[serverip]','[sql_ckey]','[sql_ip]','[sql_computerid]');") query_accesslog.Execute() #undef TOPIC_SPAM_DELAY #undef UPLOAD_LIMIT #undef MIN_CLIENT_VERSION //checks if a client is afk //3000 frames = 5 minutes /client/proc/is_afk(duration=3000) if(inactivity > duration) return inactivity return 0 //send resources to the client. It's here in its own proc so we can move it around easiliy if need be /client/proc/send_resources() getFiles( 'html/search.js', 'html/panels.css', 'html/images/loading.gif', 'html/images/ntlogo.png', 'html/images/talisman.png', 'html/bootstrap/css/bootstrap.min.css', 'html/bootstrap/js/bootstrap.min.js', 'html/jquery/jquery-2.0.0.min.js', 'html/iestats/ie-truth.min.js', 'icons/pda_icons/pda_atmos.png', 'icons/pda_icons/pda_back.png', 'icons/pda_icons/pda_bell.png', 'icons/pda_icons/pda_blank.png', 'icons/pda_icons/pda_boom.png', 'icons/pda_icons/pda_bucket.png', 'icons/pda_icons/pda_crate.png', 'icons/pda_icons/pda_cuffs.png', 'icons/pda_icons/pda_eject.png', 'icons/pda_icons/pda_exit.png', 'icons/pda_icons/pda_flashlight.png', 'icons/pda_icons/pda_honk.png', 'icons/pda_icons/pda_mail.png', 'icons/pda_icons/pda_medical.png', 'icons/pda_icons/pda_menu.png', 'icons/pda_icons/pda_mule.png', 'icons/pda_icons/pda_notes.png', 'icons/pda_icons/pda_power.png', 'icons/pda_icons/pda_rdoor.png', 'icons/pda_icons/pda_reagent.png', 'icons/pda_icons/pda_refresh.png', 'icons/pda_icons/pda_scanner.png', 'icons/pda_icons/pda_signaler.png', 'icons/pda_icons/pda_status.png', 'icons/spideros_icons/sos_1.png', 'icons/spideros_icons/sos_2.png', 'icons/spideros_icons/sos_3.png', 'icons/spideros_icons/sos_4.png', 'icons/spideros_icons/sos_5.png', 'icons/spideros_icons/sos_6.png', 'icons/spideros_icons/sos_7.png', 'icons/spideros_icons/sos_8.png', 'icons/spideros_icons/sos_9.png', 'icons/spideros_icons/sos_10.png', 'icons/spideros_icons/sos_11.png', 'icons/spideros_icons/sos_12.png', 'icons/spideros_icons/sos_13.png', 'icons/spideros_icons/sos_14.png' ) /mob/proc/MayRespawn() return 0 /client/proc/MayRespawn() if(mob) return mob.MayRespawn() // Something went wrong, client is usually kicked or transfered to a new mob at this point return 0 //I honestly can't find a good place for this atm. //If the webint interaction gets more features, I'll move it. - Skull132 /client/verb/view_linking_requests() set name = "View Linking Requests" set category = "OOC" check_linking_requests() /client/proc/check_linking_requests() if (!config.webint_url || !config.sql_enabled) return establish_db_connection(dbcon) if (!dbcon.IsConnected()) return var/list/requests = list() var/list/query_details = list(":ckey" = ckey) var/DBQuery/select_query = dbcon.NewQuery("SELECT id, forum_id, forum_username, datediff(Now(), created_at) as request_age FROM ss13_player_linking WHERE status = 'new' AND player_ckey = :ckey AND deleted_at IS NULL") select_query.Execute(query_details) while (select_query.NextRow()) requests.Add(list(list("id" = text2num(select_query.item[1]), "forum_id" = text2num(select_query.item[2]), "forum_username" = select_query.item[3], "request_age" = select_query.item[4]))) if (!requests.len) return var/dat = "
You have active requests to check!
" var/i = 0 for (var/list/request in requests) i++ var/linked_forum_name = null if (config.forumurl) var/route_attributes = list2params(list("mode" = "viewprofile", "u" = request["forum_id"])) linked_forum_name = "[request["forum_username"]]" dat += "
" dat += "#[i] - Request to link your current key ([key]) to a forum account with the username of: [linked_forum_name ? linked_forum_name : request["forum_username"]].
" dat += "The request is [request["request_age"]] days old.
" dat += "OPTIONS: Accept Request | Deny Request" src << browse(dat, "window=LinkingRequests") return /client/proc/gather_linking_requests() if (!config.webint_url || !config.sql_enabled) return establish_db_connection(dbcon) if (!dbcon.IsConnected()) return var/DBQuery/select_query = dbcon.NewQuery("SELECT COUNT(*) AS request_count FROM ss13_player_linking WHERE status = 'new' AND player_ckey = :ckey AND deleted_at IS NULL") select_query.Execute(list(":ckey" = ckey)) if (select_query.NextRow()) if (text2num(select_query.item[1]) > 0) return "You have [select_query.item[1]] account linking requests pending review. Click here to see them!" return null /client/proc/process_webint_link(var/route, var/attributes) if (!route) return var/linkURL = "" switch (route) if ("forums/members") if (!webint_validate_attributes(list("mode", "u"), attributes_text = attributes)) return if (!config.forumurl) return linkURL = "[config.forumurl]memberlist.php?" linkURL += attributes if ("interface/user/link") if (!config.webint_url) return linkURL = "[config.webint_url]user/link" if ("interface/login/sso_server") //This also validates the attributes as it runs var/new_attributes = webint_start_singlesignon(src, attributes) if (!new_attributes) return if (!config.webint_url) return linkURL = "[config.webint_url]login/sso_server?" linkURL += new_attributes else log_debug("Unrecognized process_webint_link() call used. Route sent: '[route]'.") return src << link(linkURL) return /client/verb/show_greeting() set name = "Open Greeting" set category = "OOC" // Update the information just in case. server_greeting.find_outdated_info(src, 1) server_greeting.display_to_client(src)