@@ -4,7 +4,7 @@ import toIterable from 'stream-to-it'
4
4
import { ipPortToMultiaddr as toMultiaddr } from '@libp2p/utils/ip-port-to-multiaddr'
5
5
import { CLOSE_TIMEOUT , SOCKET_TIMEOUT } from './constants.js'
6
6
import { multiaddrToNetConfig } from './utils.js'
7
- import errCode from 'err-code '
7
+ import { CodeError } from '@libp2p/interfaces/errors '
8
8
import type { Socket } from 'net'
9
9
import type { Multiaddr } from '@multiformats/multiaddr'
10
10
import type { MultiaddrConnection } from '@libp2p/interface-connection'
@@ -49,7 +49,7 @@ export const toMultiaddrConnection = (socket: Socket, options: ToConnectionOptio
49
49
if ( socket . remoteAddress == null || socket . remotePort == null ) {
50
50
// this can be undefined if the socket is destroyed (for example, if the client disconnected)
51
51
// https://nodejs.org/dist/latest-v16.x/docs/api/net.html#socketremoteaddress
52
- throw errCode ( new Error ( 'Could not determine remote address or port' ) , 'ERR_NO_REMOTE_ADDRESS' )
52
+ throw new CodeError ( 'Could not determine remote address or port' , 'ERR_NO_REMOTE_ADDRESS' )
53
53
}
54
54
55
55
remoteAddr = toMultiaddr ( socket . remoteAddress , socket . remotePort )
@@ -68,7 +68,7 @@ export const toMultiaddrConnection = (socket: Socket, options: ToConnectionOptio
68
68
// only destroy with an error if the remote has not sent the FIN message
69
69
let err : Error | undefined
70
70
if ( socket . readable ) {
71
- err = errCode ( new Error ( 'Socket read timeout' ) , 'ERR_SOCKET_READ_TIMEOUT' )
71
+ err = new CodeError ( 'Socket read timeout' , 'ERR_SOCKET_READ_TIMEOUT' )
72
72
}
73
73
74
74
// if the socket times out due to inactivity we must manually close the connection
@@ -140,7 +140,7 @@ export const toMultiaddrConnection = (socket: Socket, options: ToConnectionOptio
140
140
log ( '%s socket close timeout after %dms, destroying it manually' , lOptsStr , Date . now ( ) - start )
141
141
142
142
// will trigger 'error' and 'close' events that resolves promise
143
- socket . destroy ( errCode ( new Error ( 'Socket close timeout' ) , 'ERR_SOCKET_CLOSE_TIMEOUT' ) )
143
+ socket . destroy ( new CodeError ( 'Socket close timeout' , 'ERR_SOCKET_CLOSE_TIMEOUT' ) )
144
144
}
145
145
} , closeTimeout ) . unref ( )
146
146
0 commit comments