Skip to content

Commit

Permalink
deps(dev): bump aegir from 38.1.8 to 39.0.6 (libp2p#278)
Browse files Browse the repository at this point in the history
* deps(dev): bump aegir from 38.1.8 to 39.0.6

Bumps [aegir](https://github.com/ipfs/aegir) from 38.1.8 to 39.0.6.
- [Release notes](https://github.com/ipfs/aegir/releases)
- [Changelog](https://github.com/ipfs/aegir/blob/master/CHANGELOG.md)
- [Commits](ipfs/aegir@v38.1.8...v39.0.6)

---
updated-dependencies:
- dependency-name: aegir
  dependency-type: direct:development
  update-type: version-update:semver-major
...

Signed-off-by: dependabot[bot] <support@github.com>

* chore: fix linting

* chore: update aegir

---------

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: achingbrain <alex@achingbrain.net>
  • Loading branch information
dependabot[bot] and achingbrain committed May 17, 2023
1 parent 8fb40c3 commit 3c7229b
Show file tree
Hide file tree
Showing 12 changed files with 50 additions and 50 deletions.
2 changes: 1 addition & 1 deletion package.json
Original file line number Diff line number Diff line change
Expand Up @@ -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",
Expand Down
2 changes: 1 addition & 1 deletion src/decode.ts
Original file line number Diff line number Diff line change
@@ -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
Expand Down
8 changes: 4 additions & 4 deletions src/encode.ts
Original file line number Diff line number Diff line change
@@ -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

Expand Down
2 changes: 1 addition & 1 deletion src/index.ts
Original file line number Diff line number Diff line change
@@ -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 {
/**
Expand Down
22 changes: 11 additions & 11 deletions src/mplex.ts
Original file line number Diff line number Diff line change
@@ -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')
Expand Down
12 changes: 6 additions & 6 deletions src/stream.ts
Original file line number Diff line number Diff line change
@@ -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')

Expand Down
6 changes: 3 additions & 3 deletions test/coder.spec.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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 () => {
Expand Down
2 changes: 1 addition & 1 deletion test/fixtures/decode.ts
Original file line number Diff line number Diff line change
@@ -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) {
Expand Down
2 changes: 1 addition & 1 deletion test/fixtures/utils.ts
Original file line number Diff line number Diff line change
@@ -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]
Expand Down
18 changes: 9 additions & 9 deletions test/mplex.spec.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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 () => {
Expand Down
10 changes: 5 additions & 5 deletions test/restrict-size.spec.ts
Original file line number Diff line number Diff line change
@@ -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 () => {
Expand Down Expand Up @@ -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])
})
Expand Down
14 changes: 7 additions & 7 deletions test/stream.spec.ts
Original file line number Diff line number Diff line change
@@ -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))))
Expand Down

0 comments on commit 3c7229b

Please sign in to comment.