deps(dev): bump aegir from 38.1.8 to 39.0.6

package.json

@@ -165,7 +165,7 @@
   "devDependencies": {
     "@libp2p/interface-stream-muxer-compliance-tests": "^7.0.0",
     "@types/varint": "^6.0.0",
-    "aegir": "^38.1.7",
+    "aegir": "^39.0.7",
     "cborg": "^1.8.1",
     "delay": "^5.0.0",
     "eslint-plugin-etc": "^2.0.2",

src/decode.ts

@@ -1,5 +1,5 @@
-import { MessageTypeNames, MessageTypes } from './message-types.js'
 import { Uint8ArrayList } from 'uint8arraylist'
+import { MessageTypeNames, MessageTypes } from './message-types.js'
 import type { Message } from './message-types.js'
 
 export const MAX_MSG_SIZE = 1 << 20 // 1MB

src/encode.ts

@@ -1,9 +1,9 @@
-import type { Source } from 'it-stream-types'
-import varint from 'varint'
+import batchedBytes from 'it-batched-bytes'
 import { Uint8ArrayList } from 'uint8arraylist'
+import varint from 'varint'
 import { allocUnsafe } from './alloc-unsafe.js'
-import { Message, MessageTypes } from './message-types.js'
-import batchedBytes from 'it-batched-bytes'
+import { type Message, MessageTypes } from './message-types.js'
+import type { Source } from 'it-stream-types'
 
 const POOL_SIZE = 10 * 1024
 

src/index.ts

@@ -1,5 +1,5 @@
-import type { StreamMuxer, StreamMuxerFactory, StreamMuxerInit } from '@libp2p/interface-stream-muxer'
 import { MplexStreamMuxer } from './mplex.js'
+import type { StreamMuxer, StreamMuxerFactory, StreamMuxerInit } from '@libp2p/interface-stream-muxer'
 
 export interface MplexInit {
   /**

src/mplex.ts

@@ -1,18 +1,18 @@
-import { pushableV } from 'it-pushable'
+import { CodeError } from '@libp2p/interfaces/errors'
+import { logger } from '@libp2p/logger'
 import { abortableSource } from 'abortable-iterator'
-import { encode } from './encode.js'
+import { anySignal } from 'any-signal'
+import { pushableV } from 'it-pushable'
+import { RateLimiterMemory } from 'rate-limiter-flexible'
+import { toString as uint8ArrayToString } from 'uint8arrays'
 import { Decoder } from './decode.js'
-import { MessageTypes, MessageTypeNames, Message } from './message-types.js'
+import { encode } from './encode.js'
+import { MessageTypes, MessageTypeNames, type Message } from './message-types.js'
 import { createStream } from './stream.js'
-import { toString as uint8ArrayToString } from 'uint8arrays'
-import { logger } from '@libp2p/logger'
-import { CodeError } from '@libp2p/interfaces/errors'
-import { RateLimiterMemory } from 'rate-limiter-flexible'
-import type { Sink, Source } from 'it-stream-types'
-import type { StreamMuxer, StreamMuxerInit } from '@libp2p/interface-stream-muxer'
-import type { Stream } from '@libp2p/interface-connection'
 import type { MplexInit } from './index.js'
-import { anySignal } from 'any-signal'
+import type { Stream } from '@libp2p/interface-connection'
+import type { StreamMuxer, StreamMuxerInit } from '@libp2p/interface-stream-muxer'
+import type { Sink, Source } from 'it-stream-types'
 import type { Uint8ArrayList } from 'uint8arraylist'
 
 const log = logger('libp2p:mplex')

src/stream.ts

@@ -1,16 +1,16 @@
+import { CodeError } from '@libp2p/interfaces/errors'
+import { logger } from '@libp2p/logger'
 import { abortableSource } from 'abortable-iterator'
+import { anySignal } from 'any-signal'
 import { pushable } from 'it-pushable'
-import { CodeError } from '@libp2p/interfaces/errors'
+import { Uint8ArrayList } from 'uint8arraylist'
+import { fromString as uint8ArrayFromString } from 'uint8arrays/from-string'
 import { MAX_MSG_SIZE } from './decode.js'
-import { anySignal } from 'any-signal'
 import { InitiatorMessageTypes, ReceiverMessageTypes } from './message-types.js'
-import { fromString as uint8ArrayFromString } from 'uint8arrays/from-string'
-import { Uint8ArrayList } from 'uint8arraylist'
-import { logger } from '@libp2p/logger'
 import type { Message } from './message-types.js'
+import type { MplexStream } from './mplex.js'
 import type { StreamTimeline } from '@libp2p/interface-connection'
 import type { Source } from 'it-stream-types'
-import type { MplexStream } from './mplex.js'
 
 const log = logger('libp2p:mplex:stream')
 

test/coder.spec.ts

@@ -2,14 +2,14 @@
 /* eslint max-nested-callbacks: ["error", 5] */
 
 import { expect } from 'aegir/chai'
+import all from 'it-all'
+import { Uint8ArrayList } from 'uint8arraylist'
+import { concat as uint8ArrayConcat } from 'uint8arrays/concat'
 import { fromString as uint8ArrayFromString } from 'uint8arrays/from-string'
 import { encode } from '../src/encode.js'
 import { decode } from './fixtures/decode.js'
-import all from 'it-all'
-import { concat as uint8ArrayConcat } from 'uint8arrays/concat'
 import { messageWithBytes } from './fixtures/utils.js'
 import type { Message, NewStreamMessage } from '../src/message-types.js'
-import { Uint8ArrayList } from 'uint8arraylist'
 
 describe('coder', () => {
   it('should encode header', async () => {

test/fixtures/decode.ts

@@ -1,7 +1,7 @@
 /* eslint-env mocha */
 
-import type { Message } from '../../src/message-types.js'
 import { Decoder, MAX_MSG_QUEUE_SIZE, MAX_MSG_SIZE } from '../../src/decode.js'
+import type { Message } from '../../src/message-types.js'
 import type { Source } from 'it-stream-types'
 
 export function decode (maxMessageSize: number = MAX_MSG_SIZE, maxUnprocessedMessageQueueSize: number = MAX_MSG_QUEUE_SIZE) {

test/fixtures/utils.ts

@@ -1,4 +1,4 @@
-import { Message, MessageTypes } from '../../src/message-types.js'
+import { type Message, MessageTypes } from '../../src/message-types.js'
 
 export type MessageWithBytes = {
   [k in keyof Message]: Message[k]

test/mplex.spec.ts

@@ -2,18 +2,18 @@
 /* eslint max-nested-callbacks: ["error", 5] */
 
 import { expect } from 'aegir/chai'
-import { mplex } from '../src/index.js'
-import { CloseInitiatorMessage, Message, MessageInitiatorMessage, MessageTypes, NewStreamMessage } from '../src/message-types.js'
-import { fromString as uint8ArrayFromString } from 'uint8arrays/from-string'
-import { concat as uint8ArrayConcat } from 'uint8arrays/concat'
-import { encode } from '../src/encode.js'
-import all from 'it-all'
-import type { Source } from 'it-stream-types'
 import delay from 'delay'
-import pDefer from 'p-defer'
-import { decode } from './fixtures/decode.js'
+import all from 'it-all'
 import { pushable } from 'it-pushable'
+import pDefer from 'p-defer'
 import { Uint8ArrayList } from 'uint8arraylist'
+import { concat as uint8ArrayConcat } from 'uint8arrays/concat'
+import { fromString as uint8ArrayFromString } from 'uint8arrays/from-string'
+import { encode } from '../src/encode.js'
+import { mplex } from '../src/index.js'
+import { type CloseInitiatorMessage, type Message, type MessageInitiatorMessage, MessageTypes, type NewStreamMessage } from '../src/message-types.js'
+import { decode } from './fixtures/decode.js'
+import type { Source } from 'it-stream-types'
 
 describe('mplex', () => {
   it('should restrict number of initiator streams per connection', async () => {

test/restrict-size.spec.ts

@@ -1,16 +1,16 @@
 /* eslint-env mocha */
 
 import { expect } from 'aegir/chai'
-import { pipe } from 'it-pipe'
 import randomBytes from 'iso-random-stream/src/random.js'
 import all from 'it-all'
 import drain from 'it-drain'
 import each from 'it-foreach'
-import { Message, MessageTypes } from '../src/message-types.js'
+import { pipe } from 'it-pipe'
+import toBuffer from 'it-to-buffer'
+import { Uint8ArrayList } from 'uint8arraylist'
 import { encode } from '../src/encode.js'
+import { type Message, MessageTypes } from '../src/message-types.js'
 import { decode } from './fixtures/decode.js'
-import { Uint8ArrayList } from 'uint8arraylist'
-import toBuffer from 'it-to-buffer'
 
 describe('restrict size', () => {
   it('should throw when size is too big', async () => {
@@ -57,7 +57,7 @@ describe('restrict size', () => {
       input,
       encode,
       decode(32),
-      async (source) => await all(source)
+      async (source) => all(source)
     )
     expect(output).to.deep.equal(input[0])
   })

test/stream.spec.ts

@@ -1,21 +1,21 @@
 /* eslint-env mocha */
 
 import { expect } from 'aegir/chai'
-import { pipe } from 'it-pipe'
+import * as cborg from 'cborg'
 import randomBytes from 'iso-random-stream/src/random.js'
-import randomInt from 'random-int'
-import each from 'it-foreach'
 import drain from 'it-drain'
+import each from 'it-foreach'
 import map from 'it-map'
+import { pipe } from 'it-pipe'
 import defer from 'p-defer'
-import * as cborg from 'cborg'
-import { createStream } from '../src/stream.js'
-import { MessageTypes, MessageTypeNames } from '../src/message-types.js'
+import randomInt from 'random-int'
+import { Uint8ArrayList } from 'uint8arraylist'
 import { fromString as uint8ArrayFromString } from 'uint8arrays'
+import { MessageTypes, MessageTypeNames } from '../src/message-types.js'
+import { createStream } from '../src/stream.js'
 import { messageWithBytes } from './fixtures/utils.js'
 import type { Message } from '../src/message-types.js'
 import type { MplexStream } from '../src/mplex.js'
-import { Uint8ArrayList } from 'uint8arraylist'
 
 function randomInput (min = 1, max = 100): Uint8ArrayList[] {
   return Array.from(Array(randomInt(min, max)), () => new Uint8ArrayList(randomBytes(randomInt(1, 128))))