Merge branch 'develop' of codeberg.org:calckey/calckey into develop

packages/backend/src/queue/processors/db/import-posts.ts

@@ -81,47 +81,49 @@ export async function importPosts(
 		} else if (parsed instanceof Object) {
 			logger.info("Parsing animal style posts");
 			for (const post of parsed.orderedItems) {
-				try {
+				async () => {
-					linenum++;
-					let reply: Note | null = null;
-					if (post.object.inReplyTo != null) {
-						reply = await resolveNote(post.object.inReplyTo);
-					}
-					if (post.directMessage) {
-						continue;
-					}
-					if (job.data.signatureCheck) {
-						if (!post.signature) {
-							continue;
-						}
-					}
-					let text;
 					try {
-						text = htmlToMfm(post.object.content, post.object.tag);
+						linenum++;
-					} catch (e) {
+						let reply: Note | null = null;
-						continue;
+						if (post.object.inReplyTo != null) {
-					}
+							reply = await resolveNote(post.object.inReplyTo);
-					logger.info(`Posting[${linenum}] ...`);
+						}
+						if (post.directMessage) {
+							return;
+						}
+						if (job.data.signatureCheck) {
+							if (!post.signature) {
+								return;
+							}
+						}
+						let text;
+						try {
+							text = htmlToMfm(post.object.content, post.object.tag);
+						} catch (e) {
+							return;
+						}
+						logger.info(`Posting[${linenum}] ...`);
 
-					const note = await create(user, {
+						const note = await create(user, {
-						createdAt: new Date(post.object.published),
+							createdAt: new Date(post.object.published),
-						files: undefined,
+							files: undefined,
-						poll: undefined,
+							poll: undefined,
-						text: text || undefined,
+							text: text || undefined,
-						reply,
+							reply,
-						renote: null,
+							renote: null,
-						cw: post.sensitive,
+							cw: post.sensitive,
-						localOnly: false,
+							localOnly: false,
-						visibility: "hidden",
+							visibility: "hidden",
-						visibleUsers: [],
+							visibleUsers: [],
-						channel: null,
+							channel: null,
-						apMentions: new Array(0),
+							apMentions: new Array(0),
-						apHashtags: undefined,
+							apHashtags: undefined,
-						apEmojis: undefined,
+							apEmojis: undefined,
-					});
+						});
-				} catch (e) {
+					} catch (e) {
-					logger.warn(`Error in line:${linenum} ${e}`);
+						logger.warn(`Error in line:${linenum} ${e}`);
-				}
+					}
+				};
 			}
 		}
 	} catch (e) {