1 files changed, 146 insertions, 0 deletions
diff --git a/src/lua/modules/time/je_lua_timer.cpp b/src/lua/modules/time/je_lua_timer.cpp
new file mode 100644
index 0000000..540f205
--- /dev/null
+++ b/src/lua/modules/time/je_lua_timer.cpp
@@ -0,0 +1,146 @@
+
+#include "lua/common/je_lua_callback.h"
+#include "lua/common/je_lua_common.h"
+#include "je_lua_timer.h"
+
+using namespace JinEngine::Time;
+
+namespace JinEngine
+{
+    namespace Lua
+    {
+
+        const char* Jin_Lua_Timer = "Timer";
+
+        const char* Jin_Lua_Handler = "Handler";
+
+        typedef Shared<Timer>& SharedTimer;
+
+        static Timer::TimerCallback timerCallback = [](void* data)->void 
+        {                           
+            LuaCallback* func = static_cast<LuaCallback*>(data); 
+            func->call();                                
+        };
+
+        static Timer::FinishCallback finishCallback = [](void* data)->void 
+        {                          
+            LuaCallback* func = static_cast<LuaCallback*>(data); 
+            delete func;                                 
+        };
+
+        LUA_IMPLEMENT inline SharedTimer checkTimer(lua_State* L)
+        {
+            Proxy* proxy = (Proxy*)luax_checktype(L, 1, Jin_Lua_Timer);
+            return proxy->getShared<Timer>();
+        }
+
+        // timer:every(time, callback, parameter)
+        LUA_IMPLEMENT int l_every(lua_State* L)
+        {
+            int n = luax_gettop(L);
+            SharedTimer shared = checkTimer(L);
+            Timer* timer = shared.getObject();
+            float s = luax_checknumber(L, 2);
+            LuaCallback* func = new LuaCallback(L);
+            func->setFunc(3);
+            for(int i = 4; i <= n; ++i)
+                func->pushParam(i);
+            Timer::Handler* handler = timer->every(s, timerCallback, func, finishCallback);
+            Proxy* proxy = luax_newinstance(L, Jin_Lua_Handler);
+            Shared<Timer::Handler>* shrHandler = new Shared<Timer::Handler>(handler, Jin_Lua_Handler);
+            shrHandler->retain();
+            proxy->bind(shrHandler);
+            return 1;
+        }
+
+        // timer:after(time, callback, parameter)
+        LUA_IMPLEMENT int l_after(lua_State* L)
+        {
+            int n = luax_gettop(L);
+            SharedTimer shared = checkTimer(L);
+            Timer* timer = shared.getObject();
+            float s = luax_checknumber(L, 2);
+            LuaCallback* func = new LuaCallback(L);
+            func->setFunc(3);
+            for (int i = 4; i <= n; ++i)
+                func->pushParam(i);
+            Timer::Handler* handler = timer->after(s, timerCallback, func, finishCallback);
+            Proxy* proxy = luax_newinstance(L, Jin_Lua_Handler);
+            Shared<Timer::Handler>* shrHandler = new Shared<Timer::Handler>(handler, Jin_Lua_Handler);
+            shrHandler->retain();
+            proxy->bind(shrHandler);
+            return 1;
+        }
+
+        // timer:repeat(time, callback, parameter)
+        LUA_IMPLEMENT int l_repeat(lua_State* L)
+        {
+            int n = luax_gettop(L);
+            SharedTimer shared = checkTimer(L);
+            Timer* timer = shared.getObject();
+            float s = luax_checknumber(L, 2);
+            int count = luax_checkinteger(L, 3);
+            LuaCallback* func = new LuaCallback(L);
+            func->setFunc(4);
+            for (int i = 5; i <= n; ++i)
+                func->pushParam(i);
+            Timer::Handler* handler = timer->repeat(s, count, timerCallback, func, finishCallback);
+            Proxy* proxy = luax_newinstance(L, Jin_Lua_Handler);
+            Shared<Timer::Handler>* shrHandler = new Shared<Timer::Handler>(handler, Jin_Lua_Handler);
+            shrHandler->retain();
+            proxy->bind(shrHandler);
+            return 1;
+        }
+
+        LUA_IMPLEMENT int l_update(lua_State* L)
+        {
+            SharedTimer shared = checkTimer(L);
+            Timer* timer = shared.getObject();
+            float s = luax_checknumber(L, 2);
+            timer->update(s);
+            return 0;
+        }
+
+        LUA_IMPLEMENT int l_cancel(lua_State* L)
+        {
+            Proxy* p = (Proxy*)luax_checktype(L, 1, Jin_Lua_Timer);
+            Timer* timer = p->getObject<Timer>();
+            Proxy* ph = (Proxy*)luax_checktype(L, 2, Jin_Lua_Handler);
+            Timer::Handler* handler = ph->getObject<Timer::Handler>();
+            timer->cancel(handler);
+            return 0;
+        }
+
+        LUA_IMPLEMENT int l_cancelAll(lua_State* L)
+        {
+            Proxy* p = (Proxy*)luax_checktype(L, 1, Jin_Lua_Timer);
+            Timer* timer = p->getObject<Timer>();
+            timer->cancelAll();
+            return 0;
+        }
+
+        LUA_IMPLEMENT int l_gc(lua_State* L)
+        {
+            Proxy* p = (Proxy*)luax_checktype(L, 1, Jin_Lua_Timer);
+            p->release();
+            return 0;
+        }
+
+        LUA_EXPORT void luaopen_Timer(lua_State* L)
+        {
+            luaL_Reg f[] = {
+                { "__gc",      l_gc        },
+                { "every",     l_every     },
+                { "after",     l_after     },
+                { "duplicate", l_repeat    },
+                { "update",    l_update    },
+                { "cancel",    l_cancel    },
+                { "cancelAll", l_cancelAll },
+                { 0,           0           }
+            };
+
+            luax_newtype(L, Jin_Lua_Timer, f);
+        }
+
+    }
+}
+\ No newline at end of file