mirror of
https://github.com/ParadiseSS13/Paradise.git
synced 2025-12-27 10:41:42 +00:00
d20298e996
This commit first and foremost ports the -tg- atom pooling system, and removes the old experimental system entirely. Secondly, this PR modifies the qdel system to use a -tg- lookalike "destroy hint" system, which means that individual objects can tell qdel what to do with them beyond taking care of things they need to delete. This ties into the atom pooling system via a new hint define, QDEL_HINT_PUTINPOOL, which will place the atom in the pool instead of deleting it as per standard. Emitter beams are now fully pooled. Qdel now has semi-compatibility with all datum types, however it is not the same as -tg-'s "Queue everything!" system. It simply passes it through the GC immediately and adds it to the "hard del" lists. This means that reagents can be qdel'ed, but there is no purpose as of yet, as it is more or less the same as just deleting them, with the added effect of adding logs of them being deleted to the garbage collector.
349 lines
9.7 KiB
Plaintext
349 lines
9.7 KiB
Plaintext
var/global/list/obj/machinery/message_server/message_servers = list()
|
|
|
|
/datum/data_pda_msg
|
|
var/recipient = "Unspecified" //name of the person
|
|
var/sender = "Unspecified" //name of the sender
|
|
var/message = "Blank" //transferred message
|
|
|
|
/datum/data_pda_msg/New(var/param_rec = "",var/param_sender = "",var/param_message = "")
|
|
|
|
if(param_rec)
|
|
recipient = param_rec
|
|
if(param_sender)
|
|
sender = param_sender
|
|
if(param_message)
|
|
message = param_message
|
|
|
|
/datum/data_rc_msg
|
|
var/rec_dpt = "Unspecified" //name of the person
|
|
var/send_dpt = "Unspecified" //name of the sender
|
|
var/message = "Blank" //transferred message
|
|
var/stamp = "Unstamped"
|
|
var/id_auth = "Unauthenticated"
|
|
var/priority = "Normal"
|
|
|
|
/datum/data_rc_msg/New(var/param_rec = "",var/param_sender = "",var/param_message = "",var/param_stamp = "",var/param_id_auth = "",var/param_priority)
|
|
if(param_rec)
|
|
rec_dpt = param_rec
|
|
if(param_sender)
|
|
send_dpt = param_sender
|
|
if(param_message)
|
|
message = param_message
|
|
if(param_stamp)
|
|
stamp = param_stamp
|
|
if(param_id_auth)
|
|
id_auth = param_id_auth
|
|
if(param_priority)
|
|
switch(param_priority)
|
|
if(1)
|
|
priority = "Normal"
|
|
if(2)
|
|
priority = "High"
|
|
if(3)
|
|
priority = "Extreme"
|
|
else
|
|
priority = "Undetermined"
|
|
|
|
/obj/machinery/message_server
|
|
icon = 'icons/obj/machines/research.dmi'
|
|
icon_state = "server"
|
|
name = "Messaging Server"
|
|
density = 1
|
|
anchored = 1.0
|
|
use_power = 1
|
|
idle_power_usage = 10
|
|
active_power_usage = 100
|
|
|
|
var/list/datum/data_pda_msg/pda_msgs = list()
|
|
var/list/datum/data_rc_msg/rc_msgs = list()
|
|
var/active = 1
|
|
var/decryptkey = "password"
|
|
|
|
/obj/machinery/message_server/New()
|
|
message_servers += src
|
|
decryptkey = GenerateKey()
|
|
send_pda_message("System Administrator", "system", "This is an automated message. The messaging system is functioning correctly.")
|
|
..()
|
|
return
|
|
|
|
/obj/machinery/message_server/Destroy()
|
|
message_servers -= src
|
|
return ..()
|
|
|
|
/obj/machinery/message_server/process()
|
|
//if(decryptkey == "password")
|
|
// decryptkey = generateKey()
|
|
if(active && (stat & (BROKEN|NOPOWER)))
|
|
active = 0
|
|
return
|
|
update_icon()
|
|
return
|
|
|
|
/obj/machinery/message_server/proc/send_pda_message(var/recipient = "",var/sender = "",var/message = "")
|
|
pda_msgs += new/datum/data_pda_msg(recipient,sender,message)
|
|
|
|
/obj/machinery/message_server/proc/send_rc_message(var/recipient = "",var/sender = "",var/message = "",var/stamp = "", var/id_auth = "", var/priority = 1)
|
|
rc_msgs += new/datum/data_rc_msg(recipient,sender,message,stamp,id_auth)
|
|
|
|
/obj/machinery/message_server/attack_hand(user as mob)
|
|
// user << "\blue There seem to be some parts missing from this server. They should arrive on the station in a few days, give or take a few CentCom delays."
|
|
user << "You toggle PDA message passing from [active ? "On" : "Off"] to [active ? "Off" : "On"]"
|
|
active = !active
|
|
update_icon()
|
|
|
|
return
|
|
|
|
/obj/machinery/message_server/update_icon()
|
|
if((stat & (BROKEN|NOPOWER)))
|
|
icon_state = "server-nopower"
|
|
else if (!active)
|
|
icon_state = "server-off"
|
|
else
|
|
icon_state = "server-on"
|
|
|
|
return
|
|
|
|
|
|
/datum/feedback_variable
|
|
var/variable
|
|
var/value
|
|
var/details
|
|
|
|
/datum/feedback_variable/New(var/param_variable,var/param_value = 0)
|
|
variable = param_variable
|
|
value = param_value
|
|
|
|
/datum/feedback_variable/proc/inc(var/num = 1)
|
|
if(isnum(value))
|
|
value += num
|
|
else
|
|
value = text2num(value)
|
|
if(isnum(value))
|
|
value += num
|
|
else
|
|
value = num
|
|
|
|
/datum/feedback_variable/proc/dec(var/num = 1)
|
|
if(isnum(value))
|
|
value -= num
|
|
else
|
|
value = text2num(value)
|
|
if(isnum(value))
|
|
value -= num
|
|
else
|
|
value = -num
|
|
|
|
/datum/feedback_variable/proc/set_value(var/num)
|
|
if(isnum(num))
|
|
value = num
|
|
|
|
/datum/feedback_variable/proc/get_value()
|
|
return value
|
|
|
|
/datum/feedback_variable/proc/get_variable()
|
|
return variable
|
|
|
|
/datum/feedback_variable/proc/set_details(var/text)
|
|
if(istext(text))
|
|
details = text
|
|
|
|
/datum/feedback_variable/proc/add_details(var/text)
|
|
if(istext(text))
|
|
if(!details)
|
|
details = text
|
|
else
|
|
details += " [text]"
|
|
|
|
/datum/feedback_variable/proc/get_details()
|
|
return details
|
|
|
|
/datum/feedback_variable/proc/get_parsed()
|
|
return list(variable,value,details)
|
|
|
|
var/obj/machinery/blackbox_recorder/blackbox
|
|
|
|
/obj/machinery/blackbox_recorder
|
|
icon = 'icons/obj/stationobjs.dmi'
|
|
icon_state = "blackbox"
|
|
name = "Blackbox Recorder"
|
|
density = 1
|
|
anchored = 1.0
|
|
use_power = 1
|
|
idle_power_usage = 10
|
|
active_power_usage = 100
|
|
var/list/messages = list() //Stores messages of non-standard frequencies
|
|
var/list/messages_admin = list()
|
|
|
|
var/list/msg_common = list()
|
|
var/list/msg_science = list()
|
|
var/list/msg_command = list()
|
|
var/list/msg_medical = list()
|
|
var/list/msg_engineering = list()
|
|
var/list/msg_security = list()
|
|
var/list/msg_deathsquad = list()
|
|
var/list/msg_syndicate = list()
|
|
var/list/msg_mining = list()
|
|
var/list/msg_cargo = list()
|
|
var/list/msg_service = list()
|
|
|
|
var/list/datum/feedback_variable/feedback = new()
|
|
|
|
//Only one can exsist in the world!
|
|
/obj/machinery/blackbox_recorder/New()
|
|
if(blackbox)
|
|
if(istype(blackbox,/obj/machinery/blackbox_recorder))
|
|
del(src)
|
|
blackbox = src
|
|
|
|
/obj/machinery/blackbox_recorder/Destroy()
|
|
var/turf/T = locate(1,1,2)
|
|
if(T)
|
|
blackbox = null
|
|
var/obj/machinery/blackbox_recorder/BR = new/obj/machinery/blackbox_recorder(T)
|
|
BR.msg_common = msg_common
|
|
BR.msg_science = msg_science
|
|
BR.msg_command = msg_command
|
|
BR.msg_medical = msg_medical
|
|
BR.msg_engineering = msg_engineering
|
|
BR.msg_security = msg_security
|
|
BR.msg_deathsquad = msg_deathsquad
|
|
BR.msg_syndicate = msg_syndicate
|
|
BR.msg_mining = msg_mining
|
|
BR.msg_cargo = msg_cargo
|
|
BR.msg_service = msg_service
|
|
BR.feedback = feedback
|
|
BR.messages = messages
|
|
BR.messages_admin = messages_admin
|
|
if(blackbox != BR)
|
|
blackbox = BR
|
|
return ..()
|
|
|
|
/obj/machinery/blackbox_recorder/proc/find_feedback_datum(var/variable)
|
|
for(var/datum/feedback_variable/FV in feedback)
|
|
if(FV.get_variable() == variable)
|
|
return FV
|
|
var/datum/feedback_variable/FV = new(variable)
|
|
feedback += FV
|
|
return FV
|
|
|
|
/obj/machinery/blackbox_recorder/proc/get_round_feedback()
|
|
return feedback
|
|
|
|
/obj/machinery/blackbox_recorder/proc/round_end_data_gathering()
|
|
|
|
var/pda_msg_amt = 0
|
|
var/rc_msg_amt = 0
|
|
|
|
for(var/obj/machinery/message_server/MS in machines)
|
|
if(MS.pda_msgs.len > pda_msg_amt)
|
|
pda_msg_amt = MS.pda_msgs.len
|
|
if(MS.rc_msgs.len > rc_msg_amt)
|
|
rc_msg_amt = MS.rc_msgs.len
|
|
|
|
feedback_set_details("radio_usage","")
|
|
|
|
feedback_add_details("radio_usage","COM-[msg_common.len]")
|
|
feedback_add_details("radio_usage","SCI-[msg_science.len]")
|
|
feedback_add_details("radio_usage","HEA-[msg_command.len]")
|
|
feedback_add_details("radio_usage","MED-[msg_medical.len]")
|
|
feedback_add_details("radio_usage","ENG-[msg_engineering.len]")
|
|
feedback_add_details("radio_usage","SEC-[msg_security.len]")
|
|
feedback_add_details("radio_usage","DTH-[msg_deathsquad.len]")
|
|
feedback_add_details("radio_usage","SYN-[msg_syndicate.len]")
|
|
feedback_add_details("radio_usage","MIN-[msg_mining.len]")
|
|
feedback_add_details("radio_usage","CAR-[msg_cargo.len]")
|
|
feedback_add_details("radio_usage","SRV-[msg_service.len]")
|
|
feedback_add_details("radio_usage","OTH-[messages.len]")
|
|
feedback_add_details("radio_usage","PDA-[pda_msg_amt]")
|
|
feedback_add_details("radio_usage","RC-[rc_msg_amt]")
|
|
|
|
|
|
feedback_set_details("round_end","[time2text(world.realtime)]") //This one MUST be the last one that gets set.
|
|
|
|
|
|
//This proc is only to be called at round end.
|
|
/obj/machinery/blackbox_recorder/proc/save_all_data_to_sql()
|
|
if(!feedback) return
|
|
|
|
round_end_data_gathering() //round_end time logging and some other data processing
|
|
establish_db_connection()
|
|
if(!dbcon.IsConnected()) return
|
|
var/round_id
|
|
|
|
var/DBQuery/query = dbcon.NewQuery("SELECT MAX(round_id) AS round_id FROM erro_feedback")
|
|
query.Execute()
|
|
while(query.NextRow())
|
|
round_id = query.item[1]
|
|
|
|
if(!isnum(round_id))
|
|
round_id = text2num(round_id)
|
|
round_id++
|
|
|
|
for(var/datum/feedback_variable/FV in feedback)
|
|
var/sql = "INSERT INTO erro_feedback VALUES (null, Now(), [round_id], \"[FV.get_variable()]\", [FV.get_value()], \"[FV.get_details()]\")"
|
|
var/DBQuery/query_insert = dbcon.NewQuery(sql)
|
|
query_insert.Execute()
|
|
|
|
// Sanitize inputs to avoid SQL injection attacks
|
|
proc/sql_sanitize_text(var/text)
|
|
text = replacetext(text, "'", "''")
|
|
text = replacetext(text, ";", "")
|
|
text = replacetext(text, "&", "")
|
|
return text
|
|
|
|
proc/feedback_set(var/variable,var/value)
|
|
if(!blackbox) return
|
|
|
|
variable = sql_sanitize_text(variable)
|
|
|
|
var/datum/feedback_variable/FV = blackbox.find_feedback_datum(variable)
|
|
|
|
if(!FV) return
|
|
|
|
FV.set_value(value)
|
|
|
|
proc/feedback_inc(var/variable,var/value)
|
|
if(!blackbox) return
|
|
|
|
variable = sql_sanitize_text(variable)
|
|
|
|
var/datum/feedback_variable/FV = blackbox.find_feedback_datum(variable)
|
|
|
|
if(!FV) return
|
|
|
|
FV.inc(value)
|
|
|
|
proc/feedback_dec(var/variable,var/value)
|
|
if(!blackbox) return
|
|
|
|
variable = sql_sanitize_text(variable)
|
|
|
|
var/datum/feedback_variable/FV = blackbox.find_feedback_datum(variable)
|
|
|
|
if(!FV) return
|
|
|
|
FV.dec(value)
|
|
|
|
proc/feedback_set_details(var/variable,var/details)
|
|
if(!blackbox) return
|
|
|
|
variable = sql_sanitize_text(variable)
|
|
details = sql_sanitize_text(details)
|
|
|
|
var/datum/feedback_variable/FV = blackbox.find_feedback_datum(variable)
|
|
|
|
if(!FV) return
|
|
|
|
FV.set_details(details)
|
|
|
|
proc/feedback_add_details(var/variable,var/details)
|
|
if(!blackbox) return
|
|
|
|
variable = sql_sanitize_text(variable)
|
|
details = sql_sanitize_text(details)
|
|
|
|
var/datum/feedback_variable/FV = blackbox.find_feedback_datum(variable)
|
|
|
|
if(!FV) return
|
|
|
|
FV.add_details(details) |