mirror of
https://github.com/versia-pub/server.git
synced 2025-12-06 08:28:19 +01:00
74 lines
2.5 KiB
TypeScript
74 lines
2.5 KiB
TypeScript
import { logger } from "@loggers";
|
|
import { errorResponse, response } from "@response";
|
|
import type { SocketAddress } from "bun";
|
|
import { createMiddleware } from "hono/factory";
|
|
import { matches } from "ip-matching";
|
|
import { config } from "~packages/config-manager";
|
|
import { LogLevel } from "~packages/log-manager";
|
|
|
|
export const bait = createMiddleware(async (context, next) => {
|
|
const request_ip = context.env?.ip as SocketAddress | undefined | null;
|
|
|
|
if (config.http.bait.enabled) {
|
|
// Check for bait IPs
|
|
if (request_ip?.address) {
|
|
for (const ip of config.http.bait.bait_ips) {
|
|
try {
|
|
if (matches(ip, request_ip.address)) {
|
|
const file = Bun.file(
|
|
config.http.bait.send_file || "./beemovie.txt",
|
|
);
|
|
|
|
if (await file.exists()) {
|
|
return response(file);
|
|
}
|
|
await logger.log(
|
|
LogLevel.ERROR,
|
|
"Server.Bait",
|
|
`Bait file not found: ${config.http.bait.send_file}`,
|
|
);
|
|
}
|
|
} catch (e) {
|
|
logger.log(
|
|
LogLevel.ERROR,
|
|
"Server.IPCheck",
|
|
`Error while parsing bait IP "${ip}" `,
|
|
);
|
|
logger.logError(
|
|
LogLevel.ERROR,
|
|
"Server.IPCheck",
|
|
e as Error,
|
|
);
|
|
|
|
return errorResponse(
|
|
`A server error occured: ${(e as Error).message}`,
|
|
500,
|
|
);
|
|
}
|
|
}
|
|
}
|
|
|
|
// Check for bait user agents (regex)
|
|
const ua = context.req.header("user-agent") ?? "";
|
|
|
|
for (const agent of config.http.bait.bait_user_agents) {
|
|
if (new RegExp(agent).test(ua)) {
|
|
const file = Bun.file(
|
|
config.http.bait.send_file || "./beemovie.txt",
|
|
);
|
|
|
|
if (await file.exists()) {
|
|
return response(file);
|
|
}
|
|
await logger.log(
|
|
LogLevel.ERROR,
|
|
"Server.Bait",
|
|
`Bait file not found: ${config.http.bait.send_file}`,
|
|
);
|
|
}
|
|
}
|
|
}
|
|
|
|
await next();
|
|
});
|