fix: query return value

packages/backend/src/server/api/common/getters.ts

@@ -21,7 +21,7 @@ export async function getNote(
 	if (scyllaClient) {
 		const result = await scyllaClient.execute(
 			prepared.note.select.byId,
-			[noteId],
+			[[noteId]],
 			{ prepare: true },
 		);
 		if (result.rowLength > 0) {

packages/backend/src/server/api/endpoints/notes/timeline.ts

@@ -85,7 +85,7 @@ export default define(meta, paramDef, async (ps, user) => {
 				query.push(`AND "id" < ?`);
 				params.push(ps.untilId);
 			}
-			query.push("LIMIT 50"); // Hardcoded to enable prepared query for performance
+			query.push("LIMIT 50"); // Hardcoded for prepared query
 
 			const result = await scyllaClient.execute(query.join(" "), params, {
 				prepare: true,

packages/backend/src/services/note/create.ts

@@ -67,7 +67,7 @@ import { shouldSilenceInstance } from "@/misc/should-block-instance.js";
 import meilisearch from "../../db/meilisearch.js";
 import { redisClient } from "@/db/redis.js";
 import { Mutex } from "redis-semaphore";
-import { prepared, scyllaClient } from "@/db/scylla.js";
+import { parseScyllaNote, prepared, scyllaClient } from "@/db/scylla.js";
 import { populateEmojis } from "@/misc/populate-emojis.js";
 
 const mutedWordsCache = new Cache<
@@ -416,7 +416,7 @@ export default async (
 			!user.isBot &&
 			(await countSameRenotes(user.id, data.renote.id, note.id)) === 0
 		) {
-			incRenoteCount(data.renote);
+			await incRenoteCount(data.renote);
 		}
 
 		if (data.poll?.expiresAt) {
@@ -676,16 +676,19 @@ async function renderNoteOrRenoteActivity(data: Option, note: Note) {
 	return renderActivity(content);
 }
 
-function incRenoteCount(renote: Note) {
+async function incRenoteCount(renote: Note) {
 	if (scyllaClient) {
-		const date = new Date(renote.createdAt.getTime());
-		scyllaClient.execute(prepared.note.update.renoteCount, [
-			renote.renoteCount + 1,
-			renote.score + 1,
-			date,
-			date,
-			renote.id,
-		]);
+		await scyllaClient.execute(
+			prepared.note.update.renoteCount,
+			[
+				renote.renoteCount + 1,
+				renote.score + 1,
+				renote.createdAt,
+				renote.createdAt,
+				renote.id,
+			],
+			{ prepare: true },
+		);
 	} else {
 		Notes.createQueryBuilder()
 			.update()
@@ -849,6 +852,17 @@ async function insertNote(
 			await Notes.insert(insert);
 		}
 
+		if (scyllaClient) {
+			const result = await scyllaClient.execute(
+				prepared.note.select.byId,
+				[[insert.id]],
+				{ prepare: true },
+			);
+			if (result.rowLength > 0) {
+				return parseScyllaNote(result.first());
+			}
+		}
+
 		return insert;
 	} catch (e) {
 		// duplicate key error