Test koşumundaki keep-alive soket flake'ini kapat (#61)

CI'da ara sıra düşen `orbit-slice3-tests.ts` feed testinin kök nedenini
kapatır.

## Belirti

Test ilk `fetch`'te, hiçbir iddiaya varmadan 3-4 ms içinde düşüyordu:

```
TypeError: fetch failed
  cause: SocketError: other side closed  (UND_ERR_SOCKET)
  socket: { bytesWritten: 370, bytesRead: 1631 }
```

## Kök neden

Sunucunun ayakta olmamasıyla ilgili değil. `bytesRead` sıfır değil, yani
o soket
daha önce bir yanıt taşımış: undici'nin havuzundan gelen bir keep-alive
bağlantısı. Sunucu onu kapatmış, istemci ölü sokete yazmış.

İstemcinin kapanmayı neden kaçırdığı: bu dosyalar worker ayaktayken
`spawnSync`
ile ikinci wrangler süreçleri koşturuyor. `spawnSync` olay döngüsünü
saniyelerce
tamamen durduruyor; o sürede undici ne FIN'i işleyebiliyor ne de soketi
havuzdan
atacak zamanlayıcıyı çalıştırabiliyor. Blok biter bitmez gelen `fetch`
aynı
senkron adımda ölü sokete yazıyor.

HTTP/1.1'de yazmadan önce bağlantının açık olduğunu bilmenin yolu yok.
Normal
istemciler bunu tekrar denemeyle örter; testte örtmek istemiyoruz. Kalan
sağlam
seçenek bağlantıyı hiç yeniden kullanmamak.

## Değişiklik

`scripts/support/test-http.ts` (yeni): `useFreshConnectionPerRequest()`
—
`setGlobalDispatcher(new Agent({ pipelining: 0 }))`. `pipelining: 0`
undici'de
keep-alive'ı kapatır; undici dokümanında belgeli yol, tip tanımları da
`keepAlive` yerine bunu öneriyor.

Yerel worker'a HTTP yapan dokuz dosyada import + tek satır çağrı.
`undici`
devDependencies'e eklendi (zaten `overrides`ta pinliydi ve ağaçtaydı;
artık
doğrudan içe aktarıldığı için açıkça duruyor).

İkinci commit bir bekçi ekliyor: `setGlobalDispatcher` global bir
sembole yazıp
Node'un yerleşik `fetch`'inin onu okumasına güveniyor. Bu bağ ileride
koparsa
çağrı sessizce hiçbir şey yapmaz — keep-alive geri gelir, yarış yeniden
açılır ve
hiçbir test kırılmaz, çünkü geri gelen şey ara sıra düşen bir yarış.
Bekçi ayarın
yerleştiğini kurulum anında doğruluyor.

Hiçbir iddia gevşetilmedi, `skip` yok, süre uzatılmadı, retry yok. 126
ekleme,
sıfır silme.

## Ölçüm

`orbit-slice3-tests`, `diagnostics_channel` ile aynı 63 istek üzerinden:

| | bağlantı | istek | yeniden kullanım |
|---|---|---|---|
| önce | 2 | 57 | **55** |
| sonra | 57 | 57 | **0** |

Bekçi mutasyonla sınandı: `setGlobalDispatcher` devre dışı
bırakıldığında
ateşliyor, geri alındığında sessiz.

Çıkış kodu 0 dönenler: `npm run check` (213 dosya, 0 hata), `npm run
test:d1`
(341/341, birkaç kez).

## Dürüstlük notu

Gerçek testi istekle düşüremedik. Mekanizma izole ortamda tetiklendi
(düz fetch
8 turun 4'ünde düşüyor, `pipelining: 0` ile 0/8), ama asıl dosyada yarış
penceresi
zamanlanamayacak kadar dar. Yani: bütün kanıtlarla tutarlı olan
mekanizma
ortadan kaldırıldı; "flake kesin bitti" iddiası bu kadarıyla kanıtlanmış
değil.

Ayrıca workerd'in FIN'i tam olarak neden gönderdiği açık kalıyor.
Düzeltme
tetikleyiciden bağımsız çalışıyor (yeniden kullanılan soket yoksa yarış
da yok),
ama sebep kapatılmış sayılmamalı.

## Ayrı iş olarak kalanlar

- `orbit-slice3-tests.ts:127,134` — worker ayaktayken aynı persist
dizinine
ikinci wrangler süreci. Bu kalıp #51'de slice1'den deterministik
ECONNRESET
  sebebi olarak kaldırılmıştı, burada kalmış; bu flake'in ön koşulu olan
  bloklamayı da o yaratıyor.
- `waitForWorker` ilk 200'ü hazır sayıyor; sonradan bir yeniden başlatma
olursa
  fark edilmez.
- Altı test dosyası ortak dev registry'ye aynı worker adıyla yazıyor.

🤖 Generated with [Claude Code](https://claude.com/claude-code)

---------

Co-authored-by: Claude Opus 5 <noreply@anthropic.com>

Author: sametbasbug

package-lock.json

@@ -77,6 +77,7 @@
     "sharp": "^0.35.3",
     "tsx": "4.23.12",
     "typescript": "6.0.3",
+    "undici": "^7.29.0",
     "wrangler": "4.125.0"
   },
   "overrides": {

package.json

@@ -5,13 +5,18 @@ import { tmpdir } from 'node:os';
 import path from 'node:path';
 import { after, before, describe, test } from 'node:test';
 import { reserveWorkerPorts } from './orbit-test-ports';
+import { useFreshConnectionPerRequest } from './support/test-http';
 import { BACKUP_SCHEMA_VERSION } from '../src/server/backup/dynamic-backup';
 import {
   createOpaqueToken,
   parseOpaqueToken,
   verifyOpaqueToken,
 } from '../src/server/identity/tokens';
 
+/* Havuzda bekleyen bir keep-alive soketi, bu dosyanın spawnSync
+ * bloklarından sağ çıkmıyor; gerekçesi support/test-http.ts içinde. */
+useFreshConnectionPerRequest();
+
 const ROOT = process.cwd();
 const WRANGLER = path.join(ROOT, 'node_modules', 'wrangler', 'bin', 'wrangler.js');
 const CONFIG = 'wrangler.test.jsonc';

scripts/orbit-mcp-authorization-tests.ts

@@ -5,6 +5,7 @@ import { tmpdir } from 'node:os';
 import path from 'node:path';
 import { after, before, describe, test } from 'node:test';
 import { reserveWorkerPorts } from './orbit-test-ports';
+import { useFreshConnectionPerRequest } from './support/test-http';
 import {
   normalizeSiteAuthorizationScopes,
   parseSiteAuthorizationScopes,
@@ -30,6 +31,10 @@ import {
 } from '../src/server/identity/site-authorization-request';
 import { siteConsentPage } from '../src/server/http/site-consent-page';
 
+/* Havuzda bekleyen bir keep-alive soketi, bu dosyanın spawnSync
+ * bloklarından sağ çıkmıyor; gerekçesi support/test-http.ts içinde. */
+useFreshConnectionPerRequest();
+
 const ROOT = process.cwd();
 const WRANGLER = path.join(ROOT, 'node_modules', 'wrangler', 'bin', 'wrangler.js');
 const CONFIG = 'wrangler.test.jsonc';

scripts/orbit-site-authorization-tests.ts

@@ -21,8 +21,13 @@ import path from 'node:path';
 import { after, before, describe, test } from 'node:test';
 
 import { reserveWorkerPorts } from './orbit-test-ports';
+import { useFreshConnectionPerRequest } from './support/test-http';
 import { createOpaqueToken, hmacDigest, randomBase64Url } from '../src/server/identity/tokens';
 
+/* Havuzda bekleyen bir keep-alive soketi, bu dosyanın spawnSync
+ * bloklarından sağ çıkmıyor; gerekçesi support/test-http.ts içinde. */
+useFreshConnectionPerRequest();
+
 const ROOT = process.cwd();
 const WRANGLER = path.join(ROOT, 'node_modules', 'wrangler', 'bin', 'wrangler.js');
 const CONFIG = 'wrangler.slice1-test.jsonc';

scripts/orbit-site-client-registration-tests.ts

@@ -18,13 +18,18 @@ import { tmpdir } from 'node:os';
 import path from 'node:path';
 import { after, before, describe, test } from 'node:test';
 import { reserveWorkerPorts } from './orbit-test-ports';
+import { useFreshConnectionPerRequest } from './support/test-http';
 import {
   createOpaqueToken,
   hmacDigest,
   randomBase64Url,
   sha256Base64Url,
 } from '../src/server/identity/tokens';
 
+/* Havuzda bekleyen bir keep-alive soketi, bu dosyanın spawnSync
+ * bloklarından sağ çıkmıyor; gerekçesi support/test-http.ts içinde. */
+useFreshConnectionPerRequest();
+
 const ROOT = process.cwd();
 const WRANGLER = path.join(ROOT, 'node_modules', 'wrangler', 'bin', 'wrangler.js');
 const CONFIG = 'wrangler.slice1-test.jsonc';

scripts/orbit-site-signin-e2e-tests.ts

@@ -5,6 +5,7 @@ import { tmpdir } from 'node:os';
 import path from 'node:path';
 import { after, before, describe, test } from 'node:test';
 import { reserveWorkerPorts } from './orbit-test-ports';
+import { useFreshConnectionPerRequest } from './support/test-http';
 import {
   CSRF_COOKIE,
   CSRF_HEADER,
@@ -21,6 +22,10 @@ import {
 } from '../src/server/identity/tokens';
 import { LEGAL_LAST_UPDATED } from '../src/data/legal';
 
+/* Havuzda bekleyen bir keep-alive soketi, bu dosyanın spawnSync
+ * bloklarından sağ çıkmıyor; gerekçesi support/test-http.ts içinde. */
+useFreshConnectionPerRequest();
+
 const ROOT = process.cwd();
 const WRANGLER = path.join(ROOT, 'node_modules', 'wrangler', 'bin', 'wrangler.js');
 const CONFIG = 'wrangler.slice1-test.jsonc';

scripts/orbit-slice1-tests.ts

@@ -5,8 +5,13 @@ import { tmpdir } from 'node:os';
 import path from 'node:path';
 import { after, before, describe, test } from 'node:test';
 import { reserveWorkerPorts } from './orbit-test-ports';
+import { useFreshConnectionPerRequest } from './support/test-http';
 import { loadManifest, verifyManifest } from './orbit-slice3-manifest';
 
+/* Havuzda bekleyen bir keep-alive soketi, bu dosyanın spawnSync
+ * bloklarından sağ çıkmıyor; gerekçesi support/test-http.ts içinde. */
+useFreshConnectionPerRequest();
+
 const ROOT = process.cwd();
 const WRANGLER = path.join(ROOT, 'node_modules', 'wrangler', 'bin', 'wrangler.js');
 const CONFIG = 'wrangler.slice1-test.jsonc';

scripts/orbit-slice3-tests.ts

@@ -5,6 +5,7 @@ import { mkdtemp, readdir, readFile, rm } from 'node:fs/promises';
 import { tmpdir } from 'node:os';
 import { after, before, describe, test } from 'node:test';
 import { reserveWorkerPorts } from './orbit-test-ports';
+import { useFreshConnectionPerRequest } from './support/test-http';
 import { createEntityId } from '../src/server/foundation/ids';
 import { createOpaqueToken, hmacDigest, randomBase64Url, sha256Base64Url } from '../src/server/identity/tokens';
 import { canonicalJson } from '../src/server/publication/content';
@@ -15,6 +16,10 @@ import {
   type DynamicBackup,
 } from '../src/server/backup/dynamic-backup';
 
+/* Havuzda bekleyen bir keep-alive soketi, bu dosyanın spawnSync
+ * bloklarından sağ çıkmıyor; gerekçesi support/test-http.ts içinde. */
+useFreshConnectionPerRequest();
+
 const ROOT = process.cwd();
 const WRANGLER = path.join(ROOT, 'node_modules', 'wrangler', 'bin', 'wrangler.js');
 const TSX = path.join(ROOT, 'node_modules', 'tsx', 'dist', 'cli.mjs');

scripts/orbit-slice4-tests.ts

@@ -5,6 +5,7 @@ import { mkdtemp, rm } from 'node:fs/promises';
 import { tmpdir } from 'node:os';
 import { after, before, describe, test } from 'node:test';
 import { reserveWorkerPorts } from './orbit-test-ports';
+import { useFreshConnectionPerRequest } from './support/test-http';
 import { createEntityId } from '../src/server/foundation/ids';
 import { createOpaqueToken, hmacDigest, randomBase64Url, sha256Base64Url } from '../src/server/identity/tokens';
 import { canonicalJson } from '../src/server/publication/content';
@@ -17,6 +18,10 @@ import { verifyDynamicBackup } from '../src/server/backup/dynamic-backup';
 import { ImageTransformError, inspectImage, transformImage } from '../src/server/media/image-processor';
 import sharp from 'sharp';
 
+/* Havuzda bekleyen bir keep-alive soketi, bu dosyanın spawnSync
+ * bloklarından sağ çıkmıyor; gerekçesi support/test-http.ts içinde. */
+useFreshConnectionPerRequest();
+
 const ROOT = process.cwd();
 const WRANGLER = path.join(ROOT, 'node_modules', 'wrangler', 'bin', 'wrangler.js');
 const TSX = path.join(ROOT, 'node_modules', 'tsx', 'dist', 'cli.mjs');