diff --git a/baystation12.dme b/baystation12.dme
index 821d43b85ec..0d083ef85af 100644
--- a/baystation12.dme
+++ b/baystation12.dme
@@ -1101,6 +1101,7 @@
 #include "code\WorkInProgress\Tastyfish\Eliza.dm"
 #include "code\WorkInProgress\Tastyfish\Eliza_Data.dm"
 #include "code\WorkInProgress\Tastyfish\livestock.dm"
+#include "code\WorkInProgress\Tastyfish\mainspipe.dm"
 #include "code\WorkInProgress\Tastyfish\paiLiza.dm"
 #include "code\WorkInProgress\Tastyfish\Parser.dm"
 #include "code\WorkInProgress\Tastyfish\wallmount_frame.dm"
diff --git a/code/WorkInProgress/Tastyfish/mainspipe.dm b/code/WorkInProgress/Tastyfish/mainspipe.dm
new file mode 100644
index 00000000000..3d320a4cab9
--- /dev/null
+++ b/code/WorkInProgress/Tastyfish/mainspipe.dm
@@ -0,0 +1,495 @@
+// internal pipe, don't actually place or use these
+obj/machinery/atmospherics/pipe/mains_component
+	var/obj/machinery/atmospherics/mains_pipe/parent_pipe
+	var/list/obj/machinery/atmospherics/pipe/mains_component/nodes = new()
+
+	New(loc)
+		..(loc)
+		parent_pipe = loc
+
+	check_pressure(pressure)
+		var/datum/gas_mixture/environment = loc.loc.return_air()
+
+		var/pressure_difference = pressure - environment.return_pressure()
+
+		if(pressure_difference > parent_pipe.maximum_pressure)
+			mains_burst()
+
+		else if(pressure_difference > parent_pipe.fatigue_pressure)
+			//TODO: leak to turf, doing pfshhhhh
+			if(prob(5))
+				mains_burst()
+
+		else return 1
+
+	pipeline_expansion()
+		return nodes
+
+	disconnect(obj/machinery/atmospherics/reference)
+		if(nodes.Find(reference))
+			nodes.Remove(reference)
+
+	proc/mains_burst()
+		parent_pipe.burst()
+
+obj/machinery/atmospherics/mains_pipe
+	icon = 'mainspipe.dmi'
+	layer = 2.4 //under wires with their 2.5
+
+	var/volume = 0
+	var/force = 20
+
+	var/alert_pressure = 80*ONE_ATMOSPHERE
+
+	var/initialize_mains_directions = 0
+
+	var/list/obj/machinery/atmospherics/mains_pipe/nodes = new()
+	var/obj/machinery/atmospherics/pipe/mains_component/supply
+	var/obj/machinery/atmospherics/pipe/mains_component/scrubbers
+	var/obj/machinery/atmospherics/pipe/mains_component/aux
+
+	var/minimum_temperature_difference = 300
+	var/thermal_conductivity = 0 //WALL_HEAT_TRANSFER_COEFFICIENT No
+
+	var/maximum_pressure = 70*ONE_ATMOSPHERE
+	var/fatigue_pressure = 55*ONE_ATMOSPHERE
+	alert_pressure = 55*ONE_ATMOSPHERE
+
+	New()
+		..()
+
+		supply = new(src)
+		supply.volume = volume
+		supply.nodes.len = nodes.len
+		scrubbers = new(src)
+		scrubbers.volume = volume
+		scrubbers.nodes.len = nodes.len
+		aux = new(src)
+		aux.volume = volume
+		aux.nodes.len = nodes.len
+
+	hide(var/i)
+		if(level == 1 && istype(loc, /turf/simulated))
+			invisibility = i ? 101 : 0
+		update_icon()
+
+	proc/burst()
+		..()
+		for(var/obj/machinery/atmospherics/pipe/mains_component/pipe in contents)
+			burst()
+
+	proc/check_pressure(pressure)
+		var/datum/gas_mixture/environment = loc.return_air()
+
+		var/pressure_difference = pressure - environment.return_pressure()
+
+		if(pressure_difference > maximum_pressure)
+			burst()
+
+		else if(pressure_difference > fatigue_pressure)
+			//TODO: leak to turf, doing pfshhhhh
+			if(prob(5))
+				burst()
+
+		else return 1
+
+	disconnect()
+		..()
+		for(var/obj/machinery/atmospherics/pipe/mains_component/node in nodes)
+			node.disconnect()
+
+	Del()
+		disconnect()
+		..()
+
+	initialize()
+		for(var/i = 1 to nodes.len)
+			var/obj/machinery/atmospherics/mains_pipe/node = nodes[i]
+			if(node)
+				supply.nodes[i] = node.supply
+				scrubbers.nodes[i] = node.scrubbers
+				aux.nodes[i] = node.aux
+
+obj/machinery/atmospherics/mains_pipe/simple
+	name = "mains pipe"
+	desc = "A one meter section of 3-line mains pipe"
+
+	dir = SOUTH
+	initialize_directions = SOUTH|NORTH
+
+	New()
+		nodes.len = 2
+		..()
+		switch(dir)
+			if(SOUTH || NORTH)
+				initialize_mains_directions = SOUTH|NORTH
+			if(EAST || WEST)
+				initialize_mains_directions = EAST|WEST
+			if(NORTHEAST)
+				initialize_mains_directions = NORTH|EAST
+			if(NORTHWEST)
+				initialize_mains_directions = NORTH|WEST
+			if(SOUTHEAST)
+				initialize_mains_directions = SOUTH|EAST
+			if(SOUTHWEST)
+				initialize_mains_directions = SOUTH|WEST
+
+	proc/normalize_dir()
+		if(dir==3)
+			dir = 1
+		else if(dir==12)
+			dir = 4
+
+	update_icon()
+		if(nodes[1] && nodes[2])
+			icon_state = "intact[invisibility ? "-f" : "" ]"
+
+			//var/node1_direction = get_dir(src, node1)
+			//var/node2_direction = get_dir(src, node2)
+
+			//dir = node1_direction|node2_direction
+
+		else
+			if(!nodes[1]&&!nodes[2])
+				del(src) //TODO: silent deleting looks weird
+			var/have_node1 = nodes[1]?1:0
+			var/have_node2 = nodes[2]?1:0
+			icon_state = "exposed[have_node1][have_node2][invisibility ? "-f" : "" ]"
+
+	initialize()
+		normalize_dir()
+		var/node1_dir
+		var/node2_dir
+
+		for(var/direction in cardinal)
+			if(direction&initialize_mains_directions)
+				if (!node1_dir)
+					node1_dir = direction
+				else if (!node2_dir)
+					node2_dir = direction
+
+		for(var/obj/machinery/atmospherics/mains_pipe/target in get_step(src,node1_dir))
+			if(target.initialize_mains_directions & get_dir(target,src))
+				nodes[1] = target
+				break
+		for(var/obj/machinery/atmospherics/mains_pipe/target in get_step(src,node2_dir))
+			if(target.initialize_mains_directions & get_dir(target,src))
+				nodes[2] = target
+				break
+
+		..() // initialize internal pipes
+
+		var/turf/T = src.loc			// hide if turf is not intact
+		hide(T.intact)
+		update_icon()
+
+	hidden
+		level = 1
+		icon_state = "intact-f"
+
+	visible
+		level = 2
+		icon_state = "intact"
+
+obj/machinery/atmospherics/mains_pipe/manifold
+	name = "manifold pipe"
+	desc = "A manifold composed of mains pipes"
+
+	dir = SOUTH
+	initialize_directions = EAST|NORTH|WEST
+	volume = 105
+
+	New()
+		nodes.len = 3
+		..()
+		initialize_mains_directions = (NORTH|SOUTH|EAST|WEST) & ~dir
+
+	initialize()
+		var/connect_directions = initialize_mains_directions
+
+		for(var/direction in cardinal)
+			if(direction&connect_directions)
+				for(var/obj/machinery/atmospherics/mains_pipe/target in get_step(src,direction))
+					if(target.initialize_mains_directions & get_dir(target,src))
+						nodes[1] = target
+						connect_directions &= ~direction
+						break
+				if (nodes[1])
+					break
+
+
+		for(var/direction in cardinal)
+			if(direction&connect_directions)
+				for(var/obj/machinery/atmospherics/mains_pipe/target in get_step(src,direction))
+					if(target.initialize_mains_directions & get_dir(target,src))
+						nodes[2] = target
+						connect_directions &= ~direction
+						break
+				if (nodes[2])
+					break
+
+
+		for(var/direction in cardinal)
+			if(direction&connect_directions)
+				for(var/obj/machinery/atmospherics/mains_pipe/target in get_step(src,direction))
+					if(target.initialize_mains_directions & get_dir(target,src))
+						nodes[3] = target
+						connect_directions &= ~direction
+						break
+				if (nodes[3])
+					break
+
+		..() // initialize internal pipes
+
+		var/turf/T = src.loc			// hide if turf is not intact
+		hide(T.intact)
+		update_icon()
+
+	update_icon()
+		icon_state = "manifold[invisibility ? "-f" : "" ]"
+
+	hidden
+		level = 1
+		icon_state = "manifold-f"
+
+	visible
+		level = 2
+		icon_state = "manifold"
+
+obj/machinery/atmospherics/mains_pipe/split
+	name = "mains splitter"
+	desc = "A splitter for connected to a single pipe off a mains."
+
+	var/obj/machinery/atmospherics/pipe/mains_component/split_node
+	var/obj/machinery/atmospherics/node3
+	var/icon_type
+
+	New()
+		nodes.len = 2
+		..()
+		initialize_mains_directions = turn(dir, 90) | turn(dir, -90)
+		initialize_directions = dir // actually have a normal connection too
+
+	initialize()
+		var/node1_dir
+		var/node2_dir
+		var/node3_dir
+
+		node1_dir = turn(dir, 90)
+		node2_dir = turn(dir, -90)
+		node3_dir = dir
+
+		for(var/obj/machinery/atmospherics/mains_pipe/target in get_step(src,node1_dir))
+			if(target.initialize_mains_directions & get_dir(target,src))
+				nodes[1] = target
+				break
+		for(var/obj/machinery/atmospherics/mains_pipe/target in get_step(src,node2_dir))
+			if(target.initialize_mains_directions & get_dir(target,src))
+				nodes[2] = target
+				break
+		for(var/obj/machinery/atmospherics/target in get_step(src,node3_dir))
+			if(target.initialize_directions & get_dir(target,src))
+				node3 = target
+				break
+
+		..() // initialize internal pipes
+
+		// bind them
+		spawn(5)
+			if(node3 && split_node)
+				var/datum/pipe_network/N1 = node3.return_network(src)
+				var/datum/pipe_network/N2 = split_node.return_network(split_node)
+				if(N1 && N2)
+					N1.merge(N2)
+
+		var/turf/T = src.loc			// hide if turf is not intact
+		hide(T.intact)
+		update_icon()
+
+	update_icon()
+		icon_state = "split-[icon_type][invisibility ? "-f" : "" ]"
+
+	return_network(A)
+		return split_node.return_network(A)
+
+	supply
+		icon_type = "supply"
+
+		New()
+			..()
+			split_node = supply
+
+		hidden
+			level = 1
+			icon_state = "split-supply-f"
+
+		visible
+			level = 2
+			icon_state = "split-supply"
+
+	scrubbers
+		icon_type = "scrubbers"
+
+		New()
+			..()
+			split_node = scrubbers
+
+		hidden
+			level = 1
+			icon_state = "split-scrubbers-f"
+
+		visible
+			level = 2
+			icon_state = "split-scrubbers"
+
+	aux
+		icon_type = "aux"
+
+		New()
+			..()
+			split_node = aux
+
+		hidden
+			level = 1
+			icon_state = "split-aux-f"
+
+		visible
+			level = 2
+			icon_state = "split-aux"
+
+obj/machinery/atmospherics/mains_pipe/cap
+	name = "pipe cap"
+	desc = "A cap for the end of a mains pipe"
+
+	dir = SOUTH
+	initialize_directions = SOUTH
+	volume = 35
+
+	New()
+		nodes.len = 1
+		..()
+		initialize_mains_directions = dir
+
+	update_icon()
+		icon_state = "cap[invisibility ? "-f" : ""]"
+
+	initialize()
+		for(var/obj/machinery/atmospherics/mains_pipe/target in get_step(src,dir))
+			if(target.initialize_mains_directions & get_dir(target,src))
+				nodes[1] = target
+				break
+
+		..()
+
+		var/turf/T = src.loc	// hide if turf is not intact
+		hide(T.intact)
+		update_icon()
+
+	hidden
+		level = 1
+		icon_state = "cap-f"
+
+	visible
+		level = 2
+		icon_state = "cap"
+
+obj/machinery/atmospherics/mains_pipe/valve
+	icon_state = "mvalve0"
+
+	name = "mains shutoff valve"
+	desc = "A mains pipe valve"
+
+	var/open = 1
+
+	dir = SOUTH
+	initialize_mains_directions = SOUTH|NORTH
+
+	New()
+		nodes.len = 2
+		..()
+		initialize_mains_directions = dir | turn(dir, 180)
+
+	update_icon(animation)
+		var/turf/simulated/floor = loc
+		var/hide = istype(floor) ? floor.intact : 0
+		level = 1
+		for(var/obj/machinery/atmospherics/mains_pipe/node in nodes)
+			if(node.level == 2)
+				hide = 0
+				level = 2
+				break
+
+		if(animation)
+			flick("[hide?"h":""]mvalve[src.open][!src.open]",src)
+		else
+			icon_state = "[hide?"h":""]mvalve[open]"
+
+	initialize()
+		normalize_dir()
+		var/node1_dir
+		var/node2_dir
+
+		for(var/direction in cardinal)
+			if(direction&initialize_mains_directions)
+				if (!node1_dir)
+					node1_dir = direction
+				else if (!node2_dir)
+					node2_dir = direction
+
+		for(var/obj/machinery/atmospherics/mains_pipe/target in get_step(src,node1_dir))
+			if(target.initialize_mains_directions & get_dir(target,src))
+				nodes[1] = target
+				break
+		for(var/obj/machinery/atmospherics/mains_pipe/target in get_step(src,node2_dir))
+			if(target.initialize_mains_directions & get_dir(target,src))
+				nodes[2] = target
+				break
+
+		if(open)
+			..() // initialize internal pipes
+
+		update_icon()
+
+	proc/normalize_dir()
+		if(dir==3)
+			dir = 1
+		else if(dir==12)
+			dir = 4
+
+	proc/open()
+		if(open) return 0
+
+		open = 1
+		update_icon()
+
+		initialize()
+
+		return 1
+
+	proc/close()
+		if(!open) return 0
+
+		open = 0
+		update_icon()
+
+		for(var/obj/machinery/atmospherics/pipe/mains_component/node in src)
+			for(var/obj/machinery/atmospherics/pipe/mains_component/o in node.nodes)
+				o.disconnect(node)
+				o.build_network()
+
+		return 1
+
+	attack_ai(mob/user as mob)
+		return
+
+	attack_paw(mob/user as mob)
+		return attack_hand(user)
+
+	attack_hand(mob/user as mob)
+		src.add_fingerprint(usr)
+		update_icon(1)
+		sleep(10)
+		if (open)
+			close()
+		else
+			open()
\ No newline at end of file
diff --git a/icons/obj/atmospherics/mainspipe.dmi b/icons/obj/atmospherics/mainspipe.dmi
new file mode 100644
index 00000000000..efcc9f271a8
Binary files /dev/null and b/icons/obj/atmospherics/mainspipe.dmi differ