feat: record refresh timestamp

packages/worker/src/index.ts

@@ -4,6 +4,7 @@ import type { Env } from './types';
 
 import { makePrisma } from './prisma';
 import { handleScheduled } from './scheduled';
+import { getRefreshTimestamp } from './state';
 
 const router = Router();
 
@@ -56,7 +57,7 @@ router.get('/resources', async (request, env: Env) => {
     }
   }));
 
-  return makeResponse({ resources });
+  return makeResponse({ resources, timestamp: await getRefreshTimestamp(env) });
 
   function resolveParams():
     | {

packages/worker/src/scheduled.ts

@@ -3,6 +3,7 @@ import { fetchResourcePage } from 'animegarden';
 import type { Env } from './types';
 
 import { makePrisma } from './prisma';
+import { updateRefreshTimestamp } from './state';
 
 const teams = new Set<number>();
 const users = new Set<number>();
@@ -77,5 +78,7 @@ export async function handleScheduled(env: Env) {
     console.log(`There are ${count} resources inserted`);
   }
 
+  await updateRefreshTimestamp(env);
+
   return { count: sum };
 }

packages/worker/src/state.ts

@@ -0,0 +1,9 @@
+import type { Env } from './types';
+
+export async function updateRefreshTimestamp(env: Env) {
+  await env.animegarden.put('state/refresh-timestamp', new Date().toISOString());
+}
+
+export async function getRefreshTimestamp(env: Env) {
+  return new Date((await env.animegarden.get('state/refresh-timestamp')) ?? 0);
+}

packages/worker/src/types.ts

@@ -1,5 +1,7 @@
 export interface Env {
   DATABASE_URL: string;
 
+  animegarden: KVNamespace;
+
   database: D1Database;
 }

packages/worker/wrangler.toml

@@ -2,5 +2,9 @@ name = "animegarden"
 main = "src/index.ts"
 compatibility_date = "2023-03-22"
 
+kv_namespaces = [
+  { binding = "animegarden", id = "d0bb91899b22468db08020b251d3cef4", preview_id = "0bcc680779d340dfb80a3512a89cb533" }
+]
+
 [triggers]
 crons = ["*/5 * * * *"]