diff --git a/backend/src/data/GuildSavedMessages.ts b/backend/src/data/GuildSavedMessages.ts index 1f021f1f..1e7de899 100644 --- a/backend/src/data/GuildSavedMessages.ts +++ b/backend/src/data/GuildSavedMessages.ts @@ -203,7 +203,7 @@ export class GuildSavedMessages extends BaseGuildRepository { const savedMessageData = this.msgToSavedMessageData(msg); const postedAt = moment.utc(msg.createdTimestamp, "x").format("YYYY-MM-DD HH:mm:ss"); - return this.processEntityToDB({ + return { id: msg.id, guild_id: (msg.channel as GuildChannel).guild.id, channel_id: msg.channel.id, @@ -211,7 +211,7 @@ export class GuildSavedMessages extends BaseGuildRepository { is_bot: msg.author.bot, data: savedMessageData, posted_at: postedAt, - }); + }; } protected async insertBulk(items: Array>): Promise { @@ -222,7 +222,8 @@ export class GuildSavedMessages extends BaseGuildRepository { } } - await this.messages.createQueryBuilder().insert().values(items).execute().catch(noop); + const itemsToInsert = await asyncMap(items, (item) => this.processEntityToDB({ ...item })); + await this.messages.createQueryBuilder().insert().values(itemsToInsert).execute().catch(noop); for (const item of items) { // perf: save a db lookup and message content decryption by building the entity manually