path: root/honey/ecs/ecs.lua

math.randomseed(os.time())

local testing, glm = pcall(require, 'honey.glm')

local module = {}
setmetatable(module, {__index=_G})
setfenv(1, module)


--===== EntityDb =====--


-- EntityDb is a database of entities and their associated components
-- it should be quite efficient to query for all entities with a given component, and reasonably
-- efficient to query for all components of a given entity


EntityDb = {}
EntityDb.__index = EntityDb


function EntityDb.new(_)
	local self = {
		entities = {},
		components = {},
	}
	setmetatable(self, EntityDb)
	return self
end
setmetatable(EntityDb, {__call=EntityDb.new})


local function serialize(tbl)
	local tostr = function(x, value)
		if type(x) == "table" then
			if x.__tostring then
				return tostring(x)
			else
				return serialize(x)
			end
		elseif type(x) == "string" then
			if value then
				return string.format("\"%s\"", x)
			else
				return x
			end
		else
			return tostring(x)
		end
	end
	local str = "{"
	for key, value in pairs(tbl) do
		if type(key) == "string" and string.match(key, "^_") then
			-- ignore keys starting with an underscore
		else
			str = str .. string.format("%s=%s,", tostr(key), tostr(value, true))
		end
	end
	str = string.sub(str, 1, -2) .. "}"
	return str
end


-- save current database to file
function EntityDb.save(self, filename)
	local file, err = io.open(filename, "w")
	if not file then error(err) end

	for entity in pairs(self.entities) do
		local components = self:queryEntity(entity)
		file:write(string.format("Entity(\"%s\", %s)\n", entity, serialize(components)))
	end

	file:close()
end


-- load database from file
function EntityDb.load(self, filename)
	print(collectgarbage("count"))
	self.entities = {}
	self.components = {}
	collectgarbage()
	print(collectgarbage("count"))
	local env = {
		Entity = function(id, components)
			self:createEntity(id)
			self:addComponents(id, components)
		end,
	}
	if not testing then
		env.Vec3 = glm.Vec3
		env.Mat4 = glm.Mat4
	end
	local f, err = loadfile(filename)
	if not f then error(err) end
	setfenv(f, env)
	f()
end


-- check if a given entity id is legitimate
function EntityDb.checkIsValid(self, id)
	if not self.entities[id] then
		error(string.format("invalid entity id: %s", tostring(id)))
	end
end


local random = math.random
local function uuid()
	local template ='xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'
	return string.gsub(template, '[xy]', function (c)
		local v = (c == 'x') and random(0, 0xf) or random(8, 0xb)
		return string.format('%x', v)
	end)
end


-- create a new entity
function EntityDb.createEntity(self, id)
	local id = id or uuid() -- allow inserting entities at preset ids for loading
	self.entities[id] = true
	return id
end


-- add a component to an entity
function EntityDb.addComponent(self, id, name, value)
	self:checkIsValid(id)
	
	-- create the relevant component table if it doesn't exist
	if not self.components[name] then
		self.components[name] = { count=0, data={} }
	end

	local component = self.components[name]
	component.data[id] = value
	component.count = component.count + 1
end


-- add multiple components at once, for convenience
function EntityDb.addComponents(self, id, components)
	for name, value in pairs(components) do
		self:addComponent(id, name, value)
	end
end


-- create an entity with components
function EntityDb.createEntityWithComponents(self, components)
	local id = self:createEntity()
	self:addComponents(id, components)
	return id
end


-- get all entities with a given component
function EntityDb.queryComponent(self, name)
	local component = self.components[name]
	if component then 
		return component.data
	else
		return {}
	end
end


-- get all components associated with an entity
function EntityDb.queryEntity(self, id)
	self:checkIsValid(id)
	local query = {}
	for name, component in pairs(self.components) do
		query[name] = component.data[id]
	end
	return query
end


-- get a specific component from an entity
function EntityDb.getComponent(self, id, name)
	self:checkIsValid(id)
	local components = self.components[name]
	if not components then return nil end
	return components.data[id]
end


-- remove a component from an entity
function EntityDb.removeComponent(self, id, name)
	self:checkIsValid(id)
	local component = self.components[name]
	if component.data[id] ~= nil then
		component.data[id] = nil
		component.count = component.count - 1
		if component.count == 0 then
			self.components[name] = nil
		end
	end
end


-- remove an entity from the db
function EntityDb.deleteEntity(self, id)
	self:checkIsValid(id)
	for name in pairs(self.components) do
		self:removeComponent(id, name)
	end
	self.entities[id] = nil
end


--===== Systems =====--

System = {}
System.__index = System

function System.new(_, name, f)
	local self = {
		name = name,
		f = f,
		dependencies = {},
	}
	setmetatable(self, System)
	return self
end
setmetatable(System, {__call=System.new})

function System.addDependency(self, system)
	self.dependencies[system.name] = true
	return self
end

function System.addDependencies(self, systems)
	for _, system in ipairs(systems) do
		self:addDependency(system)
	end
	return self
end


--===== SystemDb =====--

SystemDb = {}
SystemDb.__index = SystemDb


function SystemDb.new(_, entityDb)
	local self = {
		systems = {},
		params = {},
		sort = {},
		dangling = {},
		entityDb = entityDb,
	}
	setmetatable(self, SystemDb)
	return self
end
setmetatable(SystemDb, {__call=SystemDb.new})


-- depth-first topological sort
-- thank god for wikipedia
local function tsort(systems)
	local graph = {}
	local count = 0
	for _, system in pairs(systems) do
		graph[system.name] = { name=system.name, dependencies=system.dependencies, tmark=false, pmark=false }
		count = count+1
	end

	local sort = {}
	local dangling = {}

	local visit
	visit = function(node)
		if node == nil then
			-- dangling dependency, ignore for now
			return true
		end
		if node.pmark then return false end
		if node.tmark then error("dependency cycle detected") end

		node.tmark = true

		for name in pairs(node.dependencies) do
			local dangle = visit(graph[name])
			if dangle then
				dangling[name] = true
			end
		end

		node.tmark = false
		node.pmark = true
		count = count-1
		table.insert(sort, node.name)
	end

	for _, node in pairs(graph) do
		visit(node)
		if count == 0 then break end
	end

	return sort, dangling
end


function SystemDb.addSystems(self, systems, params)
	for _, system in ipairs(systems) do
		self.systems[system.name] = system
		self.params[system.name] = params
	end
	self.sort, self.dangling = tsort(self.systems)
	return self
end


function SystemDb.update(self, dt)
	-- check for dangling dependencies
	local dangle = ""
	for dependency in pairs(self.dangling) do
		print(dependency)
		dangle = dangle .. string.format(
			"unresolved dangling dependency: %s\n",
			dependency
		)
	end
	if dangle ~= "" then
		error(dangle)
	end


	for _, name in ipairs(self.sort) do
		local system = self.systems[name]
		local params = self.params[name]
		system.f(self.db, dt, params)
	end
end


function SystemDb.removeSystems(self, systems)
	for _, system in pairs(systems) do
		self.systems[system.name] = nil
	end
	self.sort, self.dangling = tsort(self.systems)
end


--===== Access helper =====--


function Accessor(db, id)
	local tbl = {
		__db = db,
		__id = id,
	}

	setmetatable(tbl, {
		__index=function(self, key)
			return self.__db:getComponent(self.__id, key)
		end,
		__newindex=function(self, key, value)
			self.__db:addComponent(self.__id, key, value)
		end,
		__tostring=function(self)
			return string.format("Accessor<%s>", self.__id)
		end,
	})

	return tbl
end


return module