Page MenuHomePhabricator
Files F3513091

D11921.diff
No OneTemporary
Actions

D11921.diff
View Options

diff --git a/native/cpp/CommonCpp/NativeModules/CommCoreModule.h b/native/cpp/CommonCpp/NativeModules/CommCoreModule.h
--- a/native/cpp/CommonCpp/NativeModules/CommCoreModule.h
+++ b/native/cpp/CommonCpp/NativeModules/CommCoreModule.h
@@ -98,6 +98,16 @@
virtual jsi::Value processThreadActivityStoreOperations(
jsi::Runtime &rt,
jsi::Array operations) override;
+ virtual jsi::Value
+ processDBStoreOperations(jsi::Runtime &rt, jsi::Object operations) override;
+ template <typename T>
+ void appendDBStoreOps(
+ jsi::Runtime &rt,
+ jsi::Object &operations,
+ const char *key,
+ T &store,
+ std::shared_ptr<std::vector<std::unique_ptr<DBOperationBase>>>
+ &destination);
virtual jsi::Value initializeCryptoAccount(jsi::Runtime &rt) override;
virtual jsi::Value getUserPublicKey(jsi::Runtime &rt) override;
virtual jsi::Value
diff --git a/native/cpp/CommonCpp/NativeModules/CommCoreModule.cpp b/native/cpp/CommonCpp/NativeModules/CommCoreModule.cpp
--- a/native/cpp/CommonCpp/NativeModules/CommCoreModule.cpp
+++ b/native/cpp/CommonCpp/NativeModules/CommCoreModule.cpp
@@ -15,6 +15,7 @@
#include "JSIRust.h"
#include "lib.rs.h"
+#include <algorithm>
#include <string>
namespace comm {
@@ -406,6 +407,132 @@
rt, std::move(operations));
}
+template <typename T>
+void CommCoreModule::appendDBStoreOps(
+ jsi::Runtime &rt,
+ jsi::Object &operations,
+ const char *key,
+ T &store,
+ std::shared_ptr<std::vector<std::unique_ptr<DBOperationBase>>>
+ &destination) {
+ auto opsObject = operations.getProperty(rt, key);
+ if (opsObject.isObject()) {
+ auto ops = store.createOperations(rt, opsObject.asObject(rt).asArray(rt));
+ std::move(
+ std::make_move_iterator(ops.begin()),
+ std::make_move_iterator(ops.end()),
+ std::back_inserter(*destination));
+ }
+}
+
+jsi::Value CommCoreModule::processDBStoreOperations(
+ jsi::Runtime &rt,
+ jsi::Object operations) {
+ std::string createOperationsError;
+
+ auto storeOpsPtr =
+ std::make_shared<std::vector<std::unique_ptr<DBOperationBase>>>();
+ try {
+ this->appendDBStoreOps(
+ rt, operations, "draftStoreOperations", this->draftStore, storeOpsPtr);
+ this->appendDBStoreOps(
+ rt,
+ operations,
+ "threadStoreOperations",
+ this->threadStore,
+ storeOpsPtr);
+ this->appendDBStoreOps(
+ rt,
+ operations,
+ "messageStoreOperations",
+ this->messageStore,
+ storeOpsPtr);
+ this->appendDBStoreOps(
+ rt,
+ operations,
+ "reportStoreOperations",
+ this->reportStore,
+ storeOpsPtr);
+ this->appendDBStoreOps(
+ rt, operations, "userStoreOperations", this->userStore, storeOpsPtr);
+ this->appendDBStoreOps(
+ rt,
+ operations,
+ "keyserverStoreOperations",
+ this->keyserverStore,
+ storeOpsPtr);
+ this->appendDBStoreOps(
+ rt,
+ operations,
+ "communityStoreOperations",
+ this->communityStore,
+ storeOpsPtr);
+ this->appendDBStoreOps(
+ rt,
+ operations,
+ "integrityStoreOperations",
+ this->integrityStore,
+ storeOpsPtr);
+ this->appendDBStoreOps(
+ rt,
+ operations,
+ "syncedMetadataStoreOperations",
+ this->syncedMetadataStore,
+ storeOpsPtr);
+ this->appendDBStoreOps(
+ rt,
+ operations,
+ "auxUserStoreOperations",
+ this->auxUserStore,
+ storeOpsPtr);
+ this->appendDBStoreOps(
+ rt,
+ operations,
+ "threadActivityStoreOperations",
+ this->threadActivityStore,
+ storeOpsPtr);
+ } catch (std::runtime_error &e) {
+ createOperationsError = e.what();
+ }
+
+ return facebook::react::createPromiseAsJSIValue(
+ rt,
+ [=](jsi::Runtime &innerRt,
+ std::shared_ptr<facebook::react::Promise> promise) {
+ taskType job = [=]() {
+ std::string error = createOperationsError;
+
+ if (!error.size()) {
+ try {
+ DatabaseManager::getQueryExecutor().beginTransaction();
+ for (const auto &operation : *storeOpsPtr) {
+ operation->execute();
+ }
+ DatabaseManager::getQueryExecutor().captureBackupLogs();
+ DatabaseManager::getQueryExecutor().commitTransaction();
+ } catch (std::system_error &e) {
+ error = e.what();
+ DatabaseManager::getQueryExecutor().rollbackTransaction();
+ }
+ }
+
+ if (!error.size()) {
+ ::triggerBackupFileUpload();
+ }
+
+ this->jsInvoker_->invokeAsync([=]() {
+ if (error.size()) {
+ promise->reject(error);
+ } else {
+ promise->resolve(jsi::Value::undefined());
+ }
+ });
+ };
+ GlobalDBSingleton::instance.scheduleOrRunCancellable(
+ job, promise, this->jsInvoker_);
+ });
+}
+
void CommCoreModule::terminate(jsi::Runtime &rt) {
TerminateApp::terminate();
}
diff --git a/native/cpp/CommonCpp/_generated/commJSI-generated.cpp b/native/cpp/CommonCpp/_generated/commJSI-generated.cpp
--- a/native/cpp/CommonCpp/_generated/commJSI-generated.cpp
+++ b/native/cpp/CommonCpp/_generated/commJSI-generated.cpp
@@ -78,6 +78,9 @@
static jsi::Value __hostFunction_CommCoreModuleSchemaCxxSpecJSI_processThreadActivityStoreOperations(jsi::Runtime &rt, TurboModule &turboModule, const jsi::Value* args, size_t count) {
return static_cast<CommCoreModuleSchemaCxxSpecJSI *>(&turboModule)->processThreadActivityStoreOperations(rt, args[0].asObject(rt).asArray(rt));
}
+static jsi::Value __hostFunction_CommCoreModuleSchemaCxxSpecJSI_processDBStoreOperations(jsi::Runtime &rt, TurboModule &turboModule, const jsi::Value* args, size_t count) {
+ return static_cast<CommCoreModuleSchemaCxxSpecJSI *>(&turboModule)->processDBStoreOperations(rt, args[0].asObject(rt));
+}
static jsi::Value __hostFunction_CommCoreModuleSchemaCxxSpecJSI_initializeCryptoAccount(jsi::Runtime &rt, TurboModule &turboModule, const jsi::Value* args, size_t count) {
return static_cast<CommCoreModuleSchemaCxxSpecJSI *>(&turboModule)->initializeCryptoAccount(rt);
}
@@ -232,6 +235,7 @@
methodMap_["processSyncedMetadataStoreOperations"] = MethodMetadata {1, __hostFunction_CommCoreModuleSchemaCxxSpecJSI_processSyncedMetadataStoreOperations};
methodMap_["processAuxUserStoreOperations"] = MethodMetadata {1, __hostFunction_CommCoreModuleSchemaCxxSpecJSI_processAuxUserStoreOperations};
methodMap_["processThreadActivityStoreOperations"] = MethodMetadata {1, __hostFunction_CommCoreModuleSchemaCxxSpecJSI_processThreadActivityStoreOperations};
+ methodMap_["processDBStoreOperations"] = MethodMetadata {1, __hostFunction_CommCoreModuleSchemaCxxSpecJSI_processDBStoreOperations};
methodMap_["initializeCryptoAccount"] = MethodMetadata {0, __hostFunction_CommCoreModuleSchemaCxxSpecJSI_initializeCryptoAccount};
methodMap_["getUserPublicKey"] = MethodMetadata {0, __hostFunction_CommCoreModuleSchemaCxxSpecJSI_getUserPublicKey};
methodMap_["getOneTimeKeys"] = MethodMetadata {1, __hostFunction_CommCoreModuleSchemaCxxSpecJSI_getOneTimeKeys};
diff --git a/native/cpp/CommonCpp/_generated/commJSI.h b/native/cpp/CommonCpp/_generated/commJSI.h
--- a/native/cpp/CommonCpp/_generated/commJSI.h
+++ b/native/cpp/CommonCpp/_generated/commJSI.h
@@ -41,6 +41,7 @@
virtual jsi::Value processSyncedMetadataStoreOperations(jsi::Runtime &rt, jsi::Array operations) = 0;
virtual jsi::Value processAuxUserStoreOperations(jsi::Runtime &rt, jsi::Array operations) = 0;
virtual jsi::Value processThreadActivityStoreOperations(jsi::Runtime &rt, jsi::Array operations) = 0;
+ virtual jsi::Value processDBStoreOperations(jsi::Runtime &rt, jsi::Object operations) = 0;
virtual jsi::Value initializeCryptoAccount(jsi::Runtime &rt) = 0;
virtual jsi::Value getUserPublicKey(jsi::Runtime &rt) = 0;
virtual jsi::Value getOneTimeKeys(jsi::Runtime &rt, double oneTimeKeysAmount) = 0;
@@ -272,6 +273,14 @@
return bridging::callFromJs<jsi::Value>(
rt, &T::processThreadActivityStoreOperations, jsInvoker_, instance_, std::move(operations));
}
+ jsi::Value processDBStoreOperations(jsi::Runtime &rt, jsi::Object operations) override {
+ static_assert(
+ bridging::getParameterCount(&T::processDBStoreOperations) == 2,
+ "Expected processDBStoreOperations(...) to have 2 parameters");
+
+ return bridging::callFromJs<jsi::Value>(
+ rt, &T::processDBStoreOperations, jsInvoker_, instance_, std::move(operations));
+ }
jsi::Value initializeCryptoAccount(jsi::Runtime &rt) override {
static_assert(
bridging::getParameterCount(&T::initializeCryptoAccount) == 1,
diff --git a/native/schema/CommCoreModuleSchema.js b/native/schema/CommCoreModuleSchema.js
--- a/native/schema/CommCoreModuleSchema.js
+++ b/native/schema/CommCoreModuleSchema.js
@@ -26,7 +26,10 @@
import type { ClientDBMessageInfo } from 'lib/types/message-types.js';
import type { SIWEBackupSecrets } from 'lib/types/siwe-types.js';
import type { ReceivedMessageToDevice } from 'lib/types/sqlite-types.js';
-import type { ClientDBStore } from 'lib/types/store-ops-types';
+import type {
+ ClientDBStore,
+ ClientDBStoreOperations,
+} from 'lib/types/store-ops-types';
import type { ClientDBThreadInfo } from 'lib/types/thread-types.js';
type CommServicesAuthMetadata = {
@@ -85,6 +88,7 @@
+processThreadActivityStoreOperations: (
operations: $ReadOnlyArray<ClientDBThreadActivityStoreOperation>,
) => Promise<void>;
+ +processDBStoreOperations: (operations: Object) => Promise<void>;
+initializeCryptoAccount: () => Promise<string>;
+getUserPublicKey: () => Promise<ClientPublicKeys>;
+getOneTimeKeys: (oneTimeKeysAmount: number) => Promise<OneTimeKeysResult>;
@@ -193,6 +197,9 @@
siweBackupSecrets: SIWEBackupSecrets,
) => Promise<void>;
+getSIWEBackupSecrets: () => Promise<?SIWEBackupSecrets>;
+ +processDBStoreOperations: (
+ operations: ClientDBStoreOperations,
+ ) => Promise<void>;
}
export default (TurboModuleRegistry.getEnforcing<Spec>(

File Metadata

Mime Type
text/plain
Expires
Sun, Dec 22, 10:33 PM (16 h, 34 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2692753
Default Alt Text
D11921.diff (10 KB)

Event Timeline