Function processThreadStoreOperations

web/shared-worker/worker/process-operations.js:107–137

(
  sqliteQueryExecutor: SQLiteQueryExecutorWrapper,
  operations: $ReadOnlyArray<ClientDBThreadStoreOperation>,
  module: EmscriptenModule,
)

}

function processThreadStoreOperations(
  sqliteQueryExecutor: SQLiteQueryExecutorWrapper,
  operations: $ReadOnlyArray<ClientDBThreadStoreOperation>,
  module: EmscriptenModule,
) {
  for (const operation: ClientDBThreadStoreOperation of operations) {
    try {
      if (operation.type === 'remove_all') {
        sqliteQueryExecutor.removeAllThreads();
      } else if (operation.type === 'remove') {
        const { ids } = operation.payload;
        sqliteQueryExecutor.removeThreads(ids);
      } else if (operation.type === 'replace') {
        sqliteQueryExecutor.replaceThread(
          clientDBThreadInfoToWebThread(operation.payload),
          operation.isBackedUp,
        );
      } else {
        throw new Error('Unsupported thread operation');
      }
    } catch (e) {
      throw new Error(
        `Error while processing ${
          operation.type
        } thread operation: ${getProcessingStoreOpsExceptionMessage(
          e,
          module,
        )}`,
      );
    }
  }
}

function processKeyserverStoreOperations(