From 40a9eccc75f69f61494a0a6ad7b26f4fc35c0b25 Mon Sep 17 00:00:00 2001
From: qwreey74 <qwreey75@gmail.com>
Date: Fri, 17 Dec 2021 17:09:31 +0900
Subject: [PATCH] adding stire feature

---
 src/store.lua | 62 ++++++++++++++++++++++++++++++++++++++++++++++-----
 1 file changed, 57 insertions(+), 5 deletions(-)

diff --git a/src/store.lua b/src/store.lua
index 8ed6db3..94558a5 100644
--- a/src/store.lua
+++ b/src/store.lua
@@ -5,17 +5,25 @@ this feature allows get object without making some created callback and local va
 but, it can't allows mulit id and object
 this feature should be upgraded
 ]]
-
+local wrap = coroutine.wrap;
 local insert = table.insert;
 local remove = table.remove;
+
+local function catch(...)
+	local passed,err = pcall(...);
+	if not passed then
+		wran("[QUAD] Error occured while operating async task\n" .. tostring(err));
+	end
+end
+
 function module.init(shared)
 	local new = {};
 	local items = shared.items;
-
+	
 	local objSpace = {};
 	function objSpace:each(func)
 		for i,v in ipairs(self) do
-			coroutine.resume(coroutine.create(func),i,v);
+			wrap(catch)(func,i,v);
 		end
 	end
 	function objSpace:eachSync(func)
@@ -39,6 +47,15 @@ function module.init(shared)
 			end
 		end
 	end
+	function objSpace.__new()
+		return setmetatable({},objSpace);
+	end
+	function objSpace:__newIndex(key,value)
+		self:each(function (this)
+			this[key] = value;
+		end);
+	end
+	objSpace.__index = objSpace;
 
 	function new.getObjects(id)
 		return items[id];
@@ -47,16 +64,51 @@ function module.init(shared)
 		local item = items[id];
 		return item and item[1];
 	end
-	-- TODO: if item is exist already, ignore this call
+	--TODO: if item is exist already, ignore this call
 	function new.addObject(id,object)
 		local array = items[id];
 		if not array then
-			array = setmetatable({},{__index = objSpace});
+			array = objSpace.__new();
 			items[id] = array;
 		end
 		insert(array, object);
 	end
 
+	local store = {};
+	function store:__index(key)
+		self.__self[key];
+	end
+	function store:__newindex(key,value)
+		self.__self[key] = value;
+		local event = self.__evt[key];
+		if event then
+			for _,v in ipairs(event) do
+				wrap(catch)(v,value,store);
+			end
+		end
+	end
+	function store:__call(key,func)
+		local register = self.__reg[key];
+		if not register then
+			local event = {}
+			self.__evt[key] = event;
+			register = function (efunc)
+				insert(event,efunc);
+			end;
+			self.__reg[key] = register;
+		end
+	
+		if func then
+			register(func);
+		end
+		return {register,t="reg"};
+	end
+	function new.new()
+		return setmetatable(
+			{__self = {},__evt = {},__reg = {}},store
+		);
+	end
+
 	return new;
 end