feat(server): connect to redis

packages/database/package.json

@@ -48,7 +48,8 @@
     "animegarden": "workspace:*",
     "anitomy": "0.0.34",
     "drizzle-orm": "^0.29.3",
-    "postgres": "^3.4.3"
+    "postgres": "^3.4.3",
+    "unstorage": "^1.10.1"
   },
   "devDependencies": {
     "dotenv": "^16.3.1"

packages/database/src/index.ts

@@ -2,6 +2,8 @@ export * from './schema';
 
 export * from './migrate';
 
+export * from './redis';
+
 export * from './connection';
 
 export * from './operations';

packages/database/src/redis.ts

@@ -0,0 +1,11 @@
+import { createStorage } from 'unstorage';
+import redisDriver from 'unstorage/drivers/redis';
+
+export function connectRedis(url: string) {
+  return createStorage({
+    driver: redisDriver({
+      base: 'unstorage',
+      url
+    })
+  });
+}

packages/server/src/app.ts

@@ -2,6 +2,8 @@ import { format } from 'node:util';
 
 import { Hono } from 'hono';
 
+import { cors } from 'hono/cors';
+import { prettyJSON } from 'hono/pretty-json';
 import { logger as honoLogger } from 'hono/logger';
 
 import { logger } from './logger';
@@ -12,12 +14,19 @@ export async function registerApp(fn: (hono: typeof app) => Promise<void>) {
   await fn(app);
 }
 
-app.all(
+app.use('*', cors());
+app.use('*', prettyJSON());
+app.use(
   '*',
   honoLogger((message: string, ...rest: string[]) => {
     const content = format(message, ...rest);
     logger.info('request', content);
   })
 );
 
-app.get('/', (c) => c.text('Hello AnimeGarden!'));
+app.get('/', async (c) => {
+  return c.json({
+    message: 'AnimeGarden - 動漫花園 3-rd party mirror site',
+    timestamp: new Date().toString()
+  });
+});

packages/server/src/database.ts

@@ -1,8 +1,9 @@
 import { type Database, connectDatabase } from '@animegarden/database';
 
-const DATABASE_URI = process.env.POSTGRES_URI ?? process.env.DATABASE_URI;
+export const DATABASE_URI = process.env.POSTGRES_URI ?? process.env.DATABASE_URI;
+
 if (!DATABASE_URI) {
-  console.log(`Can not find database connection string`);
+  console.log(`Can not find postgres connection string`);
   process.exit(1);
 }
 

packages/server/src/index.ts

@@ -2,6 +2,7 @@ import { serve } from '@hono/node-server';
 
 import { app } from './app';
 import { logger } from './logger';
+import { storage } from './storage';
 import { database } from './database';
 
 serve(
@@ -14,5 +15,8 @@ serve(
 
     await database.query.resources.findFirst();
     logger.info(null, `Connect to postgres`);
+
+    await storage.getItem(`state/refresh-timestamp`);
+    logger.info(null, `Connect to redis`);
   }
 );

packages/server/src/storage.ts

@@ -0,0 +1,10 @@
+import { connectRedis } from '@animegarden/database';
+
+export const REDIS_URI = process.env.REDIS_URI;
+
+if (!REDIS_URI) {
+  console.log(`Can not find redis connection string`);
+  process.exit(1);
+}
+
+export const storage = connectRedis(REDIS_URI);

packages/worker/src/index.ts

@@ -18,7 +18,6 @@ app.use('*', logger());
 app.use('*', prettyJSON());
 
 app.get('/', async (c) => {
-  console.log('Req', c.env);
   return c.json({
     message: 'AnimeGarden - 動漫花園 3-rd party mirror site',
     timestamp: await getRefreshTimestamp(c.env)