Skip to content
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.

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

refactor: move error codes to @libp2p/interface/errors #2140

Closed
wants to merge 1 commit into from
Closed
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
70 changes: 70 additions & 0 deletions packages/interface/src/errors.ts
Original file line number Diff line number Diff line change
Expand Up @@ -65,3 +65,73 @@ export class InvalidCryptoTransmissionError extends Error {

static readonly code = 'ERR_INVALID_CRYPTO_TRANSMISSION'
}

export enum codes {
DHT_DISABLED = 'ERR_DHT_DISABLED',
ERR_PUBSUB_DISABLED = 'ERR_PUBSUB_DISABLED',
PUBSUB_NOT_STARTED = 'ERR_PUBSUB_NOT_STARTED',
DHT_NOT_STARTED = 'ERR_DHT_NOT_STARTED',
CONN_ENCRYPTION_REQUIRED = 'ERR_CONN_ENCRYPTION_REQUIRED',
ERR_TRANSPORTS_REQUIRED = 'ERR_TRANSPORTS_REQUIRED',
ERR_PROTECTOR_REQUIRED = 'ERR_PROTECTOR_REQUIRED',
ERR_PEER_DIAL_INTERCEPTED = 'ERR_PEER_DIAL_INTERCEPTED',
ERR_CONNECTION_INTERCEPTED = 'ERR_CONNECTION_INTERCEPTED',
ERR_INVALID_PROTOCOLS_FOR_STREAM = 'ERR_INVALID_PROTOCOLS_FOR_STREAM',
ERR_CONNECTION_ENDED = 'ERR_CONNECTION_ENDED',
ERR_CONNECTION_FAILED = 'ERR_CONNECTION_FAILED',
ERR_NODE_NOT_STARTED = 'ERR_NODE_NOT_STARTED',
ERR_ALREADY_ABORTED = 'ERR_ALREADY_ABORTED',
ERR_TOO_MANY_ADDRESSES = 'ERR_TOO_MANY_ADDRESSES',
ERR_NO_VALID_ADDRESSES = 'ERR_NO_VALID_ADDRESSES',
ERR_RELAYED_DIAL = 'ERR_RELAYED_DIAL',
ERR_DIALED_SELF = 'ERR_DIALED_SELF',
ERR_DISCOVERED_SELF = 'ERR_DISCOVERED_SELF',
ERR_DUPLICATE_TRANSPORT = 'ERR_DUPLICATE_TRANSPORT',
ERR_ENCRYPTION_FAILED = 'ERR_ENCRYPTION_FAILED',
ERR_HOP_REQUEST_FAILED = 'ERR_HOP_REQUEST_FAILED',
ERR_INVALID_KEY = 'ERR_INVALID_KEY',
ERR_INVALID_MESSAGE = 'ERR_INVALID_MESSAGE',
ERR_INVALID_PARAMETERS = 'ERR_INVALID_PARAMETERS',
ERR_INVALID_PEER = 'ERR_INVALID_PEER',
ERR_MUXER_UNAVAILABLE = 'ERR_MUXER_UNAVAILABLE',
ERR_NOT_FOUND = 'ERR_NOT_FOUND',
ERR_TIMEOUT = 'ERR_TIMEOUT',
ERR_TRANSPORT_UNAVAILABLE = 'ERR_TRANSPORT_UNAVAILABLE',
ERR_TRANSPORT_DIAL_FAILED = 'ERR_TRANSPORT_DIAL_FAILED',
ERR_UNSUPPORTED_PROTOCOL = 'ERR_UNSUPPORTED_PROTOCOL',
ERR_PROTOCOL_HANDLER_ALREADY_REGISTERED = 'ERR_PROTOCOL_HANDLER_ALREADY_REGISTERED',
ERR_INVALID_MULTIADDR = 'ERR_INVALID_MULTIADDR',
ERR_SIGNATURE_NOT_VALID = 'ERR_SIGNATURE_NOT_VALID',
ERR_FIND_SELF = 'ERR_FIND_SELF',
ERR_NO_ROUTERS_AVAILABLE = 'ERR_NO_ROUTERS_AVAILABLE',
ERR_CONNECTION_NOT_MULTIPLEXED = 'ERR_CONNECTION_NOT_MULTIPLEXED',
ERR_NO_DIAL_TOKENS = 'ERR_NO_DIAL_TOKENS',
ERR_KEYCHAIN_REQUIRED = 'ERR_KEYCHAIN_REQUIRED',
ERR_INVALID_CMS = 'ERR_INVALID_CMS',
ERR_MISSING_KEYS = 'ERR_MISSING_KEYS',
ERR_NO_KEY = 'ERR_NO_KEY',
ERR_INVALID_KEY_NAME = 'ERR_INVALID_KEY_NAME',
ERR_INVALID_KEY_TYPE = 'ERR_INVALID_KEY_TYPE',
ERR_KEY_ALREADY_EXISTS = 'ERR_KEY_ALREADY_EXISTS',
ERR_INVALID_KEY_SIZE = 'ERR_INVALID_KEY_SIZE',
ERR_KEY_NOT_FOUND = 'ERR_KEY_NOT_FOUND',
ERR_OLD_KEY_NAME_INVALID = 'ERR_OLD_KEY_NAME_INVALID',
ERR_NEW_KEY_NAME_INVALID = 'ERR_NEW_KEY_NAME_INVALID',
ERR_PASSWORD_REQUIRED = 'ERR_PASSWORD_REQUIRED',
ERR_PEM_REQUIRED = 'ERR_PEM_REQUIRED',
ERR_CANNOT_READ_KEY = 'ERR_CANNOT_READ_KEY',
ERR_MISSING_PRIVATE_KEY = 'ERR_MISSING_PRIVATE_KEY',
ERR_MISSING_PUBLIC_KEY = 'ERR_MISSING_PUBLIC_KEY',
ERR_INVALID_OLD_PASS_TYPE = 'ERR_INVALID_OLD_PASS_TYPE',
ERR_INVALID_NEW_PASS_TYPE = 'ERR_INVALID_NEW_PASS_TYPE',
ERR_INVALID_PASS_LENGTH = 'ERR_INVALID_PASS_LENGTH',
ERR_NOT_IMPLEMENTED = 'ERR_NOT_IMPLEMENTED',
ERR_WRONG_PING_ACK = 'ERR_WRONG_PING_ACK',
ERR_INVALID_RECORD = 'ERR_INVALID_RECORD',
ERR_ALREADY_SUCCEEDED = 'ERR_ALREADY_SUCCEEDED',
ERR_NO_HANDLER_FOR_PROTOCOL = 'ERR_NO_HANDLER_FOR_PROTOCOL',
ERR_TOO_MANY_OUTBOUND_PROTOCOL_STREAMS = 'ERR_TOO_MANY_OUTBOUND_PROTOCOL_STREAMS',
ERR_TOO_MANY_INBOUND_PROTOCOL_STREAMS = 'ERR_TOO_MANY_INBOUND_PROTOCOL_STREAMS',
ERR_CONNECTION_DENIED = 'ERR_CONNECTION_DENIED',
ERR_TRANSFER_LIMIT_EXCEEDED = 'ERR_TRANSFER_LIMIT_EXCEEDED'
}
3 changes: 1 addition & 2 deletions packages/libp2p/src/autonat/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
*/

import { setMaxListeners } from 'events'
import { CodeError } from '@libp2p/interface/errors'
import { CodeError, codes } from '@libp2p/interface/errors'
import { logger } from '@libp2p/logger'
import { peerIdFromBytes } from '@libp2p/peer-id'
import { createEd25519PeerId } from '@libp2p/peer-id-factory'
Expand All @@ -31,7 +31,6 @@ import map from 'it-map'
import parallel from 'it-parallel'
import { pipe } from 'it-pipe'
import isPrivateIp from 'private-ip'
import { codes } from '../errors.js'
import {
MAX_INBOUND_STREAMS,
MAX_OUTBOUND_STREAMS,
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
import { codes } from '@libp2p/interface/errors'
import { EventEmitter } from '@libp2p/interface/events'
import { logger } from '@libp2p/logger'
import pRetry from 'p-retry'
import { codes } from '../../errors.js'
import {
DEFAULT_ADVERT_BOOT_DELAY,
RELAY_RENDEZVOUS_NS
Expand Down
3 changes: 1 addition & 2 deletions packages/libp2p/src/circuit-relay/transport/index.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { CodeError } from '@libp2p/interface/errors'
import { CodeError, codes } from '@libp2p/interface/errors'
import { symbol, type Transport, type CreateListenerOptions, type Listener, type Upgrader } from '@libp2p/interface/transport'
import { logger } from '@libp2p/logger'
import { peerIdFromBytes, peerIdFromString } from '@libp2p/peer-id'
Expand All @@ -7,7 +7,6 @@ import * as mafmt from '@multiformats/mafmt'
import { multiaddr } from '@multiformats/multiaddr'
import { pbStream } from 'it-protobuf-stream'
import { MAX_CONNECTIONS } from '../../connection-manager/constants.js'
import { codes } from '../../errors.js'
import { CIRCUIT_PROTO_CODE, RELAY_V2_HOP_CODEC, RELAY_V2_STOP_CODEC } from '../constants.js'
import { StopMessage, HopMessage, Status } from '../pb/index.js'
import { RelayDiscovery, type RelayDiscoveryComponents } from './discovery.js'
Expand Down
3 changes: 1 addition & 2 deletions packages/libp2p/src/circuit-relay/utils.ts
Original file line number Diff line number Diff line change
@@ -1,9 +1,8 @@
import { CodeError } from '@libp2p/interface/errors'
import { CodeError, codes } from '@libp2p/interface/errors'
import { logger } from '@libp2p/logger'
import { anySignal } from 'any-signal'
import { CID } from 'multiformats/cid'
import { sha256 } from 'multiformats/hashes/sha2'
import { codes } from '../errors.js'
import type { Limit } from './pb/index.js'
import type { Stream } from '@libp2p/interface/connection'
import type { Source } from 'it-stream-types'
Expand Down
4 changes: 2 additions & 2 deletions packages/libp2p/src/config.ts
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
import { CodeError } from '@libp2p/interface/errors'
import { CodeError, codes } from '@libp2p/interface/errors'
import { FaultTolerance } from '@libp2p/interface/transport'
import { defaultAddressSort } from '@libp2p/utils/address-sort'
import { dnsaddrResolver } from '@multiformats/multiaddr/resolvers'
import mergeOptions from 'merge-options'
import { codes, messages } from './errors.js'
import { messages } from './errors.js'
import type { Libp2pInit } from './index.js'
import type { ServiceMap, RecursivePartial } from '@libp2p/interface'
import type { Multiaddr } from '@multiformats/multiaddr'
Expand Down
3 changes: 1 addition & 2 deletions packages/libp2p/src/connection-manager/dial-queue.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import { setMaxListeners } from 'events'
import { AbortError, CodeError } from '@libp2p/interface/errors'
import { AbortError, CodeError, codes } from '@libp2p/interface/errors'
import { logger } from '@libp2p/logger'
import { defaultAddressSort } from '@libp2p/utils/address-sort'
import { type Multiaddr, type Resolver, resolvers } from '@multiformats/multiaddr'
Expand All @@ -8,7 +8,6 @@ import { type ClearableSignal, anySignal } from 'any-signal'
import pDefer from 'p-defer'
import PQueue from 'p-queue'
import { fromString as uint8ArrayFromString } from 'uint8arrays/from-string'
import { codes } from '../errors.js'
import { getPeerAddress } from '../get-peer.js'
import {
DIAL_TIMEOUT,
Expand Down
3 changes: 1 addition & 2 deletions packages/libp2p/src/connection-manager/index.ts
Original file line number Diff line number Diff line change
@@ -1,12 +1,11 @@
import { CodeError } from '@libp2p/interface/errors'
import { CodeError, codes } from '@libp2p/interface/errors'
import { KEEP_ALIVE } from '@libp2p/interface/peer-store/tags'
import { logger } from '@libp2p/logger'
import { PeerMap } from '@libp2p/peer-collections'
import { defaultAddressSort } from '@libp2p/utils/address-sort'
import { type Multiaddr, type Resolver, multiaddr } from '@multiformats/multiaddr'
import { dnsaddrResolver } from '@multiformats/multiaddr/resolvers'
import { RateLimiterMemory } from 'rate-limiter-flexible'
import { codes } from '../errors.js'
import { getPeerAddress } from '../get-peer.js'
import { AutoDial } from './auto-dial.js'
import { ConnectionPruner } from './connection-pruner.js'
Expand Down
4 changes: 2 additions & 2 deletions packages/libp2p/src/content-routing/index.ts
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
import { CodeError } from '@libp2p/interface/errors'
import { CodeError, codes } from '@libp2p/interface/errors'
import merge from 'it-merge'
import { pipe } from 'it-pipe'
import { messages, codes } from '../errors.js'
import { messages } from '../errors.js'
import {
storeAddresses,
uniquePeers,
Expand Down
3 changes: 1 addition & 2 deletions packages/libp2p/src/dcutr/dcutr.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,10 @@
import { CodeError } from '@libp2p/interface/errors'
import { CodeError, codes } from '@libp2p/interface/errors'
import { logger } from '@libp2p/logger'
import { type Multiaddr, multiaddr } from '@multiformats/multiaddr'
import { Circuit, IP, DNS } from '@multiformats/multiaddr-matcher'
import delay from 'delay'
import { pbStream } from 'it-protobuf-stream'
import isPrivate from 'private-ip'
import { codes } from '../errors.js'
import { HolePunch } from './pb/message.js'
import { multicodec } from './index.js'
import type { DCUtRServiceComponents, DCUtRServiceInit } from './index.js'
Expand Down
70 changes: 0 additions & 70 deletions packages/libp2p/src/errors.ts
Original file line number Diff line number Diff line change
Expand Up @@ -7,73 +7,3 @@ export enum messages {
ERR_PROTECTOR_REQUIRED = 'Private network is enforced, but no protector was provided',
NOT_FOUND = 'Not found'
}

export enum codes {
DHT_DISABLED = 'ERR_DHT_DISABLED',
ERR_PUBSUB_DISABLED = 'ERR_PUBSUB_DISABLED',
PUBSUB_NOT_STARTED = 'ERR_PUBSUB_NOT_STARTED',
DHT_NOT_STARTED = 'ERR_DHT_NOT_STARTED',
CONN_ENCRYPTION_REQUIRED = 'ERR_CONN_ENCRYPTION_REQUIRED',
ERR_TRANSPORTS_REQUIRED = 'ERR_TRANSPORTS_REQUIRED',
ERR_PROTECTOR_REQUIRED = 'ERR_PROTECTOR_REQUIRED',
ERR_PEER_DIAL_INTERCEPTED = 'ERR_PEER_DIAL_INTERCEPTED',
ERR_CONNECTION_INTERCEPTED = 'ERR_CONNECTION_INTERCEPTED',
ERR_INVALID_PROTOCOLS_FOR_STREAM = 'ERR_INVALID_PROTOCOLS_FOR_STREAM',
ERR_CONNECTION_ENDED = 'ERR_CONNECTION_ENDED',
ERR_CONNECTION_FAILED = 'ERR_CONNECTION_FAILED',
ERR_NODE_NOT_STARTED = 'ERR_NODE_NOT_STARTED',
ERR_ALREADY_ABORTED = 'ERR_ALREADY_ABORTED',
ERR_TOO_MANY_ADDRESSES = 'ERR_TOO_MANY_ADDRESSES',
ERR_NO_VALID_ADDRESSES = 'ERR_NO_VALID_ADDRESSES',
ERR_RELAYED_DIAL = 'ERR_RELAYED_DIAL',
ERR_DIALED_SELF = 'ERR_DIALED_SELF',
ERR_DISCOVERED_SELF = 'ERR_DISCOVERED_SELF',
ERR_DUPLICATE_TRANSPORT = 'ERR_DUPLICATE_TRANSPORT',
ERR_ENCRYPTION_FAILED = 'ERR_ENCRYPTION_FAILED',
ERR_HOP_REQUEST_FAILED = 'ERR_HOP_REQUEST_FAILED',
ERR_INVALID_KEY = 'ERR_INVALID_KEY',
ERR_INVALID_MESSAGE = 'ERR_INVALID_MESSAGE',
ERR_INVALID_PARAMETERS = 'ERR_INVALID_PARAMETERS',
ERR_INVALID_PEER = 'ERR_INVALID_PEER',
ERR_MUXER_UNAVAILABLE = 'ERR_MUXER_UNAVAILABLE',
ERR_NOT_FOUND = 'ERR_NOT_FOUND',
ERR_TIMEOUT = 'ERR_TIMEOUT',
ERR_TRANSPORT_UNAVAILABLE = 'ERR_TRANSPORT_UNAVAILABLE',
ERR_TRANSPORT_DIAL_FAILED = 'ERR_TRANSPORT_DIAL_FAILED',
ERR_UNSUPPORTED_PROTOCOL = 'ERR_UNSUPPORTED_PROTOCOL',
ERR_PROTOCOL_HANDLER_ALREADY_REGISTERED = 'ERR_PROTOCOL_HANDLER_ALREADY_REGISTERED',
ERR_INVALID_MULTIADDR = 'ERR_INVALID_MULTIADDR',
ERR_SIGNATURE_NOT_VALID = 'ERR_SIGNATURE_NOT_VALID',
ERR_FIND_SELF = 'ERR_FIND_SELF',
ERR_NO_ROUTERS_AVAILABLE = 'ERR_NO_ROUTERS_AVAILABLE',
ERR_CONNECTION_NOT_MULTIPLEXED = 'ERR_CONNECTION_NOT_MULTIPLEXED',
ERR_NO_DIAL_TOKENS = 'ERR_NO_DIAL_TOKENS',
ERR_KEYCHAIN_REQUIRED = 'ERR_KEYCHAIN_REQUIRED',
ERR_INVALID_CMS = 'ERR_INVALID_CMS',
ERR_MISSING_KEYS = 'ERR_MISSING_KEYS',
ERR_NO_KEY = 'ERR_NO_KEY',
ERR_INVALID_KEY_NAME = 'ERR_INVALID_KEY_NAME',
ERR_INVALID_KEY_TYPE = 'ERR_INVALID_KEY_TYPE',
ERR_KEY_ALREADY_EXISTS = 'ERR_KEY_ALREADY_EXISTS',
ERR_INVALID_KEY_SIZE = 'ERR_INVALID_KEY_SIZE',
ERR_KEY_NOT_FOUND = 'ERR_KEY_NOT_FOUND',
ERR_OLD_KEY_NAME_INVALID = 'ERR_OLD_KEY_NAME_INVALID',
ERR_NEW_KEY_NAME_INVALID = 'ERR_NEW_KEY_NAME_INVALID',
ERR_PASSWORD_REQUIRED = 'ERR_PASSWORD_REQUIRED',
ERR_PEM_REQUIRED = 'ERR_PEM_REQUIRED',
ERR_CANNOT_READ_KEY = 'ERR_CANNOT_READ_KEY',
ERR_MISSING_PRIVATE_KEY = 'ERR_MISSING_PRIVATE_KEY',
ERR_MISSING_PUBLIC_KEY = 'ERR_MISSING_PUBLIC_KEY',
ERR_INVALID_OLD_PASS_TYPE = 'ERR_INVALID_OLD_PASS_TYPE',
ERR_INVALID_NEW_PASS_TYPE = 'ERR_INVALID_NEW_PASS_TYPE',
ERR_INVALID_PASS_LENGTH = 'ERR_INVALID_PASS_LENGTH',
ERR_NOT_IMPLEMENTED = 'ERR_NOT_IMPLEMENTED',
ERR_WRONG_PING_ACK = 'ERR_WRONG_PING_ACK',
ERR_INVALID_RECORD = 'ERR_INVALID_RECORD',
ERR_ALREADY_SUCCEEDED = 'ERR_ALREADY_SUCCEEDED',
ERR_NO_HANDLER_FOR_PROTOCOL = 'ERR_NO_HANDLER_FOR_PROTOCOL',
ERR_TOO_MANY_OUTBOUND_PROTOCOL_STREAMS = 'ERR_TOO_MANY_OUTBOUND_PROTOCOL_STREAMS',
ERR_TOO_MANY_INBOUND_PROTOCOL_STREAMS = 'ERR_TOO_MANY_INBOUND_PROTOCOL_STREAMS',
ERR_CONNECTION_DENIED = 'ERR_CONNECTION_DENIED',
ERR_TRANSFER_LIMIT_EXCEEDED = 'ERR_TRANSFER_LIMIT_EXCEEDED'
}
3 changes: 1 addition & 2 deletions packages/libp2p/src/fetch/index.ts
Original file line number Diff line number Diff line change
@@ -1,12 +1,11 @@
import { setMaxListeners } from 'events'
import { CodeError } from '@libp2p/interface/errors'
import { CodeError, codes } from '@libp2p/interface/errors'
import { logger } from '@libp2p/logger'
import first from 'it-first'
import * as lp from 'it-length-prefixed'
import { pipe } from 'it-pipe'
import { fromString as uint8arrayFromString } from 'uint8arrays/from-string'
import { toString as uint8arrayToString } from 'uint8arrays/to-string'
import { codes } from '../errors.js'
import { PROTOCOL_NAME, PROTOCOL_VERSION } from './constants.js'
import { FetchRequest, FetchResponse } from './pb/proto.js'
import type { AbortOptions } from '@libp2p/interface'
Expand Down
3 changes: 1 addition & 2 deletions packages/libp2p/src/get-peer.ts
Original file line number Diff line number Diff line change
@@ -1,9 +1,8 @@
import { CodeError } from '@libp2p/interface/errors'
import { CodeError, codes } from '@libp2p/interface/errors'
import { isPeerId } from '@libp2p/interface/peer-id'
import { logger } from '@libp2p/logger'
import { peerIdFromString } from '@libp2p/peer-id'
import { isMultiaddr } from '@multiformats/multiaddr'
import { codes } from './errors.js'
import type { PeerId } from '@libp2p/interface/peer-id'
import type { Multiaddr } from '@multiformats/multiaddr'

Expand Down
3 changes: 1 addition & 2 deletions packages/libp2p/src/identify/identify.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import { setMaxListeners } from 'events'
import { CodeError } from '@libp2p/interface/errors'
import { CodeError, codes } from '@libp2p/interface/errors'
import { logger } from '@libp2p/logger'
import { peerIdFromKeys } from '@libp2p/peer-id'
import { RecordEnvelope, PeerRecord } from '@libp2p/peer-record'
Expand All @@ -8,7 +8,6 @@ import { pbStream } from 'it-protobuf-stream'
import { fromString as uint8ArrayFromString } from 'uint8arrays/from-string'
import { toString as uint8ArrayToString } from 'uint8arrays/to-string'
import { isNode, isBrowser, isWebWorker, isElectronMain, isElectronRenderer, isReactNative } from 'wherearewe'
import { codes } from '../errors.js'
import {
AGENT_VERSION,
IDENTIFY_PROTOCOL_VERSION,
Expand Down
3 changes: 1 addition & 2 deletions packages/libp2p/src/libp2p.ts
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
import { setMaxListeners } from 'events'
import { unmarshalPublicKey } from '@libp2p/crypto/keys'
import { type ContentRouting, contentRouting } from '@libp2p/interface/content-routing'
import { CodeError } from '@libp2p/interface/errors'
import { CodeError, codes } from '@libp2p/interface/errors'
import { EventEmitter, CustomEvent } from '@libp2p/interface/events'
import { peerDiscovery } from '@libp2p/interface/peer-discovery'
import { type PeerRouting, peerRouting } from '@libp2p/interface/peer-routing'
Expand All @@ -22,7 +22,6 @@ import { connectionGater } from './config/connection-gater.js'
import { validateConfig } from './config.js'
import { DefaultConnectionManager } from './connection-manager/index.js'
import { CompoundContentRouting } from './content-routing/index.js'
import { codes } from './errors.js'
import { DefaultPeerRouting } from './peer-routing.js'
import { DefaultRegistrar } from './registrar.js'
import { DefaultTransportManager } from './transport-manager.js'
Expand Down
4 changes: 2 additions & 2 deletions packages/libp2p/src/peer-routing.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { CodeError } from '@libp2p/interface/errors'
import { CodeError, codes } from '@libp2p/interface/errors'
import { logger } from '@libp2p/logger'
import filter from 'it-filter'
import first from 'it-first'
Expand All @@ -9,7 +9,7 @@ import {
uniquePeers,
requirePeers
} from './content-routing/utils.js'
import { codes, messages } from './errors.js'
import { messages } from './errors.js'
import type { AbortOptions } from '@libp2p/interface'
import type { PeerId } from '@libp2p/interface/peer-id'
import type { PeerInfo } from '@libp2p/interface/peer-info'
Expand Down
3 changes: 1 addition & 2 deletions packages/libp2p/src/ping/index.ts
Original file line number Diff line number Diff line change
@@ -1,10 +1,9 @@
import { randomBytes } from '@libp2p/crypto'
import { CodeError } from '@libp2p/interface/errors'
import { CodeError, codes } from '@libp2p/interface/errors'
import { logger } from '@libp2p/logger'
import first from 'it-first'
import { pipe } from 'it-pipe'
import { equals as uint8ArrayEquals } from 'uint8arrays/equals'
import { codes } from '../errors.js'
import { PROTOCOL_PREFIX, PROTOCOL_NAME, PING_LENGTH, PROTOCOL_VERSION, TIMEOUT, MAX_INBOUND_STREAMS, MAX_OUTBOUND_STREAMS } from './constants.js'
import type { AbortOptions } from '@libp2p/interface'
import type { Stream } from '@libp2p/interface/connection'
Expand Down
3 changes: 1 addition & 2 deletions packages/libp2p/src/pnet/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -23,13 +23,12 @@
*/

import { randomBytes } from '@libp2p/crypto'
import { CodeError } from '@libp2p/interface/errors'
import { CodeError, codes } from '@libp2p/interface/errors'
import { logger } from '@libp2p/logger'
import { handshake } from 'it-handshake'
import map from 'it-map'
import { duplexPair } from 'it-pair/duplex'
import { pipe } from 'it-pipe'
import { codes } from '../errors.js'
import {
createBoxStream,
createUnboxStream,
Expand Down
3 changes: 1 addition & 2 deletions packages/libp2p/src/registrar.ts
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
import { CodeError } from '@libp2p/interface/errors'
import { CodeError, codes } from '@libp2p/interface/errors'
import { logger } from '@libp2p/logger'
import merge from 'merge-options'
import { codes } from './errors.js'
import type { Libp2pEvents, PeerUpdate } from '@libp2p/interface'
import type { EventEmitter } from '@libp2p/interface/events'
import type { PeerId } from '@libp2p/interface/peer-id'
Expand Down
3 changes: 1 addition & 2 deletions packages/libp2p/src/transport-manager.ts
Original file line number Diff line number Diff line change
@@ -1,8 +1,7 @@
import { CodeError } from '@libp2p/interface/errors'
import { CodeError, codes } from '@libp2p/interface/errors'
import { trackedMap } from '@libp2p/interface/metrics/tracked-map'
import { FaultTolerance } from '@libp2p/interface/transport'
import { logger } from '@libp2p/logger'
import { codes } from './errors.js'
import type { Libp2pEvents, AbortOptions } from '@libp2p/interface'
import type { Connection } from '@libp2p/interface/connection'
import type { EventEmitter } from '@libp2p/interface/events'
Expand Down
3 changes: 1 addition & 2 deletions packages/libp2p/src/upgrader.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,10 @@
import { setMaxListeners } from 'events'
import { CodeError } from '@libp2p/interface/errors'
import { CodeError, codes } from '@libp2p/interface/errors'
import { logger } from '@libp2p/logger'
import * as mss from '@libp2p/multistream-select'
import { peerIdFromString } from '@libp2p/peer-id'
import { createConnection } from './connection/index.js'
import { INBOUND_UPGRADE_TIMEOUT } from './connection-manager/constants.js'
import { codes } from './errors.js'
import { DEFAULT_MAX_INBOUND_STREAMS, DEFAULT_MAX_OUTBOUND_STREAMS } from './registrar.js'
import type { Libp2pEvents, AbortOptions } from '@libp2p/interface'
import type { MultiaddrConnection, Connection, Stream, ConnectionProtector, NewStreamOptions } from '@libp2p/interface/connection'
Expand Down
Loading
Loading