>3=WJ|,+\XUoL:BsGm#UwW?0&qл}"F3t(g$VgKÊ-IKh{J,Cl@Y b($/RJD~:Fe#wSP\mgdbPL!ϜjָoUg^וD;;N\cz7*#w$su|oe yuuN /|GOBhŋgCRi/vru][Q##@Yo$(T~؂7>%e~1`jd;9kj]wD @jgf& 3DRx y c4x c^}b(-ji`[ 睜}*[T1MPe Ӧjֵ.bY5pCpRP5o k¶QwhIq^MϬz$*OX7HQM/*h\k#Qf̀/{I? wcBOP[2NJo$;Á/P-hP|ZY2n-ntrnTw7ėoWRto(#>&蒩 qjg@ތjYbO͍< /q?p-&+>M6.Zr9Fh}Qʰ Ok7I$;!8\3_PXYҎWEbFU-!`k,GAvifhNvxK Y`{xd6B? AOk8K gJ$m#1"_M2ԅ $u=dy65$ "֓4R+->;MƤ==5b1{RuExka7>> kOs}Eg?+xLjKd@t6?NƋjw,Ra'g>Yoq~cH,;MuE}OZ0[BU99xkK gJ$m#1"_M2ԅܚTڢ[mcMİ58L!*Eh~^"`DKWcYkŗ)qzR^D+\6.Zr9Fh mFEf|c-Hdn<ᔾ<(|6c1#Ǐ{wJ*l0$l D~Uzw۝a۶MVqf ͍\ s8*>[w7 ,CLXuh6<_i`/YAI#0f۰.| 8뛙J5b1{RuExkaọ2Vr%ٻ<Qi[':J_[5ʼە/od/=0V-I 5a˯MQ"`'9>Hqu`#Gsci,_Op !m/0/fї뭮ktDaP,V`i~륐.^3Od/XgLhhMI:#u:Mwdmxƀ CܗD7{,ѺzoVu) z =\?-XjIXq  zޘx]ڄb^J؎,80h1O :JM=~L[J%4?Fژ ^ xoTN)Iav'@S}Dxj]=n5L! ʍ@*N*"Օ>L▪L?dUTsaeV1k%yDr8睳f 4n斶ٷL|vik>E(PKCL-4!7TU\alΗz@DYq4// 1nHq}G11)-uLPcn(7`vx Jk͊^31]"},Lc+ԍD i)0*:>Nl \Y.l~ԭ]9Q&|0[բ؜о-BY)vrzd͐{6G~G>A?MYF޵ `L&ϭ_*]9V.V\B .A)+Jj_Fz|~ߖq>hnJ:Jtp;Q9?ďJ^Ѽ/P3S<0كrZZoew%>6ʆ8G7&prбQy?F4' x@XSE&>&Fzl6qeNDjv{Ma~4n/:BNFc/ր:zy6l[Mny{!b j#dS/Ϸ{؃_@ﳾY^`B$TZ$c [Iש5tC@o)~CFWI%E+AbXJC#A0Z/6,fn~)2 DE-խwwܞLpXc#Akhuʹ`͖{-L"=Rg!luކC;!,|S9E@B҅f]"O%TRɱcoBPf@GsO @3}MF`)xUB)#T*R }]QyYa!Cψ"w$-rcfNfNs#Wg^|, HYC&YnvEM&ffέ׼`A RVvߛ#"c N%e~|5d%2yѤ᫁%*a8'4˳1=oh| ʹ$ o$U\ŻeS} X RGֱ4|,GV#g(fZJ$W<*)|WT W_IcD(g_M]!M;LMG1/1f4 sØ.zg_i.$t^%kQy?F4' x@XSE&>&1an UӪ5z~3^My\oVתS%YX\[ &}2sI8Whs*=6>jju#;v72O4CiT%§nS*'B>eOe6Ғ ~^<۞}'!7owCQ 谋넏`O- jŽTMΌΌt}y^w;4(" V٬8 =hxMұXz~ 3&뗀FzKVer[uΫQkX%"B+T#,;hc]^E L$)k `47<}Yyoclosed before the statement could be // prepared. stmt->Finalize_(); } } }; typedef void (*Work_Callback)(Baton* baton); struct Call { Call(Work_Callback cb_, Baton* baton_) : callback(cb_), baton(baton_) {}; Work_Callback callback; Baton* baton; }; struct Async { uv_async_t watcher; Statement* stmt; Rows data; NODE_SQLITE3_MUTEX_t; bool completed; int retrieved; // Store the callbacks here because we don't have // access to the baton in the async callback. Napi::FunctionReference item_cb; Napi::FunctionReference completed_cb; Async(Statement* st, uv_async_cb async_cb) : stmt(st), completed(false), retrieved(0) { watcher.data = this; NODE_SQLITE3_MUTEX_INIT stmt->Ref(); uv_loop_t *loop; napi_get_uv_event_loop(stmt->Env(), &loop); uv_async_init(loop, &watcher, async_cb); } ~Async() { stmt->Unref(); item_cb.Reset(); completed_cb.Reset(); NODE_SQLITE3_MUTEX_DESTROY } }; Statement(const Napi::CallbackInfo& info); ~Statement() { if (!finalized) Finalize_(); } WORK_DEFINITION(Bind) WORK_DEFINITION(Get) WORK_DEFINITION(Run) WORK_DEFINITION(All) WORK_DEFINITION(Each) WORK_DEFINITION(Reset) Napi::Value Finalize_(const Napi::CallbackInfo& info); protected: static void Work_BeginPrepare(Database::Baton* baton); static void Work_Prepare(napi_env env, void* data); static void Work_AfterPrepare(napi_env env, napi_status status, void* data); static void AsyncEach(uv_async_t* handle); static void CloseCallback(uv_handle_t* handle); static void Finalize_(Baton* baton); void Finalize_(); template inline std::unique_ptr BindParameter(const Napi::Value source, T pos); template T* Bind(const Napi::CallbackInfo& info, int start = 0, int end = -1); bool Bind(const Parameters ¶meters); static void GetRow(Row* row, sqlite3_stmt* stmt); static Napi::Value RowToJS(Napi::Env env, Row* row); void Schedule(Work_Callback callback, Baton* baton); void Process(); void CleanQueue(); template static void Error(T* baton); protected: Database* db; sqlite3_stmt* _handle = NULL; int status = SQLITE_OK; bool prepared = false; bool locked = true; bool finalized = false; std::queue queue; std::string message; }; } #endif