alikia2x/OpenRewind
1
1
Fork 0
Code Issues Releases 1 Activity

update: use untilID as param of /timeline instead of offset

Browse Source
This commit is contained in:
alikia2x (寒寒) 2024-12-29 21:48:56 +08:00
parent f53616f345
commit bf7be530a1
Signed by: alikia2x
GPG Key ID: 56209E0CCD8420C6
1 changed files with 29 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
src/electron/server/index.ts
View File

@ -19,22 +19,42 @@ app.use(async (c, next) => {
app.get("/ping", (c) => c.text("pong"));
app.get("/timeline", async (c) => {
const { offset = 0, limit = 50 } = c.req.query();
const db = cache.get("server:dbConnection");
const frames = db
function getLatestFrames(db: Database, limit = 50): Frame[] {
return db
.prepare(
`
SELECT id, createdAt, imgFilename, videoPath, videoFrameIndex
FROM frame
ORDER BY createdAt DESC
LIMIT ? OFFSET ?
LIMIT ?
`
)
.all(limit, offset);
.all(limit) as Frame[];
}
return c.json(frames);
function getFramesUntilID(db: Database, untilID: number, limit = 50): Frame[] {
return db
.prepare(
`
SELECT id, createdAt, imgFilename, videoPath, videoFrameIndex
FROM frame
WHERE id <= ?
ORDER BY createdAt DESC
LIMIT ?
`
)
.all(untilID, limit) as Frame[];
}
app.get("/timeline", async (c) => {
const query = c.req.query();
const limit = parseInt(query.limit) || undefined;
const db = cache.get("server:dbConnection");
if (query.untilID) {
return c.json(getFramesUntilID(db, parseInt(query.untilID), limit));
} else {
return c.json(getLatestFrames(db, limit));
}
});
app.get("/frame/:id", async (c) => {