--- @since 26.8.15
local M = {}

local function stale_cache(file)
	local url = file.url
	local stamp = url.spec.stamp:join(url:hash(true))

	local fd = fs.access():read(true):open(Url(stamp))
	if not fd then
		return true
	end

	local sig = fd:read(26)
	ya.drop(fd)
	return sig ~= file.cha:hash(true)
end

function M:fetch(job)
	return ya.co(function()
		local updates, unknown = {}, {}
		for _, file in ipairs(job.files) do
			if file.cha.is_dummy then
				coroutine.yield(file, {})
			elseif not file.cache then
				unknown[#unknown + 1] = file
			elseif not fs.cha(Url(file.cache)) then
				updates[file.url] = coroutine.yield(file, { "vfs/absent" }) and "vfs/absent" or nil
			elseif stale_cache(file) then
				updates[file.url] = coroutine.yield(file, { "vfs/stale" }) and "vfs/stale" or nil
			else
				unknown[#unknown + 1] = file
			end
		end

		if next(updates) then
			ya.emit("update_mimes", { updates = updates })
		end

		if #unknown > 0 then
			self.fallback_local(job, unknown)
		end
	end)
end

function M.fallback_local(job, unknown)
	local next = require(".local"):fetch(ya.dict_merge(job, { files = unknown }))
	local file, result = next()
	while file do
		file, result = next(coroutine.yield(file, result))
	end
end

return M