Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 9 additions & 0 deletions .changeset/new-beers-worry.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,9 @@
---
"@opennextjs/aws": patch
---

fix: remove `cf-connecting-ip` headers from external override requests

this change removes `cf-connecting-ip` headers from requests being sent to
external urls during rewrites, this allows such overrides, when run inside a
Cloudflare worker to rewrite to urls also hosted on Cloudflare
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,14 @@ const fetchProxy: ProxyExternalRequest = {
name: "fetch-proxy",
// @ts-ignore
proxy: async (internalEvent) => {
const { url, headers, method, body } = internalEvent;
const { url, headers: eventHeaders, method, body } = internalEvent;

const headers = Object.fromEntries(
Object.entries(eventHeaders).filter(
([key]) => key.toLowerCase() !== "cf-connecting-ip",
),
);

const response = await fetch(url, {
method,
headers,
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,39 @@
import fetchProxy from "@opennextjs/aws/overrides/proxyExternalRequest/fetch.js";
import { vi } from "vitest";

describe("proxyExternalRequest/fetch", () => {
// Note: if the url is hosted on the Cloudflare network we want to make sure that a `cf-connecting-ip` header is not being sent as that causes a DNS error
// (see: https://developers.cloudflare.com/support/troubleshooting/cloudflare-errors/troubleshooting-cloudflare-1xxx-errors/#error-1000-dns-points-to-prohibited-ip)
it("the proxy should remove any cf-connecting-ip headers (with any casing) before passing it to fetch", async () => {
const fetchMock = vi.fn<typeof global.fetch>(async () => new Response());
globalThis.fetch = fetchMock;

const { proxy } = fetchProxy;

await proxy({
headers: {
"header-1": "valid header 1",
"header-2": "valid header 2",
"cf-connecting-ip": "forbidden header 1",
"header-3": "valid header 3",
"CF-Connecting-IP": "forbidden header 2",
"CF-CONNECTING-IP": "forbidden header 3",
"header-4": "valid header 4",
},
});

expect(fetchMock.mock.calls.length).toEqual(1);

const headersPassedToFetch = Object.keys(
fetchMock.mock.calls[0][1]?.headers ?? {},
);

expect(headersPassedToFetch).toContain("header-1");
expect(headersPassedToFetch).toContain("header-2");
expect(headersPassedToFetch).not.toContain("cf-connecting-ip");
expect(headersPassedToFetch).toContain("header-3");
expect(headersPassedToFetch).not.toContain("CF-Connecting-IP");
expect(headersPassedToFetch).not.toContain("CF-CONNECTING-IP");
expect(headersPassedToFetch).toContain("header-4");
});
});