temp: remove the scheduleSnapshotTick job

lib/db/snapshotSchedule.ts

@@ -0,0 +1,11 @@
+import { Client } from "https://deno.land/x/postgres@v0.19.3/mod.ts";
+
+export async function getUnsnapshotedSongs(client: Client) {
+	const queryResult = await client.queryObject<{ aid: bigint }>(`
+		SELECT DISTINCT s.aid
+		FROM songs s
+		LEFT JOIN video_snapshot v ON s.aid = v.aid
+		WHERE v.aid IS NULL;
+	`);
+	return queryResult.rows.map((row) => Number(row.aid));
+}

lib/mq/init.ts

@@ -1,4 +1,4 @@
-import { MINUTE } from "$std/datetime/constants.ts";
+import { MINUTE, SECOND } from "$std/datetime/constants.ts";
 import { ClassifyVideoQueue, LatestVideosQueue, SnapshotQueue } from "lib/mq/index.ts";
 import logger from "lib/log/logger.ts";
 
@@ -15,8 +15,8 @@ export async function initMQ() {
 		every: 3 * MINUTE,
 		immediately: true,
 	});
-	await SnapshotQueue.upsertJobScheduler("scheduleSnapshotTick", {
+	await SnapshotQueue.upsertJobScheduler("snapshotTick", {
-		every: 3 * MINUTE,
+		every: 1 * SECOND,
 		immediately: true,
 	});
 

src/worker.ts

@@ -56,15 +56,15 @@ const snapshotWorker = new Worker(
 	"snapshot",
 	async (job: Job) => {
 		switch (job.name) {
-			case "scheduleSnapshotTick":
-				await snapshotTickWorker(job);
-				break;
 			case "snapshotMilestoneVideo":
 				await takeSnapshotForMilestoneVideoWorker(job);
 				break;
 			case "snapshotVideo":
 				await takeSnapshotForVideoWorker(job);
 				break;
+			case "snapshotTick":
+				await snapshotTickWorker(job);
+				break;
 			default:
 				break;
 		}