--[=[
	Should be bound to any humanoid that is ragdollable. This class exports a [Binder].
	@server
	@class Ragdollable
]=]

local require = require(script.Parent.loader).load(script)

local RagdollableBase = require("RagdollableBase")
local Maid = require("Maid")
local Motor6DStackHumanoid = require("Motor6DStackHumanoid")
local PlayerHumanoidBinder = require("PlayerHumanoidBinder")
local Ragdoll = require("Ragdoll")
local RagdollAdditionalAttachmentUtils = require("RagdollAdditionalAttachmentUtils")
local RagdollBallSocketUtils = require("RagdollBallSocketUtils")
local RagdollCollisionUtils = require("RagdollCollisionUtils")
local RagdollMotorUtils = require("RagdollMotorUtils")
local RxBrioUtils = require("RxBrioUtils")
local RxRagdollUtils = require("RxRagdollUtils")
local RagdollableInterface = require("RagdollableInterface")
local Rx = require("Rx")

local Ragdollable = setmetatable({}, RagdollableBase)
Ragdollable.ClassName = "Ragdollable"
Ragdollable.__index = Ragdollable

--[=[
	Constructs a new Ragdollable. This class exports a [Binder].
	@param humanoid Humanoid
	@param serviceBag ServiceBag
	@return Ragdollable
]=]
function Ragdollable.new(humanoid, serviceBag)
	local self = setmetatable(RagdollableBase.new(humanoid), Ragdollable)

	self._serviceBag = assert(serviceBag, "No serviceBag")
	self._ragdollBinder = self._serviceBag:GetService(Ragdoll)

	Motor6DStackHumanoid:Tag(self._obj)

	-- Ensure predefined physics rig immediatelly on the server.
	-- We do this so during replication loop-back there's no chance of death.
	self._maid:GiveTask(RxBrioUtils.flatCombineLatest({
		character = RxRagdollUtils.observeCharacterBrio(self._obj);
		rigType = RxRagdollUtils.observeRigType(self._obj);
	}):Subscribe(function(state)
		if state.character and state.rigType then
			local maid = Maid.new()

			maid:GiveTask(RagdollAdditionalAttachmentUtils.ensureAdditionalAttachments(state.character, state.rigType))
			maid:GiveTask(RagdollBallSocketUtils.ensureBallSockets(state.character, state.rigType))
			maid:GiveTask(RagdollCollisionUtils.ensureNoCollides(state.character, state.rigType))

			-- Not super guarded against race conditions but it should be fine, as this is for debugging.
			RagdollMotorUtils.initMotorAttributes(state.character, state.rigType)

			self._maid._configure = maid
		else
			self._maid._configure = nil
		end
	end))

	self._maid:GiveTask(self._ragdollBinder:ObserveInstance(self._obj, function()
		self:_onRagdollChanged()
	end))
	self:_onRagdollChanged()

	self._maid:GiveTask(RagdollableInterface.Server:Implement(self._obj, self))

	return self
end

function Ragdollable:ObserveIsRagdolled()
	return self._ragdollBinder:Observe(self._obj):Pipe({
		Rx.map(function(value)
			return value and true or false
		end)
	})
end

function Ragdollable:_onRagdollChanged()
	if self._ragdollBinder:Get(self._obj) then
		self:_setRagdollEnabled(true)
	else
		self:_setRagdollEnabled(false)
	end
end

function Ragdollable:_setRagdollEnabled(isEnabled)
	if isEnabled then
		if self._maid._ragdoll then
			return
		end

		self._maid._ragdoll = RxRagdollUtils.runLocal(self._obj)
	else
		self._maid._ragdoll = nil
	end
end

return PlayerHumanoidBinder.new("Ragdollable", Ragdollable)