fix(examples): forward abort signal in tanstack-db-web-starter Electric proxy

examples/tanstack-db-web-starter/src/lib/electric-proxy.ts

@@ -42,10 +42,16 @@ export function prepareElectricUrl(requestUrl: string): URL {
 /**
  * Proxies a request to Electric SQL and returns the response
  * @param originUrl - The prepared Electric SQL URL
+ * @param signal - The incoming request's abort signal. Forwarding it means a client disconnect
+ *   also cancels the upstream request, instead of leaving a `live=true` long-poll holding a
+ *   connection to Electric until it times out.
  * @returns The proxied response
  */
-export async function proxyElectricRequest(originUrl: URL): Promise<Response> {
-  const response = await fetch(originUrl)
+export async function proxyElectricRequest(
+  originUrl: URL,
+  signal?: AbortSignal
+): Promise<Response> {
+  const response = await fetch(originUrl, { signal })
   const headers = new Headers(response.headers)
   headers.delete(`content-encoding`)
   headers.delete(`content-length`)

examples/tanstack-db-web-starter/src/routes/api/projects.ts

@@ -20,7 +20,7 @@ const serve = async ({ request }: { request: Request }) => {
   )
   originUrl.searchParams.set(`params[1]`, session.user.id)
 
-  return proxyElectricRequest(originUrl)
+  return proxyElectricRequest(originUrl, request.signal)
 }
 
 export const Route = createFileRoute(`/api/projects`)({

examples/tanstack-db-web-starter/src/routes/api/todos.ts

@@ -17,7 +17,7 @@ const serve = async ({ request }: { request: Request }) => {
   originUrl.searchParams.set(`where`, `$1 = ANY(user_ids)`)
   originUrl.searchParams.set(`params[1]`, session.user.id)
 
-  return proxyElectricRequest(originUrl)
+  return proxyElectricRequest(originUrl, request.signal)
 }
 
 export const Route = createFileRoute(`/api/todos`)({

examples/tanstack-db-web-starter/src/routes/api/users.ts

@@ -14,7 +14,7 @@ const serve = async ({ request }: { request: Request }) => {
   const originUrl = prepareElectricUrl(request.url)
   originUrl.searchParams.set(`table`, `users`)
 
-  return proxyElectricRequest(originUrl)
+  return proxyElectricRequest(originUrl, request.signal)
 }
 
 export const Route = createFileRoute(`/api/users`)({