+ /**
+ * @brief Helper function for "updateFromProbe". Remove duplicated contacts
+ *
+ * @param string $nurl Normalised contact url
+ * @param integer $uid User id
+ * @param integer $id Contact id of a duplicate
+ * @throws \Exception
+ */
+ private static function handleDuplicates($nurl, $uid, $id)
+ {
+ $condition = ['nurl' => $nurl, 'uid' => $uid, 'deleted' => false];
+ $count = DBA::count('contact', $condition);
+ if ($count <= 1) {
+ return false;
+ }
+
+ $first_contact = DBA::selectFirst('contact', ['id'], $condition, ['order' => ['id']]);
+ if (!DBA::isResult($first_contact)) {
+ // Shouldn't happen - so we handle it
+ return false;
+ }
+
+ $first = $first_contact['id'];
+ Logger::info('Found duplicates', ['count' => $count, 'id' => $id, 'first' => $first, 'uid' => $uid, 'nurl' => $nurl, 'callstack' => System::callstack(20)]);
+ if ($uid != 0) {
+ // Don't handle non public duplicates by now
+ Logger::info('Not handling non public duplicate', ['uid' => $uid, 'nurl' => $nurl]);
+ return false;
+ }
+
+ // Find all duplicates
+ $condition = ["`nurl` = ? AND `uid` = ? AND `id` != ? AND NOT `self` AND NOT `deleted`", $nurl, $uid, $first];
+ $duplicates = DBA::select('contact', ['id'], $condition);
+ while ($duplicate = DBA::fetch($duplicates)) {
+ $dup_id = $duplicate['id'];
+ Logger::info('Handling duplicate', ['search' => $dup_id, 'replace' => $first]);
+
+ // Search and replace
+ DBA::update('item',['author-id' => $first], ['author-id' => $dup_id]);
+ DBA::update('item',['owner-id' => $first], ['owner-id' => $dup_id]);
+ DBA::update('item',['contact-id' => $first], ['contact-id' => $dup_id]);
+
+ // Remove the duplicate
+ DBA::delete('contact', ['id' => $dup_id]);
+ }
+ Logger::info('Duplicates handled', ['uid' => $uid, 'nurl' => $nurl]);
+ return true;
+ }
+