v@𹾂c' ۯE=Jn4 wO^J?7:YW=(5m^B />T*f, 8Mx+#qIj0\l9$Qވ"^VXs:6 @+sۢt>J_oٸ$6V*4N !`""dNʦiy TʱZ%hQAmYlcװQ<&j͖YBFHڼoNqGEEo'ZEBн,$.[q_]9˜b rǣc^54t=L:jYie@ 0>kN9Ksk*2F9;Rև99Z<ACq [?McI[4gqr"=%ve~msIo4N'LdRFN3PO<ӌUԿa7-4r A`8$OGuUwh8\pCNa2/y,(_.#j o!bMKDBN7 Ӄ6'Ηln9':^Xn7!o.RgAv|3i2@ۅ+xA>ŭxb\F9':^Xn7!o2AҡA 'y71_"2!e6/ .':ʧȀde]P@ 젏t<,)R 2\3#~4 !`#/L'O$f8#W 5Lߚpo*|*5`<2"|*ب9:g8$OGuUw^VĒ7hA3ܩT/NS<0 ۃNwͰN-rnW!m21oGX;nr%;YB;oJT],v;`7jz`K6{?ĸقr$|F(-Ze=bB9{:f3pr?i`IG&7Ӏ4=+j_N94Ռߜ\#IV ![S$kKc,hV[ Znn pw_~$'UaH!#aߩ<][K84_ i]"vR?'tS=.}A/KD{D Z[ge7Pgf'aXY?O i縒'J I* +Y@gAxR5نo-K/H +En{{a\[Lc7\v`'>ZAQ\Ԧ uqۅR'%vwAo ,Zţ wF';&чH:j~T/x{6+ Qc,9dOp<84&.*AOچ _rF<;dօ٭]`ݿe~-֒[ ]Nkcfyإ9@HWi%ya3ODjظ9iwJ+`\d_pzḅApY&RbGEwqJo3V_K$?o%)p1'*d8_udhBF a3C1<W*"alԺ%2Cyp!C%V[uۿLa}r.}l6qE:#GNjwi SkVUGC@`j|7F:NoeV̂x#Ӱ-ׇϼP0<%)YXxxBxL1gTp] FwAdZ;\X{x*VohwIVȶ.ol)T+ j$&niel(AKFUݢ0C :;9vZ1/ء.z!]Τk|H5?x1.f"˙E@`" ,ХwưGNQ#w,~L|Jd`5BJs^4E[0M0-ڐealT\U=RMF,t/%|eKq`V7 c9&O4J̥82gBtt 2/kUk9tj{0/<ī7ZL(^ps,4명m U=[]>4GG=p5u9kW}rאYɿ4+O/0fFpnX4gaD0G _qoM8g+RR`^G)*}Q_YM YU-K尕PfJ6(ٱƍ{ lb9<.7)ro+ n^A(L|BIU:"isAG9yQ_S8WA{Zԝ& \U `ѕXV`ot`f~?%T3|лc.O_ W״&IXW:a:s$(yԿ0w^kY,1Sc[vm:͡SʁLquP ;Q !sjh[T]L} y)yFN9wI!0]E WpaRڬl?mv³5627(ML'2|b$2+7DpVY0@M)m`ꯢ%?ݕbu-b=~nQn@vro:?kVXtrð{r|;ב&f6M!?;u[ؕS.Do̱qP0JพGRZb&Zz.P1}/@`+nclVW 4&"״?1}vGŞ :zV{sTuad+ ѓ&_(U0I zr8QJ 5 && !info[5].IsUndefined() && !info[5].IsFunction()) { Napi::TypeError::New(env, "Callback expected").ThrowAsJavaScriptException(); return; } this->db = Napi::ObjectWrap::Unwrap(info[0].As()); this->db->Ref(); auto filename = info[1].As(); auto sourceName = info[2].As(); auto destName = info[3].As(); auto filenameIsDest = info[4].As(); info.This().As().DefineProperty(Napi::PropertyDescriptor::Value("filename", filename)); info.This().As().DefineProperty(Napi::PropertyDescriptor::Value("sourceName", sourceName)); info.This().As().DefineProperty(Napi::PropertyDescriptor::Value("destName", destName)); info.This().As().DefineProperty(Napi::PropertyDescriptor::Value("filenameIsDest", filenameIsDest)); auto* baton = new InitializeBaton(this->db, info[5].As(), this); baton->filename = filename.Utf8Value(); baton->sourceName = sourceName.Utf8Value(); baton->destName = destName.Utf8Value(); baton->filenameIsDest = filenameIsDest.Value(); this->db->Schedule(Work_BeginInitialize, baton); } void Backup::Work_BeginInitialize(Database::Baton* baton) { assert(baton->db->open); baton->db->pending++; auto env = baton->db->Env(); CREATE_WORK("sqlite3.Backup.Initialize", Work_Initialize, Work_AfterInitialize); } void Backup::Work_Initialize(napi_env e, void* data) { BACKUP_INIT(InitializeBaton); // In case stepping fails, we use a mutex to make sure we get the associated // error message. auto* mtx = sqlite3_db_mutex(baton->db->_handle); sqlite3_mutex_enter(mtx); backup->status = sqlite3_open(baton->filename.c_str(), &backup->_otherDb); if (backup->status == SQLITE_OK) { backup->_handle = sqlite3_backup_init( baton->filenameIsDest ? backup->_otherDb : backup->db->_handle, baton->destName.c_str(), baton->filenameIsDest ? backup->db->_handle : backup->_otherDb, baton->sourceName.c_str()); } backup->_destDb = baton->filenameIsDest ? backup->_otherDb : backup->db->_handle; if (backup->status != SQLITE_OK) { backup->message = std::string(sqlite3_errmsg(backup->_destDb)); sqlite3_close(backup->_otherDb); backup->_otherDb = NULL; backup->_destDb = NULL; } sqlite3_mutex_leave(mtx); } void Backup::Work_AfterInitialize(napi_env e, napi_status status, void* data) { std::unique_ptr baton(static_cast(data)); auto* backup = baton->backup; auto env = backup->Env(); Napi::HandleScope scope(env); if (backup->status != SQLITE_OK) { Error(baton.get()); backup->FinishAll(); } else { backup->inited = true; Napi::Function cb = baton->callback.Value(); if (!cb.IsEmpty() && cb.IsFunction()) { Napi::Value argv[] = { env.Null() }; TRY_CATCH_CALL(backup->Value(), cb, 1, argv); } } BACKUP_END(); } Napi::Value Backup::Step(const Napi::CallbackInfo& info) { auto* backup = this; auto env = backup->Env(); REQUIRE_ARGUMENT_INTEGER(0, pages); OPTIONAL_ARGUMENT_FUNCTION(1, callback); auto* baton = new StepBaton(backup, callback, pages); backup->GetRetryErrors(baton->retryErrorsSet); backup->Schedule(Work_BeginStep, baton); return info.This(); } void Backup::Work_BeginStep(Baton* baton) { BACKUP_BEGIN(Step); } void Backup::Work_Step(napi_env e, void* data) { BACKUP_INIT(StepBaton); if (backup->_handle) { backup->status = sqlite3_backup_step(backup->_handle, baton->pages); backup->remaining = sqlite3_backup_remaining(backup->_handle); backup->pageCount = sqlite3_backup_pagecount(backup->_handle); } if (backup->status != SQLITE_OK) { // Text of message is a little awkward to get, since the error is not associated // with a db connection. #if SQLITE_VERSION_NUMBER >= 3007015 // sqlite3_errstr is a relatively new method backup->message = std::string(sqlite3_errstr(backup->status)); #else backup->message = "Sqlite error"; #endif if (baton->retryErrorsSet.size() > 0) { if (baton->retryErrorsSet.find(backup->status) == baton->retryErrorsSet.end()) { backup->FinishSqlite(); } } } } void Backup::Work_AfterStep(napi_env e, napi_status status, void* data) { std::unique_ptr baton(static_cast(data)); auto* backup = baton->backup; auto env = backup->Env(); Napi::HandleScope scope(env); if (backup->status == SQLITE_DONE) { backup->completed = true; } else if (!backup->_handle) { backup->failed = true; } if (backup->status != SQLITE_OK && backup->status != SQLITE_DONE) { Error(baton.get()); } else { // Fire callbacks. Napi::Function cb = baton->callback.Value(); if (!cb.IsEmpty() && cb.IsFunction()) { Napi::Value argv[] = { env.Null(), Napi::Boolean::New(env, backup->status == SQLITE_DONE) }; TRY_CATCH_CALL(backup->Value(), cb, 2, argv); } } BACKUP_END(); } Napi::Value Backup::Finish(const Napi::CallbackInfo& info) { auto* backup = this; auto env = backup->Env(); OPTIONAL_ARGUMENT_FUNCTION(0, callback); auto* baton = new Baton(backup, callback); backup->Schedule(Work_BeginFinish, baton); return info.This(); } void Backup::Work_BeginFinish(Baton* baton) { BACKUP_BEGIN(Finish); } void Backup::Work_Finish(napi_env e, void* data) { BACKUP_INIT(Baton); backup->FinishSqlite(); } void Backup::Work_AfterFinish(napi_env e, napi_status status, void* data) { std::unique_ptr baton(static_cast(data)); auto* backup = baton->backup; auto env = backup->Env(); Napi::HandleScope scope(env); backup->FinishAll(); // Fire callback in case there was one. Napi::Function cb = baton->callback.Value(); if (!cb.IsEmpty() && cb.IsFunction()) { TRY_CATCH_CALL(backup->Value(), cb, 0, NULL); } BACKUP_END(); } void Backup::FinishAll() { assert(!finished); if (!completed && !failed) { failed = true; } finished = true; CleanQueue(); FinishSqlite(); db->Unref(); } void Backup::FinishSqlite() { if (_handle) { sqlite3_backup_finish(_handle); _handle = NULL; } if (_otherDb) { sqlite3_close(_otherDb); _otherDb = NULL; } _destDb = NULL; } Napi::Value Backup::IdleGetter(const Napi::CallbackInfo& info) { auto* backup = this; bool idle = backup->inited && !backup->locked && backup->queue.empty(); return Napi::Boolean::New(this->Env(), idle); } Napi::Value Backup::CompletedGetter(const Napi::CallbackInfo& info) { auto* backup = this; return Napi::Boolean::New(this->Env(), backup->completed); } Napi::Value Backup::FailedGetter(const Napi::CallbackInfo& info) { auto* backup = this; return Napi::Boolean::New(this->Env(), backup->failed); } Napi::Value Backup::RemainingGetter(const Napi::CallbackInfo& info) { auto* backup = this; return Napi::Number::New(this->Env(), backup->remaining); } Napi::Value Backup::PageCountGetter(const Napi::CallbackInfo& info) { auto* backup = this; return Napi::Number::New(this->Env(), backup->pageCount); } Napi::Value Backup::RetryErrorGetter(const Napi::CallbackInfo& info) { auto* backup = this; return backup->retryErrors.Value(); } void Backup::RetryErrorSetter(const Napi::CallbackInfo& info, const Napi::Value& value) { auto* backup = this; auto env = backup->Env(); if (!value.IsArray()) { Napi::Error::New(env, "retryErrors must be an array").ThrowAsJavaScriptException(); return; } Napi::Array array = value.As(); backup->retryErrors.Reset(array, 1); } void Backup::GetRetryErrors(std::set& retryErrorsSet) { retryErrorsSet.clear(); Napi::Array array = retryErrors.Value(); auto length = array.Length(); for (size_t i = 0; i < length; i++) { Napi::Value code = (array).Get(static_cast(i)); if (code.IsNumber()) { retryErrorsSet.insert(code.As().Int32Value()); } } }