Finish basic effectset functionality
This commit is contained in:
parent
ddbe339b85
commit
3f259fb631
262
effect_set.lua
262
effect_set.lua
@ -33,9 +33,12 @@
|
||||
-- records. The ID table can instead be a simple map to records, since each
|
||||
-- effect can only have one ID.
|
||||
--
|
||||
-- Has a table uid_table that maps uids to records
|
||||
--
|
||||
-- Has a field "tables" that holds all the index tables.
|
||||
--
|
||||
-- Currently, it has index tables:
|
||||
--
|
||||
-- id_table (one-to-one)
|
||||
-- player_table (many-to-many)
|
||||
-- tag_table (many-to-many)
|
||||
-- monoid_table (many-to-many)
|
||||
@ -48,6 +51,10 @@
|
||||
--
|
||||
-- It also keeps track of the next unique ID in next_id
|
||||
--
|
||||
-- It also has two methods:
|
||||
--
|
||||
-- get(uid) - takes an effect id and returns the effect record if it exists
|
||||
-- effects() - iterator over the effect ids and effect records
|
||||
--
|
||||
-- Setmap
|
||||
--
|
||||
@ -55,6 +62,10 @@
|
||||
-- many-to-many and one-to-many relations.
|
||||
|
||||
|
||||
-- Version of db format
|
||||
local db_version
|
||||
|
||||
|
||||
-- Returns a set of results
|
||||
local function setmap_get(setmap, index)
|
||||
return setmap[index]
|
||||
@ -77,8 +88,7 @@ local function setmap_insert(setmap, indices, record)
|
||||
end
|
||||
|
||||
|
||||
local function setmap_delete(setmap, indices, record)
|
||||
local uid = record.uid
|
||||
local function setmap_delete(setmap, indices, uid)
|
||||
|
||||
for k, index in pairs(indices) do
|
||||
local set = setmap[index]
|
||||
@ -96,6 +106,88 @@ local function setmap_delete(setmap, indices, record)
|
||||
end
|
||||
|
||||
|
||||
-- Returns a new set that's the intersection of the two
|
||||
local function set_intersect(set1,set2)
|
||||
|
||||
local res_set = {}
|
||||
|
||||
for k, rec in pairs(set1) do
|
||||
if set2[k] then
|
||||
res_set[k] = rec
|
||||
end
|
||||
end
|
||||
|
||||
return res_set
|
||||
end
|
||||
|
||||
|
||||
-- Returns a new map, using the function to resolve conflicts
|
||||
local function map_intersect_with(f, set1, set2)
|
||||
|
||||
local res_map = {}
|
||||
|
||||
for k, v in pairs(set1) do
|
||||
local v2 = set2[k]
|
||||
|
||||
if v2 ~= nil then
|
||||
res_map[k] = f(v, v2)
|
||||
end
|
||||
end
|
||||
|
||||
return res_map
|
||||
end
|
||||
|
||||
|
||||
-- Returns a new setmap. Will be faster if you put the smaller one first.
|
||||
local function setmap_intersect(smap1, smap2)
|
||||
return map_intersect_with(set_intersect, smap1, smap2)
|
||||
end
|
||||
|
||||
|
||||
local function set_union(set1, set2)
|
||||
|
||||
local res_set = {}
|
||||
|
||||
for k, v in pairs(set1) do
|
||||
res_set[k] = v
|
||||
end
|
||||
|
||||
for k, v in pairs(set2) do
|
||||
res_set[k] = v
|
||||
end
|
||||
|
||||
return res_set
|
||||
end
|
||||
|
||||
|
||||
local function map_union_with(f, map1, map2)
|
||||
|
||||
local res_map = {}
|
||||
|
||||
for k, v in pairs(map1) do
|
||||
res_map[k] = v
|
||||
end
|
||||
|
||||
for k, v in pairs(map2) do
|
||||
local existing = res_map[k]
|
||||
|
||||
if (existing) then
|
||||
res_map[k] = f(existing, v)
|
||||
else
|
||||
res_map[k] = v
|
||||
end
|
||||
end
|
||||
|
||||
return res_map
|
||||
end
|
||||
|
||||
|
||||
-- Returns a new setmap. *I think* faster if the first is smaller.
|
||||
local function setmap_union(smap1, smap2)
|
||||
return map_union_with(set_union, smap1, smap2)
|
||||
end
|
||||
|
||||
|
||||
monoidal_effects.static = 1
|
||||
monoidal_effects.dynamic = 2
|
||||
|
||||
@ -115,11 +207,27 @@ local function record(id, dyn, effect_type, players, tags, monoids, dur, values)
|
||||
end
|
||||
|
||||
|
||||
local function is_perm(record)
|
||||
return record.duration == "perm"
|
||||
end
|
||||
|
||||
|
||||
local function shallow_copy(x)
|
||||
local res = {}
|
||||
|
||||
for k, v in pairs(x) do
|
||||
res[k] = v
|
||||
end
|
||||
|
||||
return res
|
||||
end
|
||||
|
||||
|
||||
-- Prepares for serialization.
|
||||
local function prep_record(record, cur_time)
|
||||
|
||||
-- Save the amount of time left
|
||||
if (record.duration ~= "perm") then
|
||||
if (not is_perm(record)) then
|
||||
record.duration = record.duration - (cur_time - record.time_started)
|
||||
end
|
||||
|
||||
@ -133,38 +241,146 @@ local function unprep_record(record, cur_time)
|
||||
end
|
||||
|
||||
|
||||
local function effect_set_get(eset, uid)
|
||||
return eset.uid_table[uid]
|
||||
end
|
||||
|
||||
|
||||
local function effect_set_effects(eset)
|
||||
return pairs(eset.uid_table)
|
||||
end
|
||||
|
||||
|
||||
local function add_methods(eset)
|
||||
eset.get = effect_set_get
|
||||
eset.effects = effect_set_effects
|
||||
eset.insert = insert_record
|
||||
eset.delete = delete_record
|
||||
eset.size = function(self)
|
||||
return #(self.uid_table)
|
||||
end
|
||||
end
|
||||
|
||||
|
||||
local function make_db()
|
||||
|
||||
local db = {}
|
||||
|
||||
db.version = db_version
|
||||
|
||||
db.next_id = 0
|
||||
|
||||
db.tables = {}
|
||||
|
||||
db.uid_table = {}
|
||||
db.player_table = {}
|
||||
db.tag_table = {}
|
||||
db.monoid_table = {}
|
||||
db.name_table = {}
|
||||
db.perm_table = {}
|
||||
db.tables.player_table = {}
|
||||
db.tables.tag_table = {}
|
||||
db.tables.monoid_table = {}
|
||||
db.tables.name_table = {}
|
||||
db.tables.perm_table = {}
|
||||
|
||||
add_methods(db)
|
||||
end
|
||||
|
||||
|
||||
-- Mutates the table to have the new record
|
||||
local function insert_record(db, record)
|
||||
local uid = record.uid
|
||||
|
||||
-- Mutates the DB to have the new record
|
||||
local function insert_record_with_uid(uid, db, record)
|
||||
db.uid_table[uid] = record
|
||||
setmap_insert(db.player_table, record.players, record)
|
||||
setmap_insert(db.tag_table, record.tags, record)
|
||||
setmap_insert(db.monoid_table, record.monoids, record)
|
||||
setmap_insert(db.name_table, {record.effect_type}, record)
|
||||
setmap_insert(db.tables.player_table, record.players, record)
|
||||
setmap_insert(db.tables.tag_table, record.tags, record)
|
||||
setmap_insert(db.tables.monoid_table, record.monoids, record)
|
||||
setmap_insert(db.tables.name_table, {record.effect_type}, record)
|
||||
|
||||
local perm
|
||||
local perm = is_perm(record)
|
||||
|
||||
setmap_insert(db.tables.name_table, {perm}, record)
|
||||
end
|
||||
|
||||
if (record.duration == "perm") then
|
||||
perm = true
|
||||
else
|
||||
perm = false
|
||||
|
||||
local function insert_record(db, record)
|
||||
local uid = db.next_id
|
||||
db.next_id = uid + 1
|
||||
|
||||
insert_record_with_uid(uid, db, record)
|
||||
end
|
||||
|
||||
|
||||
-- Mutates the DB to remove the record. Returns the deleted record, or nil if
|
||||
-- it was not found.
|
||||
local function delete_record(db, uid)
|
||||
local record = db.uid_table[uid]
|
||||
|
||||
if (record == nil) then return end
|
||||
|
||||
local players = record.players
|
||||
local tags = record.tags
|
||||
local monoids = record.monoids
|
||||
local effect_type = record.effect_type
|
||||
local perm = is_perm(record)
|
||||
|
||||
db.uid_table[uid] = nil
|
||||
|
||||
setmap_delete(db.tables.player_table, players, uid)
|
||||
setmap_delete(db.tables.tag_table, tags, uid)
|
||||
setmap_delete(db.tables.monoid_table, monoids, uid)
|
||||
setmap_delete(db.tables.name_table, {effect_type}, uid)
|
||||
setmap_delete(db.tables.perm_table, {perm}, uid)
|
||||
end
|
||||
|
||||
|
||||
local function serialize_effect_set(eset)
|
||||
local serialize_this = shallow_copy(eset.uid_table)
|
||||
|
||||
for k, v in pairs(uid_table) do
|
||||
prep_record(v)
|
||||
end
|
||||
|
||||
serialize_this.get = nil
|
||||
serialize_this.effects = nil
|
||||
serialize_this.tables = nil
|
||||
|
||||
return minetest.serialize(serialize_this)
|
||||
end
|
||||
|
||||
|
||||
local function deserialize_effect_set(str)
|
||||
local deserialized = minetest.deserialize(str)
|
||||
|
||||
for k, v in pairs(deserialized) do
|
||||
unprep_record(v)
|
||||
insert_record_with_uid(k, deserialized, v)
|
||||
end
|
||||
|
||||
setmap_insert(db.name_table, {perm}, record)
|
||||
add_methods(deserialized)
|
||||
|
||||
return deserialized
|
||||
end
|
||||
|
||||
|
||||
-- Mini namespace for effect sets
|
||||
local effectset = {}
|
||||
|
||||
effectset.new_set = make_db
|
||||
|
||||
effectset.intersect = function(es1, es2)
|
||||
local es = {}
|
||||
|
||||
es.uid_table = set_intersect(es1.uid_table, es2.uid_table)
|
||||
es.tables = map_intersect(setmap_intersect, es1.tables, es2.tables)
|
||||
|
||||
add_methods(es)
|
||||
return es
|
||||
end
|
||||
|
||||
effectset.union = function(es1, es2)
|
||||
local es = {}
|
||||
|
||||
es.uid_table = set_union(es1.uid_table, es2.uid_table)
|
||||
es.tables = map_intersect(setmap_union, es1.tables, es2.tables)
|
||||
|
||||
add_methods(es)
|
||||
return es
|
||||
end
|
||||
|
||||
|
||||
return effectset
|
||||
|
Loading…
x
Reference in New Issue
Block a user