Bubberstation/code/controllers/subsystem/market.dm

SUBSYSTEM_DEF(market)
	name = "Market"
	ss_flags = SS_BACKGROUND
	dependencies = list(
		/datum/controller/subsystem/atoms,
	)

	/// Descriptions for each shipping methods.
	var/shipping_method_descriptions = list(
		SHIPPING_METHOD_LAUNCH = "Launches the item at the station from space, with free shipping! However, you'll need to risk a spacewalk to receive your goods.",
		SHIPPING_METHOD_LTSRBT = "Long-To-Short-Range-Bluespace-Transceiver, a machine that receives items outside the station and then teleports them to the location of the uplink.",
		SHIPPING_METHOD_TELEPORT = "Teleports the item in a random area in the station, you get 60 seconds to get there first though.",
		SHIPPING_METHOD_SUPPLYPOD = "Ships the item inside a supply pod at your exact location. Showy, speedy and expensive.",
	)

	/// List of all existing markets.
	var/list/datum/market/markets = list()
	/// List of existing ltsrbts.
	var/list/obj/machinery/ltsrbt/telepads = list()
	/// Currently queued purchases.
	var/list/queued_purchases = list()
	/// How many admin items have been spawned this round? Used to iterate the identifier of admin-created market items.
	var/admin_items_spawned = 0

/datum/controller/subsystem/market/Initialize()
	for(var/market in subtypesof(/datum/market))
		markets[market] += new market

	for(var/path in subtypesof(/datum/market_item))
		initialize_item(path)

	return SS_INIT_SUCCESS

/**
 * Follows the standard process for adding an item to the market from a path.
 * @param path The path of the market datum to initialize and add to the market.
 * @param market_whitelist A list of markets to which the item should be added. If null, the item is added to all markets.
 */
/datum/controller/subsystem/market/proc/initialize_item(datum/market_item/path, list/market_whitelist)
	if(!path::item || !prob(path::availability_prob))
		return
	var/datum/market_item/item_instance = new path()
	for(var/potential_market in item_instance.markets)
		if(!markets[potential_market])
			stack_trace("SSmarket: Item [item_instance] available in market that does not exist.")
			continue
		if(isnull(market_whitelist) || (potential_market in market_whitelist))
			markets[potential_market].add_item(item_instance)

/**
 * Adds an admin polled item to the market, expecting a market_item object having been created.
 */
/datum/controller/subsystem/market/proc/initialize_admin_item(datum/market_item/item_instance, list/market_whitelist)
	if(!item_instance)
		return
	for(var/potential_market in item_instance.markets)
		if(!markets[potential_market])
			stack_trace("SSmarket: Item [item_instance] available in market that does not exist.")
			continue
		if(isnull(market_whitelist) || (potential_market in market_whitelist))
			markets[potential_market].add_item(item_instance)

/datum/controller/subsystem/market/fire(resumed)
	while(length(queued_purchases))
		var/datum/market_purchase/purchase = queued_purchases[1]
		queued_purchases.Cut(1,2)

		var/mob/buyer = recursive_loc_check(purchase.uplink.loc, /mob)

		switch(purchase.method)
			// Find a ltsrbt pad and make it handle the shipping.
			if(SHIPPING_METHOD_LTSRBT)
				if(!length(telepads))
					continue
				// Prioritize pads that don't have a cooldown active.
				var/obj/machinery/ltsrbt/lowest_cd_pad
				// The time left of the shortest cooldown amongst all telepads.
				var/lowest_timeleft = INFINITY
				for(var/obj/machinery/ltsrbt/pad as anything in telepads)
					if(!COOLDOWN_FINISHED(pad, recharge_cooldown) || (pad.machine_stat & NOPOWER))
						var/timeleft = pad.machine_stat & NOPOWER ? INFINITY - 1 : COOLDOWN_TIMELEFT(pad, recharge_cooldown)
						if(timeleft <= lowest_timeleft)
							lowest_cd_pad = pad
							lowest_timeleft = timeleft
						continue
					lowest_cd_pad = pad
					break

				lowest_cd_pad.add_to_queue(purchase)

				to_chat(buyer, span_notice("[purchase.uplink] flashes a message noting that the order is being processed by [lowest_cd_pad]."))

			// Get random area, throw it somewhere there.
			if(SHIPPING_METHOD_TELEPORT)
				var/turf/targetturf = get_safe_random_station_turf_equal_weight() //todo: split weights
				// This shouldn't happen.
				if (!targetturf)
					continue
				queued_purchases -= purchase

				to_chat(buyer, span_notice("[purchase.uplink] flashes a message noting that the order is being teleported to [get_area(targetturf)] in 60 seconds."))

				// do_teleport does not want to teleport items from nullspace, so it just forceMoves and does sparks.
				addtimer(CALLBACK(src, TYPE_PROC_REF(/datum/controller/subsystem/market, fake_teleport), purchase, targetturf), 60 SECONDS)

			// Get the current location of the uplink if it exists, then throws the item from space at the station from a random direction.
			if(SHIPPING_METHOD_LAUNCH)
				var/startSide = pick(GLOB.cardinals)
				var/turf/T = get_turf(purchase.uplink)
				var/pickedloc = spaceDebrisStartLoc(startSide, T.z)
				var/obj/delivery_pod = new /obj/structure/closet/crate/market(pickedloc)

				var/atom/movable/item = purchase.entry.spawn_item(delivery_pod, purchase)
				purchase.post_purchase_effects(item)
				delivery_pod.throw_at(purchase.uplink, 3, 3, spin = FALSE)

				to_chat(buyer, span_notice("[purchase.uplink] flashes a message noting the order is being launched at the station from [dir2text(startSide)]."))
				qdel(purchase)

			if(SHIPPING_METHOD_SUPPLYPOD)
				var/obj/structure/closet/supplypod/spawned_pod = podspawn(list(
					"target" = get_turf(purchase.uplink),
					"path" = /obj/structure/closet/supplypod/back_to_station,
				))
				purchase.entry.spawn_item(spawned_pod, purchase)

				to_chat(buyer, span_notice("[purchase.uplink] flashes a message noting the order is being launched at your location. Right here, right now!"))
				qdel(purchase)

		if(MC_TICK_CHECK)
			break

/// Used to make a teleportation effect as do_teleport does not like moving items from nullspace.
/datum/controller/subsystem/market/proc/fake_teleport(datum/market_purchase/purchase, turf/target)
	// Oopsie, whoopsie, the item is gone. So long, and thanks for all the money.
	if(QDELETED(purchase))
		return
	var/atom/movable/thing = purchase.entry.spawn_item(target, purchase)
	purchase.post_purchase_effects(thing)
	do_sparks(5, TRUE, target)
	qdel(purchase)

/// Used to add /datum/market_purchase to queued_purchases var. Returns TRUE when queued.
/datum/controller/subsystem/market/proc/queue_item(datum/market_purchase/purchase)
	if((purchase.method == SHIPPING_METHOD_LTSRBT && !telepads.len) || isnull(purchase.uplink))
		qdel(purchase)
		return FALSE
	queued_purchases += purchase
	return TRUE

///A proc that restocks one or more markets, or all if the market_whitelist is null.
/datum/controller/subsystem/market/proc/restock(list/market_whitelist)
	var/market_name = "Markets"
	if(market_whitelist && !islist(market_whitelist))
		var/datum/market/market_path = market_whitelist
		market_name = market_path::name
		market_whitelist = list(market_path)

	var/list/existing_types = list()
	for(var/path in markets)
		if(isnull(market_whitelist) || (path in market_whitelist))
			markets[path].restock(existing_types)

	for(var/datum/market_item/path as anything in (subtypesof(/datum/market_item) - existing_types))
		if(!path::restockable)
			continue
		initialize_item(path, market_whitelist)

	for(var/obj/machinery/ltsrbt/pad as anything in telepads)
		pad.say("[market_name] restocked!")
		playsound(src, 'sound/effects/cashregister.ogg', 40, FALSE)