mirror/fosrl.pangolin
1
0
Fork 0
mirror of https://github.com/fosrl/pangolin.git synced 2025-08-22 02:08:31 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Move exit node function

Browse source
This commit is contained in:
Owen 2025-08-15 15:52:09 -07:00
parent 5c94887949
commit 21ce678e5b
No known key found for this signature in database
GPG key ID: 8271FDFFD9E0CCBD
2 changed files with 14 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

12
server/lib/exitNodes/exitNodes.ts
View file

@ -1,5 +1,6 @@
import { db, exitNodes } from "@server/db"; import { db, exitNodes } from "@server/db";
import logger from "@server/logger"; import logger from "@server/logger";
import { ExitNodePingResult } from "@server/routers/newt";
import { eq, and, or } from "drizzle-orm"; import { eq, and, or } from "drizzle-orm";
export async function verifyExitNodeOrgAccess( export async function verifyExitNodeOrgAccess(
@ -41,3 +42,14 @@ export async function listExitNodes(orgId: string, filterOnline = false) {
return allExitNodes; return allExitNodes;
} }
export function selectBestExitNode(
pingResults: ExitNodePingResult[]
): ExitNodePingResult | null {
if (!pingResults || pingResults.length === 0) {
logger.warn("No ping results provided");
return null;
}
return pingResults[0];
}

13
server/routers/newt/handleNewtRegisterMessage.ts
View file

@ -9,7 +9,7 @@ import {
findNextAvailableCidr, findNextAvailableCidr,
getNextAvailableClientSubnet getNextAvailableClientSubnet
} from "@server/lib/ip"; } from "@server/lib/ip";
import { verifyExitNodeOrgAccess } from "@server/lib/exitNodes"; import { selectBestExitNode, verifyExitNodeOrgAccess } from "@server/lib/exitNodes";
export type ExitNodePingResult = { export type ExitNodePingResult = {
exitNodeId: number; exitNodeId: number;
@ -266,14 +266,3 @@ export const handleNewtRegisterMessage: MessageHandler = async (context) => {
excludeSender: false // Include sender in broadcast excludeSender: false // Include sender in broadcast
}; };
}; };
function selectBestExitNode(
pingResults: ExitNodePingResult[]
): ExitNodePingResult | null {
if (!pingResults || pingResults.length === 0) {
logger.warn("No ping results provided");
return null;
}
return pingResults[0];
}