mix.nim

# SPDX-License-Identifier: Apache-2.0 OR MIT
# Copyright (c) Logos

import results
import chronos
import libp2p
import ./mix/[mix_protocol, mix_node, entry_connection, exit_layer]

export results

export toConnection
export MixProtocolID
export MixProtocol

export initializeMixNodes
export getMixPubInfoByIndex
export writeMixPubInfoToFile
export writeMixNodeInfoToFile
export getMixNodeInfo
export `new`
export init
export getMaxMessageSizeForCodec
export deleteNodeInfoFolder
export deletePubInfoFolder
export MixDestination
export MixParameters
export destReadBehaviorCb
export registerDestReadBehavior
export MixNodes
export initMixMultiAddrByIndex

when defined(mix_experimental_exit_is_destination):
  export exitNode
  export forwardToAddr

proc readLp*(maxSize: int): destReadBehaviorCb =
  ## create callback to read length prefixed msg, with the length encoded as a varint
  return proc(
      conn: Connection
  ): Future[seq[byte]] {.async: (raises: [CancelledError, LPStreamError]).} =
    await conn.readLp(maxSize)

proc readExactly*(nBytes: int): destReadBehaviorCb =
  ## create callback that waits for `nbytes` to be available, then read
  ## them and return them
  return proc(
      conn: Connection
  ): Future[seq[byte]] {.async: (raises: [CancelledError, LPStreamError]).} =
    let buf = newSeqUninitialized[byte](nBytes)
    await conn.readExactly(addr buf[0], nBytes)
    return buf