chore: add template newSeqUninit (#1518)

2026-01-09 22:28:27 -05:00 · 2025-07-11 15:19:24 +02:00
parent 45f0f9f47a
commit 13c613c26c
21 changed files with 88 additions and 63 deletions
--- a/libp2p/cid.nim
+++ b/libp2p/cid.nim
@@ -15,6 +15,7 @@
 import tables, hashes
 import multibase, multicodec, multihash, vbuffer, varint, results
 import stew/base58
+import ./utils/sequninit

 export results

@@ -123,7 +124,7 @@ proc decode(data: openArray[char]): Result[Cid, CidError] =
    return err(CidError.Incorrect)
  if len(data) == 46:
    if data[0] == 'Q' and data[1] == 'm':
-      buffer = newSeqUninitialized[byte](BTCBase58.decodedLength(len(data)))
+      buffer = newSeqUninit[byte](BTCBase58.decodedLength(len(data)))
      if BTCBase58.decode(data, buffer, plen) != Base58Status.Success:
        return err(CidError.Incorrect)
      buffer.setLen(plen)
@@ -131,7 +132,7 @@ proc decode(data: openArray[char]): Result[Cid, CidError] =
    let length = MultiBase.decodedLength(data[0], len(data))
    if length == -1:
      return err(CidError.Incorrect)
-    buffer = newSeqUninitialized[byte](length)
+    buffer = newSeqUninit[byte](length)
    if MultiBase.decode(data, buffer, plen) != MultiBaseStatus.Success:
      return err(CidError.Incorrect)
    buffer.setLen(plen)
--- a/libp2p/crypto/crypto.nim
+++ b/libp2p/crypto/crypto.nim
@@ -11,6 +11,7 @@
 {.push raises: [].}

 from strutils import split, strip, cmpIgnoreCase
+import ../utils/sequninit

 const libp2p_pki_schemes* {.strdefine.} = "rsa,ed25519,secp256k1,ecnist"

@@ -176,7 +177,7 @@ proc shuffle*[T](rng: ref HmacDrbgContext, x: var openArray[T]) =
  if x.len == 0:
    return

-  var randValues = newSeqUninitialized[byte](len(x) * 2)
+  var randValues = newSeqUninit[byte](len(x) * 2)
  hmacDrbgGenerate(rng[], randValues)

  for i in countdown(x.high, 1):
@@ -873,7 +874,7 @@ proc stretchKeys*(
  var seed = "key expansion"
  result.macsize = 20
  let length = result.ivsize + result.keysize + result.macsize
-  result.data = newSeqUninitialized[byte](2 * length)
+  result.data = newSeqUninit[byte](2 * length)

  if hashType == "SHA256":
    makeSecret(result.data, HMAC[sha256], sharedSecret, seed)
@@ -904,7 +905,7 @@ template macOpenArray*(secret: Secret, id: int): untyped =

 proc iv*(secret: Secret, id: int): seq[byte] {.inline.} =
  ## Get array of bytes with with initial vector.
-  result = newSeqUninitialized[byte](secret.ivsize)
+  result = newSeqUninit[byte](secret.ivsize)
  var offset =
    if id == 0:
      0
@@ -913,7 +914,7 @@ proc iv*(secret: Secret, id: int): seq[byte] {.inline.} =
  copyMem(addr result[0], unsafeAddr secret.data[offset], secret.ivsize)

 proc key*(secret: Secret, id: int): seq[byte] {.inline.} =
-  result = newSeqUninitialized[byte](secret.keysize)
+  result = newSeqUninit[byte](secret.keysize)
  var offset =
    if id == 0:
      0
@@ -923,7 +924,7 @@ proc key*(secret: Secret, id: int): seq[byte] {.inline.} =
  copyMem(addr result[0], unsafeAddr secret.data[offset], secret.keysize)

 proc mac*(secret: Secret, id: int): seq[byte] {.inline.} =
-  result = newSeqUninitialized[byte](secret.macsize)
+  result = newSeqUninit[byte](secret.macsize)
  var offset =
    if id == 0:
      0
--- a/libp2p/crypto/ecnist.nim
+++ b/libp2p/crypto/ecnist.nim
@@ -23,6 +23,7 @@ import minasn1
 export minasn1.Asn1Error
 import stew/ctops
 import results
+import ../utils/sequninit

 import ../utility

@@ -458,7 +459,7 @@ proc getBytes*(seckey: EcPrivateKey): EcResult[seq[byte]] =
  if isNil(seckey):
    return err(EcKeyIncorrectError)
  if seckey.key.curve in EcSupportedCurvesCint:
-    var res = newSeqUninitialized[byte](0)
+    var res = newSeqUninit[byte](0)
    let length = ?seckey.toBytes(res)
    res.setLen(length)
    discard ?seckey.toBytes(res)
@@ -471,7 +472,7 @@ proc getBytes*(pubkey: EcPublicKey): EcResult[seq[byte]] =
  if isNil(pubkey):
    return err(EcKeyIncorrectError)
  if pubkey.key.curve in EcSupportedCurvesCint:
-    var res = newSeqUninitialized[byte](0)
+    var res = newSeqUninit[byte](0)
    let length = ?pubkey.toBytes(res)
    res.setLen(length)
    discard ?pubkey.toBytes(res)
@@ -483,7 +484,7 @@ proc getBytes*(sig: EcSignature): EcResult[seq[byte]] =
  ## Serialize EC signature ``sig`` to ASN.1 DER binary form and return it.
  if isNil(sig):
    return err(EcSignatureError)
-  var res = newSeqUninitialized[byte](0)
+  var res = newSeqUninit[byte](0)
  let length = ?sig.toBytes(res)
  res.setLen(length)
  discard ?sig.toBytes(res)
@@ -494,7 +495,7 @@ proc getRawBytes*(seckey: EcPrivateKey): EcResult[seq[byte]] =
  if isNil(seckey):
    return err(EcKeyIncorrectError)
  if seckey.key.curve in EcSupportedCurvesCint:
-    var res = newSeqUninitialized[byte](0)
+    var res = newSeqUninit[byte](0)
    let length = ?seckey.toRawBytes(res)
    res.setLen(length)
    discard ?seckey.toRawBytes(res)
@@ -507,7 +508,7 @@ proc getRawBytes*(pubkey: EcPublicKey): EcResult[seq[byte]] =
  if isNil(pubkey):
    return err(EcKeyIncorrectError)
  if pubkey.key.curve in EcSupportedCurvesCint:
-    var res = newSeqUninitialized[byte](0)
+    var res = newSeqUninit[byte](0)
    let length = ?pubkey.toRawBytes(res)
    res.setLen(length)
    discard ?pubkey.toRawBytes(res)
@@ -519,7 +520,7 @@ proc getRawBytes*(sig: EcSignature): EcResult[seq[byte]] =
  ## Serialize EC signature ``sig`` to raw binary form and return it.
  if isNil(sig):
    return err(EcSignatureError)
-  var res = newSeqUninitialized[byte](0)
+  var res = newSeqUninit[byte](0)
  let length = ?sig.toBytes(res)
  res.setLen(length)
  discard ?sig.toBytes(res)
@@ -929,7 +930,7 @@ proc getSecret*(pubkey: EcPublicKey, seckey: EcPrivateKey): seq[byte] =
  var data: array[Secret521Length, byte]
  let res = toSecret(pubkey, seckey, data)
  if res > 0:
-    result = newSeqUninitialized[byte](res)
+    result = newSeqUninit[byte](res)
    copyMem(addr result[0], addr data[0], res)

 proc sign*[T: byte | char](
@@ -943,7 +944,7 @@ proc sign*[T: byte | char](
  var impl = ecGetDefault()
  if seckey.key.curve in EcSupportedCurvesCint:
    var sig = new EcSignature
-    sig.buffer = newSeqUninitialized[byte](256)
+    sig.buffer = newSeqUninit[byte](256)
    var kv = addr sha256Vtable
    kv.init(addr hc.vtable)
    if len(message) > 0:
--- a/libp2p/crypto/minasn1.nim
+++ b/libp2p/crypto/minasn1.nim
@@ -17,6 +17,7 @@ export results
 # We use `ncrutils` for constant-time hexadecimal encoding/decoding procedures.
 import nimcrypto/utils as ncrutils
 import ../utility
+import ../utils/sequninit

 type
  Asn1Error* {.pure.} = enum
@@ -679,15 +680,15 @@ proc init*(t: typedesc[Asn1Buffer], data: string): Asn1Buffer =

 proc init*(t: typedesc[Asn1Buffer]): Asn1Buffer =
  ## Initialize empty ``Asn1Buffer``.
-  Asn1Buffer(buffer: newSeqUninitialized[byte](0))
+  Asn1Buffer(buffer: newSeqUninit[byte](0))

 proc init*(t: typedesc[Asn1Composite], tag: Asn1Tag): Asn1Composite =
  ## Initialize ``Asn1Composite`` with tag ``tag``.
-  Asn1Composite(tag: tag, buffer: newSeqUninitialized[byte](0))
+  Asn1Composite(tag: tag, buffer: newSeqUninit[byte](0))

 proc init*(t: typedesc[Asn1Composite], idx: int): Asn1Composite =
  ## Initialize ``Asn1Composite`` with tag context-specific id ``id``.
-  Asn1Composite(tag: Asn1Tag.Context, idx: idx, buffer: newSeqUninitialized[byte](0))
+  Asn1Composite(tag: Asn1Tag.Context, idx: idx, buffer: newSeqUninit[byte](0))

 proc `$`*(buffer: Asn1Buffer): string =
  ## Return string representation of ``buffer``.
--- a/libp2p/crypto/rsa.nim
+++ b/libp2p/crypto/rsa.nim
@@ -21,6 +21,7 @@ import results
 import stew/ctops
 # We use `ncrutils` for constant-time hexadecimal encoding/decoding procedures.
 import nimcrypto/utils as ncrutils
+import ../utils/sequninit

 export Asn1Error, results

@@ -124,7 +125,7 @@ proc random*[T: RsaKP](
    length = eko + ((bits + 7) shr 3)

  let res = new T
-  res.buffer = newSeqUninitialized[byte](length)
+  res.buffer = newSeqUninit[byte](length)

  var keygen = rsaKeygenGetDefault()

@@ -169,7 +170,7 @@ proc copy*[T: RsaPKI](key: T): T =
        key.seck.dqlen.uint + key.seck.iqlen.uint + key.pubk.nlen.uint +
        key.pubk.elen.uint + key.pexplen.uint
      result = new RsaPrivateKey
-      result.buffer = newSeqUninitialized[byte](length)
+      result.buffer = newSeqUninit[byte](length)
      let po: uint = 0
      let qo = po + key.seck.plen
      let dpo = qo + key.seck.qlen
@@ -207,7 +208,7 @@ proc copy*[T: RsaPKI](key: T): T =
    if len(key.buffer) > 0:
      let length = key.key.nlen + key.key.elen
      result = new RsaPublicKey
-      result.buffer = newSeqUninitialized[byte](length)
+      result.buffer = newSeqUninit[byte](length)
      let no = 0
      let eo = no + key.key.nlen
      copyMem(addr result.buffer[no], key.key.n, key.key.nlen)
@@ -226,7 +227,7 @@ proc getPublicKey*(key: RsaPrivateKey): RsaPublicKey =
  doAssert(not isNil(key))
  let length = key.pubk.nlen + key.pubk.elen
  result = new RsaPublicKey
-  result.buffer = newSeqUninitialized[byte](length)
+  result.buffer = newSeqUninit[byte](length)
  result.key.n = addr result.buffer[0]
  result.key.e = addr result.buffer[key.pubk.nlen]
  copyMem(addr result.buffer[0], cast[pointer](key.pubk.n), key.pubk.nlen)
@@ -357,7 +358,7 @@ proc getBytes*(key: RsaPrivateKey): RsaResult[seq[byte]] =
  ## return it.
  if isNil(key):
    return err(RsaKeyIncorrectError)
-  var res = newSeqUninitialized[byte](4096)
+  var res = newSeqUninit[byte](4096)
  let length = ?key.toBytes(res)
  if length > 0:
    res.setLen(length)
@@ -370,7 +371,7 @@ proc getBytes*(key: RsaPublicKey): RsaResult[seq[byte]] =
  ## return it.
  if isNil(key):
    return err(RsaKeyIncorrectError)
-  var res = newSeqUninitialized[byte](4096)
+  var res = newSeqUninit[byte](4096)
  let length = ?key.toBytes(res)
  if length > 0:
    res.setLen(length)
@@ -382,7 +383,7 @@ proc getBytes*(sig: RsaSignature): RsaResult[seq[byte]] =
  ## Serialize RSA signature ``sig`` to raw binary form and return it.
  if isNil(sig):
    return err(RsaSignatureError)
-  var res = newSeqUninitialized[byte](4096)
+  var res = newSeqUninit[byte](4096)
  let length = ?sig.toBytes(res)
  if length > 0:
    res.setLen(length)
@@ -753,7 +754,7 @@ proc sign*[T: byte | char](
  var hash: array[32, byte]
  let impl = rsaPkcs1SignGetDefault()
  var res = new RsaSignature
-  res.buffer = newSeqUninitialized[byte]((key.seck.nBitlen + 7) shr 3)
+  res.buffer = newSeqUninit[byte]((key.seck.nBitlen + 7) shr 3)
  var kv = addr sha256Vtable
  kv.init(addr hc.vtable)
  if len(message) > 0:
--- a/libp2p/crypto/secp.nim
+++ b/libp2p/crypto/secp.nim
@@ -11,6 +11,7 @@

 import bearssl/rand
 import secp256k1, results, stew/byteutils, nimcrypto/[hash, sha2]
+import ../utils/sequninit

 export sha2, results, rand

@@ -182,7 +183,7 @@ proc getBytes*(key: SkPublicKey): seq[byte] {.inline.} =

 proc getBytes*(sig: SkSignature): seq[byte] {.inline.} =
  ## Serialize Secp256k1 `signature` and return it.
-  result = newSeqUninitialized[byte](72)
+  result = newSeqUninit[byte](72)
  let length = toBytes(sig, result)
  result.setLen(length)

--- a/libp2p/daemon/daemonapi.nim
+++ b/libp2p/daemon/daemonapi.nim
@@ -15,6 +15,7 @@ import pkg/[chronos, chronicles]
 import ../varint, ../multiaddress, ../multicodec, ../cid, ../peerid
 import ../wire, ../multihash, ../protobuf/minprotobuf, ../errors
 import ../crypto/crypto, ../utility
+import ../utils/sequninit

 export peerid, multiaddress, multicodec, multihash, cid, crypto, wire, errors

@@ -496,7 +497,7 @@ proc recvMessage(
    size: uint
    length: int
    res: VarintResult[void]
-  var buffer = newSeqUninitialized[byte](10)
+  var buffer = newSeqUninit[byte](10)
  try:
    for i in 0 ..< len(buffer):
      await conn.readExactly(addr buffer[i], 1)
@@ -957,7 +958,7 @@ proc openStream*(
      var res: seq[byte]
      if pb.getRequiredField(ResponseType.STREAMINFO.int, res).isOk():
        let resPb = initProtoBuffer(res)
-        var raddress = newSeqUninitialized[byte](0)
+        var raddress = newSeqUninit[byte](0)
        stream.protocol = ""
        resPb.getRequiredField(1, stream.peer).tryGet()
        resPb.getRequiredField(2, raddress).tryGet()
@@ -976,7 +977,7 @@ proc streamHandler(server: StreamServer, transp: StreamTransport) {.async.} =
  var message = await transp.recvMessage()
  var pb = initProtoBuffer(message)
  var stream = new P2PStream
-  var raddress = newSeqUninitialized[byte](0)
+  var raddress = newSeqUninit[byte](0)
  stream.protocol = ""
  pb.getRequiredField(1, stream.peer).tryGet()
  pb.getRequiredField(2, raddress).tryGet()
@@ -1115,7 +1116,7 @@ proc dhtGetSinglePeerInfo(pb: ProtoBuffer): PeerInfo {.raises: [DaemonLocalError
    raise newException(DaemonLocalError, "Missing required field `peer`!")

 proc dhtGetSingleValue(pb: ProtoBuffer): seq[byte] {.raises: [DaemonLocalError].} =
-  result = newSeqUninitialized[byte](0)
+  result = newSeqUninit[byte](0)
  if pb.getRequiredField(3, result).isErr():
    raise newException(DaemonLocalError, "Missing field `value`!")

@@ -1452,8 +1453,8 @@ proc pubsubPublish*(
    await api.closeConnection(transp)

 proc getPubsubMessage*(pb: ProtoBuffer): PubSubMessage =
-  result.data = newSeqUninitialized[byte](0)
-  result.seqno = newSeqUninitialized[byte](0)
+  result.data = newSeqUninit[byte](0)
+  result.seqno = newSeqUninit[byte](0)
  discard pb.getField(1, result.peer)
  discard pb.getField(2, result.data)
  discard pb.getField(3, result.seqno)
--- a/libp2p/multiaddress.nim
+++ b/libp2p/multiaddress.nim
@@ -27,6 +27,7 @@ import
  utility
 import stew/[base58, base32, endians2]
 export results, vbuffer, errors, utility
+import ./utils/sequninit

 logScope:
  topics = "libp2p multiaddress"
@@ -223,7 +224,7 @@ proc p2pStB(s: string, vb: var VBuffer): bool =

 proc p2pBtS(vb: var VBuffer, s: var string): bool =
  ## P2P address bufferToString() implementation.
-  var address = newSeqUninitialized[byte](0)
+  var address = newSeqUninit[byte](0)
  if vb.readSeq(address) > 0:
    var mh: MultiHash
    if MultiHash.decode(address, mh).isOk:
@@ -232,7 +233,7 @@ proc p2pBtS(vb: var VBuffer, s: var string): bool =

 proc p2pVB(vb: var VBuffer): bool =
  ## P2P address validateBuffer() implementation.
-  var address = newSeqUninitialized[byte](0)
+  var address = newSeqUninit[byte](0)
  if vb.readSeq(address) > 0:
    var mh: MultiHash
    if MultiHash.decode(address, mh).isOk:
@@ -555,7 +556,7 @@ proc protoAddress*(ma: MultiAddress): MaResult[seq[byte]] =
  ##
  ## If current MultiAddress do not have argument value, then result array will
  ## be empty.
-  var buffer = newSeqUninitialized[byte](len(ma.data.buffer))
+  var buffer = newSeqUninit[byte](len(ma.data.buffer))
  let res = ?protoArgument(ma, buffer)
  buffer.setLen(res)
  ok(buffer)
@@ -569,7 +570,7 @@ proc protoArgument*(ma: MultiAddress): MaResult[seq[byte]] =

 proc getPart(ma: MultiAddress, index: int): MaResult[MultiAddress] =
  var header: uint64
-  var data = newSeqUninitialized[byte](0)
+  var data = newSeqUninit[byte](0)
  var offset = 0
  var vb = ma
  var res: MultiAddress
@@ -643,7 +644,7 @@ proc `[]`*(ma: MultiAddress, slice: HSlice): MaResult[MultiAddress] {.inline.} =
 iterator items*(ma: MultiAddress): MaResult[MultiAddress] =
  ## Iterates over all addresses inside of MultiAddress ``ma``.
  var header: uint64
-  var data = newSeqUninitialized[byte](0)
+  var data = newSeqUninit[byte](0)
  var vb = ma
  while true:
    if vb.data.isEmpty():
--- a/libp2p/multibase.nim
+++ b/libp2p/multibase.nim
@@ -18,6 +18,7 @@
 import tables
 import results
 import stew/[base32, base58, base64]
+import ./utils/sequninit

 type
  MultiBaseStatus* {.pure.} = enum
@@ -533,7 +534,7 @@ proc decode*(
    let empty: seq[byte] = @[]
    ok(empty) # empty
  else:
-    var buffer = newSeqUninitialized[byte](mb.decl(length - 1))
+    var buffer = newSeqUninit[byte](mb.decl(length - 1))
    var outlen = 0
    let res = mb.decr(inbytes.toOpenArray(1, length - 1), buffer, outlen)
    if res != MultiBaseStatus.Success:
--- a/libp2p/muxers/yamux/yamux.nim
+++ b/libp2p/muxers/yamux/yamux.nim
@@ -12,7 +12,7 @@
 import sequtils, std/[tables]
 import chronos, chronicles, metrics, stew/[endians2, byteutils, objects]
 import ../muxer, ../../stream/connection
-import ../../utils/zeroqueue
+import ../../utils/[zeroqueue, sequninit]

 export muxer

@@ -339,7 +339,7 @@ proc trySend(
      bytesAvailable = channel.lengthSendQueue()
      toSend = min(channel.sendWindow, bytesAvailable)
    var
-      sendBuffer = newSeqUninitialized[byte](toSend + 12)
+      sendBuffer = newSeqUninit[byte](toSend + 12)
      header = YamuxHeader.data(channel.id, toSend.uint32)
      inBuffer = 0

@@ -581,7 +581,7 @@ method handle*(m: Yamux) {.async: (raises: []).} =
                raise
                  newException(YamuxError, "Peer exhausted the recvWindow after reset")
              if header.length > 0:
-                var buffer = newSeqUninitialized[byte](header.length)
+                var buffer = newSeqUninit[byte](header.length)
                await m.connection.readExactly(addr buffer[0], int(header.length))
          do:
            raise newException(YamuxError, "Unknown stream ID: " & $header.streamId)
@@ -607,7 +607,7 @@ method handle*(m: Yamux) {.async: (raises: []).} =
            raise newException(YamuxError, "Peer exhausted the recvWindow")

          if header.length > 0:
-            var buffer = newSeqUninitialized[byte](header.length)
+            var buffer = newSeqUninit[byte](header.length)
            await m.connection.readExactly(addr buffer[0], int(header.length))
            trace "Msg Rcv", description = shortLog(buffer)
            await channel.gotDataFromRemote(buffer)
--- a/libp2p/nameresolving/dnsresolver.nim
+++ b/libp2p/nameresolving/dnsresolver.nim
@@ -15,7 +15,8 @@ import
  chronicles,
  stew/byteutils,
  dnsclientpkg/[protocol, types],
-  ../utility
+  ../utility,
+  ../utils/sequninit

 import nameresolver

@@ -37,18 +38,18 @@ proc questionToBuf(address: string, kind: QKind): seq[byte] =
    let dataLen = requestStream.getPosition()
    requestStream.setPosition(0)

-    var buf = newSeqUninitialized[byte](dataLen)
+    var buf = newSeqUninit[byte](dataLen)
    discard requestStream.readData(addr buf[0], dataLen)
    buf
  except IOError as exc:
    info "Failed to created DNS buffer", description = exc.msg
-    newSeqUninitialized[byte](0)
+    newSeqUninit[byte](0)
  except OSError as exc:
    info "Failed to created DNS buffer", description = exc.msg
-    newSeqUninitialized[byte](0)
+    newSeqUninit[byte](0)
  except ValueError as exc:
    info "Failed to created DNS buffer", description = exc.msg
-    newSeqUninitialized[byte](0)
+    newSeqUninit[byte](0)

 proc getDnsResponse(
    dnsServer: TransportAddress, address: string, kind: QKind
--- a/libp2p/peerid.nim
+++ b/libp2p/peerid.nim
@@ -24,7 +24,8 @@ import
  ./multicodec,
  ./multihash,
  ./vbuffer,
-  ./protobuf/minprotobuf
+  ./protobuf/minprotobuf,
+  ./utils/sequninit

 export results, utility

@@ -142,7 +143,7 @@ func init*(pid: var PeerId, data: string): bool =
  ## Initialize peer id from base58 encoded string representation.
  ##
  ## Returns ``true`` if peer was successfully initialiazed.
-  var p = newSeqUninitialized[byte](len(data) + 4)
+  var p = newSeqUninit[byte](len(data) + 4)
  var length = 0
  if Base58.decode(data, p, length) == Base58Status.Success:
    p.setLen(length)
--- a/libp2p/protobuf/minprotobuf.nim
+++ b/libp2p/protobuf/minprotobuf.nim
@@ -12,6 +12,7 @@
 {.push raises: [].}

 import ../varint, ../utility, stew/endians2, results
+import ../utils/sequninit
 export results, utility

 {.push public.}
@@ -147,12 +148,12 @@ proc initProtoBuffer*(options: set[ProtoFlags] = {}): ProtoBuffer =
  if WithVarintLength in options:
    # Our buffer will start from position 10, so we can store length of buffer
    # in [0, 9].
-    result.buffer = newSeqUninitialized[byte](10)
+    result.buffer = newSeqUninit[byte](10)
    result.offset = 10
  elif {WithUint32LeLength, WithUint32BeLength} * options != {}:
    # Our buffer will start from position 4, so we can store length of buffer
    # in [0, 3].
-    result.buffer = newSeqUninitialized[byte](4)
+    result.buffer = newSeqUninit[byte](4)
    result.offset = 4

 proc write*[T: ProtoScalar](pb: var ProtoBuffer, field: int, value: T) =
--- a/libp2p/protocols/kademlia/routingtable.nim
+++ b/libp2p/protocols/kademlia/routingtable.nim
@@ -7,6 +7,7 @@ import ./keys
 import ./xordistance
 import ../../peerid
 import sequtils
+import ../../utils/sequninit

 logScope:
  topics = "kad-dht rtable"
@@ -112,7 +113,7 @@ proc randomKeyInBucketRange*(
  let totalBits = raw.len * 8
  let lsbStart = bucketIndex + 1
  let lsbBytes = (totalBits - lsbStart + 7) div 8
-  var randomBuf = newSeqUninitialized[byte](lsbBytes)
+  var randomBuf = newSeqUninit[byte](lsbBytes)
  hmacDrbgGenerate(rng[], randomBuf)

  for i in lsbStart ..< totalBits:
--- a/libp2p/protocols/pubsub/pubsubpeer.nim
+++ b/libp2p/protocols/pubsub/pubsubpeer.nim
@@ -20,7 +20,8 @@ import
  ../../stream/connection,
  ../../crypto/crypto,
  ../../protobuf/minprotobuf,
-  ../../utility
+  ../../utility,
+  ../../utils/sequninit

 export peerid, connection, deques

@@ -221,7 +222,7 @@ proc handle*(p: PubSubPeer, conn: Connection) {.async: (raises: []).} =
          conn, peer = p, closed = conn.closed, data = data.shortLog

        await p.handler(p, data)
-        data = newSeqUninitialized[byte](0) # Release memory
+        data = newSeqUninit[byte](0) # Release memory
    except PeerRateLimitError as exc:
      debug "Peer rate limit exceeded, exiting read while",
        conn, peer = p, description = exc.msg
--- a/libp2p/protocols/secure/noise.nim
+++ b/libp2p/protocols/secure/noise.nim
@@ -20,7 +20,7 @@ import ../../peerid
 import ../../peerinfo
 import ../../protobuf/minprotobuf
 import ../../utility
-import ../../utils/bytesview
+import ../../utils/[bytesview, sequninit]

 import secure, ../../crypto/[crypto, chacha20poly1305, curve25519, hkdf]

@@ -315,7 +315,7 @@ proc readFrame(
  if size == 0:
    return

-  var buffer = newSeqUninitialized[byte](size)
+  var buffer = newSeqUninit[byte](size)
  await sconn.readExactly(addr buffer[0], buffer.len)
  return buffer

@@ -458,7 +458,7 @@ method write*(
  let frames = (message.len + MaxPlainSize - 1) div MaxPlainSize

  var
-    cipherFrames = newSeqUninitialized[byte](message.len + frames * FramingSize)
+    cipherFrames = newSeqUninit[byte](message.len + frames * FramingSize)
    left = message.len
    offset = 0
    woffset = 0
--- a/libp2p/stream/lpstream.nim
+++ b/libp2p/stream/lpstream.nim
@@ -16,6 +16,7 @@ import std/oids
 import stew/byteutils
 import chronicles, chronos, metrics
 import ../varint, ../peerinfo, ../multiaddress, ../utility, ../errors
+import ../utils/sequninit

 export errors

@@ -232,7 +233,7 @@ method readLp*(
  if length == 0:
    return

-  var res = newSeqUninitialized[byte](length)
+  var res = newSeqUninit[byte](length)
  await s.readExactly(addr res[0], res.len)
  res

@@ -251,7 +252,7 @@ method writeLp*(
 .} =
  ## Write `msg` with a varint-encoded length prefix
  let vbytes = PB.toBytes(msg.len().uint64)
-  var buf = newSeqUninitialized[byte](msg.len() + vbytes.len)
+  var buf = newSeqUninit[byte](msg.len() + vbytes.len)
  buf[0 ..< vbytes.len] = vbytes.toOpenArray()
  buf[vbytes.len ..< buf.len] = msg
  s.write(buf)
--- a/libp2p/transports/tls/certificate.nim
+++ b/libp2p/transports/tls/certificate.nim
@@ -17,6 +17,7 @@ import ../../crypto/crypto
 import ../../errors
 import ./certificate_ffi
 import ../../../libp2p/peerid
+import ../../utils/sequninit

 logScope:
  topics = "libp2p tls certificate"
@@ -98,7 +99,7 @@ func makeSignatureMessage(pubKey: seq[byte]): seq[byte] {.inline.} =
  ##
  let P2P_SIGNING_PREFIX = "libp2p-tls-handshake:".toBytes()
  let prefixLen = P2P_SIGNING_PREFIX.len.int
-  let msg = newSeqUninitialized[byte](prefixLen + pubKey.len)
+  let msg = newSeqUninit[byte](prefixLen + pubKey.len)
  copyMem(msg[0].unsafeAddr, P2P_SIGNING_PREFIX[0].unsafeAddr, prefixLen)
  copyMem(msg[prefixLen].unsafeAddr, pubKey[0].unsafeAddr, pubKey.len.int)

--- a/libp2p/utils/sequninit.nim
+++ b/libp2p/utils/sequninit.nim
@@ -0,0 +1,7 @@
+{.used.}
+
+when not declared(newSeqUninit):
+  # newSeqUninit template avoids deprecated errors
+  # for newSeqUninitialized in nim > 2.2
+  template newSeqUninit*[T: byte](len: Natural): seq[byte] =
+    newSeqUninitialized[byte](len)
--- a/libp2p/utils/zeroqueue.nim
+++ b/libp2p/utils/zeroqueue.nim
@@ -8,6 +8,7 @@
 # those terms.

 import std/deques
+import ./sequninit

 type Chunk = ref object
  data: seq[byte]
@@ -77,7 +78,7 @@ proc popChunkSeq*(q: var ZeroQueue, count: int): seq[byte] =
    return @[]

  let chunk = q.popChunk(count)
-  var dest = newSeqUninitialized[byte](chunk.len())
+  var dest = newSeqUninit[byte](chunk.len())
  let offsetPtr = cast[ptr byte](cast[int](unsafeAddr chunk.data[0]) + chunk.start)
  copyMem(dest[0].addr, offsetPtr, chunk.len())

--- a/libp2p/vbuffer.nim
+++ b/libp2p/vbuffer.nim
@@ -12,6 +12,7 @@
 {.push raises: [].}

 import varint, strutils
+import ./utils/sequninit

 type VBuffer* = object
  buffer*: seq[byte]
@@ -42,7 +43,7 @@ proc initVBuffer*(data: seq[byte], offset = 0): VBuffer =

 proc initVBuffer*(data: openArray[byte], offset = 0): VBuffer =
  ## Initialize VBuffer with copy of ``data``.
-  result.buffer = newSeqUninitialized[byte](len(data))
+  result.buffer = newSeqUninit[byte](len(data))
  if len(data) > 0:
    copyMem(addr result.buffer[0], unsafeAddr data[0], len(data))
  result.offset = offset