From ba33cb9895563503e50d2c90129db35303c44f6c Mon Sep 17 00:00:00 2001 From: Owen Date: Wed, 1 Jul 2026 15:44:08 -0400 Subject: [PATCH] Increment config version for this --- .../routers/remoteExitNode/setRemoteExitNodeResources.ts | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/server/private/routers/remoteExitNode/setRemoteExitNodeResources.ts b/server/private/routers/remoteExitNode/setRemoteExitNodeResources.ts index 8416f0169..feea447ed 100644 --- a/server/private/routers/remoteExitNode/setRemoteExitNodeResources.ts +++ b/server/private/routers/remoteExitNode/setRemoteExitNodeResources.ts @@ -27,6 +27,7 @@ import createHttpError from "http-errors"; import logger from "@server/logger"; import { fromError } from "zod-validation-error"; import { sendToClientsBatch } from "#private/routers/ws"; +import { canCompress } from "@server/lib/clientVersionChecks"; const paramsSchema = z.strictObject({ orgId: z.string().min(1), @@ -123,17 +124,21 @@ export async function setRemoteExitNodeResources( // Notify all newts connected to this remote exit node's exit node if (remoteExitNode.exitNodeId) { const connectedNewts = await db - .select({ newtId: newts.newtId }) + .select({ newtId: newts.newtId, version: newts.version }) .from(newts) .innerJoin(sites, eq(newts.siteId, sites.siteId)) .where(eq(sites.exitNodeId, remoteExitNode.exitNodeId)); await sendToClientsBatch( - connectedNewts.map(({ newtId }) => ({ + connectedNewts.map(({ newtId, version }) => ({ clientId: newtId, message: { type: "newt/wg/subnets/update", data: { subnets: destinations } + }, + options: { + incrementConfigVersion: true, + compress: canCompress(version, "newt") } })) );