Function processDBStoreOperations

native/database/sqlite-api.js:49–83

(
    storeOperations: StoreOperations,
    dbID: DatabaseIdentifier,
  )

  removeAllOutboundP2PMessages: commCoreModule.removeAllOutboundP2PMessages,

  async processDBStoreOperations(
    storeOperations: StoreOperations,
    dbID: DatabaseIdentifier,
  ): Promise<void> {
    const keyserversToRemoveFromNotifsStore =
      getKeyserversToRemoveFromNotifsStore(
        storeOperations.keyserverStoreOperations ?? [],
      );

    try {
      const promises = [];
      if (keyserversToRemoveFromNotifsStore.length > 0) {
        promises.push(
          commCoreModule.removeKeyserverDataFromNotifStorage(
            keyserversToRemoveFromNotifsStore,
          ),
        );
      }

      const dbOps =
        convertStoreOperationsToClientDBStoreOperations(storeOperations);
      if (values(dbOps).some(ops => ops && ops.length > 0)) {
        promises.push(commCoreModule.processDBStoreOperations(dbOps, dbID));
      }
      await Promise.all(promises);
    } catch (e) {
      if (isTaskCancelledError(e)) {
        return;
      }
      // this code will make an entry in SecureStore and cause re-creating
      // database when user will open app again
      commCoreModule.reportDBOperationsFailure();
      commCoreModule.terminate();
    }
  },

  //backup
  async restoreUserData(qrAuthBackupData: QRAuthBackupData): Promise<void> {