45 lines
1.1 KiB
TypeScript
45 lines
1.1 KiB
TypeScript
import { Client } from "https://deno.land/x/postgres@v0.19.3/mod.ts";
|
|
import { LatestSnapshotType } from "db/schema.d.ts";
|
|
|
|
export async function getVideosNearMilestone(client: Client) {
|
|
const queryResult = await client.queryObject<LatestSnapshotType>(`
|
|
SELECT ls.*
|
|
FROM latest_video_snapshot ls
|
|
INNER JOIN
|
|
songs s ON ls.aid = s.aid
|
|
AND s.deleted = false
|
|
WHERE
|
|
s.deleted = false AND
|
|
(views >= 90000 AND views < 100000) OR
|
|
(views >= 900000 AND views < 1000000) OR
|
|
(views >= 9900000 AND views < 10000000)
|
|
`);
|
|
return queryResult.rows.map((row) => {
|
|
return {
|
|
...row,
|
|
aid: Number(row.aid),
|
|
};
|
|
});
|
|
}
|
|
|
|
export async function getLatestVideoSnapshot(client: Client, aid: number): Promise<null | LatestSnapshotType> {
|
|
const queryResult = await client.queryObject<LatestSnapshotType>(
|
|
`
|
|
SELECT *
|
|
FROM latest_video_snapshot
|
|
WHERE aid = $1
|
|
`,
|
|
[aid],
|
|
);
|
|
if (queryResult.rows.length === 0) {
|
|
return null;
|
|
}
|
|
return queryResult.rows.map((row) => {
|
|
return {
|
|
...row,
|
|
aid: Number(row.aid),
|
|
time: new Date(row.time).getTime(),
|
|
};
|
|
})[0];
|
|
}
|