Function applyDuplicateDeviceTokenMerge

src/InstallationDedup.js:117–171

({
  database,
  idMatch,
  deviceTokenMatch,
  action,
  mergePriority,
  enforceAuth,
  runOptions,
  validSchemaController,
})

 * @returns {Promise<string>} survivor's objectId
 */
export async function applyDuplicateDeviceTokenMerge({
  database,
  idMatch,
  deviceTokenMatch,
  action,
  mergePriority,
  enforceAuth,
  runOptions,
  validSchemaController,
}) {
  // Self-merge guard: when both matches resolve to the same row, there's
  // nothing to clean up. Skip the action so we don't destroy/update the row
  // we're about to return as the survivor.
  if (idMatch.objectId === deviceTokenMatch.objectId) {
    return idMatch.objectId;
  }
  const opts = enforceAuth ? runOptions : {};
  let loser;
  let survivorId;
  let fieldToClear;
  if (mergePriority === 'deviceToken') {
    loser = idMatch;
    survivorId = deviceTokenMatch.objectId;
    fieldToClear = 'installationId';
  } else if (mergePriority === 'installationId') {
    loser = deviceTokenMatch;
    survivorId = idMatch.objectId;
    fieldToClear = 'deviceToken';
  } else {
    throw new Error(`Unknown installation dedup mergePriority: ${mergePriority}`);
  }

  try {
    await performAction({
      database,
      query: { objectId: loser.objectId },
      action,
      fieldToClear,
      runOptions: opts,
      many: false,
      validSchemaController,
    });
    logResult(action, 1, null);
  } catch (err) {
    if (err && err.code === Parse.Error.OBJECT_NOT_FOUND) {
      logResult(action, 0, err);
    } else if (err && err.code === Parse.Error.OPERATION_FORBIDDEN) {
      logResult(action, null, err);
    } else {
      logResult(action, null, err);
      throw err;
    }
  }
  return survivorId;
}

export default {
  removeConflictingDeviceToken,