Effect-TS/effect @effect/platform-node-shared@4.0.0-rc.113

on GitHub

Patch Changes

• #8071 2f106a5 Thanks @javascript-unsafe! - Wake NodeStream.pipeThroughDuplex readers when the upstream fails so the original error is propagated instead of hanging.

• #8018 ba2fd82 Thanks @tim-smart! - Wait for Node child process groups to exit during scoped release and kill.

  After signalling a process group, both operations now wait for its leader and descendants. Without forceKillAfter, the wait is limited to one second and never escalates. With forceKillAfter, the group receives SIGKILL at the deadline, followed by a final wait of up to one second. Native timers keep escalation working under a TestClock, and cleanup no longer depends on stdio closing.

  exitCode and isRunning remain tied to the leader's exit, and a leader that already exited successfully still leaves its group untouched. Process group checks count zombies, so cleanup may wait for the full bound under a non-reaping PID 1.

• #7511 a4bb2aa Thanks @tim-smart! - Add NodeSocket.makeTls, NodeSocket.makeTlsChannel, and NodeSocket.layerTls for TLS client connections.

  These mirror the existing makeNet family but dial tls.connect, so they take the full tls.ConnectionOptions set:
  trust anchors (ca), client certificates (cert / key), ALPN protocols, and servername. The socket opens once the
  handshake completes; a failed handshake fails with a SocketOpenError.

• #7512 5664c94 Thanks @tim-smart! - Add NodeSocketServer.makeTls and NodeSocketServer.layerTls for TLS socket servers.

• #7514 b76a1cf Thanks @tim-smart! - Add Socket.upgrade, for upgrading tcp sockets using STARTTLS

• #7514 b76a1cf Thanks @tim-smart! - Use the node-shared socket server on Deno so accepted TCP connections support reader-scoped server TLS upgrades.

  Breaking changes

  DenoSocketServer.make and layer now accept Node listen options. Use host instead of hostname for TCP and
  { path } instead of { transport: "unix", path } for Unix sockets. Deno 2.8.3 or newer is now required.

• #7525 53843f6 Thanks @fubhy! - Add ByteSize module and use it across the ecosystem

• #8110 4ab4e83 Thanks @tim-smart! - Prevent precision loss in Node/Bun filesystem operations and HttpPlatform file responses.

• #8108 c85fc0b Thanks @tim-smart! - On Node and Deno, FileSystem.File.seek now rejects negative resulting positions with a BadArgument platform error, leaving the cursor unchanged. Its return type is now Effect<bigint, PlatformError>.

• #8148 7999b07 Thanks @tim-smart! - Preserve the response Content-Type when compressing file, raw, stream, and byte-array responses on Node, Bun, Deno, and the web platform, including headers overridden after body construction.

• #8112 a6ceb98 Thanks @tim-smart! - Fix File.readAlloc on Node and Deno to fail with PlatformError (BadArgument) for negative, fractional, non-finite, or unallocatable sizes without moving the cursor. Zero-size reads continue to return Option.none() without moving the cursor.

• #7524 0a08ae0 Thanks @fubhy! - Add NetAddress under effect/unstable/net for MAC, IP, internet socket, and Unix socket addresses, with checked parsing, schemas, equality, canonical string serialization, and URL formatting. Companion modules IpInterface and IpNetwork represent IP interfaces and CIDR networks.

  HTTP and socket servers now expose NetAddress.SocketAddress. Replace TCP hostname access with NetAddress.formatIp(address.address) and use UnixPathAddress.path for Unix sockets. URL helpers bracket IPv6 addresses and reject scoped IPv6. Bun and Deno HTTP server layers can now fail with ServeError when listener address conversion fails.

  PostgreSQL inet values now use IpInterface; cidr values use IpNetwork and reject addresses with host bits set.

• #7714 615c41e Thanks @kitlangton! - Prevent Node sinks from submitting buffered writes after interruption while waiting for writable backpressure.

• #7712 d0a6c5e Thanks @kitlangton! - Fix NodeSink hanging when a writable reports an error during finalization.

• #7838 500c60b Thanks @tim-smart! - Remove the ignored bufferSize option from NodeStream.

• #7710 163cebd Thanks @kitlangton! - Fix watch event classification for targets outside the current working directory.

• #7708 37cdd69 Thanks @kitlangton! - Allow File.writeAll to accept empty buffers.

• #7728 0beaf69 Thanks @kitlangton! - Route pipeline handle input through the first process.

• #7487 ba53b64 Thanks @tim-smart! - Redesign Socket around a scoped, pull-based reader with transport backpressure.

  Socket now exposes reader and writer. Client reader acquisition dials and yields a pull of non-empty batches: one buffer for TCP and one entry per WebSocket frame. TCP applies backpressure while paused; pausable WebSockets pause at highWaterMark (64 KiB by default) and resume after draining. Browser WebSockets cannot pause, so they can fail with SocketReadError at a configured highWaterMark. Writes await native drain signals and batch with cork / uncork where available.

  Breaking changes

  • Socket.run, Socket.runString, and Socket.runRaw are removed. Acquire socket.reader (or Socket.readerBytes / Socket.readerString) in a scope and pull in a loop. Code before the first pull replaces onOpen.
  • Socket.make now takes { reader, writer }. The writer acquisition is infallible and yields a Writer with write and writeAll; both operations can still fail with SocketError.
  • Every close fails the pull with SocketError wrapping SocketCloseError. The close-code predicates are removed; use Effect.retry around the scoped read loop to reconnect.
  • Socket.toChannel and Socket.toChannelString now read from the pull and fail on close. Socket.toStream is added for read-only consumption.
  • fromWebSocket drops the onInitialRun option; SendQueueCapacity is removed.
  • Accepted server sockets pause immediately. Their reader attaches to the existing connection and cannot reconnect after close.

• Updated dependencies [49e3901, b945ded, d6422f4, 5a80204, 53511ef, 79ae49f, 0d083ba, be0f822, debe8fd, a8588f9, f17eb0a, f30cbfe, 78cc9c0, ccbdbd5, a63dcbf, b845b18, 381b794, 4ffcaf4, ba2fd82, 02be94c, 115d8c2, 1452635, 77f85fe, a3f2b31, 310f8d3, 291d616, 48dbbb2, b43bfd6, 1c89c78, 9bbe1a5, dd99ab0, 8f397ed, d7ae6b6, 8cf1203, 87654c5, f05ae0b, 436f5eb, d8ff960, 8766475, b64f406, 4697aaa, cec6c2d, 9956f0e, 5c7eed0, 183c2ea, 1e92dbd, 4eb0fa7, 534b8b9, b76a1cf, acc1e53, 4950a91, c020987, abe95d1, 027ceb9, 3d203b7, a29b8f4, ce4aa65, a8ea807, a3ebb7f, 473bd81, 53843f6, c5eca65, d6f9eba, 8d1e97a, b28ab48, 9960708, 8ac53b6, 84ad49a, 72cfa24, 95c2581, d5c7cd2, fe4fed1, d150a64, 05b1e80, 414dc90, 3f51acd, d68ff05, f3cf1e6, 6525771, 4ab4e83, f7f1d78, 47b358a, 45ffa72, 6232650, 4b73e1b, 284050c, c85fc0b, 7999b07, 7d455f5, d681c2e, 84d2a47, ed74b18, 2245997, d386979, fc9fedf, 7750dbe, fc91af6, 39b9738, 88093b5, d14c463, d473bd3, 84864bc, e2ae724, f921ed3, 1df933d, 829aff9, aa0aba3, a71140f, 0276a27, 10d2c98, c86c999, 975f758, 2a3a478, 1e6e206, fa6027b, 7616f73, fc668b6, d425c8c, ce120f4, 248201f, e80d397, f1a941d, 73bc3a1, b628bb1, 6e3ae7b, e891247, 53e6c73, 1579d6f, d3c6b73, 4a59c6a, 145d8e1, f74282c, 0a38623, 0a08ae0, fa6a56b, d60c5d4, 07ffd25, 9b517ad, 604b1c1, ccc2e02, 14d810a, a9d1ee3, a31adbe, 7245f87, 3a0828b, cd83544, 6550a07, 6f090d4, b505c0d, 186dd49, 9f37e58, 4446451, 58be972, 1320075, ba53b64, f7490d4, c8ea602, 62d82f4, a2c9e7c, 97dd022, f984ee8, f1b2910, a29e05a, 1aa1d8b, bb99734, 222e7ca, 797c9e3, b4d5398, c8349ed, 8426e5f, 26e0085, 1a86166, 0856631, 0af0985, bc582c9, 2c63f1e, 0d98213, ca6f0dc, d8cc9ed, 42fd969, 5641ad3, 629870d, d592c14, 10d2c98, 53909a9, 78a4269, 06c6307, 0847c41, 5a77084, 96f99b3, 7bb8781, 4907e9b, 2a30248, 8364ddd, ad67d8c, ec0c087, fa6a56b, a2c1ce6, 91e9af0, 7bd3f34, ef16581, 1693a87, df3fc47, e11be41, 2e39e8b, 11c5ee7, 1742d2f, 8efc70e, 9642776, 6680828, c34edcb, 7b2c5bd, 1a2ccee, db995df, af0ccdd, addeaea, 7704034, e72b12f, 310dd9c, 1c2afc1, 44f44ca, f43b9d6, 56e72b3, 50ef80e, fc3b718, ee336d8, d12f922, 46d8310, 59812fd, f9d0dec, 4372c79, 81485ef, bd393d6, 0c95c04]:

  • effect@4.0.0-rc.113