3 Commits

Author SHA1 Message Date
Indrawan I.
67be3acc6e fix: proper error handler (#23)
* re use legacy errors

* 8.3.6-alpha
2026-05-14 09:56:52 +07:00
SNEK WAIFU
e92cb6ca8a ee 2026-05-14 08:09:23 +07:00
SNEK WAIFU
85a45cf575 eeee 2026-05-14 08:09:04 +07:00
3 changed files with 72 additions and 72 deletions

View File

@@ -1,6 +1,6 @@
{ {
"name": "lustpress", "name": "lustpress",
"version": "8.3.4-alpha", "version": "8.3.6-alpha",
"description": "RESTful and experimental API for PH and other R18 websites", "description": "RESTful and experimental API for PH and other R18 websites",
"main": "src/index.ts", "main": "src/index.ts",
"scripts": { "scripts": {

View File

@@ -9,7 +9,7 @@ const keyv = process.env.REDIS_URL
: new Keyv(); : new Keyv();
keyv.on("error", (err) => console.log("Connection Error", err)); keyv.on("error", (err) => console.log("Connection Error", err));
const ttl = 1000 * 60 * 60 * Number(process.env.EXPIRE_CACHE); const ttl = 1000 * 60 * 60 * Number(process.env.EXPIRE_CACHE || "1");
const GEO_TIMEOUT_MS = 3000; const GEO_TIMEOUT_MS = 3000;
let cachedLastLocation: string | null = null; let cachedLastLocation: string | null = null;
@@ -88,7 +88,7 @@ class LustPress {
const domain = new URL(url).hostname; const domain = new URL(url).hostname;
const headers: Record<string, string> = { const headers: Record<string, string> = {
"User-Agent": isPornhub ? this.browserUA : this.useragent, "User-Agent": isPornhub ? this.browserUA : this.useragent
}; };
if (isPornhub) { if (isPornhub) {

View File

@@ -1,69 +1,69 @@
import { Elysia } from "elysia"; import { Elysia } from "elysia";
import { cors } from "@elysiajs/cors"; import { cors } from "@elysiajs/cors";
import { swagger } from "@elysiajs/swagger"; import { swagger } from "@elysiajs/swagger";
import { lust } from "./LustPress"; import { lust } from "./LustPress";
import { scrapeRoutes } from "./router/endpoint"; import { scrapeRoutes } from "./router/endpoint";
import pkg from "../package.json"; import pkg from "../package.json";
const app = new Elysia() const app = new Elysia()
.use(cors()) .use(cors())
.use( .use(
swagger({ swagger({
path: "/docs", path: "/docs",
documentation: { documentation: {
info: { info: {
title: "Lustpress API", title: "Lustpress API",
version: pkg.version, version: pkg.version,
description: pkg.description, description: pkg.description,
}, },
}, },
}) })
) )
.get("/", async () => ({ .get("/", async () => ({
success: true, success: true,
playground: "https://sinkaroid.github.io/lustpress", playground: "https://sinkaroid.github.io/lustpress",
endpoint: endpoint:
"https://github.com/sinkaroid/lustpress/blob/master/README.md#routing", "https://github.com/sinkaroid/lustpress/blob/master/README.md#routing",
date: new Date().toLocaleString(), date: new Date().toLocaleString(),
rss: lust.currentProccess().rss, rss: lust.currentProccess().rss,
heap: lust.currentProccess().heap, heap: lust.currentProccess().heap,
server: await lust.getServer(), server: await lust.getServer(),
version: pkg.version, version: pkg.version,
})) }))
.use(scrapeRoutes) .onError(({ code, error, set }) => {
.onError(({ code, error, set }) => { if (code === "NOT_FOUND") {
if (code === "NOT_FOUND") { set.status = 404;
set.status = 404; return {
return { success: false,
success: false, message: (error as Error).message || "Not Found",
message: (error as Error).message || "Not Found", };
}; }
} if (code === "VALIDATION") {
if (code === "VALIDATION") { set.status = 400;
set.status = 400; return {
return { success: false,
success: false, message: JSON.parse((error as Error).message)[0]?.message || "Validation Error",
message: JSON.parse((error as Error).message)[0]?.message || "Validation Error", };
}; }
} if (code === "UNKNOWN") {
if (code === "UNKNOWN") { set.status = 400;
set.status = 400; return {
return { success: false,
success: false, message: (error as Error).message,
message: (error as Error).message, };
}; }
} set.status = 500;
set.status = 500; return {
return { success: false,
success: false, message: (error as Error).message || "Internal Server Error",
message: (error as Error).message || "Internal Server Error", stack: (error as Error).stack,
stack: (error as Error).stack, };
}; })
}) .use(scrapeRoutes) // reuse legacy error handling
.listen(process.env.PORT || 3000); .listen(process.env.PORT || 3000);
console.log( console.log(
`Lustpress is running at ${app.server?.hostname}:${app.server?.port}` `Lustpress is running at ${app.server?.hostname}:${app.server?.port}`
); );
export type App = typeof app; export type App = typeof app;