imterah/hermes
1
0
Fork 0
Code Issues 1 Pull requests Projects Releases 1 Packages Wiki Activity Actions

chore: Adds option to customize pulling rate.

Browse source
This commit is contained in:
greysoh 2024-05-07 18:44:26 -04:00
parent a9fcdea037
commit 0e059d6443
Signed by: imterah
GPG key ID: 8FA7DD57BA6CEA37
1 changed files with 11 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

14
lom/src/commands/connections.ts
View file

@ -88,9 +88,11 @@ export async function run(
getInbound.description("Shows all current connections"); getInbound.description("Shows all current connections");
getInbound.argument("<id>", "Tunnel ID to view inbound connections of"); getInbound.argument("<id>", "Tunnel ID to view inbound connections of");
getInbound.option("-t, --tail", "Live-view of connection list"); getInbound.option("-t, --tail", "Live-view of connection list");
getInbound.option("-s, --tail-pull-rate <ms>", "Controls the speed to pull at (in ms)");
getInbound.action(async(idStr: string, options: { getInbound.action(async(idStr: string, options: {
tail?: boolean tail?: boolean,
tailPullRate?: string
}): Promise<void> => { }): Promise<void> => {
type InboundConnectionSuccess = { type InboundConnectionSuccess = {
success: true, success: true,
@ -107,11 +109,17 @@ export async function run(
}[] }[]
}; };
const pullRate: number = options.tailPullRate ? parseInt(options.tailPullRate) : 2000;
const id = parseInt(idStr); const id = parseInt(idStr);
if (Number.isNaN(id)) { if (Number.isNaN(id)) {
println("ID (%s) is not a number\n", idStr); println("ID (%s) is not a number\n", idStr);
return; return resolve(null);
}
if (Number.isNaN(pullRate)) {
println("Pull rate is not a number\n");
return resolve(null);
} }
if (options.tail) { if (options.tail) {
@ -146,7 +154,7 @@ export async function run(
previousEntries = simplifiedArray; previousEntries = simplifiedArray;
await new Promise((i) => setTimeout(i, 2000)); await new Promise((i) => setTimeout(i, pullRate));
} }
} else { } else {
const response = await axios.post("/api/v1/forward/connections", { const response = await axios.post("/api/v1/forward/connections", {