gh_mirrors/newsnow
1
0
Fork 0
mirror of https://github.com/ourongxing/newsnow.git synced 2025-01-31 19:08:05 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: optimize cache logi

Browse Source
This commit is contained in:
Ou 2024-10-14 21:50:27 +08:00
parent fcb83d1ed0
commit 5e84629e23
2 changed files with 32 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
server/middleware/auth.ts
View File

@ -3,17 +3,23 @@ import { jwtVerify } from "jose"
export default defineEventHandler(async (event) => { export default defineEventHandler(async (event) => {
if (["JWT_SECRET", "G_CLIENT_ID", "G_CLIENT_SECRET"].find(k => !process.env[k])) { if (["JWT_SECRET", "G_CLIENT_ID", "G_CLIENT_SECRET"].find(k => !process.env[k])) {
event.context.user = true event.context.disabledLogin = true
} else { } else {
const token = getHeader(event, "Authorization") const url = getRequestURL(event)
if (token && process.env.JWT_SECRET) { if (/^\/(?:me|s)\//.test(url.pathname)) {
try { const token = getHeader(event, "Authorization")
const { payload } = await jwtVerify(token.replace("Bearer ", ""), new TextEncoder().encode(process.env.JWT_SECRET)) as { payload?: { id: string, type: string } } if (token && process.env.JWT_SECRET) {
if (payload?.id) { try {
event.context.user = payload.id const { payload } = await jwtVerify(token.replace("Bearer ", ""), new TextEncoder().encode(process.env.JWT_SECRET)) as { payload?: { id: string, type: string } }
if (payload?.id) {
event.context.user = {
id: payload.id,
type: payload.type,
}
}
} catch {
logger.error("JWT verification failed")
} }
} catch {
logger.error("JWT verification failed")
} }
} }
} }

25
server/routes/s/[id].ts
View File

@ -26,7 +26,7 @@ export default defineEventHandler(async (event): Promise<SourceResponse> => {
const cache = await cacheTable.get(id) const cache = await cacheTable.get(id)
if (cache) { if (cache) {
// interval 刷新间隔，对于缓存失效也要执行的。本质上表示本来内容更新就很慢，这个间隔内可能内容压根不会更新。 // interval 刷新间隔，对于缓存失效也要执行的。本质上表示本来内容更新就很慢，这个间隔内可能内容压根不会更新。
// 默认 10 分钟，是低于 TTL 的，但部分 Source 的间隔会超过 TTL，甚至有的一天刷新一次。 // 默认 10 分钟，是低于 TTL 的，但部分 Source 的更新间隔会超过 TTL，甚至有的一天更新一次。
const interval = sources[id].interval const interval = sources[id].interval
if (now - cache.updated < interval) { if (now - cache.updated < interval) {
return { return {
@ -40,13 +40,22 @@ export default defineEventHandler(async (event): Promise<SourceResponse> => {
// 而 TTL 缓存失效时间，在时间范围内，就算内容更新了也要用这个缓存。 // 而 TTL 缓存失效时间，在时间范围内，就算内容更新了也要用这个缓存。
// 复用缓存是不会更新时间的。 // 复用缓存是不会更新时间的。
if ((!latest || !event.context.user) && now - cache.updated < TTL) { if (now - cache.updated < TTL) {
return { // 有 latest
status: "cache", // 没有 latest，但服务器禁止登录
data: {
updatedTime: cache.updated, // 没有 latest
items: cache.data, // 有 latest，服务器可以登录但没有登录
}, if (!latest || (!event.context.disabledLogin && !event.context.user)) {
if (event.context.disabledLogin) {
return {
status: "cache",
data: {
updatedTime: cache.updated,
items: cache.data,
},
}
}
} }
} }
} }