pangolin_mirror/pangolin
1
0
Fork 0
mirror of https://github.com/fosrl/pangolin.git synced 2026-03-07 11:16:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

Import tcm

Browse Source
This commit is contained in:
Owen
2025-08-12 16:31:53 -07:00
parent 39e35bc1d6
commit 880a123149
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
server/hybridClientServer.ts
View File

@@ -6,8 +6,13 @@ import config from "@server/lib/config";
import { WebSocketClient, createWebSocketClient } from "./routers/ws/client"; import { WebSocketClient, createWebSocketClient } from "./routers/ws/client";
import { addPeer, deletePeer } from "./routers/gerbil/peers"; import { addPeer, deletePeer } from "./routers/gerbil/peers";
import { db, exitNodes } from "./db"; import { db, exitNodes } from "./db";
import { TraefikConfigManager } from "./lib/remoteTraefikConfig";
export async function createHybridClientServer() { export async function createHybridClientServer() {
const monitor = new TraefikConfigManager();
await monitor.start();
if ( if (
!config.getRawConfig().hybrid?.id || !config.getRawConfig().hybrid?.id ||
!config.getRawConfig().hybrid?.secret || !config.getRawConfig().hybrid?.secret ||
@@ -33,7 +38,7 @@ export async function createHybridClientServer() {
client.registerHandler("remote/peers/add", async (message) => { client.registerHandler("remote/peers/add", async (message) => {
const { pubKey, allowedIps } = message.data; const { pubKey, allowedIps } = message.data;
// TODO: we are getting the exit node twice here // TODO: we are getting the exit node twice here
// NOTE: there should only be one gerbil registered so... // NOTE: there should only be one gerbil registered so...
const [exitNode] = await db.select().from(exitNodes).limit(1); const [exitNode] = await db.select().from(exitNodes).limit(1);
await addPeer(exitNode.exitNodeId, { await addPeer(exitNode.exitNodeId, {
@@ -45,7 +50,7 @@ export async function createHybridClientServer() {
client.registerHandler("remote/peers/remove", async (message) => { client.registerHandler("remote/peers/remove", async (message) => {
const { pubKey } = message.data; const { pubKey } = message.data;
// TODO: we are getting the exit node twice here // TODO: we are getting the exit node twice here
// NOTE: there should only be one gerbil registered so... // NOTE: there should only be one gerbil registered so...
const [exitNode] = await db.select().from(exitNodes).limit(1); const [exitNode] = await db.select().from(exitNodes).limit(1);
await deletePeer(exitNode.exitNodeId, pubKey); await deletePeer(exitNode.exitNodeId, pubKey);