style: formatting changes
This commit is contained in:
+43
-38
@@ -4,47 +4,52 @@ import { Redis } from "ioredis";
|
||||
config();
|
||||
|
||||
export class AniwatchAPICache {
|
||||
private _client: Redis | null;
|
||||
public isOptional: boolean = true;
|
||||
private _client: Redis | null;
|
||||
public isOptional: boolean = true;
|
||||
|
||||
static DEFAULT_CACHE_EXPIRY_SECONDS = 60 as const;
|
||||
static CACHE_EXPIRY_HEADER_NAME = "X-ANIWATCH-CACHE-EXPIRY" as const;
|
||||
static DEFAULT_CACHE_EXPIRY_SECONDS = 60 as const;
|
||||
static CACHE_EXPIRY_HEADER_NAME = "X-ANIWATCH-CACHE-EXPIRY" as const;
|
||||
|
||||
constructor() {
|
||||
const redisConnURL = process.env?.ANIWATCH_API_REDIS_CONN_URL;
|
||||
this.isOptional = !Boolean(redisConnURL);
|
||||
this._client = this.isOptional ? null : new Redis(String(redisConnURL));
|
||||
}
|
||||
|
||||
set(key: string | Buffer, value: string | Buffer | number) {
|
||||
if (this.isOptional) return;
|
||||
return this._client?.set(key, value);
|
||||
}
|
||||
|
||||
get(key: string | Buffer) {
|
||||
if (this.isOptional) return;
|
||||
return this._client?.get(key);
|
||||
}
|
||||
|
||||
/**
|
||||
* @param expirySeconds set to 60 by default
|
||||
*/
|
||||
async getOrSet<T>(
|
||||
setCB: () => Promise<T>,
|
||||
key: string | Buffer,
|
||||
expirySeconds: number = AniwatchAPICache.DEFAULT_CACHE_EXPIRY_SECONDS
|
||||
) {
|
||||
const cachedData = this.isOptional
|
||||
? null
|
||||
: (await this._client?.get(key)) || null;
|
||||
let data = JSON.parse(String(cachedData)) as T;
|
||||
|
||||
if (!data) {
|
||||
data = await setCB();
|
||||
await this._client?.set(key, JSON.stringify(data), "EX", expirySeconds);
|
||||
constructor() {
|
||||
const redisConnURL = process.env?.ANIWATCH_API_REDIS_CONN_URL;
|
||||
this.isOptional = !Boolean(redisConnURL);
|
||||
this._client = this.isOptional ? null : new Redis(String(redisConnURL));
|
||||
}
|
||||
|
||||
set(key: string | Buffer, value: string | Buffer | number) {
|
||||
if (this.isOptional) return;
|
||||
return this._client?.set(key, value);
|
||||
}
|
||||
|
||||
get(key: string | Buffer) {
|
||||
if (this.isOptional) return;
|
||||
return this._client?.get(key);
|
||||
}
|
||||
|
||||
/**
|
||||
* @param expirySeconds set to 60 by default
|
||||
*/
|
||||
async getOrSet<T>(
|
||||
setCB: () => Promise<T>,
|
||||
key: string | Buffer,
|
||||
expirySeconds: number = AniwatchAPICache.DEFAULT_CACHE_EXPIRY_SECONDS
|
||||
) {
|
||||
const cachedData = this.isOptional
|
||||
? null
|
||||
: (await this._client?.get(key)) || null;
|
||||
let data = JSON.parse(String(cachedData)) as T;
|
||||
|
||||
if (!data) {
|
||||
data = await setCB();
|
||||
await this._client?.set(
|
||||
key,
|
||||
JSON.stringify(data),
|
||||
"EX",
|
||||
expirySeconds
|
||||
);
|
||||
}
|
||||
return data;
|
||||
}
|
||||
return data;
|
||||
}
|
||||
}
|
||||
|
||||
export const cache = new AniwatchAPICache();
|
||||
|
||||
+35
-30
@@ -5,8 +5,8 @@ import corsConfig from "./config/cors.js";
|
||||
import { ratelimit } from "./config/ratelimit.js";
|
||||
|
||||
import {
|
||||
cacheConfigSetter,
|
||||
cacheControlMiddleware,
|
||||
cacheConfigSetter,
|
||||
cacheControlMiddleware,
|
||||
} from "./middleware/cache.js";
|
||||
import { hianimeRouter } from "./routes/hianime.js";
|
||||
|
||||
@@ -36,52 +36,57 @@ app.use(cacheControlMiddleware);
|
||||
// or other issues if you do.
|
||||
const ISNT_PERSONAL_DEPLOYMENT = Boolean(ANIWATCH_API_HOSTNAME);
|
||||
if (ISNT_PERSONAL_DEPLOYMENT) {
|
||||
app.use(ratelimit);
|
||||
app.use(ratelimit);
|
||||
}
|
||||
|
||||
app.use("/", serveStatic({ root: "public" }));
|
||||
app.get("/health", (c) => c.text("daijoubu", { status: 200 }));
|
||||
app.get("/v", async (c) =>
|
||||
c.text(
|
||||
`v${"version" in pkgJson && pkgJson?.version ? pkgJson.version : "-1"}`
|
||||
)
|
||||
c.text(
|
||||
`v${"version" in pkgJson && pkgJson?.version ? pkgJson.version : "-1"}`
|
||||
)
|
||||
);
|
||||
|
||||
app.use(cacheConfigSetter(BASE_PATH.length));
|
||||
|
||||
app.basePath(BASE_PATH).route("/hianime", hianimeRouter);
|
||||
app
|
||||
.basePath(BASE_PATH)
|
||||
.get("/anicrush", (c) => c.text("Anicrush could be implemented in future."));
|
||||
app.basePath(BASE_PATH).get("/anicrush", (c) =>
|
||||
c.text("Anicrush could be implemented in future.")
|
||||
);
|
||||
|
||||
app.notFound(notFoundHandler);
|
||||
app.onError(errorHandler);
|
||||
|
||||
// NOTE: this env is "required" for vercel deployments
|
||||
if (!Boolean(process.env?.ANIWATCH_API_VERCEL_DEPLOYMENT)) {
|
||||
serve({
|
||||
port: PORT,
|
||||
fetch: app.fetch,
|
||||
}).addListener("listening", () =>
|
||||
console.info(
|
||||
"\x1b[1;36m" + `aniwatch-api at http://localhost:${PORT}` + "\x1b[0m"
|
||||
)
|
||||
);
|
||||
serve({
|
||||
port: PORT,
|
||||
fetch: app.fetch,
|
||||
}).addListener("listening", () =>
|
||||
console.info(
|
||||
"\x1b[1;36m" +
|
||||
`aniwatch-api at http://localhost:${PORT}` +
|
||||
"\x1b[0m"
|
||||
)
|
||||
);
|
||||
|
||||
// NOTE: remove the `if` block below for personal deployments
|
||||
if (ISNT_PERSONAL_DEPLOYMENT) {
|
||||
const interval = 9 * 60 * 1000; // 9mins
|
||||
// NOTE: remove the `if` block below for personal deployments
|
||||
if (ISNT_PERSONAL_DEPLOYMENT) {
|
||||
const interval = 9 * 60 * 1000; // 9mins
|
||||
|
||||
// don't sleep
|
||||
setInterval(() => {
|
||||
console.log("aniwatch-api HEALTH_CHECK at", new Date().toISOString());
|
||||
https
|
||||
.get(`https://${ANIWATCH_API_HOSTNAME}/health`)
|
||||
.on("error", (err) => {
|
||||
console.error(err.message);
|
||||
});
|
||||
}, interval);
|
||||
}
|
||||
// don't sleep
|
||||
setInterval(() => {
|
||||
console.log(
|
||||
"aniwatch-api HEALTH_CHECK at",
|
||||
new Date().toISOString()
|
||||
);
|
||||
https
|
||||
.get(`https://${ANIWATCH_API_HOSTNAME}/health`)
|
||||
.on("error", (err) => {
|
||||
console.error(err.message);
|
||||
});
|
||||
}, interval);
|
||||
}
|
||||
}
|
||||
|
||||
export default app;
|
||||
|
||||
Reference in New Issue
Block a user