From e656910d130748e1b3fb0d148880aaf2d925bd7e Mon Sep 17 00:00:00 2001 From: Zack Davis Date: Thu, 16 Apr 2026 17:14:13 -0500 Subject: [PATCH 1/2] Fix: honor HTTPS_PROXY/HTTP_PROXY env vars in proxy-only environments Node.js built-in fetch (undici) does not respect HTTP_PROXY/HTTPS_PROXY environment variables, causing EAI_AGAIN DNS failures in proxy-only environments (corporate networks, containerized sandboxes, Claude Code remote). Adds undici as an explicit dependency and installs a ProxyAgent as the global fetch dispatcher at startup when any proxy env var is detected. Closes #83 Co-Authored-By: Claude Sonnet 4.6 --- package-lock.json | 10 +++++ package.json | 1 + src/index.ts | 1 + src/utils/proxy.ts | 11 ++++++ tests/unit/utils/proxy.test.ts | 67 ++++++++++++++++++++++++++++++++++ 5 files changed, 90 insertions(+) create mode 100644 src/utils/proxy.ts create mode 100644 tests/unit/utils/proxy.test.ts diff --git a/package-lock.json b/package-lock.json index 17f5b84..e04a50a 100644 --- a/package-lock.json +++ b/package-lock.json @@ -12,6 +12,7 @@ "@modelcontextprotocol/sdk": "^1.26.0", "dotenv": "^17.2.1", "rollbar": "^3.0.0-alpha.6", + "undici": "^7.25.0", "zod": "^3.25.76" }, "bin": { @@ -5871,6 +5872,15 @@ "typescript": ">=4.8.4 <6.0.0" } }, + "node_modules/undici": { + "version": "7.25.0", + "resolved": "https://registry.npmjs.org/undici/-/undici-7.25.0.tgz", + "integrity": "sha512-xXnp4kTyor2Zq+J1FfPI6Eq3ew5h6Vl0F/8d9XU5zZQf1tX9s2Su1/3PiMmUANFULpmksxkClamIZcaUqryHsQ==", + "license": "MIT", + "engines": { + "node": ">=20.18.1" + } + }, "node_modules/undici-types": { "version": "7.16.0", "resolved": "https://registry.npmjs.org/undici-types/-/undici-types-7.16.0.tgz", diff --git a/package.json b/package.json index 28528c9..b74ee91 100644 --- a/package.json +++ b/package.json @@ -48,6 +48,7 @@ "@modelcontextprotocol/sdk": "^1.26.0", "dotenv": "^17.2.1", "rollbar": "^3.0.0-alpha.6", + "undici": "^7.25.0", "zod": "^3.25.76" }, "devDependencies": { diff --git a/src/index.ts b/src/index.ts index 0faf428..2e47fd9 100644 --- a/src/index.ts +++ b/src/index.ts @@ -1,5 +1,6 @@ #!/usr/bin/env node +import "./utils/proxy.js"; import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js"; import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js"; import { registerAllTools } from "./tools/index.js"; diff --git a/src/utils/proxy.ts b/src/utils/proxy.ts new file mode 100644 index 0000000..7fd1819 --- /dev/null +++ b/src/utils/proxy.ts @@ -0,0 +1,11 @@ +import { ProxyAgent, setGlobalDispatcher } from "undici"; + +const proxyUrl = + process.env.HTTPS_PROXY || + process.env.HTTP_PROXY || + process.env.https_proxy || + process.env.http_proxy; + +if (proxyUrl) { + setGlobalDispatcher(new ProxyAgent(proxyUrl)); +} diff --git a/tests/unit/utils/proxy.test.ts b/tests/unit/utils/proxy.test.ts new file mode 100644 index 0000000..80d0bfd --- /dev/null +++ b/tests/unit/utils/proxy.test.ts @@ -0,0 +1,67 @@ +import { describe, it, expect, vi, beforeEach, afterEach } from 'vitest'; + +const mockSetGlobalDispatcher = vi.fn(); +const mockProxyAgentConstructor = vi.fn(); + +vi.mock('undici', () => ({ + setGlobalDispatcher: mockSetGlobalDispatcher, + ProxyAgent: mockProxyAgentConstructor, +})); + +describe('proxy setup', () => { + const originalEnv = process.env; + + beforeEach(() => { + process.env = { ...originalEnv }; + vi.clearAllMocks(); + vi.resetModules(); + }); + + afterEach(() => { + process.env = originalEnv; + }); + + it('sets global dispatcher when HTTPS_PROXY is set', async () => { + process.env.HTTPS_PROXY = 'http://proxy.example.com:8080'; + await import('../../../src/utils/proxy.js'); + expect(mockProxyAgentConstructor).toHaveBeenCalledWith('http://proxy.example.com:8080'); + expect(mockSetGlobalDispatcher).toHaveBeenCalledTimes(1); + }); + + it('sets global dispatcher when HTTP_PROXY is set', async () => { + process.env.HTTP_PROXY = 'http://proxy.example.com:8080'; + await import('../../../src/utils/proxy.js'); + expect(mockProxyAgentConstructor).toHaveBeenCalledWith('http://proxy.example.com:8080'); + expect(mockSetGlobalDispatcher).toHaveBeenCalledTimes(1); + }); + + it('sets global dispatcher when lowercase https_proxy is set', async () => { + process.env.https_proxy = 'http://proxy.example.com:8080'; + await import('../../../src/utils/proxy.js'); + expect(mockProxyAgentConstructor).toHaveBeenCalledWith('http://proxy.example.com:8080'); + expect(mockSetGlobalDispatcher).toHaveBeenCalledTimes(1); + }); + + it('sets global dispatcher when lowercase http_proxy is set', async () => { + process.env.http_proxy = 'http://proxy.example.com:8080'; + await import('../../../src/utils/proxy.js'); + expect(mockProxyAgentConstructor).toHaveBeenCalledWith('http://proxy.example.com:8080'); + expect(mockSetGlobalDispatcher).toHaveBeenCalledTimes(1); + }); + + it('prefers HTTPS_PROXY over HTTP_PROXY', async () => { + process.env.HTTPS_PROXY = 'http://https-proxy.example.com:8080'; + process.env.HTTP_PROXY = 'http://http-proxy.example.com:8080'; + await import('../../../src/utils/proxy.js'); + expect(mockProxyAgentConstructor).toHaveBeenCalledWith('http://https-proxy.example.com:8080'); + }); + + it('does not set global dispatcher when no proxy env vars are set', async () => { + delete process.env.HTTPS_PROXY; + delete process.env.HTTP_PROXY; + delete process.env.https_proxy; + delete process.env.http_proxy; + await import('../../../src/utils/proxy.js'); + expect(mockSetGlobalDispatcher).not.toHaveBeenCalled(); + }); +}); From c127f1d5bd5f10385fbf778d0b60a7a59714c418 Mon Sep 17 00:00:00 2001 From: Brian Rue Date: Thu, 16 Apr 2026 16:19:38 -0700 Subject: [PATCH 2/2] Load .env before proxy setup --- src/config.ts | 6 +-- src/index.ts | 1 + src/load-env.ts | 4 ++ tests/unit/utils/proxy.test.ts | 96 +++++++++++++++++++++++++--------- 4 files changed, 76 insertions(+), 31 deletions(-) create mode 100644 src/load-env.ts diff --git a/src/config.ts b/src/config.ts index d5c960a..25b6bbd 100644 --- a/src/config.ts +++ b/src/config.ts @@ -1,14 +1,10 @@ -import dotenv from "dotenv"; +import "./load-env.js"; import { readFileSync, existsSync } from "node:fs"; import path from "node:path"; import { homedir } from "node:os"; import packageJson from "../package.json" with { type: "json" }; import { z } from "zod"; -// Load environment variables from .env file -// `quiet: true` to prevent logging to stdio which disrupts some mcp clients -dotenv.config({ quiet: true } as Parameters[0]); - const DEFAULT_ROLLBAR_API_BASE = "https://api.rollbar.com/api/1"; const HttpUrlSchema = z diff --git a/src/index.ts b/src/index.ts index 2e47fd9..72ad5c2 100644 --- a/src/index.ts +++ b/src/index.ts @@ -1,5 +1,6 @@ #!/usr/bin/env node +import "./load-env.js"; import "./utils/proxy.js"; import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js"; import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js"; diff --git a/src/load-env.ts b/src/load-env.ts new file mode 100644 index 0000000..1d73df5 --- /dev/null +++ b/src/load-env.ts @@ -0,0 +1,4 @@ +import dotenv from "dotenv"; + +// Keep dotenv quiet so MCP stdio stays clean for clients. +dotenv.config({ quiet: true } as Parameters[0]); diff --git a/tests/unit/utils/proxy.test.ts b/tests/unit/utils/proxy.test.ts index 80d0bfd..9d25593 100644 --- a/tests/unit/utils/proxy.test.ts +++ b/tests/unit/utils/proxy.test.ts @@ -1,15 +1,19 @@ -import { describe, it, expect, vi, beforeEach, afterEach } from 'vitest'; +import { describe, it, expect, vi, beforeEach, afterEach } from "vitest"; +import { mkdtempSync, writeFileSync } from "node:fs"; +import { tmpdir } from "node:os"; +import path from "node:path"; const mockSetGlobalDispatcher = vi.fn(); const mockProxyAgentConstructor = vi.fn(); -vi.mock('undici', () => ({ +vi.mock("undici", () => ({ setGlobalDispatcher: mockSetGlobalDispatcher, ProxyAgent: mockProxyAgentConstructor, })); -describe('proxy setup', () => { +describe("proxy setup", () => { const originalEnv = process.env; + const originalCwd = process.cwd(); beforeEach(() => { process.env = { ...originalEnv }; @@ -19,49 +23,89 @@ describe('proxy setup', () => { afterEach(() => { process.env = originalEnv; + process.chdir(originalCwd); }); - it('sets global dispatcher when HTTPS_PROXY is set', async () => { - process.env.HTTPS_PROXY = 'http://proxy.example.com:8080'; - await import('../../../src/utils/proxy.js'); - expect(mockProxyAgentConstructor).toHaveBeenCalledWith('http://proxy.example.com:8080'); + it("sets global dispatcher when HTTPS_PROXY is set", async () => { + process.env.HTTPS_PROXY = "http://proxy.example.com:8080"; + await import("../../../src/utils/proxy.js"); + expect(mockProxyAgentConstructor).toHaveBeenCalledWith( + "http://proxy.example.com:8080", + ); expect(mockSetGlobalDispatcher).toHaveBeenCalledTimes(1); }); - it('sets global dispatcher when HTTP_PROXY is set', async () => { - process.env.HTTP_PROXY = 'http://proxy.example.com:8080'; - await import('../../../src/utils/proxy.js'); - expect(mockProxyAgentConstructor).toHaveBeenCalledWith('http://proxy.example.com:8080'); + it("sets global dispatcher when HTTP_PROXY is set", async () => { + process.env.HTTP_PROXY = "http://proxy.example.com:8080"; + await import("../../../src/utils/proxy.js"); + expect(mockProxyAgentConstructor).toHaveBeenCalledWith( + "http://proxy.example.com:8080", + ); expect(mockSetGlobalDispatcher).toHaveBeenCalledTimes(1); }); - it('sets global dispatcher when lowercase https_proxy is set', async () => { - process.env.https_proxy = 'http://proxy.example.com:8080'; - await import('../../../src/utils/proxy.js'); - expect(mockProxyAgentConstructor).toHaveBeenCalledWith('http://proxy.example.com:8080'); + it("sets global dispatcher when lowercase https_proxy is set", async () => { + process.env.https_proxy = "http://proxy.example.com:8080"; + await import("../../../src/utils/proxy.js"); + expect(mockProxyAgentConstructor).toHaveBeenCalledWith( + "http://proxy.example.com:8080", + ); expect(mockSetGlobalDispatcher).toHaveBeenCalledTimes(1); }); - it('sets global dispatcher when lowercase http_proxy is set', async () => { - process.env.http_proxy = 'http://proxy.example.com:8080'; - await import('../../../src/utils/proxy.js'); - expect(mockProxyAgentConstructor).toHaveBeenCalledWith('http://proxy.example.com:8080'); + it("sets global dispatcher when lowercase http_proxy is set", async () => { + process.env.http_proxy = "http://proxy.example.com:8080"; + await import("../../../src/utils/proxy.js"); + expect(mockProxyAgentConstructor).toHaveBeenCalledWith( + "http://proxy.example.com:8080", + ); expect(mockSetGlobalDispatcher).toHaveBeenCalledTimes(1); }); - it('prefers HTTPS_PROXY over HTTP_PROXY', async () => { - process.env.HTTPS_PROXY = 'http://https-proxy.example.com:8080'; - process.env.HTTP_PROXY = 'http://http-proxy.example.com:8080'; - await import('../../../src/utils/proxy.js'); - expect(mockProxyAgentConstructor).toHaveBeenCalledWith('http://https-proxy.example.com:8080'); + it("prefers HTTPS_PROXY over HTTP_PROXY", async () => { + process.env.HTTPS_PROXY = "http://https-proxy.example.com:8080"; + process.env.HTTP_PROXY = "http://http-proxy.example.com:8080"; + await import("../../../src/utils/proxy.js"); + expect(mockProxyAgentConstructor).toHaveBeenCalledWith( + "http://https-proxy.example.com:8080", + ); }); - it('does not set global dispatcher when no proxy env vars are set', async () => { + it("does not set global dispatcher when no proxy env vars are set", async () => { delete process.env.HTTPS_PROXY; delete process.env.HTTP_PROXY; delete process.env.https_proxy; delete process.env.http_proxy; - await import('../../../src/utils/proxy.js'); + await import("../../../src/utils/proxy.js"); expect(mockSetGlobalDispatcher).not.toHaveBeenCalled(); }); + + it("honors proxy values loaded from .env before proxy setup runs", async () => { + const tempDir = mkdtempSync(path.join(tmpdir(), "rollbar-mcp-proxy-")); + + writeFileSync( + path.join(tempDir, ".env"), + "ROLLBAR_ACCESS_TOKEN=test-token\nHTTPS_PROXY=http://proxy.example.com:8080\n", + ); + + process.chdir(tempDir); + process.env = { + ...originalEnv, + HOME: tempDir, + }; + delete process.env.ROLLBAR_ACCESS_TOKEN; + delete process.env.ROLLBAR_CONFIG_FILE; + delete process.env.HTTPS_PROXY; + delete process.env.HTTP_PROXY; + delete process.env.https_proxy; + delete process.env.http_proxy; + + await import("../../../src/load-env.js"); + await import("../../../src/utils/proxy.js"); + + expect(mockProxyAgentConstructor).toHaveBeenCalledWith( + "http://proxy.example.com:8080", + ); + expect(mockSetGlobalDispatcher).toHaveBeenCalledTimes(1); + }); });