From 6020605d5c0cedfe96a7ccc8087887e4d362db1e Mon Sep 17 00:00:00 2001
From: Michael <heluecht@pirati.ca>
Date: Mon, 1 Oct 2018 19:22:13 +0000
Subject: [PATCH] Account deletion could work now.

---
 src/Protocol/ActivityPub.php | 37 ++++++++++++++++++++++++++++++++----
 src/Worker/APDelivery.php    |  2 ++
 src/Worker/Notifier.php      |  8 ++++++++
 3 files changed, 43 insertions(+), 4 deletions(-)

diff --git a/src/Protocol/ActivityPub.php b/src/Protocol/ActivityPub.php
index 4c77c8dff..b5cd102a5 100644
--- a/src/Protocol/ActivityPub.php
+++ b/src/Protocol/ActivityPub.php
@@ -57,7 +57,6 @@ use Friendica\Core\Config;
  * - Undo Accept (Problem: This could invert a contact accept or an event accept)
  *
  * Transmitter:
- * - Delete (Application, Group, Organization, Person, Service)
  * - Event
  *
  * Complicated:
@@ -441,9 +440,13 @@ class ActivityPub
 	{
 		$inboxes = [];
 
-		$contacts = DBA::select('contact', ['notify', 'batch'], ['uid' => $uid,
-			'rel' => [Contact::FOLLOWER, Contact::FRIEND], 'network' => Protocol::ACTIVITYPUB,
-			'archive' => false, 'pending' => false]);
+		$condition = ['uid' => $uid, 'network' => Protocol::ACTIVITYPUB, 'archive' => false, 'pending' => false];
+
+		if (!empty($uid)) {
+			$condition['rel'] = [Contact::FOLLOWER, Contact::FRIEND];
+		}
+
+		$contacts = DBA::select('contact', ['notify', 'batch'], $condition);
 		while ($contact = DBA::fetch($contacts)) {
 			$contact = defaults($contact, 'batch', $contact['notify']);
 			$inboxes[$contact] = $contact;
@@ -731,6 +734,32 @@ class ActivityPub
 		return $data;
 	}
 
+	/**
+	 * @brief Transmits a profile deletion to a given inbox
+	 *
+	 * @param integer $uid User ID
+	 * @param string $inbox Target inbox
+	 */
+	public static function transmitProfileDeletion($uid, $inbox)
+	{
+		$owner = User::getOwnerDataById($uid);
+		$profile = APContact::getByURL($owner['url']);
+
+		$data = ['@context' => 'https://www.w3.org/ns/activitystreams',
+			'id' => System::baseUrl() . '/activity/' . System::createGUID(),
+			'type' => 'Delete',
+			'actor' => $owner['url'],
+			'object' => self::profile($uid),
+			'published' => DateTimeFormat::utcNow(DateTimeFormat::ATOM),
+			'to' => [self::PUBLIC_COLLECTION],
+			'cc' => []];
+
+		$signed = LDSignature::sign($data, $owner);
+
+		logger('Deliver profile deletion for user ' . $uid . ' to ' . $inbox .' via ActivityPub', LOGGER_DEBUG);
+		HTTPSignature::transmit($signed, $inbox, $uid);
+	}
+
 	/**
 	 * @brief Transmits a profile change to a given inbox
 	 *
diff --git a/src/Worker/APDelivery.php b/src/Worker/APDelivery.php
index eb0b3d9b1..22b8c8f0f 100644
--- a/src/Worker/APDelivery.php
+++ b/src/Worker/APDelivery.php
@@ -18,6 +18,8 @@ class APDelivery extends BaseObject
 		if ($cmd == Delivery::MAIL) {
 		} elseif ($cmd == Delivery::SUGGESTION) {
 		} elseif ($cmd == Delivery::RELOCATION) {
+		} elseif ($cmd == Delivery::REMOVAL) {
+			ActivityPub::transmitProfileDeletion($uid, $inbox);
 		} elseif ($cmd == Delivery::PROFILEUPDATE) {
 			ActivityPub::transmitProfileUpdate($uid, $inbox);
 		} else {
diff --git a/src/Worker/Notifier.php b/src/Worker/Notifier.php
index b457b7800..3ab238422 100644
--- a/src/Worker/Notifier.php
+++ b/src/Worker/Notifier.php
@@ -99,6 +99,14 @@ class Notifier
 			foreach ($r as $contact) {
 				Contact::terminateFriendship($user, $contact, true);
 			}
+
+			$inboxes = ActivityPub::fetchTargetInboxesforUser(0);
+			foreach ($inboxes as $inbox) {
+				logger('Account removal for user ' . $uid . ' to ' . $inbox .' via ActivityPub', LOGGER_DEBUG);
+				Worker::add(['priority' => $a->queue['priority'], 'created' => $a->queue['created'], 'dont_fork' => true],
+					'APDelivery', Delivery::REMOVAL, '', $inbox, $uid);
+			}
+
 			return;
 		} elseif ($cmd == Delivery::RELOCATION) {
 			$normal_mode = false;