From dcf9421560def611c85f495466010f2091a13beb Mon Sep 17 00:00:00 2001
From: syuilo <syuilotan@yahoo.co.jp>
Date: Fri, 12 Apr 2019 13:07:56 +0900
Subject: [PATCH] Better error handling

---
 src/remote/activitypub/models/note.ts | 8 +++++++-
 src/services/note/create.ts           | 8 +++-----
 2 files changed, 10 insertions(+), 6 deletions(-)

diff --git a/src/remote/activitypub/models/note.ts b/src/remote/activitypub/models/note.ts
index 07991d4eb..eb4175875 100644
--- a/src/remote/activitypub/models/note.ts
+++ b/src/remote/activitypub/models/note.ts
@@ -242,7 +242,13 @@ export async function resolveNote(value: string | IObject, resolver?: Resolver):
 	// リモートサーバーからフェッチしてきて登録
 	// ここでuriの代わりに添付されてきたNote Objectが指定されていると、サーバーフェッチを経ずにノートが生成されるが
 	// 添付されてきたNote Objectは偽装されている可能性があるため、常にuriを指定してサーバーフェッチを行う。
-	return await createNote(uri, resolver);
+	return await createNote(uri, resolver).catch(e => {
+		if (e.name === 'duplicated') {
+			return fetchNote(uri);
+		} else {
+			throw e;
+		}
+	});
 }
 
 export async function extractEmojis(tags: ITag[], host: string) {
diff --git a/src/services/note/create.ts b/src/services/note/create.ts
index b66f61ae8..6906bc71c 100644
--- a/src/services/note/create.ts
+++ b/src/services/note/create.ts
@@ -193,10 +193,6 @@ export default async (user: User, data: Option, silent = false) => new Promise<N
 
 	res(note);
 
-	if (note == null) {
-		return;
-	}
-
 	// 統計を更新
 	notesChart.update(note, true);
 	perUserNotesChart.update(user, note, true);
@@ -424,7 +420,9 @@ async function insertNote(user: User, data: Option, tags: string[], emojis: stri
 	} catch (e) {
 		// duplicate key error
 		if (isDuplicateKeyValueError(e)) {
-			return null;
+			const err = new Error('Duplicated note');
+			err.name = 'duplicated';
+			throw err;
 		}
 
 		console.error(e);