Method decryptAndPersist

native/cpp/CommonCpp/NativeModules/CommCoreModule.cpp:1912–1991

}

jsi::Value CommCoreModule::decryptAndPersist(
    jsi::Runtime &rt,
    jsi::Object encryptedDataJSI,
    jsi::String deviceID,
    jsi::String userID,
    jsi::String messageID) {
  size_t messageType =
      std::lround(encryptedDataJSI.getProperty(rt, "messageType").asNumber());
  std::string message =
      encryptedDataJSI.getProperty(rt, "message").asString(rt).utf8(rt);

  std::optional<int> sessionVersion;
  if (encryptedDataJSI.hasProperty(rt, "sessionVersion")) {
    sessionVersion = std::lround(
        encryptedDataJSI.getProperty(rt, "sessionVersion").asNumber());
  }

  auto deviceIDCpp{deviceID.utf8(rt)};
  auto messageIDCpp{messageID.utf8(rt)};
  auto userIDCpp{userID.utf8(rt)};
  return createPromiseAsJSIValue(
      rt, [=](jsi::Runtime &innerRt, std::shared_ptr<Promise> promise) {
        taskType job = [=, &innerRt]() {
          std::string error;
          std::string decryptedMessage;
          try {
            crypto::EncryptedData encryptedData{
                message, messageType, sessionVersion};
            decryptedMessage =
                this->contentCryptoModule->decrypt(deviceIDCpp, encryptedData);

            std::string storedSecretKey =
                getAccountDataKey(secureStoreAccountDataKey);
            crypto::Persist newContentPersist =
                this->contentCryptoModule->storeAsB64(storedSecretKey);

            std::promise<void> persistencePromise;
            std::future<void> persistenceFuture =
                persistencePromise.get_future();
            GlobalDBSingleton::instance.scheduleOrRunCancellable(
                [=, &persistencePromise]() {
                  try {
                    InboundP2PMessage message{
                        messageIDCpp,
                        deviceIDCpp,
                        decryptedMessage,
                        "decrypted",
                        userIDCpp};

                    DatabaseManager::getQueryExecutor().beginTransaction();
                    DatabaseManager::getQueryExecutor().addInboundP2PMessage(
                        message);
                    DatabaseManager::getQueryExecutor().storeOlmPersistData(
                        DatabaseManager::getQueryExecutor()
                            .getContentAccountID(),
                        newContentPersist);
                    DatabaseManager::getQueryExecutor().commitTransaction();
                    persistencePromise.set_value();