Skip to content
This repository was archived by the owner on Aug 29, 2023. It is now read-only.

deps(dev): bump aegir from 38.1.8 to 39.0.10 #279

Merged
merged 3 commits into from
Jun 15, 2023
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
3 changes: 2 additions & 1 deletion package.json
Original file line number Diff line number Diff line change
Expand Up @@ -149,12 +149,13 @@
"@libp2p/utils": "^3.0.2",
"@multiformats/mafmt": "^12.0.0",
"@multiformats/multiaddr": "^12.0.0",
"@types/sinon": "^10.0.15",
"stream-to-it": "^0.2.2"
},
"devDependencies": {
"@libp2p/interface-mocks": "^11.0.0",
"@libp2p/interface-transport-compliance-tests": "^4.0.0",
"aegir": "^38.1.0",
"aegir": "^39.0.10",
"it-all": "^3.0.1",
"it-pipe": "^3.0.1",
"p-defer": "^4.0.0",
Expand Down
24 changes: 10 additions & 14 deletions src/index.ts
Original file line number Diff line number Diff line change
@@ -1,16 +1,16 @@
import net from 'net'
import * as mafmt from '@multiformats/mafmt'
import { type CreateListenerOptions, type DialOptions, type Listener, symbol, type Transport } from '@libp2p/interface-transport'
import { AbortError, CodeError } from '@libp2p/interfaces/errors'
import { logger } from '@libp2p/logger'
import * as mafmt from '@multiformats/mafmt'
import { CODE_CIRCUIT, CODE_P2P, CODE_UNIX } from './constants.js'
import { type CloseServerOnMaxConnectionsOpts, TCPListener } from './listener.js'
import { toMultiaddrConnection } from './socket-to-conn.js'
import { CloseServerOnMaxConnectionsOpts, TCPListener } from './listener.js'
import { multiaddrToNetConfig } from './utils.js'
import { AbortError, CodeError } from '@libp2p/interfaces/errors'
import { CODE_CIRCUIT, CODE_P2P, CODE_UNIX } from './constants.js'
import { CreateListenerOptions, DialOptions, Listener, symbol, Transport } from '@libp2p/interface-transport'
import type { AbortOptions, Multiaddr } from '@multiformats/multiaddr'
import type { Socket, IpcSocketConnectOpts, TcpSocketConnectOpts } from 'net'
import type { Connection } from '@libp2p/interface-connection'
import type { CounterGroup, Metrics } from '@libp2p/interface-metrics'
import type { AbortOptions, Multiaddr } from '@multiformats/multiaddr'
import type { Socket, IpcSocketConnectOpts, TcpSocketConnectOpts } from 'net'

const log = logger('libp2p:tcp')

Expand Down Expand Up @@ -94,13 +94,9 @@ class TCP implements Transport {
}
}

get [symbol] (): true {
return true
}
readonly [symbol] = true

get [Symbol.toStringTag] (): string {
return '@libp2p/tcp'
}
readonly [Symbol.toStringTag] = '@libp2p/tcp'

async dial (ma: Multiaddr, options: TCPDialOptions): Promise<Connection> {
options.keepAlive = options.keepAlive ?? true
Expand Down Expand Up @@ -149,7 +145,7 @@ class TCP implements Transport {
throw new AbortError()
}

return await new Promise<Socket>((resolve, reject) => {
return new Promise<Socket>((resolve, reject) => {
const start = Date.now()
const cOpts = multiaddrToNetConfig(ma) as (IpcSocketConnectOpts & TcpSocketConnectOpts)
const cOptsStr = cOpts.path ?? `${cOpts.host ?? ''}:${cOpts.port}`
Expand Down
10 changes: 5 additions & 5 deletions src/listener.ts
Original file line number Diff line number Diff line change
@@ -1,18 +1,18 @@
import net from 'net'
import { EventEmitter, CustomEvent } from '@libp2p/interfaces/events'
import { logger } from '@libp2p/logger'
import { toMultiaddrConnection } from './socket-to-conn.js'
import { CODE_P2P } from './constants.js'
import { toMultiaddrConnection } from './socket-to-conn.js'
import {
getMultiaddrs,
multiaddrToNetConfig,
NetConfig
type NetConfig
} from './utils.js'
import { EventEmitter, CustomEvent } from '@libp2p/interfaces/events'
import type { TCPCreateListenerOptions } from './index.js'
import type { MultiaddrConnection, Connection } from '@libp2p/interface-connection'
import type { CounterGroup, MetricGroup, Metrics } from '@libp2p/interface-metrics'
import type { Upgrader, Listener, ListenerEvents } from '@libp2p/interface-transport'
import type { Multiaddr } from '@multiformats/multiaddr'
import type { TCPCreateListenerOptions } from './index.js'
import type { CounterGroup, MetricGroup, Metrics } from '@libp2p/interface-metrics'

const log = logger('libp2p:tcp:listener')

Expand Down
8 changes: 4 additions & 4 deletions src/socket-to-conn.ts
Original file line number Diff line number Diff line change
@@ -1,14 +1,14 @@
import { CodeError } from '@libp2p/interfaces/errors'
import { logger } from '@libp2p/logger'
import { ipPortToMultiaddr as toMultiaddr } from '@libp2p/utils/ip-port-to-multiaddr'
// @ts-expect-error no types
import toIterable from 'stream-to-it'
import { ipPortToMultiaddr as toMultiaddr } from '@libp2p/utils/ip-port-to-multiaddr'
import { CLOSE_TIMEOUT, SOCKET_TIMEOUT } from './constants.js'
import { multiaddrToNetConfig } from './utils.js'
import { CodeError } from '@libp2p/interfaces/errors'
import type { Socket } from 'net'
import type { Multiaddr } from '@multiformats/multiaddr'
import type { MultiaddrConnection } from '@libp2p/interface-connection'
import type { CounterGroup } from '@libp2p/interface-metrics'
import type { Multiaddr } from '@multiformats/multiaddr'
import type { Socket } from 'net'

const log = logger('libp2p:tcp:socket')

Expand Down
4 changes: 2 additions & 2 deletions src/utils.ts
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
import os from 'os'
import path from 'path'
import { multiaddr } from '@multiformats/multiaddr'
import type { Multiaddr } from '@multiformats/multiaddr'
import type { ListenOptions, IpcSocketConnectOpts, TcpSocketConnectOpts } from 'net'
import os from 'os'
import path from 'path'

const ProtoFamily = { ip4: 'IPv4', ip6: 'IPv6' }

Expand Down
4 changes: 2 additions & 2 deletions test/compliance.spec.ts
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
import sinon from 'sinon'
import net from 'net'
import tests from '@libp2p/interface-transport-compliance-tests'
import { multiaddr } from '@multiformats/multiaddr'
import net from 'net'
import sinon from 'sinon'
import { tcp } from '../src/index.js'

describe('interface-transport compliance', () => {
Expand Down
6 changes: 3 additions & 3 deletions test/connection.spec.ts
Original file line number Diff line number Diff line change
@@ -1,10 +1,10 @@
import { mockUpgrader } from '@libp2p/interface-mocks'
import { EventEmitter } from '@libp2p/interfaces/events'
import { multiaddr } from '@multiformats/multiaddr'
import { expect } from 'aegir/chai'
import { tcp } from '../src/index.js'
import { multiaddr } from '@multiformats/multiaddr'
import { mockUpgrader } from '@libp2p/interface-mocks'
import type { Connection } from '@libp2p/interface-connection'
import type { Transport, Upgrader } from '@libp2p/interface-transport'
import { EventEmitter } from '@libp2p/interfaces/events'

describe('valid localAddr and remoteAddr', () => {
let transport: Transport
Expand Down
2 changes: 1 addition & 1 deletion test/filter.spec.ts
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
import { multiaddr } from '@multiformats/multiaddr'
import { expect } from 'aegir/chai'
import { tcp } from '../src/index.js'
import { multiaddr } from '@multiformats/multiaddr'
import type { Transport } from '@libp2p/interface-transport'

describe('filter addrs', () => {
Expand Down
22 changes: 11 additions & 11 deletions test/listen-dial.spec.ts
Original file line number Diff line number Diff line change
@@ -1,16 +1,16 @@
import { expect } from 'aegir/chai'
import { tcp } from '../src/index.js'
import os from 'os'
import path from 'path'
import { mockRegistrar, mockUpgrader } from '@libp2p/interface-mocks'
import { EventEmitter } from '@libp2p/interfaces/events'
import { multiaddr } from '@multiformats/multiaddr'
import { pipe } from 'it-pipe'
import { expect } from 'aegir/chai'
import all from 'it-all'
import { mockRegistrar, mockUpgrader } from '@libp2p/interface-mocks'
import { fromString as uint8ArrayFromString } from 'uint8arrays/from-string'
import type { Transport, Upgrader } from '@libp2p/interface-transport'
import { pipe } from 'it-pipe'
import pDefer from 'p-defer'
import { fromString as uint8ArrayFromString } from 'uint8arrays/from-string'
import { tcp } from '../src/index.js'
import type { MultiaddrConnection } from '@libp2p/interface-connection'
import { EventEmitter } from '@libp2p/interfaces/events'
import type { Transport, Upgrader } from '@libp2p/interface-transport'

const isCI = process.env.CI

Expand Down Expand Up @@ -196,7 +196,7 @@ describe('dial', () => {
const values = await pipe(
[uint8ArrayFromString('hey')],
stream,
async (source) => await all(source)
async (source) => all(source)
)

expect(values[0].subarray()).to.equalBytes(uint8ArrayFromString('hey'))
Expand All @@ -222,7 +222,7 @@ describe('dial', () => {
const values = await pipe(
[uint8ArrayFromString('hey')],
stream,
async (source) => await all(source)
async (source) => all(source)
)
expect(values[0].subarray()).to.equalBytes(uint8ArrayFromString('hey'))
await conn.close()
Expand All @@ -244,7 +244,7 @@ describe('dial', () => {
const values = await pipe(
[uint8ArrayFromString('hey')],
stream,
async (source) => await all(source)
async (source) => all(source)
)

expect(values[0].subarray()).to.equalBytes(uint8ArrayFromString('hey'))
Expand Down Expand Up @@ -326,7 +326,7 @@ describe('dial', () => {
const values = await pipe(
[uint8ArrayFromString('hey')],
stream,
async (source) => await all(source)
async (source) => all(source)
)
expect(values[0].subarray()).to.equalBytes(uint8ArrayFromString('hey'))

Expand Down
4 changes: 2 additions & 2 deletions test/max-connections-close.spec.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@
import net from 'node:net'
import { promisify } from 'util'
import { expect } from 'aegir/chai'
import { mockUpgrader } from '@libp2p/interface-mocks'
import { EventEmitter } from '@libp2p/interfaces/events'
import { multiaddr } from '@multiformats/multiaddr'
import { expect } from 'aegir/chai'
import { tcp } from '../src/index.js'
import type { TCPListener } from '../src/listener.js'
import { EventEmitter } from '@libp2p/interfaces/events'

describe('close server on maxConnections', () => {
const afterEachCallbacks: Array<() => Promise<any> | any> = []
Expand Down
4 changes: 2 additions & 2 deletions test/max-connections.spec.ts
Original file line number Diff line number Diff line change
@@ -1,10 +1,10 @@
import { expect } from 'aegir/chai'
import net from 'node:net'
import { promisify } from 'node:util'
import { mockUpgrader } from '@libp2p/interface-mocks'
import { EventEmitter } from '@libp2p/interfaces/events'
import { multiaddr } from '@multiformats/multiaddr'
import { expect } from 'aegir/chai'
import { tcp } from '../src/index.js'
import { EventEmitter } from '@libp2p/interfaces/events'

describe('maxConnections', () => {
const afterEachCallbacks: Array<() => Promise<any> | any> = []
Expand Down
5 changes: 2 additions & 3 deletions test/socket-to-conn.spec.ts
Original file line number Diff line number Diff line change
@@ -1,9 +1,8 @@
import { createServer, Socket, type Server, type ServerOpts, type SocketConstructorOpts } from 'net'
import os from 'os'
import { expect } from 'aegir/chai'
import { createServer, Socket, Server } from 'net'
import defer from 'p-defer'
import { toMultiaddrConnection } from '../src/socket-to-conn.js'
import os from 'os'
import type { ServerOpts, SocketConstructorOpts } from 'net'

async function setup (opts?: { server?: ServerOpts, client?: SocketConstructorOpts }): Promise<{ server: Server, serverSocket: Socket, clientSocket: Socket }> {
const serverListening = defer()
Expand Down