Skip to content

chore: use random bytes for echo #3477

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
tabcat merged 3 commits into from
Apr 25, 2026
+5 −3
Merged

chore: use random bytes for echo #3477

Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
e559d84
chore: use random bytes for echo
achingbrain Apr 24, 2026
5a0f6be
chore: size
achingbrain Apr 24, 2026
8fcde5f
chore: use random bytes for many small writes too
tabcat Apr 25, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 5 additions & 3 deletions packages/interface-compliance-tests/src/transport/index.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
import { randomBytes } from '@libp2p/crypto'
import { stop, TimeoutError } from '@libp2p/interface'
import { prefixLogger } from '@libp2p/logger'
import { expect } from 'aegir/chai'
Expand All @@ -10,6 +11,7 @@ import pRetry from 'p-retry'
import pWaitFor from 'p-wait-for'
import { raceSignal } from 'race-signal'
import { Uint8ArrayList } from 'uint8arraylist'
import { concat as uint8ArrayConcat } from 'uint8arrays'
import { isValidTick } from '../is-valid-tick.js'
import { createPeer, getTransportManager, getUpgrader } from './utils.ts'
import type { TestSetup } from '../index.js'
Expand Down Expand Up @@ -333,7 +335,7 @@ export default (common: TestSetup<TransportTestFixtures>): void => {

const connection = await dialer.dial(dialAddrs[0])

const input = new Uint8Array(1024).fill(5)
const input = randomBytes(1024)
const output = await dialer.services.echo.echo(connection.remotePeer, input, {
signal: AbortSignal.timeout(timeout)
})
Expand All @@ -349,7 +351,7 @@ export default (common: TestSetup<TransportTestFixtures>): void => {

const connection = await dialer.dial(dialAddrs[0])

const input = new Uint8Array(1024 * 1024 * 10).fill(5)
const input = uint8ArrayConcat(new Array(160).fill(0).map(() => randomBytes(65536)))
const output = await dialer.services.echo.echo(connection.remotePeer, input, {
signal: AbortSignal.timeout(timeout)
})
Expand All @@ -367,7 +369,7 @@ export default (common: TestSetup<TransportTestFixtures>): void => {
const echoProtocol = dialer.services.echo.protocol

for (let i = 0; i < 2_000; i++) {
const input = new Uint8Array(1024).fill(5)
const input = randomBytes(1024)
const output = await dialer.services.echo.echo(connection.remotePeer, input, {
signal: AbortSignal.timeout(timeout)
})
Expand Down
Loading