{-# LANGUAGE DataKinds #-}
{-# LANGUAGE GADTs #-}
{-# LANGUAGE OverloadedStrings #-}
{-# LANGUAGE PatternSynonyms #-}
{-# LANGUAGE ScopedTypeVariables #-}
{-# LANGUAGE TypeApplications #-}

-- | Per-function tests for the smp-web TypeScript SMP client library.
-- Each test calls the Haskell function and the corresponding TypeScript function
-- via node, then asserts byte-identical output.
--
-- Prerequisites: cd smp-web && npm install && npm run build
-- Run: cabal test --test-option=--match="/SMP Web Client/"
module SMPWebTests (smpWebTests) where

import Control.Concurrent.STM
import Control.Monad (forM, forM_, when)
import Data.Bifunctor (first)
import Control.Exception (bracket)
import Control.Monad.Except (ExceptT, liftEither, runExceptT, throwError, withExceptT)
import Crypto.Random (ChaChaDRG)
import Data.IORef
import System.IO (Handle, hFlush, hGetLine, hPutStr, hSetBuffering, BufferMode (..))
import System.Process (CreateProcess (..), StdStream (..), ProcessHandle, createProcess, proc, terminateProcess)
import qualified Data.ByteString as B
import qualified Data.ByteString.Char8 as BC
import Data.List (isInfixOf, isPrefixOf)
import Data.List.NonEmpty (NonEmpty (..))
import System.Directory (doesDirectoryExist)
import Data.Word (Word16)
import qualified Simplex.Messaging.Agent as A
import qualified Simplex.Messaging.Agent.Protocol as AP
import Simplex.Messaging.Agent.Protocol (CreatedConnLink (..), UserLinkData (..), UserContactData (..), UserConnLinkData (..))
import Simplex.Messaging.Client (pattern NRMInteractive, authTransmission, getProtocolClient, defaultSMPClientConfig, ProtocolClientConfig (..), connectSMPProxiedRelay, proxySMPMessage, closeProtocolClient, ProxyClientError (..))
import Simplex.Messaging.Version (mkVersionRange)
import Simplex.Messaging.Version.Internal (Version (..))
import qualified Simplex.Messaging.Crypto as C
import Simplex.Messaging.Crypto (Algorithm (..))
import qualified Simplex.Messaging.Crypto.Ratchet as CR
import Simplex.Messaging.Crypto.SNTRUP761.Bindings (KEMPublicKey (..), KEMSecretKey, KEMCiphertext (..), KEMSharedKey (..), sntrup761Keypair, sntrup761Enc, sntrup761Dec)
import qualified Crypto.Cipher.Types as AES
import qualified Data.Map.Strict as M
import qualified Data.ByteArray as BA
import Simplex.Messaging.Crypto.ShortLink (contactShortLinkKdf, invShortLinkKdf)
import Simplex.Messaging.Encoding
import Simplex.Messaging.Encoding.String (Str (..), strEncode)
import Simplex.Messaging.Protocol (EntityId (..), SMPServer, SubscriptionMode (..), MsgFlags (..), noMsgFlags, pattern SMPServer, pattern NoEntity, encodeProtocol, Cmd (..), SParty (..), Command (..), NewQueueReq (..), QueueReqData (..), BrokerMsg (..), RcvMessage (..), EncRcvMsgBody (..), QueueIdsKeys (..), PubHeader (..), PrivHeader (..), ClientMessage (..), ClientMsgEnvelope (..), pattern VersionSMPC)
import Simplex.Messaging.Server.Env.STM (AStoreType (..), ServerConfig (..))
import Simplex.Messaging.Server.MsgStore.Types (SMSType (..), SQSType (..))
import Simplex.Messaging.Server.Web (attachStaticAndWS)
import Data.Time.Clock (getCurrentTime)
import Simplex.Messaging.Transport (TLS, transport, smpBlockSize, currentServerSMPRelayVersion, currentClientSMPRelayVersion, minServerSMPRelayVersion, supportedClientSMPRelayVRange, alpnSupportedSMPHandshakes)
import Simplex.Messaging.Version (mkVersionRange)
import Simplex.Messaging.Transport.Server (ServerCredentials (..), mkTransportServerConfig)
import Simplex.Messaging.Transport.HTTP2 (httpALPN)
import Simplex.Messaging.Transport.Client (TransportHost (..))
import SMPAgentClient (agentCfg, initAgentServers, testDB)
import SMPClient (cfgWebOn, cfgMS, proxyCfgMS, updateCfg, testKeyHash, testPort, testPort2, testSMPClient, testSMPClient_, testHost2, testStoreLogFile2, testStoreMsgsDir2, journalCfg, withSmpServerConfig, withSmpServerConfigOn)
import ServerTests (sendRecv, signSendRecv, tGet1, decryptMsgV3, _SEND, pattern Resp, pattern Ids, pattern Msg, pattern New)
import AgentTests.DoubleRatchetTests (testEncryptDecrypt, testSkippedMessages, testManyMessages, testSkippedAfterRatchetAdvance)
import AgentTests.FunctionalAPITests (withAgent)
import Test.Hspec hiding (it)
import Util
import XFTPWebTests (callNode_, jsOut, jsUint8)

smpWebDir :: FilePath
smpWebDir = "smp-web"

callNode :: String -> IO B.ByteString
callNode = callNode_ smpWebDir

impEnc :: String
impEnc = "import { Decoder, decodeBytes, decodeLarge, encodeBytes, encodeWord16 } from '@simplex-chat/xftp-web/dist/protocol/encoding.js';"

impProto_ :: String
impProto_ = "import { encodeTransmission, encodeTransmissionForAuth, authTransmission, tEncodeAuth, tEncode, tEncodeBatch1, tEncodeForBatch, batchTransmissions, transmissionP, tParse, tDecodeClient, protocolError, encodeLGET, decodeLNK, decodeResponse, encodeNEW, encodeKEY, encodeSKEY, encodeSUB, encodeACK, encodeSEND, encodeOFF, encodeDEL, encodeGET, encodeQUE, encodePING, encodeProtocolServer, encodePRXY, encodePFWD, paddedProxiedTLength } from './dist/protocol.js';"

impProto :: String
impProto = impEnc <> impProto_

impTransport :: String
impTransport = "import { decodeSMPServerHandshake, encodeSMPClientHandshake } from './dist/transport.js';"
  <> "import { Decoder, encodeWord16 } from '@simplex-chat/xftp-web/dist/protocol/encoding.js';"

impWS :: String
impWS = "import { connectSMP, sendBlock, receiveBlock } from './dist/transport/websockets.js';"
  <> "import { blockPad, blockUnpad } from '@simplex-chat/xftp-web/dist/protocol/transmission.js';"

impAgentProto_ :: String
impAgentProto_ = "import { connShortLinkStrP, decodeConnLinkData, decodeFixedLinkData, decodeProtocolServer, decodeConnShortLink, decodeOwnerAuth, decodeUserLinkData, parseProfile } from './dist/agent/protocol.js';"

impAgentProto :: String
impAgentProto = impEnc <> impAgentProto_

impCryptoShortLink :: String
impCryptoShortLink = "import { contactShortLinkKdf, invShortLinkKdf, decryptLinkData } from './dist/crypto/shortLink.js';"

impRatchet :: String
impRatchet = "import { generateX448KeyPair, pqX3dhSnd, pqX3dhRcv, x448DH, encodePubKeyX448, decodePubKeyX448, chainKdf, rootKdf, initSndRatchet, initRcvRatchet, rcEncrypt, rcDecrypt } from './dist/crypto/ratchet.js';"
  <> "import { encryptAEAD, decryptAEAD } from './dist/crypto.js';"

impSntrup :: String
impSntrup = "import { initSntrup761, sntrup761Keypair, sntrup761Enc, sntrup761Dec } from './dist/crypto/sntrup761.js'; await initSntrup761();"

impAgentMsg :: String
impAgentMsg = "import { encodeAMessage, decodeAMessage, encodeAPrivHeader, decodeAPrivHeader, encodeAgentMessage, decodeAgentMessage, encodeAgentMsgEnvelope, decodeAgentMsgEnvelope } from './dist/agent/message.js';"

impProtoE2E :: String
impProtoE2E = "import { encodePubHeader, decodePubHeader, encodePrivHeader, decodePrivHeader, encodeClientMessage, decodeClientMessage, encodeClientMsgEnvelope, decodeClientMsgEnvelope, agentCbEncrypt, agentCbDecrypt, e2eEncMessageLength } from './dist/protocol.js';"

impCrypto :: String
impCrypto = "import { sbcInit, sbcHkdf, sbEncryptBlock, sbDecryptBlock } from './dist/crypto.js';"

-- Init sodium from xftp-web's copy (same instance secretbox.ts uses)
impSodium :: String
impSodium = "import sodium from '@simplex-chat/xftp-web/node_modules/libsodium-wrappers-sumo/dist/modules-sumo/libsodium-wrappers.js'; await sodium.ready;"

jsStr :: B.ByteString -> String
jsStr bs = "'" <> BC.unpack bs <> "'"

paddedMsgLen :: Int
paddedMsgLen = 100

-- -- TestPeer: sum type for cross-language ratchet tests

type HsPeer a = TVar (TVar ChaChaDRG, CR.Ratchet a, CR.SkippedMsgKeys)

data TestPeer
  = forall a. (C.AlgorithmI a, C.DhAlgorithm a) => TestPeerHS (HsPeer a)
  | TestPeerJS Handle Handle ProcessHandle  -- stdin, stdout, process

-- dispatch functions

tpEncrypt :: TestPeer -> B.ByteString -> IO (Either C.CryptoError B.ByteString)
tpEncrypt (TestPeerHS tvar) msg = do
  (_, rc, smks) <- readTVarIO tvar
  result <- runExceptT $ do
    (mek, rc') <- CR.rcEncryptHeader rc Nothing CR.currentE2EEncryptVersion
    ct <- CR.rcEncryptMsg mek paddedMsgLen msg
    pure (ct, rc')
  case result of
    Right (ct, rc') -> do
      (g, _, smks') <- readTVarIO tvar
      atomically $ writeTVar tvar (g, rc', smks')
      pure $ Right ct
    Left e -> pure $ Left e
tpEncrypt (TestPeerJS hIn hOut _) msg = do
  hPutStrLn' hIn $ "E " <> BC.unpack msg
  resp <- hGetLine hOut
  case parseResponse resp of
    Right hex -> pure $ Right $ hexToBS hex
    Left err -> error $ "tpEncrypt JS error: " <> err

tpDecrypt :: TestPeer -> B.ByteString -> IO (Either C.CryptoError (Either C.CryptoError B.ByteString))
tpDecrypt (TestPeerHS tvar) ct = do
  (g, rc, smks) <- readTVarIO tvar
  result <- runExceptT $ CR.rcDecrypt g rc smks ct
  case result of
    Right (msg, rc', smDiff) -> do
      atomically $ writeTVar tvar (g, rc', CR.applySMDiff smks smDiff)
      pure $ Right msg
    Left e -> pure $ Left e
tpDecrypt (TestPeerJS hIn hOut _) ct = do
  hPutStrLn' hIn $ "D " <> bsToHex ct
  resp <- hGetLine hOut
  case parseResponse resp of
    Right txt -> pure $ Right $ Right $ BC.pack txt
    Left err -> parseJsError err

-- Map JS REPL error strings to CryptoError at the correct Either level.
-- Outer Left: errors that abort rcDecrypt (header failure, first skipMessageKeys).
-- Inner Right (Left _): errors from second skipMessageKeys (duplicate/earlier in current ratchet state).
parseJsError :: String -> IO (Either C.CryptoError (Either C.CryptoError B.ByteString))
parseJsError err
  -- Outer errors (ExceptT failures in Haskell rcDecrypt)
  | has "CERatchetHeader" = pure $ Left C.CERatchetHeader
  | has "CERatchetKEMState" = pure $ Left C.CERatchetKEMState
  -- Inner errors (pure Left in second skipMessageKeys)
  | has "CERatchetDuplicateMessage" = pure $ Right $ Left C.CERatchetDuplicateMessage
  | has "CERatchetEarlierMessage" = pure $ Right $ Left $ C.CERatchetEarlierMessage 0
  | has "CERatchetTooManySkipped" = pure $ Right $ Left $ C.CERatchetTooManySkipped 0
  | has "CERatchetState" = pure $ Right $ Left C.CERatchetState
  | otherwise = pure $ Left $ C.CryptoHeaderError err
  where
    has s = s `isInfixOf` err

tpSndKEM :: TestPeer -> IO Bool
tpSndKEM (TestPeerHS tvar) = do
  (_, rc, _) <- readTVarIO tvar
  pure $ CR.enablePQ $ CR.rcSndKEM rc
tpSndKEM (TestPeerJS hIn hOut _) = do
  hPutStrLn' hIn "SNDKEM"
  resp <- hGetLine hOut
  pure $ resp == "ok: 1"

tpRcvKEM :: TestPeer -> IO Bool
tpRcvKEM (TestPeerHS tvar) = do
  (_, rc, _) <- readTVarIO tvar
  pure $ CR.enablePQ $ CR.rcRcvKEM rc
tpRcvKEM (TestPeerJS hIn hOut _) = do
  hPutStrLn' hIn "RCVKEM"
  resp <- hGetLine hOut
  pure $ resp == "ok: 1"

tpEncryptDecrypt :: Maybe CR.PQEncryption -> Bool -> Bool -> (TestPeer, B.ByteString) -> TestPeer -> Expectation
tpEncryptDecrypt _pqEnc expectSndKEM expectRcvKEM (sender, msg) receiver = do
  Right ct <- tpEncrypt sender msg
  sndK <- tpSndKEM sender
  when (sndK /= expectSndKEM) $ expectationFailure $ "sndKEM: expected " <> show expectSndKEM <> ", got " <> show sndK
  Right (Right msg') <- tpDecrypt receiver ct
  rcvK <- tpRcvKEM receiver
  when (rcvK /= expectRcvKEM) $ expectationFailure $ "rcvKEM: expected " <> show expectRcvKEM <> ", got " <> show rcvK
  msg' `shouldBe` msg

-- TestPeer operators (matching Haskell DoubleRatchetTests)
tp_noKEM, tp_hasKEM :: (TestPeer, B.ByteString) -> TestPeer -> Expectation
tp_noKEM = tpEncryptDecrypt Nothing False False
tp_hasKEM = tpEncryptDecrypt Nothing True True

-- JS process helpers

spawnJsRatchet :: IO (Handle, Handle, ProcessHandle)
spawnJsRatchet = do
  let cp = (proc "node" ["dist-test/ratchet-repl.js"]) {cwd = Just "smp-web", std_in = CreatePipe, std_out = CreatePipe, std_err = CreatePipe}
  (Just hIn, Just hOut, _, ph) <- createProcess cp
  hSetBuffering hIn LineBuffering
  hSetBuffering hOut LineBuffering
  pure (hIn, hOut, ph)

spawnJsClient :: IO (Handle, Handle, ProcessHandle)
spawnJsClient = do
  let cp = (proc "node" ["dist-test/client-repl.js"]) {cwd = Just "smp-web", std_in = CreatePipe, std_out = CreatePipe, std_err = Inherit}
  (Just hIn, Just hOut, _, ph) <- createProcess cp
  hSetBuffering hIn LineBuffering
  hSetBuffering hOut LineBuffering
  pure (hIn, hOut, ph)

destroyJsRatchet :: TestPeer -> IO ()
destroyJsRatchet (TestPeerJS _ _ ph) = terminateProcess ph
destroyJsRatchet _ = pure ()

jsCmd :: Handle -> Handle -> String -> IO String
jsCmd hIn hOut cmd = do
  hPutStrLn' hIn cmd
  hGetLine hOut

hPutStrLn' :: Handle -> String -> IO ()
hPutStrLn' h s = do
  hPutStr h (s <> "\n")
  hFlush h

parseResponse :: String -> Either String String
parseResponse resp
  | take 4 resp == "ok: " = Right $ drop 4 resp
  | take 7 resp == "error: " = Left $ drop 7 resp
  | otherwise = Left $ "unexpected response: " <> resp

bsToHex :: B.ByteString -> String
bsToHex = concatMap (\w -> let h = showHex' w in h) . B.unpack
  where
    showHex' w = [hexDigit (w `div` 16), hexDigit (w `mod` 16)]
    hexDigit n | n < 10 = toEnum (fromEnum '0' + fromIntegral n)
               | otherwise = toEnum (fromEnum 'a' + fromIntegral n - 10)

hexToBS :: String -> B.ByteString
hexToBS = B.pack . go
  where
    go [] = []
    go (a:b:rest) = fromIntegral (hexVal a * 16 + hexVal b) : go rest
    go _ = []
    hexVal c
      | c >= '0' && c <= '9' = fromEnum c - fromEnum '0'
      | c >= 'a' && c <= 'f' = fromEnum c - fromEnum 'a' + 10
      | c >= 'A' && c <= 'F' = fromEnum c - fromEnum 'A' + 10
      | otherwise = 0

runRight :: (Show e, HasCallStack) => ExceptT e IO a -> IO a
runRight action = runExceptT action >>= either (error . ("Unexpected error: " <>) . show) pure

-- -- Cross-language ratchet init functions and test patterns

withCrossPeers :: IO (TestPeer, TestPeer) -> ((TestPeer, TestPeer) -> IO ()) -> IO ()
withCrossPeers initPeers test = bracket initPeers cleanup test
  where
    cleanup (a, b) = destroyJsRatchet a >> destroyJsRatchet b

-- HS (receiver) <-> JS (sender), no PQ
initHsJs_noPQ :: IO (TestPeer, TestPeer)
initHsJs_noPQ = do
  g <- C.newRandom
  let v = CR.currentE2EEncryptVersion
      Version vNum = v
  (pkAlice1, pkAlice2, Nothing, e2eAlice) <- CR.generateRcvE2EParams @'X448 g v CR.PQSupportOff
  let aliceE2EHex = bsToHex $ smpEncode e2eAlice
  (hIn, hOut, ph) <- spawnJsRatchet
  bobE2EHex <- either error pure . parseResponse =<< jsCmd hIn hOut ("INIT_SND " ++ show vNum ++ " none " ++ aliceE2EHex)
  Right (CR.AE2ERatchetParams _ bobE2E :: CR.AE2ERatchetParams 'X448) <- pure $ smpDecode $ hexToBS bobE2EHex
  Right (aliceInitParams, _) <- runExceptT $ CR.pqX3dhRcv pkAlice1 pkAlice2 Nothing bobE2E
  let aliceRatchet = CR.initRcvRatchet (CR.RatchetVersions v v) pkAlice2 (aliceInitParams, Nothing) CR.PQSupportOff
  ga <- C.newRandom
  aliceTVar <- newTVarIO (ga, aliceRatchet, M.empty :: CR.SkippedMsgKeys)
  pure (TestPeerHS aliceTVar, TestPeerJS hIn hOut ph)

-- HS (receiver) <-> JS (sender), PQ KEM accepted
initHsJs_PQ :: IO (TestPeer, TestPeer)
initHsJs_PQ = do
  g <- C.newRandom
  let v = CR.currentE2EEncryptVersion
      Version vNum = v
  (pkAlice1, pkAlice2, alicePKem_@(Just _), e2eAlice) <- CR.generateRcvE2EParams @'X448 g v CR.PQSupportOn
  let aliceE2EHex = bsToHex $ smpEncode e2eAlice
  (hIn, hOut, ph) <- spawnJsRatchet
  bobE2EHex <- either error pure . parseResponse =<< jsCmd hIn hOut ("INIT_SND " ++ show vNum ++ " accept " ++ aliceE2EHex)
  Right (CR.AE2ERatchetParams _ bobE2E :: CR.AE2ERatchetParams 'X448) <- pure $ smpDecode $ hexToBS bobE2EHex
  Right (aliceInitParams, aliceKemKp_) <- runExceptT $ CR.pqX3dhRcv pkAlice1 pkAlice2 alicePKem_ bobE2E
  let aliceRatchet = CR.initRcvRatchet (CR.RatchetVersions v v) pkAlice2 (aliceInitParams, aliceKemKp_) CR.PQSupportOn
  ga <- C.newRandom
  aliceTVar <- newTVarIO (ga, aliceRatchet, M.empty :: CR.SkippedMsgKeys)
  pure (TestPeerHS aliceTVar, TestPeerJS hIn hOut ph)

-- JS (receiver) <-> JS (sender), no PQ
initTsTs_noPQ :: IO (TestPeer, TestPeer)
initTsTs_noPQ = do
  let Version vNum = CR.currentE2EEncryptVersion
  (hInA, hOutA, phA) <- spawnJsRatchet
  aliceE2EHex <- either error pure . parseResponse =<< jsCmd hInA hOutA ("INIT_RCV " ++ show vNum ++ " 0")
  (hInB, hOutB, phB) <- spawnJsRatchet
  bobE2EHex <- either error pure . parseResponse =<< jsCmd hInB hOutB ("INIT_SND " ++ show vNum ++ " none " ++ aliceE2EHex)
  completeResp <- jsCmd hInA hOutA ("COMPLETE " ++ bobE2EHex)
  when (completeResp /= "ok") $ error $ "COMPLETE failed: " ++ completeResp
  pure (TestPeerJS hInA hOutA phA, TestPeerJS hInB hOutB phB)

-- JS (receiver) <-> JS (sender), PQ KEM accepted
initTsTs_PQ :: IO (TestPeer, TestPeer)
initTsTs_PQ = do
  let Version vNum = CR.currentE2EEncryptVersion
  (hInA, hOutA, phA) <- spawnJsRatchet
  aliceE2EHex <- either error pure . parseResponse =<< jsCmd hInA hOutA ("INIT_RCV " ++ show vNum ++ " 1")
  (hInB, hOutB, phB) <- spawnJsRatchet
  bobE2EHex <- either error pure . parseResponse =<< jsCmd hInB hOutB ("INIT_SND " ++ show vNum ++ " accept " ++ aliceE2EHex)
  completeResp <- jsCmd hInA hOutA ("COMPLETE " ++ bobE2EHex)
  when (completeResp /= "ok") $ error $ "COMPLETE failed: " ++ completeResp
  pure (TestPeerJS hInA hOutA phA, TestPeerJS hInB hOutB phB)

smpWebTests :: SpecWith ()
smpWebTests = describe "SMP Web Client" $ do
  distExists <- runIO $ doesDirectoryExist (smpWebDir <> "/dist")
  if distExists
    then smpWebTests_
    else
      it "skipped (run 'cd smp-web && npm install && npm run build' first)" $
        pendingWith "TS project not compiled"

smpWebTests_ :: SpecWith ()
smpWebTests_ = do
  describe "protocol" $ do
    describe "transmission" $ do
      it "encodeTransmission matches Haskell" $ do
        let corrId = "1"
            entityId = B.pack [1..24]
            command = "LGET"
            hsEncoded = smpEncode (corrId :: B.ByteString, entityId :: B.ByteString) <> command
        tsEncoded <- callNode $ impProto
          <> jsOut ("encodeTransmission("
          <> jsUint8 corrId <> ","
          <> jsUint8 entityId <> ","
          <> "new Uint8Array([0x4C,0x47,0x45,0x54])"
          <> ")")
        tsEncoded `shouldBe` hsEncoded

      it "transmissionP parses Haskell-encoded" $ do
        let corrId = "abc"
            entityId = B.pack [10..33]
            command = "TEST"
            -- Wire format: auth(ByteString) + corrId(ByteString) + entityId(ByteString) + command(rest)
            encoded = smpEncode (B.empty :: B.ByteString)
              <> smpEncode corrId
              <> smpEncode entityId
              <> command
        tsResult <- callNode $ impProto
          <> "const t = transmissionP(" <> jsUint8 encoded <> ");"
          <> jsOut ("new Uint8Array([...t.corrId, ...t.entityId, ...t.command])")
        tsResult `shouldBe` (corrId <> entityId <> command)

    describe "LGET" $ do
      it "encodeLGET produces correct bytes" $ do
        tsResult <- callNode $ impProto <> jsOut "encodeLGET()"
        tsResult `shouldBe` "LGET"

    describe "LNK" $ do
      it "decodeLNK parses correctly" $ do
        let senderId = B.pack [1..24]
            fixedData = B.pack [100..110]
            userData = B.pack [200..220]
            encoded = smpEncode senderId <> smpEncode (Large fixedData) <> smpEncode (Large userData)
        tsResult <- callNode $ impProto
          <> "const r = decodeLNK(new Decoder(" <> jsUint8 encoded <> "));"
          <> jsOut ("new Uint8Array([...r.senderId, ...r.encFixedData, ...r.encUserData])")
        tsResult `shouldBe` (senderId <> fixedData <> userData)

    describe "decodeResponse" $ do
      it "decodes LNK response" $ do
        let senderId = B.pack [1..24]
            fixedData = B.pack [100..110]
            userData = B.pack [200..220]
            commandBytes = "LNK " <> smpEncode senderId <> smpEncode (Large fixedData) <> smpEncode (Large userData)
        tsResult <- callNode $ impProto
          <> "const r = decodeResponse(new Decoder(" <> jsUint8 commandBytes <> "));"
          <> "if (r.type !== 'LNK') throw new Error('expected LNK, got ' + r.type);"
          <> jsOut ("new Uint8Array([...r.response.senderId])")
        tsResult `shouldBe` senderId

      it "decodes OK response" $ do
        tsResult <- callNode $ impProto
          <> "const r = decodeResponse(new Decoder(new Uint8Array([0x4F, 0x4B])));"
          <> jsOut ("new Uint8Array([r.type === 'OK' ? 1 : 0])")
        tsResult `shouldBe` B.singleton 1

    describe "commands" $ do
      let v = currentServerSMPRelayVersion

      it "encodeNEW matches Haskell" $ do
        g <- C.newRandom
        (rcvAuthPub, _) <- atomically $ C.generateAuthKeyPair C.SX25519 g
        (rcvDhPub, _) <- atomically $ C.generateKeyPair @'C.X25519 g
        let rcvAuthPubDer = C.encodePubKey rcvAuthPub
            rcvDhPubDer = C.encodePubKey rcvDhPub
            cmd = NEW $ NewQueueReq rcvAuthPub rcvDhPub Nothing SMSubscribe (Just $ QRMessaging Nothing) Nothing
            hsEncoded = encodeProtocol v cmd
        tsEncoded <- callNode $ impProto
          <> jsOut ("encodeNEW(" <> jsUint8 rcvAuthPubDer <> "," <> jsUint8 rcvDhPubDer <> ", null, true)")
        tsEncoded `shouldBe` hsEncoded

      it "encodeSUB matches Haskell" $ do
        let hsEncoded = encodeProtocol v SUB
        tsEncoded <- callNode $ impProto <> jsOut "encodeSUB()"
        tsEncoded `shouldBe` hsEncoded

      it "encodeKEY matches Haskell" $ do
        let keyDer = B.pack [0x30, 0x2a, 0x30, 0x05, 0x06, 0x03, 0x2b, 0x65, 0x6e, 0x03, 0x21, 0x00] <> B.pack [1..32]
            hsEncoded = "KEY " <> smpEncode keyDer
        tsEncoded <- callNode $ impProto
          <> jsOut ("encodeKEY(" <> jsUint8 keyDer <> ")")
        tsEncoded `shouldBe` hsEncoded

      it "encodeSKEY matches Haskell" $ do
        let keyDer = B.pack [0x30, 0x2a, 0x30, 0x05, 0x06, 0x03, 0x2b, 0x65, 0x6e, 0x03, 0x21, 0x00] <> B.pack [1..32]
            hsEncoded = "SKEY " <> smpEncode keyDer
        tsEncoded <- callNode $ impProto
          <> jsOut ("encodeSKEY(" <> jsUint8 keyDer <> ")")
        tsEncoded `shouldBe` hsEncoded

      it "encodeACK matches Haskell" $ do
        let msgId = B.pack [1..24]
            hsEncoded = encodeProtocol v (ACK msgId)
        tsEncoded <- callNode $ impProto
          <> jsOut ("encodeACK(" <> jsUint8 msgId <> ")")
        tsEncoded `shouldBe` hsEncoded

      it "encodeSEND matches Haskell" $ do
        let flags = MsgFlags {notification = True}
            body = "hello world"
            hsEncoded = encodeProtocol v (SEND flags body)
        tsEncoded <- callNode $ impProto
          <> jsOut ("encodeSEND(true, new TextEncoder().encode('hello world'))")
        tsEncoded `shouldBe` hsEncoded

      it "decodes IDS response" $ do
        let rcvId = B.pack [1..24]
            sndId = B.pack [25..48]
            srvDhKey = B.pack [0x30, 0x2a, 0x30, 0x05, 0x06, 0x03, 0x2b, 0x65, 0x6e, 0x03, 0x21, 0x00] <> B.pack [50..81]
            -- Manually encode IDS response: "IDS " <> rcvId <> sndId <> srvDhKey <> Maybe queueMode <> Maybe linkId ...
            encoded = "IDS " <> smpEncode (EntityId rcvId) <> smpEncode (EntityId sndId) <> smpEncode srvDhKey
              <> smpEncode (Nothing :: Maybe B.ByteString) <> smpEncode (Nothing :: Maybe B.ByteString)
              <> smpEncode (Nothing :: Maybe B.ByteString) <> smpEncode (Nothing :: Maybe B.ByteString)
        tsResult <- callNode $ impProto
          <> "const r = decodeResponse(new Decoder(" <> jsUint8 encoded <> "));"
          <> "if (r.type !== 'IDS') throw new Error('expected IDS, got ' + r.type);"
          <> jsOut ("new Uint8Array([...r.response.rcvId, ...r.response.sndId])")
        tsResult `shouldBe` (rcvId <> sndId)

      it "decodes Haskell-encoded MSG response" $ do
        let msgId = B.pack [1..24]
            body = "encrypted message body"
            hsEncoded = "MSG " <> smpEncode msgId <> body
        tsResult <- callNode $ impProto
          <> "const r = decodeResponse(new Decoder(" <> jsUint8 hsEncoded <> "));"
          <> "if (r.type !== 'MSG') throw new Error('expected MSG, got ' + r.type);"
          <> jsOut ("new Uint8Array([...r.response.msgId, ...r.response.msgBody])")
        tsResult `shouldBe` (msgId <> body)

  describe "transport" $ do
    describe "SMPServerHandshake" $ do
      it "TypeScript parses Haskell-encoded server handshake (no authPubKey)" $ do
        -- Manually construct: smpEncode (versionRange, sessionId) <> "" (no authPubKey)
        let vRange = (6 :: Word16, 18 :: Word16)
            sessId = B.pack [1..32]
            encoded = smpEncode vRange <> smpEncode sessId
        tsResult <- callNode $ impTransport
          <> "const hs = decodeSMPServerHandshake(new Decoder(" <> jsUint8 encoded <> "));"
          <> jsOut ("new Uint8Array(["
          <> "hs.smpVersionRange.min, hs.smpVersionRange.max,"
          <> "hs.authPubKey === null ? 1 : 0,"
          <> "hs.sessionId.length"
          <> "])")
        tsResult `shouldBe` B.pack [6, 18, 1, 32]

    describe "SMPClientHandshake" $ do
      it "TypeScript-encoded client handshake matches Haskell (no authPubKey)" $ do
        -- Haskell encoding: smpEncode (v18, keyHash) <> "" (no authPubKey) <> smpEncode False <> smpEncode (Nothing :: Maybe ())
        let v = 18 :: Word16
            keyHash = B.pack [1..32]
            hsEncoded = smpEncode (v, keyHash)
              <> ""  -- authPubKey Nothing = empty
              <> smpEncode False  -- proxyServer
              <> smpEncode (Nothing :: Maybe B.ByteString) -- clientService
        tsEncoded <- callNode $ impTransport
          <> jsOut ("encodeSMPClientHandshake({"
          <> "smpVersion: 18,"
          <> "keyHash: " <> jsUint8 keyHash <> ","
          <> "authPubKey: null,"
          <> "proxyServer: false,"
          <> "clientService: null"
          <> "})")
        tsEncoded `shouldBe` hsEncoded

  describe "crypto/shortLink" $ do
    describe "contactShortLinkKdf" $ do
      it "TypeScript produces same linkId and sbKey as Haskell" $ do
        let linkKey = AP.LinkKey $ B.pack [1..32]
            (EntityId hsLinkId, C.SbKey hsKey) = contactShortLinkKdf linkKey
        tsResult <- callNode $ impCryptoShortLink
          <> "const r = contactShortLinkKdf(" <> jsUint8 (B.pack [1..32]) <> ");"
          <> jsOut ("new Uint8Array([...r.linkId, ...r.sbKey])")
        tsResult `shouldBe` (hsLinkId <> hsKey)

    describe "invShortLinkKdf" $ do
      it "TypeScript produces same sbKey as Haskell" $ do
        let linkKey = AP.LinkKey $ B.pack [50..81]
            C.SbKey hsKey = invShortLinkKdf linkKey
        tsResult <- callNode $ impCryptoShortLink
          <> jsOut ("invShortLinkKdf(" <> jsUint8 (B.pack [50..81]) <> ")")
        tsResult `shouldBe` hsKey

    describe "decryptLinkData" $ do
      it "TypeScript decrypts Haskell-encrypted data" $ do
        let sbKey = C.unsafeSbKey $ B.pack [1..32]
            nonce = C.cbNonce $ B.pack [1..24]
            -- Simulate encodeSign: smpEncode signature <> plaintext
            fakeSig = B.pack [1..64] -- 64-byte "signature"
            fixedPlain = "fixed-data-here"
            userPlain = "user-data-here"
            signedFixed = smpEncode fakeSig <> fixedPlain
            signedUser = smpEncode fakeSig <> userPlain
        case (,) <$> C.sbEncrypt sbKey nonce signedFixed 2008
                 <*> C.sbEncrypt sbKey nonce signedUser 13784 of
          Left e -> expectationFailure $ "encrypt failed: " <> show e
          Right (ctFixed, ctUser) -> do
            let encFixed = C.unCbNonce nonce <> ctFixed
                encUser = C.unCbNonce nonce <> ctUser
            tsResult <- callNode $ impSodium <> impCryptoShortLink
              <> "const r = decryptLinkData("
              <> jsUint8 (C.unSbKey sbKey) <> ","
              <> jsUint8 encFixed <> ","
              <> jsUint8 encUser <> ");"
              <> jsOut ("new Uint8Array([...r.fixedData, 0, ...r.userData])")
            tsResult `shouldBe` (fixedPlain <> B.singleton 0 <> userPlain)

  describe "crypto/sntrup761" $ do
    it "TypeScript encapsulates, Haskell decapsulates - shared secret matches" $ do
      g <- C.newRandom
      (KEMPublicKey pkBytes, sk) <- sntrup761Keypair g
      tsResult <- callNode $ impSntrup
        <> "const enc = sntrup761Enc(" <> jsUint8 pkBytes <> ");"
        <> jsOut ("new Uint8Array([...enc.ciphertext, ...enc.sharedSecret])")
      let (ctBytes, tsSharedSecret) = B.splitAt 1039 tsResult
      KEMSharedKey hsSharedSecret <- sntrup761Dec (KEMCiphertext ctBytes) sk
      (BA.convert hsSharedSecret :: B.ByteString) `shouldBe` tsSharedSecret

    it "Haskell encapsulates, TypeScript decapsulates - shared secret matches" $ do
      -- TypeScript generates keypair, passes public key to Haskell via stdout,
      -- but callNode is one-shot. So: TypeScript generates keypair, outputs (pk, sk).
      -- Then Haskell encapsulates against pk, passes (ct) to TypeScript.
      -- TypeScript decapsulates with sk, outputs shared secret.
      -- We compare with Haskell's shared secret.
      --
      -- Two callNode calls: first to get keypair, second to decapsulate.
      kpResult <- callNode $ impSntrup
        <> "const kp = sntrup761Keypair();"
        <> jsOut ("new Uint8Array([...kp.publicKey, ...kp.secretKey])")
      let (tsPk, tsSk) = B.splitAt 1158 kpResult
      g <- C.newRandom
      (KEMCiphertext ctBytes, KEMSharedKey hsSharedSecret) <- sntrup761Enc g (KEMPublicKey tsPk)
      tsResult <- callNode $ impSntrup
        <> "const ss = sntrup761Dec(" <> jsUint8 ctBytes <> "," <> jsUint8 tsSk <> ");"
        <> jsOut ("ss")
      tsResult `shouldBe` (BA.convert hsSharedSecret :: B.ByteString)

  describe "crypto/aesGcm" $ do
    it "Haskell encryptAEAD (16-byte IV), TypeScript decrypts" $ do
      let key = C.Key $ B.pack [1..32]
          iv = C.IV $ B.pack [1..16]
          ad = "associated data"
          msg = "hello from haskell aes-gcm"
      Right (C.AuthTag authTag, ct) <- runExceptT $ C.encryptAEAD key iv 64 ad msg
      let tagBytes = BA.convert authTag :: B.ByteString
      tsResult <- callNode $ impEnc
        <> "import { gcm } from '@noble/ciphers/aes.js';"
        <> "const key = " <> jsUint8 (B.pack [1..32]) <> ";"
        <> "const iv = " <> jsUint8 (B.pack [1..16]) <> ";"
        <> "const ad = new TextEncoder().encode('associated data');"
        <> "const ct = " <> jsUint8 ct <> ";"
        <> "const tag = " <> jsUint8 tagBytes <> ";"
        <> "const cipher = gcm(key, iv, ad);"
        <> "const encrypted = new Uint8Array([...ct, ...tag]);"
        <> "const decrypted = cipher.decrypt(encrypted);"
        -- unpad: 2-byte BE length prefix + message + '#' padding
        <> "const len = (decrypted[0] << 8) | decrypted[1];"
        <> jsOut ("decrypted.subarray(2, 2 + len)")
      tsResult `shouldBe` msg

  describe "crypto/ratchet" $ do
    describe "X3DH" $ do
      it "pqX3dhSnd and pqX3dhRcv produce same ratchetKey" $ do
        -- TypeScript generates two key pairs, computes X3DH from both sides, verifies match
        tsResult <- callNode $ impSodium <> impRatchet
          <> "const alice1 = generateX448KeyPair();"
          <> "const alice2 = generateX448KeyPair();"
          <> "const bob1 = generateX448KeyPair();"
          <> "const bob2 = generateX448KeyPair();"
          -- Bob (joiner) inits sending ratchet with Alice's public keys
          <> "const snd = pqX3dhSnd(bob1.privateKey, bob2.privateKey, alice1.publicKey, alice2.publicKey);"
          -- Alice (initiator) inits receiving ratchet with Bob's public keys
          <> "const rcv = pqX3dhRcv(alice1.privateKey, alice2.privateKey, bob1.publicKey, bob2.publicKey);"
          -- ratchetKey, sndHK, rcvNextHK should match
          <> "const match = snd.ratchetKey.every((b, i) => b === rcv.ratchetKey[i]) && snd.sndHK.every((b, i) => b === rcv.sndHK[i]) && snd.rcvNextHK.every((b, i) => b === rcv.rcvNextHK[i]);"
          <> jsOut ("new Uint8Array([match ? 1 : 0, snd.ratchetKey.length, snd.sndHK.length, snd.rcvNextHK.length])")
        tsResult `shouldBe` B.pack [1, 32, 32, 32]

    describe "chainKdf" $ do
      it "TypeScript chainKdf produces correct output via HKDF" $ do
        -- chainKdf is hkdf3("", ck, "SimpleXChainRatchet") split into 32+32+16+16
        -- Since hkdf is already tested against Haskell, test the split logic
        tsResult <- callNode $ impRatchet
          <> "const r = chainKdf(" <> jsUint8 (B.pack [1..32]) <> ");"
          <> jsOut ("new Uint8Array([r.ck.length, r.mk.length, r.iv.length, r.ehIV.length])")
        tsResult `shouldBe` B.pack [32, 32, 16, 16]

    describe "encryptAEAD" $ do
      it "TypeScript encrypt matches Haskell encrypt (same ciphertext)" $ do
        let key = C.Key $ B.pack [1..32]
            iv = C.IV $ B.pack [1..16]
            ad = "test associated data"
            msg = "ratchet plaintext"
        Right (C.AuthTag hsTag, hsCt) <- runExceptT $ C.encryptAEAD key iv 64 ad msg
        let hsTagBytes = BA.convert hsTag :: B.ByteString
        tsResult <- callNode $ impRatchet
          <> "const r = encryptAEAD(" <> jsUint8 (B.pack [1..32]) <> "," <> jsUint8 (B.pack [1..16]) <> ",64,"
          <> "new TextEncoder().encode('test associated data'),"
          <> "new TextEncoder().encode('ratchet plaintext'));"
          <> jsOut ("new Uint8Array([...r.authTag, ...r.ciphertext])")
        tsResult `shouldBe` (hsTagBytes <> hsCt)

      it "TypeScript decrypts Haskell-encrypted" $ do
        let key = C.Key $ B.pack [10..41]
            iv = C.IV $ B.pack [10..25]
            ad = "ad for decrypt test"
            msg = "hello from haskell ratchet"
        Right (C.AuthTag hsTag, hsCt) <- runExceptT $ C.encryptAEAD key iv 64 ad msg
        let hsTagBytes = BA.convert hsTag :: B.ByteString
        tsResult <- callNode $ impRatchet
          <> "const plain = decryptAEAD(" <> jsUint8 (B.pack [10..41]) <> "," <> jsUint8 (B.pack [10..25]) <> ","
          <> "new TextEncoder().encode('ad for decrypt test'),"
          <> jsUint8 hsCt <> "," <> jsUint8 hsTagBytes <> ");"
          <> jsOut ("plain")
        tsResult `shouldBe` msg

      it "Haskell decrypts TypeScript-encrypted" $ do
        let key = C.Key $ B.pack [20..51]
            iv = C.IV $ B.pack [20..35]
            ad = "ad for ts encrypt"
            msg = "hello from typescript ratchet"
        tsResult <- callNode $ impRatchet
          <> "const r = encryptAEAD(" <> jsUint8 (B.pack [20..51]) <> "," <> jsUint8 (B.pack [20..35]) <> ",64,"
          <> "new TextEncoder().encode('ad for ts encrypt'),"
          <> "new TextEncoder().encode('hello from typescript ratchet'));"
          <> jsOut ("new Uint8Array([...r.authTag, ...r.ciphertext])")
        let (tsTag, tsCt) = B.splitAt 16 tsResult
        Right hsPlain <- runExceptT $ C.decryptAEAD key iv ad tsCt (C.AuthTag $ AES.AuthTag $ BA.convert tsTag)
        hsPlain `shouldBe` msg

    describe "ratchet encrypt/decrypt" $ do
      it "TypeScript ratchet self-consistency: encrypt, decrypt, ratchet advance, skipped" $ do
        tsResult <- callNode $ impRatchet
          <> "const a1 = generateX448KeyPair(), a2 = generateX448KeyPair();"
          <> "const b1 = generateX448KeyPair(), b2 = generateX448KeyPair();"
          <> "const bp = pqX3dhSnd(b1.privateKey, b2.privateKey, a1.publicKey, a2.publicKey);"
          <> "const ap = pqX3dhRcv(a1.privateKey, a2.privateKey, b1.publicKey, b2.publicKey);"
          <> "const b3 = generateX448KeyPair();"
          <> "let bob = initSndRatchet({current:3,maxSupported:3}, a2.publicKey, b3.privateKey, bp, null);"
          <> "let alice = initRcvRatchet({current:3,maxSupported:3}, a2.privateKey, ap, null, false);"
          <> "let sk = new Map();"
          -- Bob sends 3
          <> "const e1 = rcEncrypt(bob, new TextEncoder().encode('msg1'), 100); bob = e1.state;"
          <> "const e2 = rcEncrypt(bob, new TextEncoder().encode('msg2'), 100); bob = e2.state;"
          <> "const e3 = rcEncrypt(bob, new TextEncoder().encode('msg3'), 100); bob = e3.state;"
          -- Alice decrypts msg3 first (skip 1,2)
          <> "let d3 = rcDecrypt(alice, sk, e3.ciphertext); alice = d3.state; sk = d3.skippedKeys;"
          -- Alice decrypts msg1 from skipped
          <> "let d1 = rcDecrypt(alice, sk, e1.ciphertext); alice = d1.state; sk = d1.skippedKeys;"
          -- Alice responds
          <> "const ea = rcEncrypt(alice, new TextEncoder().encode('reply'), 100); alice = ea.state;"
          <> "const da = rcDecrypt(bob, new Map(), ea.ciphertext); bob = da.state;"
          -- Verify
          <> "const ok = new TextDecoder().decode(d3.plaintext) === 'msg3'"
          <> " && new TextDecoder().decode(d1.plaintext) === 'msg1'"
          <> " && new TextDecoder().decode(da.plaintext) === 'reply';"
          <> jsOut ("new Uint8Array([ok ? 1 : 0])")
        tsResult `shouldBe` B.singleton 1

      it "cross-language: Haskell encrypts, TypeScript decrypts" $ do
        -- Round 1: TypeScript generates alice's keys, outputs private keys + smpEncoded E2E params
        tsAliceOutput <- callNode $ impEnc <> impRatchet
          <> "const a1 = generateX448KeyPair(), a2 = generateX448KeyPair();"
          -- smpEncode E2ERatchetParams v3: (version, pk1, pk2, Maybe KEMParams)
          -- Nothing = 0x30 ('0')
          <> "const e2e = new Uint8Array([...encodeWord16(3), ...encodeBytes(encodePubKeyX448(a1.publicKey)), ...encodeBytes(encodePubKeyX448(a2.publicKey)), 0x30]);"
          -- Output: a1.privateKey(56) + a2.privateKey(56) + e2e_len(2) + e2e_bytes
          <> "const lenBuf = new Uint8Array(2); lenBuf[0] = (e2e.length >> 8) & 0xff; lenBuf[1] = e2e.length & 0xff;"
          <> jsOut ("new Uint8Array([...a1.privateKey, ...a2.privateKey, ...lenBuf, ...e2e])")
        let (alicePriv1, rest1) = B.splitAt 56 tsAliceOutput
            (alicePriv2, rest2) = B.splitAt 56 rest1
            e2eLen = fromIntegral (B.index rest2 0) * 256 + fromIntegral (B.index rest2 1)
            aliceE2EBytes = B.take e2eLen $ B.drop 2 rest2

        -- Round 2: Haskell decodes alice's E2E params, generates bob, encrypts
        g <- C.newRandom
        let v = CR.currentE2EEncryptVersion
        Right (aliceE2E@(CR.E2ERatchetParams _ _ alicePk2 _) :: CR.E2ERatchetParams 'CR.RKSProposed 'X448) <- pure $ smpDecode aliceE2EBytes
        (bobPk1, bobPk2, _pKem, CR.AE2ERatchetParams _ bobE2E) <- CR.generateSndE2EParams @'X448 g v Nothing
        Right (bobInitParams, _) <- pure $ CR.pqX3dhSnd bobPk1 bobPk2 Nothing aliceE2E
        (_, bobDHRs) <- atomically $ C.generateKeyPair @'X448 g
        let bobRatchet = CR.initSndRatchet (CR.RatchetVersions v v) alicePk2 bobDHRs (bobInitParams, Nothing)
        Right (mek, _) <- runExceptT $ CR.rcEncryptHeader bobRatchet Nothing v
        Right ciphertext <- runExceptT $ CR.rcEncryptMsg mek paddedMsgLen "hello from haskell ratchet"
        let bobE2EBytes = smpEncode bobE2E

        -- Round 3: TypeScript decodes bob's params, inits ratchet, decrypts
        tsResult <- callNode $ impEnc <> impRatchet
          -- Parse bob's E2E params
          <> "const d = new Decoder(" <> jsUint8 bobE2EBytes <> ");"
          <> "const bobV = d.anyByte() * 256 + d.anyByte();"
          <> "const bobPk1Raw = decodePubKeyX448(decodeBytes(d));"
          <> "const bobPk2Raw = decodePubKeyX448(decodeBytes(d));"
          <> "const a1Priv = " <> jsUint8 alicePriv1 <> ";"
          <> "const a2Priv = " <> jsUint8 alicePriv2 <> ";"
          <> "const ap = pqX3dhRcv(a1Priv, a2Priv, bobPk1Raw, bobPk2Raw);"
          <> "const alice = initRcvRatchet({current:3,maxSupported:3}, a2Priv, ap, null, false);"
          <> "const dec = rcDecrypt(alice, new Map(), " <> jsUint8 ciphertext <> ");"
          <> jsOut ("dec.plaintext")
        tsResult `shouldBe` "hello from haskell ratchet"

      it "cross-language: TypeScript encrypts, Haskell decrypts" $ do
        -- Round 1: Haskell generates alice's keys, outputs encoded E2E params
        g <- C.newRandom
        let v = CR.currentE2EEncryptVersion
        (alicePk1, alicePk2, _pKem, aliceE2E) <- CR.generateRcvE2EParams @'X448 g v CR.PQSupportOff
        let aliceE2EBytes = smpEncode aliceE2E

        -- Round 2: TypeScript generates bob's keys, does X3DH, inits snd ratchet, encrypts
        tsOutput <- callNode $ impEnc <> impRatchet
          -- Parse alice's E2E params
          <> "const d = new Decoder(" <> jsUint8 aliceE2EBytes <> ");"
          <> "const aliceV = d.anyByte() * 256 + d.anyByte();"
          <> "const alicePk1Raw = decodePubKeyX448(decodeBytes(d));"
          <> "const alicePk2Raw = decodePubKeyX448(decodeBytes(d));"
          -- Bob generates keys
          <> "const b1 = generateX448KeyPair(), b2 = generateX448KeyPair();"
          <> "const b3 = generateX448KeyPair();"
          -- X3DH (bob is sender)
          <> "const bp = pqX3dhSnd(b1.privateKey, b2.privateKey, alicePk1Raw, alicePk2Raw);"
          -- Init sending ratchet
          <> "let bob = initSndRatchet({current:3,maxSupported:3}, alicePk2Raw, b3.privateKey, bp, null);"
          -- Encrypt
          <> "const enc = rcEncrypt(bob, new TextEncoder().encode('hello from typescript ratchet'), 100);"
          -- Output: bob's E2E params (version + 2 DER keys + Nothing KEM) + ciphertext
          <> "const bobE2E = new Uint8Array([...encodeWord16(3), ...encodeBytes(encodePubKeyX448(b1.publicKey)), ...encodeBytes(encodePubKeyX448(b2.publicKey)), 0x30]);"
          <> "const lenBuf = new Uint8Array(2); lenBuf[0] = (bobE2E.length >> 8) & 0xff; lenBuf[1] = bobE2E.length & 0xff;"
          <> "const ctLenBuf = new Uint8Array(2); ctLenBuf[0] = (enc.ciphertext.length >> 8) & 0xff; ctLenBuf[1] = enc.ciphertext.length & 0xff;"
          <> jsOut ("new Uint8Array([...lenBuf, ...bobE2E, ...ctLenBuf, ...enc.ciphertext])")
        -- Parse output: [2 bytes e2e len][e2e bytes][2 bytes ct len][ct bytes]
        let (e2eLenBs, rest1) = B.splitAt 2 tsOutput
            bobE2ELen = fromIntegral (B.index e2eLenBs 0) * 256 + fromIntegral (B.index e2eLenBs 1)
            (bobE2EBytes, rest2) = B.splitAt bobE2ELen rest1
            (ctLenBs, rest3) = B.splitAt 2 rest2
            ctLen = fromIntegral (B.index ctLenBs 0) * 256 + fromIntegral (B.index ctLenBs 1)
            ciphertext = B.take ctLen rest3

        -- Round 3: Haskell decodes bob's params, does X3DH, inits rcv ratchet, decrypts
        Right (CR.AE2ERatchetParams _ bobE2EParams :: CR.AE2ERatchetParams 'X448) <- pure $ smpDecode bobE2EBytes
        Right (aliceInitParams, _) <- runExceptT $ CR.pqX3dhRcv alicePk1 alicePk2 Nothing bobE2EParams
        let aliceRatchet = CR.initRcvRatchet (CR.RatchetVersions v v) alicePk2 (aliceInitParams, Nothing) CR.PQSupportOff
        gAlice <- C.newRandom
        Right (msg, _, _) <- runExceptT $ CR.rcDecrypt gAlice aliceRatchet M.empty ciphertext
        msg `shouldBe` Right "hello from typescript ratchet"

      it "cross-language: PQ X3DH - Haskell proposes KEM, TypeScript accepts, encrypts" $ do
        -- Round 1: Haskell (alice) generates keys with PQ KEM proposal
        g <- C.newRandom
        let v = CR.currentE2EEncryptVersion
        (alicePk1, alicePk2, alicePKem_@(Just _), aliceE2E) <- CR.generateRcvE2EParams @'X448 g v CR.PQSupportOn
        let aliceE2EBytes = smpEncode aliceE2E

        -- Round 2: TypeScript (bob) accepts KEM, does X3DH, inits snd ratchet, encrypts
        tsOutput <- callNode $ impEnc <> impSodium <> impRatchet <> impSntrup
          -- Parse alice's E2E params (v3: version + pk1 + pk2 + Maybe ARKEMParams)
          <> "const d = new Decoder(" <> jsUint8 aliceE2EBytes <> ");"
          <> "const aliceV = d.anyByte() * 256 + d.anyByte();"
          <> "const alicePk1Raw = decodePubKeyX448(decodeBytes(d));"
          <> "const alicePk2Raw = decodePubKeyX448(decodeBytes(d));"
          -- Parse Maybe ARKEMParams: '1' + 'P' + KEMPublicKey(Large)
          <> "const maybeByte = d.anyByte();"
          <> "if (maybeByte !== 0x31) throw new Error('expected Just KEM');"
          <> "const kemTag = d.anyByte();"
          <> "if (kemTag !== 0x50) throw new Error('expected P (proposed), got ' + kemTag);"
          <> "const aliceKemPk = decodeLarge(d);"
          -- Bob generates DH keys
          <> "const b1 = generateX448KeyPair(), b2 = generateX448KeyPair();"
          <> "const b3 = generateX448KeyPair();"
          -- Bob encapsulates against alice's KEM public key
          <> "const kemEnc = sntrup761Enc(aliceKemPk);"
          -- Bob generates his own KEM keypair for future ratchet steps
          <> "const bobKem = sntrup761Keypair();"
          -- Construct kemAccepted matching Haskell RatchetKEMAccepted:
          -- rcPQRr = alice's KEM public key (received)
          -- rcPQRss = shared secret (from encapsulation)
          -- rcPQRct = ciphertext (sent to alice)
          <> "const kemAccepted = {rcPQRr: aliceKemPk, rcPQRss: kemEnc.sharedSecret, rcPQRct: kemEnc.ciphertext};"
          -- X3DH with kemAccepted (folds shared secret into HKDF AND stores in RatchetInitParams)
          <> "const bp = pqX3dhSnd(b1.privateKey, b2.privateKey, alicePk1Raw, alicePk2Raw, kemAccepted);"
          -- Init sending ratchet with bob's KEM keypair
          <> "let bob = initSndRatchet({current:3,maxSupported:3}, alicePk2Raw, b3.privateKey, bp, bobKem);"
          -- Encrypt
          <> "const enc = rcEncrypt(bob, new TextEncoder().encode('hello with PQ'), 100);"
          -- Build bob's E2E params: version + pk1 + pk2 + Just(Accepted(ct, bobKemPk))
          -- smpEncode ('A', ct, bobKemPk) where ct and pk are Large-encoded
          <> "const bobE2E = new Uint8Array(["
          <> "  ...encodeWord16(3),"
          <> "  ...encodeBytes(encodePubKeyX448(b1.publicKey)),"
          <> "  ...encodeBytes(encodePubKeyX448(b2.publicKey)),"
          <> "  0x31,"  -- Just
          <> "  0x41,"  -- 'A' = Accepted
          <> "  ...new Uint8Array([(kemEnc.ciphertext.length >> 8) & 0xff, kemEnc.ciphertext.length & 0xff]), ...kemEnc.ciphertext,"
          <> "  ...new Uint8Array([(bobKem.publicKey.length >> 8) & 0xff, bobKem.publicKey.length & 0xff]), ...bobKem.publicKey,"
          <> "]);"
          <> "const lenBuf = new Uint8Array(2); lenBuf[0] = (bobE2E.length >> 8) & 0xff; lenBuf[1] = bobE2E.length & 0xff;"
          <> "const ctLenBuf = new Uint8Array(2); ctLenBuf[0] = (enc.ciphertext.length >> 8) & 0xff; ctLenBuf[1] = enc.ciphertext.length & 0xff;"
          <> jsOut ("new Uint8Array([...lenBuf, ...bobE2E, ...ctLenBuf, ...enc.ciphertext])")
        let (e2eLenBs, rest1) = B.splitAt 2 tsOutput
            bobE2ELen = fromIntegral (B.index e2eLenBs 0) * 256 + fromIntegral (B.index e2eLenBs 1)
            (bobE2EBytes, rest2) = B.splitAt bobE2ELen rest1
            (ctLenBs, rest3) = B.splitAt 2 rest2
            ctLen = fromIntegral (B.index ctLenBs 0) * 256 + fromIntegral (B.index ctLenBs 1)
            ciphertext = B.take ctLen rest3

        -- Round 3: Haskell decodes bob's params (with KEM accepted), does X3DH with KEM, decrypts
        Right (CR.AE2ERatchetParams _ bobE2EParams :: CR.AE2ERatchetParams 'X448) <- pure $ smpDecode bobE2EBytes
        Right (aliceInitParams, aliceKemKp_) <- runExceptT $ CR.pqX3dhRcv alicePk1 alicePk2 alicePKem_ bobE2EParams
        let aliceRatchet = CR.initRcvRatchet (CR.RatchetVersions v v) alicePk2 (aliceInitParams, aliceKemKp_) CR.PQSupportOn
        gAlice <- C.newRandom
        result <- runExceptT $ CR.rcDecrypt gAlice aliceRatchet M.empty ciphertext
        case result of
          Right (msg, _, _) -> msg `shouldBe` Right "hello with PQ"
          Left e -> expectationFailure $ "rcDecrypt failed: " <> show e

      it "TypeScript PQ ratchet self-consistency: multi-message with KEM ratchet steps" $ do
        tsResult <- callNode $ impSodium <> impSntrup <> impRatchet
          <> "const a1 = generateX448KeyPair(), a2 = generateX448KeyPair();"
          <> "const b1 = generateX448KeyPair(), b2 = generateX448KeyPair();"
          <> "const b3 = generateX448KeyPair();"
          -- Alice proposes KEM
          <> "const aliceKem = sntrup761Keypair();"
          -- Bob accepts: encapsulate against alice's KEM public key
          <> "const kemEnc = sntrup761Enc(aliceKem.publicKey);"
          <> "const bobKem = sntrup761Keypair();"
          <> "const kemAccepted = {rcPQRr: aliceKem.publicKey, rcPQRss: kemEnc.sharedSecret, rcPQRct: kemEnc.ciphertext};"
          -- Alice receives bob's acceptance: decapsulate to get shared secret
          <> "const aliceSS = sntrup761Dec(kemEnc.ciphertext, aliceKem.secretKey);"
          <> "const aliceKemAccepted = {rcPQRr: bobKem.publicKey, rcPQRss: aliceSS, rcPQRct: kemEnc.ciphertext};"
          -- X3DH for both sides
          <> "const bp = pqX3dhSnd(b1.privateKey, b2.privateKey, a1.publicKey, a2.publicKey, kemAccepted);"
          <> "const ap = pqX3dhRcv(a1.privateKey, a2.privateKey, b1.publicKey, b2.publicKey, aliceKemAccepted);"
          -- Init ratchets with KEM keypairs
          <> "let bob = initSndRatchet({current:3,maxSupported:3}, a2.publicKey, b3.privateKey, bp, bobKem);"
          <> "let alice = initRcvRatchet({current:3,maxSupported:3}, a2.privateKey, ap, aliceKem, true);"
          <> "let sk = new Map();"
          -- Bob sends msg1 (has KEM params in header from initSndRatchet)
          <> "const e1 = rcEncrypt(bob, new TextEncoder().encode('pq msg1'), 100); bob = e1.state;"
          -- Alice decrypts msg1 (triggers ratchet advance with KEM)
          <> "let d1 = rcDecrypt(alice, sk, e1.ciphertext); alice = d1.state; sk = d1.skippedKeys;"
          -- Alice sends msg2 (ratchet advanced, has KEM params from pqRatchetStep)
          <> "const e2 = rcEncrypt(alice, new TextEncoder().encode('pq msg2'), 100); alice = e2.state;"
          -- Bob decrypts msg2 (triggers ratchet advance with KEM on bob's side)
          <> "let d2 = rcDecrypt(bob, new Map(), e2.ciphertext); bob = d2.state;"
          -- Bob sends msg3 (another ratchet advance with KEM)
          <> "const e3 = rcEncrypt(bob, new TextEncoder().encode('pq msg3'), 100); bob = e3.state;"
          -- Alice decrypts msg3
          <> "let d3 = rcDecrypt(alice, sk, e3.ciphertext); alice = d3.state; sk = d3.skippedKeys;"
          -- Verify all messages
          <> "const ok = new TextDecoder().decode(d1.plaintext) === 'pq msg1'"
          <> " && new TextDecoder().decode(d2.plaintext) === 'pq msg2'"
          <> " && new TextDecoder().decode(d3.plaintext) === 'pq msg3'"
          -- Verify KEM state is maintained
          <> " && alice.rcKEM !== null && bob.rcKEM !== null"
          <> " && alice.rcSndKEM === true && bob.rcSndKEM === true;"
          <> jsOut ("new Uint8Array([ok ? 1 : 0])")
        tsResult `shouldBe` B.singleton 1

    describe "DER encoding" $ do
      it "X448 DER round-trips" $ do
        tsResult <- callNode $ impRatchet
          <> "const kp = generateX448KeyPair();"
          <> "const der = encodePubKeyX448(kp.publicKey);"
          <> "const raw = decodePubKeyX448(der);"
          <> "const match = kp.publicKey.every((b, i) => b === raw[i]);"
          <> jsOut ("new Uint8Array([match ? 1 : 0, der.length, raw.length])")
        tsResult `shouldBe` B.pack [1, 68, 56]

    describe "cross-language ratchet advance" $ do
      let run initPeers op test = withCrossPeers initPeers $ \(alice, bob) ->
            test alice bob tpEncrypt tpDecrypt op
      describe "HS rcv, JS snd, no PQ" $ do
        it "encrypt and decrypt" $ run initHsJs_noPQ tp_noKEM testEncryptDecrypt
        it "skipped messages" $ run initHsJs_noPQ tp_noKEM testSkippedMessages
        it "many messages" $ run initHsJs_noPQ tp_noKEM testManyMessages
        it "skipped after ratchet advance" $ run initHsJs_noPQ tp_noKEM testSkippedAfterRatchetAdvance
      describe "HS rcv, JS snd, PQ" $ do
        it "encrypt and decrypt" $ run initHsJs_PQ tp_hasKEM testEncryptDecrypt
        it "skipped messages" $ run initHsJs_PQ tp_hasKEM testSkippedMessages
        it "many messages" $ run initHsJs_PQ tp_hasKEM testManyMessages
        it "skipped after ratchet advance" $ run initHsJs_PQ tp_hasKEM testSkippedAfterRatchetAdvance
      describe "JS rcv, JS snd, no PQ" $ do
        it "encrypt and decrypt" $ run initTsTs_noPQ tp_noKEM testEncryptDecrypt
        it "skipped messages" $ run initTsTs_noPQ tp_noKEM testSkippedMessages
        it "many messages" $ run initTsTs_noPQ tp_noKEM testManyMessages
        it "skipped after ratchet advance" $ run initTsTs_noPQ tp_noKEM testSkippedAfterRatchetAdvance
      describe "JS rcv, JS snd, PQ" $ do
        it "encrypt and decrypt" $ run initTsTs_PQ tp_hasKEM testEncryptDecrypt
        it "skipped messages" $ run initTsTs_PQ tp_hasKEM testSkippedMessages
        it "many messages" $ run initTsTs_PQ tp_hasKEM testManyMessages
        it "skipped after ratchet advance" $ run initTsTs_PQ tp_hasKEM testSkippedAfterRatchetAdvance

  describe "crypto/blockEncryption" $ do
    describe "sbcInit + sbcHkdf" $ do
      it "TypeScript produces same sbKey/nonce via sbcInit+sbcHkdf as Haskell" $ do
        let sessId = B.pack [1..32]
            secret = B.pack [50..81]
            (sndCk, _rcvCk) = C.sbcInit sessId secret
            ((C.SbKey sbKey, C.CbNonce nonce), _nextCk) = C.sbcHkdf sndCk
        -- TypeScript does sbcInit then sbcHkdf on sndKey, should produce same sbKey/nonce
        tsResult <- callNode $ impSodium <> impCrypto
          <> "const ck = sbcInit(" <> jsUint8 sessId <> "," <> jsUint8 secret <> ");"
          <> "const r = sbcHkdf(ck.sndKey);"
          <> jsOut ("new Uint8Array([...r.keyNonce.sbKey, ...r.keyNonce.nonce])")
        tsResult `shouldBe` (sbKey <> nonce)

    describe "block encrypt/decrypt" $ do
      it "Haskell encrypts, TypeScript decrypts" $ do
        let sessId = B.pack [1..32]
            secret = B.pack [1..32]
            (sndCk, _) = C.sbcInit sessId secret
            msg = "hello encrypted block"
            ((sk, nonce), _nextCk) = C.sbcHkdf sndCk
        case C.sbEncrypt sk nonce msg (smpBlockSize - 16) of
          Left e -> expectationFailure $ "encrypt failed: " <> show e
          Right ct -> do
            tsResult <- callNode $ impSodium <> impCrypto
              <> "const ck = sbcInit(" <> jsUint8 sessId <> "," <> jsUint8 secret <> ");"
              <> "const r = sbDecryptBlock(ck.sndKey," <> jsUint8 ct <> ");"
              <> jsOut ("r.decrypted")
            tsResult `shouldBe` msg

      it "TypeScript encrypts, Haskell decrypts" $ do
        let sessId = B.pack [10..41]
            secret = B.pack [10..41]
            (sndCk, _) = C.sbcInit sessId secret
            msg = "hello from typescript"
        tsResult <- callNode $ impSodium <> impCrypto
          <> "const ck = sbcInit(" <> jsUint8 sessId <> "," <> jsUint8 secret <> ");"
          <> jsOut ("sbEncryptBlock(ck.sndKey, new TextEncoder().encode('hello from typescript'), " <> show (smpBlockSize - 16) <> ").encrypted")
        let ((sk, nonce), _nextCk) = C.sbcHkdf sndCk
        case C.sbDecrypt sk nonce tsResult of
          Left e -> expectationFailure $ "decrypt failed: " <> show e
          Right plain -> plain `shouldBe` msg

  describe "agent/protocol" $ do
    describe "ProtocolServer binary" $ do
      it "decodes Haskell-encoded server" $ do
        let srv = SMPServer ("smp.example.com" :| ["smp2.example.com"]) "5223" (C.KeyHash $ B.pack [1..32])
            encoded = smpEncode srv
        tsResult <- callNode $ impAgentProto
          <> "const s = decodeProtocolServer(new Decoder(" <> jsUint8 encoded <> "));"
          <> "const enc = new TextEncoder();"
          <> jsOut ("new Uint8Array([s.hosts.length, ...s.keyHash, ...enc.encode(new TextDecoder().decode(s.port))])")
        tsResult `shouldBe` B.pack ([2] ++ [1..32]) <> "5223"

    describe "ConnShortLink binary" $ do
      it "decodes Haskell-encoded contact link" $ do
        let srv = SMPServer ("relay.example.com" :| []) "" (C.KeyHash $ B.pack [1..32])
            linkKey = AP.LinkKey $ B.pack [50..81]
            link = AP.CSLContact AP.SLSServer AP.CCTGroup srv linkKey
            encoded = smpEncode link
        tsResult <- callNode $ impAgentProto
          <> "const l = decodeConnShortLink(new Decoder(" <> jsUint8 encoded <> "));"
          <> jsOut ("new Uint8Array([l.mode === 'contact' ? 1 : 0, l.connType === 'group' ? 1 : 0, ...l.linkKey])")
        tsResult `shouldBe` B.pack ([1, 1] ++ [50..81])

    describe "ConnLinkData" $ do
      it "decodes Haskell-encoded ContactLinkData with profile" $ do
        let profileJson = "{\"displayName\":\"alice\",\"fullName\":\"Alice A\"}"
            userData = AP.UserLinkData profileJson
            ucd = AP.UserContactData {AP.direct = True, AP.owners = [], AP.relays = [], AP.userData = userData}
            cld = AP.ContactLinkData (mkVersionRange (Version 1) (Version 3)) ucd :: AP.ConnLinkData 'AP.CMContact
            encoded = smpEncode cld
        tsResult <- callNode $ impAgentProto
          <> "const r = decodeConnLinkData(new Decoder(" <> jsUint8 encoded <> "));"
          <> "const p = parseProfile(r.userContactData.userData);"
          <> "const enc = new TextEncoder();"
          <> jsOut ("new Uint8Array(["
          <> "r.agentVRange.min >> 8, r.agentVRange.min & 0xff,"
          <> "r.agentVRange.max >> 8, r.agentVRange.max & 0xff,"
          <> "r.userContactData.direct ? 1 : 0,"
          <> "r.userContactData.owners.length,"
          <> "r.userContactData.relays.length,"
          <> "...enc.encode(p.displayName)"
          <> "])")
        tsResult `shouldBe` B.pack [0, 1, 0, 3, 1, 0, 0] <> "alice"

    describe "ConnShortLink URI" $ do
      it "parses simplex: contact link" $ do
        let srv = SMPServer ("smp1.example.com" :| []) "" (C.KeyHash $ B.pack [1..32])
            linkKey = AP.LinkKey $ B.pack [100..131]
            link = AP.CSLContact AP.SLSSimplex AP.CCTContact srv linkKey
            uri = strEncode link
        tsResult <- callNode $ impAgentProto
          <> "const r = connShortLinkStrP(" <> jsStr uri <> ");"
          <> jsOut ("new Uint8Array([...r.linkKey, ...r.server.keyHash])")
        tsResult `shouldBe` (B.pack [100..131] <> B.pack [1..32])

      it "parses https: contact link with port" $ do
        let srv = SMPServer ("smp2.example.com" :| []) "5223" (C.KeyHash $ B.pack [50..81])
            linkKey = AP.LinkKey $ B.pack [200..231]
            link = AP.CSLContact AP.SLSServer AP.CCTContact srv linkKey
            uri = strEncode link
        tsResult <- callNode $ impAgentProto
          <> "const r = connShortLinkStrP(" <> jsStr uri <> ");"
          <> "const enc = new TextEncoder();"
          <> jsOut ("new Uint8Array([...r.linkKey, ...r.server.keyHash, ...enc.encode(r.server.port), 0, ...enc.encode(r.server.hosts.join(','))])")
        let expected = B.pack [200..231] <> B.pack [50..81] <> "5223" <> B.singleton 0 <> "smp2.example.com"
        tsResult `shouldBe` expected

      it "parses simplex: contact link with multiple hosts" $ do
        let srv = SMPServer ("host1.example.com" :| ["host2.example.com"]) "" (C.KeyHash $ B.pack [1..32])
            linkKey = AP.LinkKey $ B.pack [10..41]
            link = AP.CSLContact AP.SLSSimplex AP.CCTContact srv linkKey
            uri = strEncode link
        tsResult <- callNode $ impAgentProto
          <> "const r = connShortLinkStrP(" <> jsStr uri <> ");"
          <> "const enc = new TextEncoder();"
          <> jsOut ("new Uint8Array([...r.linkKey, ...enc.encode(r.server.hosts.join(','))])")
        tsResult `shouldBe` (B.pack [10..41] <> "host1.example.com,host2.example.com")

      it "parses group link type" $ do
        let srv = SMPServer ("smp.example.com" :| []) "" (C.KeyHash $ B.pack [1..32])
            linkKey = AP.LinkKey $ B.pack [10..41]
            link = AP.CSLContact AP.SLSSimplex AP.CCTGroup srv linkKey
            uri = strEncode link
        tsResult <- callNode $ impAgentProto
          <> "const r = connShortLinkStrP(" <> jsStr uri <> ");"
          <> "const enc = new TextEncoder();"
          <> jsOut ("enc.encode(r.connType)")
        tsResult `shouldBe` "group"

      it "round-trips: Haskell encode -> TypeScript parse -> fields match" $ do
        let srv = SMPServer ("server1.simplex.im" :| ["server2.simplex.im"]) "443" (C.KeyHash $ B.pack [1..32])
            linkKey = AP.LinkKey $ B.pack [200..231]
            link = AP.CSLContact AP.SLSServer AP.CCTContact srv linkKey
            uri = strEncode link
        -- TypeScript returns: mode, scheme, connType, host count, port, linkKey
        tsResult <- callNode $ impAgentProto
          <> "const r = connShortLinkStrP(" <> jsStr uri <> ");"
          <> "const enc = new TextEncoder();"
          <> jsOut ("new Uint8Array(["
          <> "r.mode === 'contact' ? 1 : 0,"
          <> "r.scheme === 'https' ? 1 : 0,"
          <> "r.connType === 'contact' ? 1 : 0,"
          <> "r.server.hosts.length,"
          <> "...r.linkKey"
          <> "])")
        tsResult `shouldBe` B.pack ([1, 1, 1, 2] ++ [200..231])

    describe "WebSocket handshake" $ do
      it "TypeScript connects with block encryption, verifies identity, sends encrypted PING" $ do
        let msType = ASType SQSMemory SMSJournal
        attachStaticAndWS "tests/fixtures" $ \attachHTTP ->
          withSmpServerConfig (cfgWebOn msType testPort) (Just attachHTTP) $ \_ -> do
            let C.KeyHash kh = testKeyHash
            tsResult <- callNode $ impSodium <> impWS <> impProto
              <> "import { sendEncryptedBlock, receiveEncryptedBlock } from './dist/transport/websockets.js';"
              <> "try {"
              <> "const conn = await connectSMP('wss://localhost:" <> testPort <> "', " <> jsUint8 kh <> ", {rejectUnauthorized: false, ALPNProtocols: ['http/1.1']});"
              <> "if (!conn.sndKey || !conn.rcvKey) throw new Error('no block encryption keys');"
              <> "const ping = tEncodeBatch1(null, encodeTransmission(new Uint8Array([0x31]), new Uint8Array(0), encodePING()));"
              <> "sendEncryptedBlock(conn, ping);"
              <> "const resp = await receiveEncryptedBlock(conn);"
              <> "const ts = tParse(resp);"
              <> "const t = ts[0];"
              <> jsOut ("t.command")
              <> "conn.ws.close(); setTimeout(() => process.exit(0), 100);"
              <> "} catch(e) { process.stderr.write('ERROR: ' + e.message + '\\n'); process.exit(1); }"
            tsResult `shouldBe` "PONG"

  describe "end-to-end" $ do
    it "TypeScript fetches short link data via WebSocket" $ do
      let msType = ASType SQSMemory SMSJournal
      attachStaticAndWS "tests/fixtures" $ \attachHTTP ->
        withSmpServerConfig (cfgWebOn msType testPort) (Just attachHTTP) $ \_serverThread ->
          withAgent 1 agentCfg initAgentServers testDB $ \a -> do
            let testData = "hello from short link"
                userData = UserLinkData testData
                userCtData = UserContactData {direct = True, owners = [], relays = [], userData = userData}
                newLinkData = UserContactLinkData userCtData
            (_connId, (CCLink _connReq (Just shortLink), Nothing)) <-
              runRight $ A.createConnection a NRMInteractive 1 True True AP.SCMContact (Just newLinkData) Nothing CR.IKPQOn SMSubscribe
            let linkUri = strEncode shortLink
            tsResult <- callNode $ impSodium <> impWS <> impAgentProto <> impProto_ <> impCryptoShortLink
              <> "import { sendEncryptedBlock, receiveEncryptedBlock } from './dist/transport/websockets.js';"
              <> "try {"
              -- 1. Parse short link URI
              <> "const link = connShortLinkStrP(" <> jsStr linkUri <> ");"
              -- 2. Derive keys
              <> "const {linkId, sbKey} = contactShortLinkKdf(link.linkKey);"
              -- 3. Connect via WSS (with block encryption)
              <> "const conn = await connectSMP('wss://localhost:" <> testPort <> "', " <> jsUint8 (C.unKeyHash testKeyHash) <> ", {rejectUnauthorized: false, ALPNProtocols: ['http/1.1']});"
              -- 4. Send LGET (encrypted)
              <> "const lget = tEncodeBatch1(null, encodeTransmission(new Uint8Array([0x31]), linkId, encodeLGET()));"
              <> "sendEncryptedBlock(conn, lget);"
              -- 5. Receive LNK response (encrypted)
              <> "const resp = await receiveEncryptedBlock(conn);"
              <> "const ts = tParse(resp);"
              <> "const r = decodeResponse(new Decoder(ts[0].command));"
              <> "if (r.type !== 'LNK') throw new Error('expected LNK, got ' + r.type);"
              -- 6. Decrypt link data
              <> "const dec = decryptLinkData(sbKey, r.response.encFixedData, r.response.encUserData);"
              -- 7. Parse FixedLinkData (rootKey) and ConnLinkData (userData)
              <> "const fld = decodeFixedLinkData(new Decoder(dec.fixedData));"
              <> "const cld = decodeConnLinkData(new Decoder(dec.userData));"
              -- Return rootKey length (44 = valid DER Ed25519) + userData
              <> jsOut ("new Uint8Array([fld.rootKey.length, ...cld.userContactData.userData])")
              <> "conn.ws.close(); setTimeout(() => process.exit(0), 100);"
              <> "} catch(e) { process.stderr.write('ERROR: ' + e.message + '\\n'); process.exit(1); }"
            -- First byte: rootKey DER length (44 for Ed25519), rest: userData
            B.head tsResult `shouldBe` 44
            B.tail tsResult `shouldBe` testData

  describe "agent/message" $ do
    describe "AMessage" $ do
      it "HELLO encoding matches Haskell" $ do
        let hsBytes = smpEncode AP.HELLO
        tsBytes <- callNode $ impAgentMsg <> jsOut "encodeAMessage({type: 'HELLO'})"
        tsBytes `shouldBe` hsBytes

      it "A_MSG encoding matches Haskell" $ do
        let body = "hello world from agent"
            hsBytes = smpEncode (AP.A_MSG body)
        tsBytes <- callNode $ impAgentMsg <> jsOut ("encodeAMessage({type: 'A_MSG', body: new TextEncoder().encode('hello world from agent')})")
        tsBytes `shouldBe` hsBytes

      it "EREADY encoding matches Haskell" $ do
        let hsBytes = smpEncode (AP.EREADY 42)
        tsBytes <- callNode $ impEnc <> impAgentMsg <> jsOut ("encodeAMessage({type: 'EREADY', lastDecryptedMsgId: 42n})")
        tsBytes `shouldBe` hsBytes

      it "TypeScript decodes Haskell A_MSG" $ do
        let body = "decode test"
            hsBytes = smpEncode (AP.A_MSG body)
        tsResult <- callNode $ impEnc <> impAgentMsg
          <> "const msg = decodeAMessage(new Decoder(" <> jsUint8 hsBytes <> "));"
          <> jsOut ("msg.body")
        tsResult `shouldBe` body

    describe "APrivHeader" $ do
      it "encoding matches Haskell" $ do
        let hdr = AP.APrivHeader 1 (B.replicate 32 0xAB)
            hsBytes = smpEncode hdr
        tsBytes <- callNode $ impEnc <> impAgentMsg
          <> jsOut ("encodeAPrivHeader({sndMsgId: 1n, prevMsgHash: " <> jsUint8 (B.replicate 32 0xAB) <> "})")
        tsBytes `shouldBe` hsBytes

    describe "AgentMessage" $ do
      it "M variant encoding matches Haskell" $ do
        let hdr = AP.APrivHeader 5 (B.replicate 32 0)
            msg = AP.AgentMessage hdr (AP.A_MSG "test body")
            hsBytes = smpEncode msg
        tsBytes <- callNode $ impEnc <> impAgentMsg
          <> jsOut ("encodeAgentMessage({type: 'message', header: {sndMsgId: 5n, prevMsgHash: new Uint8Array(32)}, msg: {type: 'A_MSG', body: new TextEncoder().encode('test body')}})")
        tsBytes `shouldBe` hsBytes

      it "TypeScript decodes Haskell AgentMessage M" $ do
        let hdr = AP.APrivHeader 99 (B.pack [1..32])
            msg = AP.AgentMessage hdr (AP.A_MSG "cross-language message")
            hsBytes = smpEncode msg
        tsResult <- callNode $ impEnc <> impAgentMsg
          <> "const m = decodeAgentMessage(new Decoder(" <> jsUint8 hsBytes <> "));"
          <> "if (m.type !== 'message') throw new Error('expected message');"
          <> "if (m.msg.type !== 'A_MSG') throw new Error('expected A_MSG');"
          <> jsOut ("new Uint8Array([...new TextEncoder().encode(m.header.sndMsgId.toString()), 0, ...m.msg.body])")
        let (idStr, rest) = B.break (== 0) tsResult
        idStr `shouldBe` "99"
        B.tail rest `shouldBe` "cross-language message"

    describe "AgentMsgEnvelope" $ do
      it "M variant encoding matches Haskell" $ do
        let env = AP.AgentMsgEnvelope {AP.agentVersion = AP.currentSMPAgentVersion, AP.encAgentMessage = "encrypted payload"}
            hsBytes = smpEncode env
        tsBytes <- callNode $ impEnc <> impAgentMsg
          <> jsOut ("encodeAgentMsgEnvelope({type: 'envelope', agentVersion: 7, encAgentMessage: new TextEncoder().encode('encrypted payload')})")
        tsBytes `shouldBe` hsBytes

      it "TypeScript decodes Haskell AgentMsgEnvelope M" $ do
        let env = AP.AgentMsgEnvelope {AP.agentVersion = AP.currentSMPAgentVersion, AP.encAgentMessage = "decrypt me"}
            hsBytes = smpEncode env
        tsResult <- callNode $ impEnc <> impAgentMsg
          <> "const e = decodeAgentMsgEnvelope(new Decoder(" <> jsUint8 hsBytes <> "));"
          <> "if (e.type !== 'envelope') throw new Error('expected envelope');"
          <> jsOut ("e.encAgentMessage")
        tsResult `shouldBe` "decrypt me"

  describe "protocol/e2e" $ do
    describe "PubHeader" $ do
      it "encoding without key matches Haskell" $ do
        let h = PubHeader (VersionSMPC 19) Nothing
            hsBytes = smpEncode h
        tsBytes <- callNode $ impEnc <> impProtoE2E <> jsOut "encodePubHeader({phVersion: 19, phE2ePubDhKey: null})"
        tsBytes `shouldBe` hsBytes

      it "encoding with key matches Haskell" $ do
        g <- C.newRandom
        (k, _) <- atomically $ C.generateKeyPair @'C.X25519 g
        let derKey = C.encodePubKey k  -- raw DER bytes without smpEncode length prefix
            h = PubHeader (VersionSMPC 19) (Just k)
            hsBytes = smpEncode h
        tsBytes <- callNode $ impEnc <> impProtoE2E
          <> jsOut ("encodePubHeader({phVersion: 19, phE2ePubDhKey: " <> jsUint8 derKey <> "})")
        tsBytes `shouldBe` hsBytes

    describe "PrivHeader" $ do
      it "PHEmpty encoding matches Haskell" $ do
        let hsBytes = smpEncode PHEmpty
        tsBytes <- callNode $ impProtoE2E <> jsOut "encodePrivHeader({type: 'PHEmpty'})"
        tsBytes `shouldBe` hsBytes

    describe "ClientMessage" $ do
      it "encoding matches Haskell" $ do
        let body = "agent envelope bytes here"
            msg = ClientMessage PHEmpty body
            hsBytes = smpEncode msg
        tsBytes <- callNode $ impEnc <> impProtoE2E
          <> jsOut ("encodeClientMessage({privHeader: {type: 'PHEmpty'}, body: new TextEncoder().encode('agent envelope bytes here')})")
        tsBytes `shouldBe` hsBytes

    describe "ClientMsgEnvelope" $ do
      it "encoding matches Haskell" $ do
        let nonce = C.cbNonce $ B.pack [1..24]
            h = PubHeader (VersionSMPC 19) Nothing
            env = ClientMsgEnvelope {cmHeader = h, cmNonce = nonce, cmEncBody = "encrypted body data"}
            hsBytes = smpEncode env
        tsBytes <- callNode $ impEnc <> impProtoE2E
          <> jsOut ("encodeClientMsgEnvelope({cmHeader: {phVersion: 19, phE2ePubDhKey: null}, cmNonce: " <> jsUint8 (B.pack [1..24]) <> ", cmEncBody: new TextEncoder().encode('encrypted body data')})")
        tsBytes `shouldBe` hsBytes

      it "TypeScript decodes Haskell-encoded" $ do
        let nonce = C.cbNonce $ B.pack [10..33]
            h = PubHeader (VersionSMPC 19) Nothing
            env = ClientMsgEnvelope {cmHeader = h, cmNonce = nonce, cmEncBody = "test ciphertext"}
            hsBytes = smpEncode env
        tsResult <- callNode $ impEnc <> impProtoE2E
          <> "const env = decodeClientMsgEnvelope(new Decoder(" <> jsUint8 hsBytes <> "));"
          <> jsOut ("new Uint8Array([env.cmHeader.phVersion >> 8, env.cmHeader.phVersion & 0xff, env.cmHeader.phE2ePubDhKey === null ? 1 : 0, ...env.cmNonce, ...env.cmEncBody])")
        let (version, rest1) = B.splitAt 2 tsResult
            (nullByte, rest2) = B.splitAt 1 rest1
            (nonceBytes, bodyBytes) = B.splitAt 24 rest2
        version `shouldBe` B.pack [0, 19]
        nullByte `shouldBe` B.singleton 1
        nonceBytes `shouldBe` B.pack [10..33]
        bodyBytes `shouldBe` "test ciphertext"

    describe "per-queue E2E encrypt/decrypt" $ do
      it "TypeScript encrypts, Haskell decrypts" $ do
        -- Haskell generates receiver keypair
        g <- C.newRandom
        (rcvPub, rcvPriv) <- atomically $ C.generateKeyPair @'C.X25519 g
        let rcvPubRaw = C.pubKeyBytes rcvPub
        -- TypeScript generates sender keypair, computes DH, encrypts
        tsOutput <- callNode $ impSodium <> impEnc <> impProtoE2E
          <> "import { generateX25519KeyPair, dh, encodePubKeyX25519 } from '@simplex-chat/xftp-web/dist/crypto/keys.js';"
          <> "const sndKp = generateX25519KeyPair();"
          <> "const rcvPub = " <> jsUint8 rcvPubRaw <> ";"
          <> "const dhSecret = dh(rcvPub, sndKp.privateKey);"
          <> "const clientMsg = encodeClientMessage({privHeader: {type: 'PHEmpty'}, body: new TextEncoder().encode('hello from typescript e2e')});"
          <> "const encrypted = agentCbEncrypt(dhSecret, 19, null, clientMsg);"
          -- Output: DER-encoded sndPubKey (ByteString-encoded: 1-byte len + DER) + encrypted
          <> "const sndDer = encodePubKeyX25519(sndKp.publicKey);"
          <> jsOut ("new Uint8Array([sndDer.length, ...sndDer, ...encrypted])")
        -- Parse output: [1 byte len][DER sndPubKey][encrypted]
        let sndDerLen = fromIntegral $ B.head tsOutput
            (sndDerBytes, encrypted) = B.splitAt sndDerLen $ B.drop 1 tsOutput
        -- Haskell decodes sender's DER public key and decrypts
        let decoded = do
              apk <- C.decodePubKey sndDerBytes
              dhSecret <- case apk of
                C.APublicKey C.SX25519 pk -> Right $ C.dh' pk rcvPriv
                _ -> Left "not X25519"
              cme <- smpDecode encrypted
              plaintext <- first show $ C.cbDecrypt dhSecret (cmNonce cme) (cmEncBody cme)
              cm <- smpDecode plaintext
              case cm of
                ClientMessage PHEmpty body -> Right body
                _ -> Left "unexpected PrivHeader"
        decoded `shouldBe` Right "hello from typescript e2e"

  describe "protocol/transmission" $ do
    describe "sha512Hash" $ do
      it "matches Haskell" $ do
        let msg = "test message for hashing"
            hsHash = C.sha512Hash msg
        tsHash <- callNode $ impEnc
          <> "import { sha512Hash } from './dist/crypto.js';"
          <> jsOut ("sha512Hash(new TextEncoder().encode('test message for hashing'))")
        tsHash `shouldBe` hsHash

    describe "cbAuthenticator" $ do
      it "matches Haskell" $ do
        g <- C.newRandom
        (serverPub, _) <- atomically $ C.generateKeyPair @'C.X25519 g
        (_, entityPriv) <- atomically $ C.generateKeyPair @'C.X25519 g
        let nonce = C.cbNonce $ B.pack [1..24]
            msg = "transmission bytes to authenticate"
            C.CbAuthenticator hsAuth = C.cbAuthenticate serverPub entityPriv nonce msg
            C.PrivateKeyX25519 sk = entityPriv
            entityPrivBytes = BA.convert sk :: B.ByteString
        tsAuth <- callNode $ impSodium <> impEnc
          <> "import { cbAuthenticator } from './dist/crypto.js';"
          <> jsOut ("cbAuthenticator("
          <> jsUint8 (C.pubKeyBytes serverPub) <> ","
          <> jsUint8 entityPrivBytes <> ","
          <> jsUint8 (B.pack [1..24]) <> ","
          <> "new TextEncoder().encode('transmission bytes to authenticate'))")
        tsAuth `shouldBe` hsAuth

    describe "encodeTransmissionForAuth" $ do
      it "matches Haskell" $ do
        let sessId = B.pack [1..32]
            corrId = B.pack [10..33]
            entityId = B.pack [40..63]
            command = "PING"
            -- Haskell: tForAuth = sessionId <> encodeTransmission_(corrId, entityId, command)
            -- tToSend = encodeTransmission_(corrId, entityId, command) [implySessId=true]
            tToSend = smpEncode (corrId :: B.ByteString, entityId :: B.ByteString) <> command
            tForAuth = smpEncode sessId <> tToSend
        tsResult <- callNode $ impProto
          <> "const r = encodeTransmissionForAuth("
          <> jsUint8 sessId <> ","
          <> jsUint8 corrId <> ","
          <> jsUint8 entityId <> ","
          <> "new Uint8Array([0x50,0x49,0x4E,0x47]));"
          <> jsOut ("new Uint8Array([...r.tForAuth, 0xFF, ...r.tToSend])")
        let (tsTForAuth, rest) = B.break (== 0xFF) tsResult
            tsTToSend = B.drop 1 rest
        tsTForAuth `shouldBe` tForAuth
        tsTToSend `shouldBe` tToSend

    describe "tEncodeBatch1" $ do
      it "matches Haskell tEncodeBatch1" $ do
        -- Haskell: tEncodeBatch1 serviceAuth=false (auth, tToSend) = lenEncode 1 `cons` Large(tEncodeAuth auth <> tToSend)
        let tToSend = "corrId-entity-command-bytes"
            -- No auth: tEncodeAuth Nothing = smpEncode "" = [0x00]
            encoded = B.singleton 1 <> smpEncode (Large (smpEncode (B.empty :: B.ByteString) <> tToSend))
        tsEncoded <- callNode $ impProto
          <> jsOut ("tEncodeBatch1(null, new TextEncoder().encode('corrId-entity-command-bytes'))")
        tsEncoded `shouldBe` encoded

    describe "tParse" $ do
      it "parses Haskell-encoded batch response" $ do
        -- Build a batch with one transmission: count=1 + Large(auth + corrId + entityId + command)
        let corrId = B.pack [1..24]
            entityId = B.pack [30..53]
            command = "PONG"
            auth = B.empty  -- empty auth
            inner = smpEncode auth <> smpEncode corrId <> smpEncode entityId <> command
            block = B.singleton 1 <> smpEncode (Large inner)
        tsResult <- callNode $ impProto
          <> "const ts = tParse(" <> jsUint8 block <> ");"
          <> "if (ts.length !== 1) throw new Error('expected 1 transmission');"
          <> jsOut ("new Uint8Array([...ts[0].corrId, ...ts[0].entityId, ...ts[0].command])")
        tsResult `shouldBe` (corrId <> entityId <> command)

    describe "reverseNonce" $ do
      it "matches Haskell" $ do
        let nonce = B.pack [1..24]
            hsReversed = B.reverse nonce
        tsReversed <- callNode $ impProto
          <> "import { reverseNonce } from './dist/crypto.js';"
          <> jsOut ("reverseNonce(" <> jsUint8 nonce <> ")")
        tsReversed `shouldBe` hsReversed

    describe "encodeProtocolServer" $ do
      it "matches Haskell" $ do
        let srv = SMPServer ("smp1.example.com" :| ["smp2.example.com"]) "5223" (C.KeyHash $ B.pack [1..32])
            hsEncoded = smpEncode srv
        tsEncoded <- callNode $ impProto
          <> jsOut ("encodeProtocolServer(['smp1.example.com','smp2.example.com'], '5223', " <> jsUint8 (B.pack [1..32]) <> ")")
        tsEncoded `shouldBe` hsEncoded

    describe "encodePRXY" $ do
      it "matches Haskell" $ do
        let srv = SMPServer ("relay.example.com" :| []) "" (C.KeyHash $ B.pack [1..32])
            cmd = Cmd SProxiedClient $ PRXY srv Nothing
            v = currentServerSMPRelayVersion
            hsEncoded = encodeProtocol v cmd
        tsEncoded <- callNode $ impProto
          <> jsOut ("encodePRXY(['relay.example.com'], '', " <> jsUint8 (B.pack [1..32]) <> ", null)")
        tsEncoded `shouldBe` hsEncoded

  describe "full-stack" $ do
    it "Haskell encodes all layers, TypeScript decodes" $ do
      g <- C.newRandom
      let v = CR.currentE2EEncryptVersion
      -- Alice (receiver) ratchet keys - extract raw private bytes for TypeScript
      (alicePk1, alicePk2, Nothing, e2eAlice) <- CR.generateRcvE2EParams @'X448 g v CR.PQSupportOff
      let C.PrivateKeyX448 sk1 = alicePk1; alicePriv1 = BA.convert sk1 :: B.ByteString
          C.PrivateKeyX448 sk2 = alicePk2; alicePriv2 = BA.convert sk2 :: B.ByteString
      -- Bob (sender) ratchet: X3DH + init
      (bobPk1, bobPk2, Nothing, CR.AE2ERatchetParams _ e2eBob) <- CR.generateSndE2EParams @'X448 g v Nothing
      Right bobInitParams <- pure $ CR.pqX3dhSnd bobPk1 bobPk2 Nothing e2eAlice
      (_, bobDHRs) <- atomically $ C.generateKeyPair @'X448 g
      let bobRatchet = CR.initSndRatchet (CR.RatchetVersions v v) (C.publicKey alicePk2) bobDHRs bobInitParams
          bobE2EBytes = smpEncode e2eBob
      -- Per-queue E2E: shared DH secret (pass raw bytes to both sides)
      (_, e2eSndPriv) <- atomically $ C.generateKeyPair @'C.X25519 g
      (e2eRcvPub, _) <- atomically $ C.generateKeyPair @'C.X25519 g
      let dhSecret = C.dh' e2eRcvPub e2eSndPriv
          dhSecretBytes = C.dhBytes' dhSecret
      -- Haskell: encode A_MSG through all layers
      let aMsg = AP.AgentMessage (AP.APrivHeader 1 (B.replicate 32 0)) (AP.A_MSG "hello full stack")
          agentMsgBytes = smpEncode aMsg
      Right (mek, _) <- runExceptT $ CR.rcEncryptHeader bobRatchet Nothing CR.currentE2EEncryptVersion
      Right encAgentMsg <- runExceptT $ CR.rcEncryptMsg mek (AP.e2eEncAgentMsgLength AP.currentSMPAgentVersion CR.PQSupportOff) agentMsgBytes
      let envBytes = smpEncode $ AP.AgentMsgEnvelope {AP.agentVersion = AP.currentSMPAgentVersion, AP.encAgentMessage = encAgentMsg}
          clientMsgBytes = smpEncode $ ClientMessage PHEmpty envBytes
      cmNonce <- atomically $ C.randomCbNonce g
      Right cmEncBody <- pure $ C.cbEncrypt dhSecret cmNonce clientMsgBytes 16000
      let cmeBytes = smpEncode $ ClientMsgEnvelope (PubHeader (VersionSMPC 19) Nothing) cmNonce cmEncBody
      -- TypeScript: init alice ratchet + decode all layers
      tsResult <- callNode $ impSodium <> impEnc <> impRatchet <> impAgentMsg <> impProtoE2E
        <> "import { cbDecrypt } from '@simplex-chat/xftp-web/dist/crypto/secretbox.js';"
        -- Init alice's receiver ratchet
        <> "const a1Priv = " <> jsUint8 alicePriv1 <> ";"
        <> "const a2Priv = " <> jsUint8 alicePriv2 <> ";"
        <> "const rd = new Decoder(" <> jsUint8 bobE2EBytes <> ");"
        <> "rd.anyByte(); rd.anyByte();"  -- skip version
        <> "const bpk1 = decodePubKeyX448(decodeBytes(rd));"
        <> "const bpk2 = decodePubKeyX448(decodeBytes(rd));"
        <> "const ap = pqX3dhRcv(a1Priv, a2Priv, bpk1, bpk2);"
        <> "let alice = initRcvRatchet({current:3,maxSupported:3}, a2Priv, ap, null, false);"
        <> "let sk = new Map();"
        -- Layer 1: per-queue E2E decrypt
        <> "const dhSecret = " <> jsUint8 dhSecretBytes <> ";"
        <> "const {clientMessage} = agentCbDecrypt(dhSecret, " <> jsUint8 cmeBytes <> ");"
        -- Layer 2: decode AgentMsgEnvelope
        <> "const env = decodeAgentMsgEnvelope(new Decoder(clientMessage.body));"
        <> "if (env.type !== 'envelope') throw new Error('expected envelope, got ' + env.type);"
        -- Layer 3: ratchet decrypt
        <> "const dec = rcDecrypt(alice, sk, env.encAgentMessage);"
        -- Layer 4: decode AgentMessage + AMessage
        <> "const agentMsg = decodeAgentMessage(new Decoder(dec.plaintext));"
        <> "if (agentMsg.type !== 'message') throw new Error('expected message, got ' + agentMsg.type);"
        <> "if (agentMsg.msg.type !== 'A_MSG') throw new Error('expected A_MSG, got ' + agentMsg.msg.type);"
        <> jsOut ("agentMsg.msg.body")
      tsResult `shouldBe` "hello full stack"

    it "TypeScript encodes all layers, Haskell decodes" $ do
      g <- C.newRandom
      let v = CR.currentE2EEncryptVersion
      -- Alice (receiver): Haskell generates ratchet rcv params + X25519 for per-queue E2E
      (alicePk1, alicePk2, Nothing, e2eAlice) <- CR.generateRcvE2EParams @'X448 g v CR.PQSupportOff
      let aliceE2EBytes = smpEncode e2eAlice
      (e2eRcvPub, e2eRcvPriv) <- atomically $ C.generateKeyPair @'C.X25519 g
      -- TypeScript: init bob's sender ratchet, encode full stack, output keys + ciphertext
      tsOutput <- callNode $ impSodium <> impEnc <> impRatchet <> impAgentMsg <> impProtoE2E
        <> "import { generateX25519KeyPair, dh, encodePubKeyX25519 } from '@simplex-chat/xftp-web/dist/crypto/keys.js';"
        -- Init bob's sender ratchet
        <> "const d = new Decoder(" <> jsUint8 aliceE2EBytes <> ");"
        <> "const aliceV = d.anyByte() * 256 + d.anyByte();"
        <> "const alicePk1Raw = decodePubKeyX448(decodeBytes(d));"
        <> "const alicePk2Raw = decodePubKeyX448(decodeBytes(d));"
        <> "const b1 = generateX448KeyPair(), b2 = generateX448KeyPair(), b3 = generateX448KeyPair();"
        <> "const bp = pqX3dhSnd(b1.privateKey, b2.privateKey, alicePk1Raw, alicePk2Raw);"
        <> "let bob = initSndRatchet({current:3,maxSupported:3}, alicePk2Raw, b3.privateKey, bp, null);"
        -- Layer 4: encode AgentMessage
        <> "const agentMsg = encodeAgentMessage({type: 'message', header: {sndMsgId: 1n, prevMsgHash: new Uint8Array(32)}, msg: {type: 'A_MSG', body: new TextEncoder().encode('hello from ts full stack')}});"
        -- Layer 3: ratchet encrypt
        <> "const enc = rcEncrypt(bob, agentMsg, 15840);"
        -- Layer 2: wrap in AgentMsgEnvelope
        <> "const envBytes = encodeAgentMsgEnvelope({type: 'envelope', agentVersion: 7, encAgentMessage: enc.ciphertext});"
        -- Layer 1: per-queue E2E encrypt
        <> "const sndKp = generateX25519KeyPair();"
        <> "const rcvPub = " <> jsUint8 (C.pubKeyBytes e2eRcvPub) <> ";"
        <> "const dhSecret = dh(rcvPub, sndKp.privateKey);"
        <> "const clientMsg = encodeClientMessage({privHeader: {type: 'PHEmpty'}, body: envBytes});"
        <> "const cmeBytes = agentCbEncrypt(dhSecret, 19, null, clientMsg);"
        -- Output: bob E2E params + snd DER pubkey + cmeBytes
        <> "const bobE2E = new Uint8Array([...encodeWord16(3), ...encodeBytes(encodePubKeyX448(b1.publicKey)), ...encodeBytes(encodePubKeyX448(b2.publicKey)), 0x30]);"
        <> "const sndDer = encodePubKeyX25519(sndKp.publicKey);"
        <> "const out = new Uint8Array(["
        <> "  (bobE2E.length >> 8) & 0xff, bobE2E.length & 0xff, ...bobE2E,"
        <> "  sndDer.length, ...sndDer,"
        <> "  ...cmeBytes"
        <> "]);"
        <> jsOut ("out")
      -- Parse TypeScript output
      let (e2eLenBs, r1) = B.splitAt 2 tsOutput
          bobE2ELen = fromIntegral (B.index e2eLenBs 0) * 256 + fromIntegral (B.index e2eLenBs 1)
          (bobE2EBytes, r2) = B.splitAt bobE2ELen r1
          sndDerLen = fromIntegral $ B.head r2
          (sndDerBytes, cmeBytes) = B.splitAt sndDerLen $ B.drop 1 r2
      -- Haskell: init alice's receiver ratchet, decode all layers
      Right (CR.AE2ERatchetParams _ bobE2E :: CR.AE2ERatchetParams 'X448) <- pure $ smpDecode bobE2EBytes
      Right (aliceInitParams, _) <- runExceptT $ CR.pqX3dhRcv alicePk1 alicePk2 Nothing bobE2E
      let aliceRatchet = CR.initRcvRatchet (CR.RatchetVersions v v) alicePk2 (aliceInitParams, Nothing) CR.PQSupportOff
      -- Decode all layers using ExceptT to chain pure Either + IO
      gAlice <- C.newRandom
      result <- runExceptT $ do
        -- Per-queue E2E decrypt (pure)
        apk <- liftEither $ C.decodePubKey sndDerBytes
        dhSecret <- case apk of
          C.APublicKey C.SX25519 pk -> pure $ C.dh' pk e2eRcvPriv
          _ -> throwError "not X25519"
        cme <- liftEither $ smpDecode cmeBytes
        plaintext <- liftEither $ first show $ C.cbDecrypt dhSecret (cmNonce cme) (cmEncBody cme)
        cm <- liftEither $ smpDecode plaintext
        envBody <- case cm of
          ClientMessage PHEmpty b -> pure b
          _ -> throwError "unexpected PrivHeader"
        -- Decode envelope
        env <- liftEither $ smpDecode envBody
        encMsg <- case env of
          AP.AgentMsgEnvelope {AP.encAgentMessage = m} -> pure m
          _ -> throwError "unexpected AgentMsgEnvelope variant"
        -- Ratchet decrypt (IO)
        (msgBody_, _, _) <- withExceptT show $ CR.rcDecrypt gAlice aliceRatchet M.empty encMsg
        liftEither $ first show msgBody_
      -- Decode agent message from result
      agentMsgBytes <- either (error . ("decode failed: " <>)) pure result
      Right (AP.AgentMessage _ (AP.A_MSG body)) <- pure $ smpDecode agentMsgBytes
      body `shouldBe` "hello from ts full stack"

  describe "client" $ do
    it "JS client REPL: PING/PONG via SMP server" $ do
      let msType = ASType SQSMemory SMSJournal
      attachStaticAndWS "tests/fixtures" $ \attachHTTP ->
        withSmpServerConfig (cfgWebOn msType testPort) (Just attachHTTP) $ \_ -> do
          (hIn, hOut, ph) <- spawnJsClient
          let C.KeyHash kh = testKeyHash
          resp <- jsCmd hIn hOut $ "CONNECT wss://localhost:" <> testPort <> " " <> bsToHex kh <> " " <> "{\"rejectUnauthorized\":false,\"ALPNProtocols\":[\"http/1.1\"]}"
          resp `shouldBe` "ok"
          pingResp <- jsCmd hIn hOut "PING"
          pingResp `shouldBe` "ok"
          _ <- jsCmd hIn hOut "CLOSE"
          terminateProcess ph

    it "authTransmission full batch block matches Haskell" $ do
      g <- C.newRandom
      -- Known inputs
      let sessId = B.pack [1..48]  -- 48-byte sessionId like real server
          corrId = B.pack [50..73]  -- 24-byte corrId/nonce
      (serverPub, _serverPriv) <- atomically $ C.generateKeyPair @'C.X25519 g
      (_, entityPriv) <- atomically $ C.generateKeyPair @'C.X25519 g
      let C.PrivateKeyX25519 sk = entityPriv
          entityPrivBytes = BA.convert sk :: B.ByteString
          nonce = C.cbNonce corrId
          -- Haskell: encodeTransmissionForAuth
          tToSend = smpEncode (corrId :: B.ByteString, B.empty :: B.ByteString) <> "PING"
          tForAuth = smpEncode sessId <> tToSend
          -- Haskell: cbAuthenticate
          hsAuth = C.cbAuthenticate serverPub entityPriv nonce tForAuth
          C.CbAuthenticator hsAuthBytes = hsAuth
          -- Haskell: tEncodeBatch1 (with serviceAuth=true: auth + Nothing serviceSig)
          hsBlock = B.singleton 1 <> smpEncode (Large (smpEncode hsAuthBytes <> smpEncode (Nothing :: Maybe B.ByteString) <> tToSend))
      -- TypeScript: same computation
      tsBlock <- callNode $ impSodium <> impProto
        <> "const sessId = " <> jsUint8 sessId <> ";"
        <> "const corrId = " <> jsUint8 corrId <> ";"
        <> "const serverPub = " <> jsUint8 (C.pubKeyBytes serverPub) <> ";"
        <> "const entityPriv = " <> jsUint8 entityPrivBytes <> ";"
        <> "const {tForAuth, tToSend} = encodeTransmissionForAuth(sessId, corrId, new Uint8Array(0), encodePING());"
        <> "const auth = authTransmission(serverPub, {type:'x25519', key:entityPriv}, corrId, tForAuth);"
        <> jsOut ("tEncodeBatch1(auth, tToSend)")
      tsBlock `shouldBe` hsBlock

    it "JS client REPL: create queue and send/receive message" $ do
      let msType = ASType SQSMemory SMSJournal
      attachStaticAndWS "tests/fixtures" $ \attachHTTP ->
        withSmpServerConfig (cfgWebOn msType testPort) (Just attachHTTP) $ \_ -> do
          -- Generate auth keys (X25519 DH auth for v7+)
          g <- C.newRandom
          (rcvAuthPub, rcvAuthPriv) <- atomically $ C.generateKeyPair @'C.X25519 g
          let rcvAuthPubDer = C.encodePubKey rcvAuthPub
              C.PrivateKeyX25519 sk = rcvAuthPriv
              rcvAuthPrivBytes = BA.convert sk :: B.ByteString
          (sndAuthPub, sndAuthPriv) <- atomically $ C.generateKeyPair @'C.X25519 g
          let sndAuthPubDer = C.encodePubKey sndAuthPub
              C.PrivateKeyX25519 sndSk = sndAuthPriv
              sndAuthPrivBytes = BA.convert sndSk :: B.ByteString

          -- Spawn receiver and sender clients
          (rcvIn, rcvOut, rcvPh) <- spawnJsClient
          (sndIn, sndOut, sndPh) <- spawnJsClient
          let connectCmd = "CONNECT wss://localhost:" <> testPort <> " " <> bsToHex (C.unKeyHash testKeyHash) <> " {\"rejectUnauthorized\":false,\"ALPNProtocols\":[\"http/1.1\"]}"
          "ok" <- jsCmd rcvIn rcvOut connectCmd
          "ok" <- jsCmd sndIn sndOut connectCmd

          -- Receiver: create queue (REPL generates DH keypair internally)
          newResp <- jsCmd rcvIn rcvOut $ "NEW " <> bsToHex rcvAuthPubDer <> " " <> bsToHex rcvAuthPrivBytes
          let newParts = words newResp
          when (head newParts /= "ok:") $ expectationFailure $ "NEW failed: " <> newResp
          head newParts `shouldBe` "ok:"
          let rcvIdHex = newParts !! 1
              sndIdHex = newParts !! 2
          -- Receiver: secure queue with sender's public key
          keyResp <- jsCmd rcvIn rcvOut $ "KEY " <> rcvIdHex <> " " <> bsToHex rcvAuthPrivBytes <> " " <> bsToHex sndAuthPubDer
          when (keyResp /= "ok") $ expectationFailure $ "KEY failed: " <> keyResp
          -- Receiver: subscribe
          subResp <- jsCmd rcvIn rcvOut $ "SUB " <> rcvIdHex <> " " <> bsToHex rcvAuthPrivBytes
          when (subResp /= "ok") $ expectationFailure $ "SUB failed: " <> subResp

          -- Sender: send message (with auth)
          let testMsg = "hello from sender"
          "ok" <- jsCmd sndIn sndOut $ "SEND " <> sndIdHex <> " " <> bsToHex sndAuthPrivBytes <> " 1 " <> bsToHex testMsg

          -- Receiver: receive and decrypt message
          recvResp <- jsCmd rcvIn rcvOut "RECV 5000"
          let recvParts = words recvResp
          head recvParts `shouldBe` "ok:"
          length recvParts `shouldSatisfy` (>= 4)
          let bodyHex = recvParts !! 3
          hexToBS bodyHex `shouldBe` testMsg

          -- Cleanup
          _ <- jsCmd rcvIn rcvOut "CLOSE"
          _ <- jsCmd sndIn sndOut "CLOSE"
          terminateProcess rcvPh
          terminateProcess sndPh

    it "cross-language: HS sender, JS receiver" $ do
      let msType = ASType SQSMemory SMSJournal
      attachStaticAndWS "tests/fixtures" $ \attachHTTP ->
        withSmpServerConfig (cfgWebOn msType testPort) (Just attachHTTP) $ \_ -> do
          g <- C.newRandom
          -- JS receiver: connect, create queue
          (rcvIn, rcvOut, rcvPh) <- spawnJsClient
          "ok" <- jsCmd rcvIn rcvOut $ "CONNECT wss://localhost:" <> testPort <> " " <> bsToHex (C.unKeyHash testKeyHash) <> " {\"rejectUnauthorized\":false,\"ALPNProtocols\":[\"http/1.1\"]}"
          (rcvAuthPub, rcvAuthPriv) <- atomically $ C.generateKeyPair @'C.X25519 g
          let C.PrivateKeyX25519 sk = rcvAuthPriv
              rcvAuthPrivBytes = BA.convert sk :: B.ByteString
          newResp <- jsCmd rcvIn rcvOut $ "NEW " <> bsToHex (C.encodePubKey rcvAuthPub) <> " " <> bsToHex rcvAuthPrivBytes
          let newParts = words newResp
          when (head newParts /= "ok:") $ expectationFailure $ "NEW failed: " <> newResp
          let sndIdHex = newParts !! 2
              rcvIdHex = newParts !! 1
              sndId = hexToBS sndIdHex
          -- JS receiver: subscribe (no KEY — sender sends unsigned)
          subResp <- jsCmd rcvIn rcvOut $ "SUB " <> rcvIdHex <> " " <> bsToHex rcvAuthPrivBytes
          when (subResp /= "ok") $ expectationFailure $ "SUB failed: " <> subResp
          -- HS sender: connect via TLS, send message
          testSMPClient @TLS $ \sh -> do
            let testMsg = "hello from haskell"
            Resp _ _ ok <- sendRecv sh (Nothing, "1234", EntityId sndId, _SEND testMsg)
            ok `shouldBe` OK
            -- JS receiver: receive and decrypt
            recvResp <- jsCmd rcvIn rcvOut "RECV 5000"
            let recvParts = words recvResp
            head recvParts `shouldBe` "ok:"
            let bodyHex = recvParts !! 3
            hexToBS bodyHex `shouldBe` testMsg
          _ <- jsCmd rcvIn rcvOut "CLOSE"
          terminateProcess rcvPh

    it "cross-language: JS sender, HS receiver" $ do
      let msType = ASType SQSMemory SMSJournal
      attachStaticAndWS "tests/fixtures" $ \attachHTTP ->
        withSmpServerConfig (cfgWebOn msType testPort) (Just attachHTTP) $ \_ -> do
          g <- C.newRandom
          -- HS receiver: connect via TLS, create queue
          testSMPClient @TLS $ \rh -> do
            (rPub, rKey) <- atomically $ C.generateAuthKeyPair C.SEd448 g
            (dhPub, dhPriv :: C.PrivateKeyX25519) <- atomically $ C.generateKeyPair g
            Resp "abcd" _ (Ids _rId sId srvDh) <- signSendRecv rh rKey ("abcd", NoEntity, New rPub dhPub)
            let dec = decryptMsgV3 $ C.dh' srvDh dhPriv
            -- JS sender: connect via WebSocket, send message
            (sndIn, sndOut, sndPh) <- spawnJsClient
            "ok" <- jsCmd sndIn sndOut $ "CONNECT wss://localhost:" <> testPort <> " " <> bsToHex (C.unKeyHash testKeyHash) <> " {\"rejectUnauthorized\":false,\"ALPNProtocols\":[\"http/1.1\"]}"
            let testMsg = "hello from typescript"
            "ok" <- jsCmd sndIn sndOut $ "SEND " <> bsToHex (unEntityId sId) <> " none 1 " <> bsToHex testMsg
            -- HS receiver: receive and decrypt
            Resp "" _ (Msg mId1 msg1) <- tGet1 rh
            dec mId1 msg1 `shouldBe` Right testMsg
            Resp "bcda" _ OK <- signSendRecv rh rKey ("bcda", _rId, ACK mId1)
            _ <- jsCmd sndIn sndOut "CLOSE"
            terminateProcess sndPh

    it "cross-language: JS sends via proxy to HS receiver" $ do
      let msType = ASType SQSMemory SMSJournal
          -- Proxy server with WebSocket: enable proxy on the web-enabled config
          proxyCfgWeb = updateCfg (cfgWebOn msType testPort) $ \cfg' ->
            cfg' {allowSMPProxy = True}
          -- Relay server on testPort2: standard config
          relayCfg = journalCfg (cfgMS msType) testStoreLogFile2 testStoreMsgsDir2
      attachStaticAndWS "tests/fixtures" $ \attachHTTP ->
        withSmpServerConfig proxyCfgWeb (Just attachHTTP) $ \_ ->
          withSmpServerConfigOn (transport @TLS) relayCfg testPort2 $ \_ -> do
            g <- C.newRandom
            -- HS receiver: create queue on RELAY server via TLS
            let (h :| _) = testHost2
            testSMPClient_ @TLS h testPort2 supportedClientSMPRelayVRange $ \rh -> do
              (rPub, rKey) <- atomically $ C.generateAuthKeyPair C.SEd448 g
              (dhPub, dhPriv :: C.PrivateKeyX25519) <- atomically $ C.generateKeyPair g
              Resp "abcd" _ (Ids _rId sId srvDh) <- signSendRecv rh rKey ("abcd", NoEntity, New rPub dhPub)
              let dec = decryptMsgV3 $ C.dh' srvDh dhPriv
              -- JS sender: connect to PROXY via WebSocket, send PRXY for relay
              (sndIn, sndOut, sndPh) <- spawnJsClient
              "ok" <- jsCmd sndIn sndOut $ "CONNECT wss://localhost:" <> testPort <> " " <> bsToHex (C.unKeyHash testKeyHash) <> " {\"rejectUnauthorized\":false,\"ALPNProtocols\":[\"http/1.1\"]}"
              -- Connect to relay via proxy
              prxyResp <- jsCmd sndIn sndOut $ "PRXY localhost " <> testPort2 <> " " <> bsToHex (C.unKeyHash testKeyHash)
              when (not $ "ok:" `isPrefixOf` prxyResp) $ expectationFailure $ "PRXY failed: " <> prxyResp
              -- Send message via proxy
              let testMsg = "hello via proxy"
              sendResp <- jsCmd sndIn sndOut $ "PSEND " <> bsToHex (unEntityId sId) <> " none 1 " <> bsToHex testMsg
              when (sendResp /= "ok") $ expectationFailure $ "PSEND failed: " <> sendResp
              -- HS receiver: receive and decrypt
              Resp "" _ (Msg mId1 msg1) <- tGet1 rh
              dec mId1 msg1 `shouldBe` Right testMsg
              _ <- jsCmd sndIn sndOut "CLOSE"
              terminateProcess sndPh

    it "JS batch subscribe: create 3 queues, batch subscribe, receive messages" $ do
      let msType = ASType SQSMemory SMSJournal
      attachStaticAndWS "tests/fixtures" $ \attachHTTP ->
        withSmpServerConfig (cfgWebOn msType testPort) (Just attachHTTP) $ \_ -> do
          g <- C.newRandom
          -- JS receiver
          (rcvIn, rcvOut, rcvPh) <- spawnJsClient
          "ok" <- jsCmd rcvIn rcvOut $ "CONNECT wss://localhost:" <> testPort <> " " <> bsToHex (C.unKeyHash testKeyHash) <> " {\"rejectUnauthorized\":false,\"ALPNProtocols\":[\"http/1.1\"]}"
          -- Create 3 queues
          sndIds <- forM [1..3 :: Int] $ \_ -> do
            (authPub, authPriv) <- atomically $ C.generateKeyPair @'C.X25519 g
            let C.PrivateKeyX25519 sk = authPriv
                privBytes = BA.convert sk :: B.ByteString
            newResp <- jsCmd rcvIn rcvOut $ "NEW " <> bsToHex (C.encodePubKey authPub) <> " " <> bsToHex privBytes
            let newParts = words newResp
            when (head newParts /= "ok:") $ expectationFailure $ "NEW failed: " <> newResp
            pure (newParts !! 1, newParts !! 2, bsToHex privBytes) -- rcvIdHex, sndIdHex, privKeyHex
          -- Batch subscribe
          let bsubArg = unwords [rcvId <> ":" <> pk | (rcvId, _, pk) <- sndIds]
          bsubResp <- jsCmd rcvIn rcvOut $ "BSUB " <> bsubArg
          when (bsubResp /= "ok") $ expectationFailure $ "BSUB failed: " <> bsubResp
          -- HS sender: send a message to each queue
          testSMPClient @TLS $ \sh -> do
            forM_ (zip [1..] sndIds) $ \(i :: Int, (_, sndIdHex, _)) -> do
              let sndId = hexToBS sndIdHex
                  msg = "batch msg " <> BC.pack (show i)
              Resp _ _ OK <- sendRecv sh (Nothing, BC.pack (show i), EntityId sndId, _SEND msg)
              pure ()
            -- JS receiver: receive 3 messages
            forM_ [1..3 :: Int] $ \i -> do
              recvResp <- jsCmd rcvIn rcvOut "RECV 5000"
              let recvParts = words recvResp
              head recvParts `shouldBe` "ok:"
              let bodyHex = recvParts !! 3
              hexToBS bodyHex `shouldBe` ("batch msg " <> BC.pack (show i))
          _ <- jsCmd rcvIn rcvOut "CLOSE"
          terminateProcess rcvPh

    it "cross-language: HS sends via proxy to JS receiver (one server)" $ do
      let msType = ASType SQSMemory SMSJournal
          -- One server: WebSocket + proxy enabled (like oneServer in SMPProxyTests)
          proxyCfgWeb = updateCfg (cfgWebOn msType testPort) $ \cfg' ->
            cfg' {allowSMPProxy = True}
      attachStaticAndWS "tests/fixtures" $ \attachHTTP ->
        withSmpServerConfig proxyCfgWeb (Just attachHTTP) $ \_ -> do
          g <- C.newRandom
          -- JS receiver: create queue on server via WebSocket
          (rcvIn, rcvOut, rcvPh) <- spawnJsClient
          "ok" <- jsCmd rcvIn rcvOut $ "CONNECT wss://localhost:" <> testPort <> " " <> bsToHex (C.unKeyHash testKeyHash) <> " {\"rejectUnauthorized\":false,\"ALPNProtocols\":[\"http/1.1\"]}"
          (rcvAuthPub, rcvAuthPriv) <- atomically $ C.generateKeyPair @'C.X25519 g
          let C.PrivateKeyX25519 sk = rcvAuthPriv
              rcvAuthPrivBytes = BA.convert sk :: B.ByteString
          newResp <- jsCmd rcvIn rcvOut $ "NEW " <> bsToHex (C.encodePubKey rcvAuthPub) <> " " <> bsToHex rcvAuthPrivBytes
          let newParts = words newResp
          when (head newParts /= "ok:") $ expectationFailure $ "NEW failed: " <> newResp
          let sndIdHex = newParts !! 2
              rcvIdHex = newParts !! 1
              sndId = hexToBS sndIdHex
          -- JS receiver: subscribe
          subResp <- jsCmd rcvIn rcvOut $ "SUB " <> rcvIdHex <> " " <> bsToHex rcvAuthPrivBytes
          when (subResp /= "ok") $ expectationFailure $ "SUB failed: " <> subResp
          -- HS sender: connect via TLS, use proxy to send to SAME server
          let srv = SMPServer ("localhost" :| []) testPort testKeyHash
          ts <- getCurrentTime
          Right pc <- getProtocolClient g NRMInteractive (1, srv, Nothing)
            defaultSMPClientConfig {serverVRange = mkVersionRange minServerSMPRelayVersion currentClientSMPRelayVersion}
            [] Nothing ts (\_ -> pure ())
          -- Connect proxy session to same server
          sess <- runRight $ connectSMPProxiedRelay pc NRMInteractive srv Nothing
          -- Send via proxy
          let testMsg = "hello from haskell via proxy"
          Right (Right ()) <- runExceptT $ proxySMPMessage pc NRMInteractive sess Nothing (EntityId sndId) noMsgFlags testMsg
          -- JS receiver: receive and decrypt
          recvResp <- jsCmd rcvIn rcvOut "RECV 5000"
          let recvParts = words recvResp
          head recvParts `shouldBe` "ok:"
          let bodyHex = recvParts !! 3
          hexToBS bodyHex `shouldBe` testMsg
          closeProtocolClient pc
          _ <- jsCmd rcvIn rcvOut "CLOSE"
          terminateProcess rcvPh