From 536277122d6c8f951114df6f7867095639343991 Mon Sep 17 00:00:00 2001
From: syuilo <syuilotan@yahoo.co.jp>
Date: Mon, 9 Apr 2018 05:02:52 +0900
Subject: wip

---
 src/remote/activitypub/kernel/delete/index.ts | 36 +++++++++++++++++++++++++++
 src/remote/activitypub/kernel/delete/note.ts  | 30 ++++++++++++++++++++++
 2 files changed, 66 insertions(+)
 create mode 100644 src/remote/activitypub/kernel/delete/index.ts
 create mode 100644 src/remote/activitypub/kernel/delete/note.ts

(limited to 'src/remote/activitypub/kernel/delete')

diff --git a/src/remote/activitypub/kernel/delete/index.ts b/src/remote/activitypub/kernel/delete/index.ts
new file mode 100644
index 0000000000..10b47dc4ca
--- /dev/null
+++ b/src/remote/activitypub/kernel/delete/index.ts
@@ -0,0 +1,36 @@
+import Resolver from '../../resolver';
+import deleteNote from './note';
+import Note from '../../../../models/note';
+import { IRemoteUser } from '../../../../models/user';
+
+/**
+ * 削除アクティビティを捌きます
+ */
+export default async (actor: IRemoteUser, activity): Promise<void> => {
+	if ('actor' in activity && actor.uri !== activity.actor) {
+		throw new Error('invalid actor');
+	}
+
+	const resolver = new Resolver();
+
+	const object = await resolver.resolve(activity.object);
+
+	const uri = (object as any).id;
+
+	switch (object.type) {
+	case 'Note':
+		deleteNote(actor, uri);
+		break;
+
+	case 'Tombstone':
+		const note = await Note.findOne({ uri });
+		if (note != null) {
+			deleteNote(actor, uri);
+		}
+		break;
+
+	default:
+		console.warn(`Unknown type: ${object.type}`);
+		break;
+	}
+};
diff --git a/src/remote/activitypub/kernel/delete/note.ts b/src/remote/activitypub/kernel/delete/note.ts
new file mode 100644
index 0000000000..64c342d39b
--- /dev/null
+++ b/src/remote/activitypub/kernel/delete/note.ts
@@ -0,0 +1,30 @@
+import * as debug from 'debug';
+
+import Note from '../../../../models/note';
+import { IRemoteUser } from '../../../../models/user';
+
+const log = debug('misskey:activitypub');
+
+export default async function(actor: IRemoteUser, uri: string): Promise<void> {
+	log(`Deleting the Note: ${uri}`);
+
+	const note = await Note.findOne({ uri });
+
+	if (note == null) {
+		throw new Error('note not found');
+	}
+
+	if (!note.userId.equals(actor._id)) {
+		throw new Error('投稿を削除しようとしているユーザーは投稿の作成者ではありません');
+	}
+
+	Note.update({ _id: note._id }, {
+		$set: {
+			deletedAt: new Date(),
+			text: null,
+			textHtml: null,
+			mediaIds: [],
+			poll: null
+		}
+	});
+}
-- 
cgit v1.2.3-freya