summary refs log tree commit diff
path: root/src
diff options
context:
space:
mode:
authorSamuel <34555296+Flam3rboy@users.noreply.github.com>2023-03-18 04:13:04 +0100
committerSamuel <34555296+Flam3rboy@users.noreply.github.com>2023-03-18 04:13:04 +0100
commit7b00e9905327c826b82fc47cfa22e37b9c5161a9 (patch)
tree5a9458701dacc77bf8c6265ebf96035bf0b93e5f /src
parentfix: missing id in select query (diff)
downloadserver-7b00e9905327c826b82fc47cfa22e37b9c5161a9.tar.xz
fix: use entity.save() instead of insert (needed for caching)
Diffstat (limited to 'src')
-rw-r--r--src/api/routes/users/@me/notes.ts6
-rw-r--r--src/api/util/handlers/Message.ts2
-rw-r--r--src/util/util/Database.ts4
3 files changed, 6 insertions, 6 deletions
diff --git a/src/api/routes/users/@me/notes.ts b/src/api/routes/users/@me/notes.ts
index 64730c1a..f82c3ca1 100644
--- a/src/api/routes/users/@me/notes.ts
+++ b/src/api/routes/users/@me/notes.ts
@@ -52,17 +52,17 @@ router.put("/:id", route({}), async (req: Request, res: Response) => {
 				where: { owner: { id: owner.id }, target: { id: target.id } },
 			})
 		) {
-			Note.update(
+			await Note.update(
 				{ owner: { id: owner.id }, target: { id: target.id } },
 				{ owner, target, content: note },
 			);
 		} else {
-			Note.insert({
+			await Note.create({
 				id: Snowflake.generate(),
 				owner,
 				target,
 				content: note,
-			});
+			}).save();
 		}
 	} else {
 		await Note.delete({
diff --git a/src/api/util/handlers/Message.ts b/src/api/util/handlers/Message.ts
index e514d400..8fbbf4bf 100644
--- a/src/api/util/handlers/Message.ts
+++ b/src/api/util/handlers/Message.ts
@@ -274,7 +274,7 @@ export async function sendMessage(opts: MessageOptions) {
 	const message = await handleMessage({ ...opts, timestamp: new Date() });
 
 	await Promise.all([
-		Message.insert(message),
+		message.save(),
 		emitEvent({
 			event: "MESSAGE_CREATE",
 			channel_id: opts.channel_id,
diff --git a/src/util/util/Database.ts b/src/util/util/Database.ts
index 5c5c8b4c..5d48ac03 100644
--- a/src/util/util/Database.ts
+++ b/src/util/util/Database.ts
@@ -127,10 +127,10 @@ export async function initDatabase(): Promise<DataSource> {
 		// Manually insert every current migration to prevent this:
 		await Promise.all(
 			dbConnection.migrations.map((migration) =>
-				Migration.insert({
+				Migration.create({
 					name: migration.name,
 					timestamp: Date.now(),
-				}),
+				}).save(),
 			),
 		);
 	} else {