diff --git a/packages/frontend/src/api/sqs.ts b/packages/frontend/src/api/sqs.ts index e1d29ed..83ee682 100644 --- a/packages/frontend/src/api/sqs.ts +++ b/packages/frontend/src/api/sqs.ts @@ -1,5 +1,5 @@ import { useMutation, useQuery, useQueryClient } from "@tanstack/react-query"; -import { apiClient } from "@/lib/api-client"; +import { apiClient, getConfigHeaders } from "@/lib/api-client"; // --- Interfaces --- @@ -233,7 +233,10 @@ export async function receiveMessagesPoll( const url = new URL(`/api/sqs/${queueName}/messages`, window.location.origin); url.searchParams.set("maxMessages", String(maxMessages)); url.searchParams.set("waitTimeSeconds", String(waitTimeSeconds)); - const response = await fetch(url.toString(), { signal }); + const response = await fetch(url.toString(), { + signal, + headers: { ...getConfigHeaders() }, + }); if (!response.ok) { const body = await response .json() diff --git a/packages/frontend/src/lib/api-client.ts b/packages/frontend/src/lib/api-client.ts index 08a3728..987aeeb 100644 --- a/packages/frontend/src/lib/api-client.ts +++ b/packages/frontend/src/lib/api-client.ts @@ -2,7 +2,7 @@ import { useConfigStore } from "@/stores/config"; const BASE_URL = "/api"; -function getConfigHeaders(): Record { +export function getConfigHeaders(): Record { const { endpoint, region } = useConfigStore.getState(); return { "x-localstack-endpoint": endpoint,