Page MenuHomePhabricator
Differential D10629

[native] Start/stop backup client from JS
ClosedPublic
Actions

Authored by michal on Jan 15 2024, 4:40 AM.
Tags
None
Referenced Files
Unknown Object (File)
Wed, Mar 12, 11:52 AM
Unknown Object (File)
Mar 2 2025, 6:05 PM
Unknown Object (File)
Feb 28 2025, 10:45 PM
Unknown Object (File)
Feb 28 2025, 10:45 PM
Unknown Object (File)
Feb 17 2025, 2:42 PM
Unknown Object (File)
Feb 3 2025, 1:31 PM
Unknown Object (File)
Feb 3 2025, 10:59 AM
Unknown Object (File)
Jan 30 2025, 1:57 PM
View All 64 Files
Subscribers
ashoat
tomek

Details

Reviewers
marcin
bartek
kamil
Commits
rCOMMdba062686647: [native] Start/stop backup client from JS
Summary

ENG-6213 : Create long lived backup client

Start and stop the rust backup client handler from JS if a user is a logged in staff and enables it in the settings.

Depends on D10621

Test Plan

Monitor backup service logs and:

  • Enable the backup handler in menu -> the websocket in connected
  • Check that the websocket is disconnected after disabling the backup handler in menu or logging out
  • Check that the websocket automatically reconnects after app is closed and opened (without logging out) and when backup service is killed (simulating network issues)

Diff Detail

Repository
rCOMM Comm
Lint
Lint Not Applicable
Unit
Tests Not Applicable

Revision Contents
Changeset List

PathSize
native/
backup/
77 lines

Diff 36153

View Options

native/backup/backup-handler.js

Show First 20 Lines • Show All 1,660 Lines • ▼ Show 20 LinesCommCoreModule::restoreBackup(jsi::Runtime &rt, jsi::String backupSecret) {
std::string backupSecretStr = backupSecret.utf8(rt); std::string backupSecretStr = backupSecret.utf8(rt);
return createPromiseAsJSIValue( return createPromiseAsJSIValue(
rt, [=](jsi::Runtime &innerRt, std::shared_ptr<Promise> promise) { rt, [=](jsi::Runtime &innerRt, std::shared_ptr<Promise> promise) {
auto currentID = RustPromiseManager::instance.addPromise( auto currentID = RustPromiseManager::instance.addPromise(
{promise, this->jsInvoker_, innerRt}); {promise, this->jsInvoker_, innerRt});
::restoreBackup(rust::string(backupSecretStr), currentID); ::restoreBackup(rust::string(backupSecretStr), currentID);
}); });
} }
jsi::Value CommCoreModule::restoreBackupData(
jsi::Runtime &rt,
jsi::String backupID,
jsi::String backupDataKey,
jsi::String backupLogDataKey) {
std::string backupIDStr = backupID.utf8(rt);
std::string backupDataKeyStr = backupDataKey.utf8(rt);
std::string backupLogDataKeyStr = backupLogDataKey.utf8(rt);
return createPromiseAsJSIValue(
rt, [=](jsi::Runtime &innerRt, std::shared_ptr<Promise> promise) {
auto currentID = RustPromiseManager::instance.addPromise(
{promise, this->jsInvoker_, innerRt});
::restoreBackupData(
rust::string(backupIDStr),
rust::string(backupDataKeyStr),
rust::string(backupLogDataKeyStr),
currentID);
});
}
jsi::Value
CommCoreModule::retrieveBackupKeys(jsi::Runtime &rt, jsi::String backupSecret) {
std::string backupSecretStr = backupSecret.utf8(rt);
return createPromiseAsJSIValue(
rt, [=](jsi::Runtime &innerRt, std::shared_ptr<Promise> promise) {
auto currentID = RustPromiseManager::instance.addPromise(
{promise, this->jsInvoker_, innerRt});
::retrieveBackupKeys(rust::string(backupSecretStr), currentID);
});
}
} // namespace comm } // namespace comm
View Options

native/backup/constants.js

Show First 20 Lines • Show All 1,660 Lines • ▼ Show 20 LinesCommCoreModule::restoreBackup(jsi::Runtime &rt, jsi::String backupSecret) {
std::string backupSecretStr = backupSecret.utf8(rt); std::string backupSecretStr = backupSecret.utf8(rt);
return createPromiseAsJSIValue( return createPromiseAsJSIValue(
rt, [=](jsi::Runtime &innerRt, std::shared_ptr<Promise> promise) { rt, [=](jsi::Runtime &innerRt, std::shared_ptr<Promise> promise) {
auto currentID = RustPromiseManager::instance.addPromise( auto currentID = RustPromiseManager::instance.addPromise(
{promise, this->jsInvoker_, innerRt}); {promise, this->jsInvoker_, innerRt});
::restoreBackup(rust::string(backupSecretStr), currentID); ::restoreBackup(rust::string(backupSecretStr), currentID);
}); });
} }
jsi::Value CommCoreModule::restoreBackupData(
jsi::Runtime &rt,
jsi::String backupID,
jsi::String backupDataKey,
jsi::String backupLogDataKey) {
std::string backupIDStr = backupID.utf8(rt);
std::string backupDataKeyStr = backupDataKey.utf8(rt);
std::string backupLogDataKeyStr = backupLogDataKey.utf8(rt);
return createPromiseAsJSIValue(
rt, [=](jsi::Runtime &innerRt, std::shared_ptr<Promise> promise) {
auto currentID = RustPromiseManager::instance.addPromise(
{promise, this->jsInvoker_, innerRt});
::restoreBackupData(
rust::string(backupIDStr),
rust::string(backupDataKeyStr),
rust::string(backupLogDataKeyStr),
currentID);
});
}
jsi::Value
CommCoreModule::retrieveBackupKeys(jsi::Runtime &rt, jsi::String backupSecret) {
std::string backupSecretStr = backupSecret.utf8(rt);
return createPromiseAsJSIValue(
rt, [=](jsi::Runtime &innerRt, std::shared_ptr<Promise> promise) {
auto currentID = RustPromiseManager::instance.addPromise(
{promise, this->jsInvoker_, innerRt});
::retrieveBackupKeys(rust::string(backupSecretStr), currentID);
});
}
} // namespace comm } // namespace comm