tcp.bend relies on unsafe/foreign

raw source on the hub · import 0xd66ee682d4ce8c656782ca9e0e4634cb/tcp.bend as Tcp

TCP byte effects: raw send, raw recv and one-frame recv over the existing Socket handle.

The binary twins of Base's TCP.send / TCP.recv (which speak String), so WebSocket frames are not forced through UTF-8.

Import as: import ./tcp.bend as TCP (from lib) or import ../../lib/tcp.bend as TCP (from tests/io). Then TCP.send_bytes, TCP.recv_bytes, TCP.recv_frame.

1 import

import Base

Effects (foreign code)

effect send_bytes source · line 15 · raw

@sock:Socket -> @data:List<&2, U32> -> IO(Pair(Socket, Result<&1, &1, Pair(U32, String), Unit>))

Sends every byte of the list, handing the socket back. A value past 255 fails with EINVAL before any byte leaves; a full socket (non- blocking, so EAGAIN) parks until writable.

foreign: effs/tcp_send_bytes.c, effs/tcp_send_bytes.js

effect recv_bytes source · line 22 · raw

@sock:Socket -> @max:U32 -> IO(Pair(Socket, Result<&1, &1, Pair(U32, String), List<&2, U32>>))

Receives at most max bytes as a byte list, handing the socket back; parks until the socket is readable.

foreign: effs/tcp_recv_bytes.c, effs/tcp_recv_bytes.js

effect recv_frame source · line 34 · raw

@sock:Socket -> @buf:List<&2, U32> -> @max:U32 -> IO(Pair(Socket, Result<&1, &1, Pair(U32, String), Pair(List<&2, U32>, List<&2, U32>)>))

Isolates exactly one WebSocket frame: reads the socket until the length prefix says the frame is complete, then answers the frame plus every byte already read past it, so the caller threads the rest into the next call and no byte is lost. buf seeds the read (usually the previous rest); max caps the frame (a larger total is Fail 413), a partial EOF is Fail 400 "eof". The length prefix alone decides the size; the pure codec rejects invalid frames out of the isolated bytes.

foreign: effs/tcp_recv_frame.c, effs/tcp_recv_frame.js