await deliver

mei23 · Apr 5, 2024 · a42e7eb · a42e7eb
1 parent ed0cc11
commit a42e7eb
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 6 deletions.
diff --git a/src/remote/activitypub/deliver-manager.ts b/src/remote/activitypub/deliver-manager.ts
@@ -177,12 +177,13 @@ export default class DeliverManager {
 
 				if (await isSelfSilencedHost(host)) {
 					const act = publicToHome(this.activity, this.actor); 
-					deliver(this.actor, act, inbox.url, lowSeverity, inbox);
+					await deliver(this.actor, act, inbox.url, lowSeverity, inbox);
 				} else {
-					deliver(this.actor, this.activity, inbox.url, lowSeverity, inbox);
+					await deliver(this.actor, this.activity, inbox.url, lowSeverity, inbox);
 				}
-
-			} catch { }
+			} catch (e) {
+				console.warn(`deliver failed ${e}`);
+			}
 		}
 	}
 }

diff --git a/src/services/suspend-user.ts b/src/services/suspend-user.ts
@@ -86,7 +86,11 @@ export async function sendDeleteActivity(user: IUser) {
 		]) as { _id: string }[];
 
 		for (const inbox of results.map(x => x._id)) {
-			deliver(user as any, content, inbox);
+			try {
+				await deliver(user as any, content, inbox);
+			} catch (e) {
+				console.warn(`deliver failed ${e}`);
+			}
 		}
 	}
 }

diff --git a/src/services/unsuspend-user.ts b/src/services/unsuspend-user.ts
@@ -43,7 +43,11 @@ export async function doPostUnsuspend(user: IUser) {
 		]) as { _id: string }[];
 
 		for (const inbox of results.map(x => x._id)) {
-			deliver(user as any, content, inbox);
+			try {
+				await deliver(user as any, content, inbox);
+			} catch (e) {
+				console.warn(`deliver failed ${e}`);
+			}
 		}
 	}
 }