/////////////////////////////////////////////
// Chem smoke
/////////////////////////////////////////////

/obj/effect/particle_effect/chem_smoke
	icon = 'icons/goonstation/effects/64x64.dmi'
	icon_state = "smoke"
	density = FALSE
	opacity = FALSE
	layer = ABOVE_MOB_LAYER
	animate_movement = NO_STEPS
	var/matrix/first = matrix()
	var/matrix/second = matrix()
	var/matrix/third = matrix()
	var/first_scale = 0.1
	var/second_scale = 5
	var/third_scale = 2
	var/spread_amount = 96

/obj/effect/particle_effect/chem_smoke/New(location, chem_color)
	..(location)
	color = chem_color
	pixel_x += -16 + rand(-3, 3)
	pixel_y += -16 + rand(-3, 3)

	first = turn(first, rand(-90, 90))
	first.Scale(first_scale, first_scale)
	transform = first

	second = first
	second.Scale(second_scale, second_scale)

	third.Scale(third_scale, third_scale)

	animate(src,transform = second, time = 5, alpha = 200)
	animate(transform = third, time = 20, pixel_y = rand(-spread_amount, spread_amount), pixel_x = rand(-spread_amount, spread_amount), alpha = 1)
	QDEL_IN(src, 26)


/obj/effect/particle_effect/chem_smoke/small
	first_scale = 0.05
	second_scale = 2.5
	third_scale = 1
	spread_amount = 48


/datum/effect_system/smoke_spread/chem
	var/eff_range = 2
	var/eff_colour = "#12A5F4" // This is a random blue incase it doesnt get set right
	var/process_count = 0
	var/max_process_count = 50 //50 ticks, every 0.2 seconds, or 10 seconds of smoke.
	var/obj/chemholder
	var/list/smoked_atoms = list()

/datum/effect_system/smoke_spread/chem/New()
	..()
	chemholder = new
	chemholder.create_reagents(1000)
	chemholder.reagents.set_reacting(FALSE) // Just in case

/datum/effect_system/smoke_spread/chem/Destroy()
	QDEL_NULL(chemholder)
	smoked_atoms.Cut()
	return ..()

/datum/effect_system/smoke_spread/chem/set_up(datum/reagents/carry = null, loca, silent = FALSE)
	if(isturf(loca))
		location = loca
	else
		location = get_turf(loca)
	carry.copy_to(chemholder, carry.total_volume)
	carry.clear_reagents()
	if(!silent)
		var/contained = ""
		for(var/reagent in carry.reagent_list)
			contained += " [reagent] "
		if(contained)
			contained = "\[[contained]\]"
		var/area/A = get_area(location)

		var/where = "[A.name] | [location.x], [location.y]"
		var/whereLink = "<A href='byond://?_src_=holder;adminplayerobservecoodjump=1;X=[location.x];Y=[location.y];Z=[location.z]'>[where]</a>"

		if(carry && carry.my_atom)
			if(carry.my_atom.fingerprintslast)
				var/mob/M = get_mob_by_key(carry.my_atom.fingerprintslast)
				var/more = ""
				if(M)
					more = " "
				add_attack_logs(M, location, "Caused a chemical smoke reaction containing [contained]. Last associated key is [carry.my_atom.fingerprintslast][more]", ATKLOG_FEW)
				log_game("A chemical smoke reaction has taken place in ([where])[contained]. Last associated key is [carry.my_atom.fingerprintslast].")
			else
				msg_admin_attack("A chemical smoke reaction has taken place in ([whereLink])[contained]. No associated key.", ATKLOG_FEW)
				log_game("A chemical smoke reaction has taken place in ([where])[contained]. No associated key.")
		else
			msg_admin_attack("A chemical smoke reaction has taken place in ([whereLink])[contained]. No associated key. CODERS: carry.my_atom may be null.", ATKLOG_FEW)
			log_game("A chemical smoke reaction has taken place in ([where])[contained]. No associated key. CODERS: carry.my_atom may be null.")


/datum/effect_system/smoke_spread/chem/start(effect_range = 2)
	eff_colour = mix_color_from_reagents(chemholder.reagents.reagent_list)
	eff_range = effect_range
	START_PROCESSING(SSfastprocess, src)

/datum/effect_system/smoke_spread/chem/process()
	process_count++
	for(var/i in 1 to (2 * rand(2, 6))) // Every 0.2 seconds, create 4-12 smoke particles. This keeps it consitant with the 2-6 every 0.1 seconds before
		if(eff_range < 3)
			new /obj/effect/particle_effect/chem_smoke/small(location, eff_colour)
		else
			new /obj/effect/particle_effect/chem_smoke(location, eff_colour)
	if(process_count % 5 == 0) //Every 5 ssfastprocess, 10 ticks, or 1 second.
		INVOKE_ASYNC(src, PROC_REF(SmokeEm), eff_range)
	if(process_count > max_process_count)
		STOP_PROCESSING(SSfastprocess, src)
		qdel(src)


/datum/effect_system/smoke_spread/chem/proc/SmokeEm(effect_range = 2)
	for(var/atom/A in view(effect_range, get_turf(location)))
		if(istype(A, /obj/effect/particle_effect)) // Don't impact particle effects, as there can be hundreds of them in a small area. Also, we don't want smoke particles adding themselves to this list. Major performance issue.
			continue
		if(A in smoked_atoms)
			continue
		smoked_atoms += A
		chemholder.reagents.reaction(A)
		SEND_SIGNAL(A, COMSIG_ATOM_EXPOSE_REAGENTS, chemholder.reagents, chemholder, chemholder.reagents.total_volume)
		if(iscarbon(A))
			var/mob/living/carbon/C = A
			if(C.can_breathe_gas())
				chemholder.reagents.copy_to(C, chemholder.reagents.total_volume)

/datum/effect_system/smoke_spread/chem/plant

/datum/effect_system/smoke_spread/chem/plant/SmokeEm(effect_range)
	var/list/mobs_to_smoke = list()
	for(var/atom/A in view(effect_range, get_turf(location)))
		if(istype(A, /obj/effect/particle_effect)) // Don't impact particle effects, as there can be hundreds of them in a small area. Also, we don't want smoke particles adding themselves to this list. Major performance issue.
			continue
		if(A in smoked_atoms)
			continue
		smoked_atoms += A
		chemholder.reagents.reaction(A)
		SEND_SIGNAL(A, COMSIG_ATOM_EXPOSE_REAGENTS, chemholder.reagents, chemholder, chemholder.reagents.total_volume)
		if(iscarbon(A))
			mobs_to_smoke += A

	if(!length(mobs_to_smoke))
		return

	var/percentage_to_add = chemholder.reagents.total_volume / length(mobs_to_smoke)

	for(var/mob/living/carbon/smoker as anything in mobs_to_smoke)
		if(smoker.can_breathe_gas())
			chemholder.reagents.copy_to(smoker, percentage_to_add)