diff --git a/app/lib/common-libs/constants.ts b/app/lib/common-libs/constants.ts
index 637bc0e042a9870d74c1eff9634630c7d991eab2..f9cda71f7a61d29af6075eeb98a09c2b9264a49b 100644
--- a/app/lib/common-libs/constants.ts
+++ b/app/lib/common-libs/constants.ts
@@ -33,9 +33,7 @@ const CONDITIONS = "(&&|\\|\\|| |[()]|(SIG\\(" + PUBKEY + "\\)|(XHX\\([A-F0-9]
const BMA_REGEXP = /^BASIC_MERKLED_API( ([a-z_][a-z0-9-_.]*))?( ([0-9.]+))?( ([0-9a-f:]+))?( ([0-9]+))$/
const BMATOR_REGEXP = /^BMATOR( ([a-z0-9]{16})\.onion)( ([0-9.]+))?( ([0-9a-f:]+))?( ([0-9]+))$/
const WS2P_REGEXP = /^WS2P ([a-f0-9]{8}) ([a-z_][a-z0-9-_.]*|[0-9.]+|[0-9a-f:]+) ([0-9]+)(?: (.+))?$/
-const WS2P_V2_REGEXP = /^WS2P ([0-9]+) ([a-f0-9]{8}) ([a-z_][a-z0-9-_.]*|[0-9.]+|[0-9a-f:]+) ([0-9]+)(?: (.+))?$/
const WS2PTOR_REGEXP = /^WS2PTOR ([a-f0-9]{8}) ([a-z0-9-_.]*|[0-9.]+|[0-9a-f:]+.onion) ([0-9]+)(?: (.+))?$/
-const WS2PTOR_V2_REGEXP = /^WS2PTOR ([0-9]+) ([a-f0-9]{8}) ([a-z0-9-_.]*|[0-9.]+|[0-9a-f:]+.onion) ([0-9]+)(?: (.+))?$/
const WS_FULL_ADDRESS_ONION_REGEX = /^(?:wss?:\/\/)(?:www\.)?([0-9a-z]{16}\.onion)(:[0-9]+)?$/
const IPV4_REGEXP = /^(([0-9]|[1-9][0-9]|1[0-9]{2}|2[0-4][0-9]|25[0-5])\.){3}([0-9]|[1-9][0-9]|1[0-9]{2}|2[0-4][0-9]|25[0-5])$/;
const IPV6_REGEXP = /^((([0-9A-Fa-f]{1,4}:){7}[0-9A-Fa-f]{1,4})|(([0-9A-Fa-f]{1,4}:){6}:[0-9A-Fa-f]{1,4})|(([0-9A-Fa-f]{1,4}:){5}:([0-9A-Fa-f]{1,4}:)?[0-9A-Fa-f]{1,4})|(([0-9A-Fa-f]{1,4}:){4}:([0-9A-Fa-f]{1,4}:){0,2}[0-9A-Fa-f]{1,4})|(([0-9A-Fa-f]{1,4}:){3}:([0-9A-Fa-f]{1,4}:){0,3}[0-9A-Fa-f]{1,4})|(([0-9A-Fa-f]{1,4}:){2}:([0-9A-Fa-f]{1,4}:){0,4}[0-9A-Fa-f]{1,4})|(([0-9A-Fa-f]{1,4}:){6}((b((25[0-5])|(1d{2})|(2[0-4]d)|(d{1,2}))b).){3}(b((25[0-5])|(1d{2})|(2[0-4]d)|(d{1,2}))b))|(([0-9A-Fa-f]{1,4}:){0,5}:((b((25[0-5])|(1d{2})|(2[0-4]d)|(d{1,2}))b).){3}(b((25[0-5])|(1d{2})|(2[0-4]d)|(d{1,2}))b))|(::([0-9A-Fa-f]{1,4}:){0,5}((b((25[0-5])|(1d{2})|(2[0-4]d)|(d{1,2}))b).){3}(b((25[0-5])|(1d{2})|(2[0-4]d)|(d{1,2}))b))|([0-9A-Fa-f]{1,4}::([0-9A-Fa-f]{1,4}:){0,5}[0-9A-Fa-f]{1,4})|(::([0-9A-Fa-f]{1,4}:){0,6}[0-9A-Fa-f]{1,4})|(([0-9A-Fa-f]{1,4}:){1,7}:))$/;
@@ -97,9 +95,7 @@ export const CommonConstants = {
BMA_REGEXP,
BMATOR_REGEXP,
WS2P_REGEXP,
- WS2P_V2_REGEXP,
WS2PTOR_REGEXP,
- WS2PTOR_V2_REGEXP,
WS_FULL_ADDRESS_ONION_REGEX,
IPV4_REGEXP,
IPV6_REGEXP,
diff --git a/app/lib/dto/PeerDTO.ts b/app/lib/dto/PeerDTO.ts
index 0704fe141b82fed1f2f9535509d4034258b6a7cd..dc5754b6893349a0009b66e1cbb21c78d7b116a7 100644
--- a/app/lib/dto/PeerDTO.ts
+++ b/app/lib/dto/PeerDTO.ts
@@ -2,7 +2,6 @@ import {DBPeer} from "../dal/sqliteDAL/PeerDAL"
import {hashf} from "../common"
import {CommonConstants} from "../common-libs/constants"
import {Cloneable} from "./Cloneable"
-import { WS2PConstants } from '../../modules/ws2p/lib/constants';
export interface WS2PEndpoint {
uuid:string
@@ -95,59 +94,29 @@ export class PeerDTO implements Cloneable {
return bma || {};
}
- getOnceWS2PEndpoint(canReachTorEp:boolean, canReachClearEp:boolean, uuidExcluded:string[] = []) {
- let api:{ version:number, uuid:string, host:string, port:number, path:string }|null = null
- let bestWS2PVersionAvailable:number = 0
- let bestWS2PTORVersionAvailable:number = 0
+ getWS2P(canReachTorEp:boolean, canReachClearEp:boolean) {
+ let api:{ uuid:string, host:string, port:number, path:string }|null = null
+ const endpointRegexp = (canReachTorEp) ? CommonConstants.WS2PTOR_REGEXP:CommonConstants.WS2P_REGEXP
for (const ep of this.endpoints) {
if (canReachTorEp) {
- let matches:any = ep.match(CommonConstants.WS2PTOR_V2_REGEXP)
- if (matches && parseInt(matches[1]) > bestWS2PTORVersionAvailable && (uuidExcluded.indexOf(matches[2]) === -1)) {
- bestWS2PTORVersionAvailable = matches[1]
- api = {
- version: parseInt(matches[1]),
- uuid: matches[2],
- host: matches[3] || '',
- port: parseInt(matches[4]) || 0,
- path: matches[5]
- }
- } else {
- matches = ep.match(CommonConstants.WS2PTOR_REGEXP)
- if (matches && bestWS2PTORVersionAvailable == 0 && (uuidExcluded.indexOf(matches[1]) === -1)) {
- bestWS2PTORVersionAvailable = 1
- api = {
- version: 1,
- uuid: matches[1],
- host: matches[2] || '',
- port: parseInt(matches[3]) || 0,
- path: matches[4]
- }
+ const matches:any = ep.match(CommonConstants.WS2PTOR_REGEXP)
+ if (matches) {
+ return {
+ uuid: matches[1],
+ host: matches[2] || '',
+ port: parseInt(matches[3]) || 0,
+ path: matches[4]
}
}
}
- // If can reach clear endpoint and not found tor endpoint
- if (canReachClearEp && bestWS2PTORVersionAvailable == 0) {
- let matches:any = ep.match(CommonConstants.WS2P_V2_REGEXP)
- if (matches && parseInt(matches[1]) > bestWS2PVersionAvailable && (uuidExcluded.indexOf(matches[2]) === -1)) {
- bestWS2PVersionAvailable = parseInt(matches[1])
+ if (canReachClearEp) {
+ const matches:any = !api && ep.match(CommonConstants.WS2P_REGEXP)
+ if (matches) {
api = {
- version: parseInt(matches[1]),
- uuid: matches[2],
- host: matches[3] || '',
- port: parseInt(matches[4]) || 0,
- path: matches[5]
- }
- } else {
- matches = ep.match(CommonConstants.WS2P_REGEXP)
- if (matches && bestWS2PVersionAvailable == 0 && (uuidExcluded.indexOf(matches[1]) === -1)) {
- bestWS2PVersionAvailable = 1
- api = {
- version: 1,
- uuid: matches[1],
- host: matches[2] || '',
- port: parseInt(matches[3]) || 0,
- path: matches[4]
- }
+ uuid: matches[1],
+ host: matches[2] || '',
+ port: parseInt(matches[3]) || 0,
+ path: matches[4]
}
}
}
@@ -155,18 +124,6 @@ export class PeerDTO implements Cloneable {
return api || null
}
- getAllWS2PEndpoints(canReachTorEp:boolean, canReachClearEp:boolean, myUUID:string) {
- let apis:{ uuid:string, host:string, port:number, path:string }[] = []
- let uuidExcluded:string[] = [myUUID]
- let api = this.getOnceWS2PEndpoint(canReachTorEp, canReachClearEp, uuidExcluded)
- while (api !== null) {
- uuidExcluded.push(api.uuid)
- apis.push(api)
- api = this.getOnceWS2PEndpoint(canReachTorEp, canReachClearEp, uuidExcluded)
- }
- return apis
- }
-
getDns() {
const bma = this.getBMA();
return bma.dns ? bma.dns : null;
diff --git a/app/modules/ws2p/lib/WS2PCluster.ts b/app/modules/ws2p/lib/WS2PCluster.ts
index fdd829af2d8b531dd789bb0c017bb1d989b2c190..b89408190d6059ede8769bd429ca89bb1560cdec 100644
--- a/app/modules/ws2p/lib/WS2PCluster.ts
+++ b/app/modules/ws2p/lib/WS2PCluster.ts
@@ -17,7 +17,6 @@ import { CommonConstants } from '../../../lib/common-libs/constants';
import { Package } from "../../../lib/common/package";
import { Constants } from "../../prover/lib/constants";
import { ProxiesConf } from '../../../lib/proxy';
-import { Keypair } from '../../../lib/dto/ConfDTO';
const es = require('event-stream')
const nuuid = require('node-uuid')
@@ -269,7 +268,7 @@ export class WS2PCluster {
this.ws2pServer = await WS2PServer.bindOn(this.server, host, port, this.fifo, (pubkey:string, connectedPubkeys:string[]) => {
const privilegedNodes = (this.server.conf.ws2p && this.server.conf.ws2p.privilegedNodes) ? this.server.conf.ws2p.privilegedNodes:[]
return this.acceptPubkey(pubkey, connectedPubkeys, [], () => this.servedCount(), this.maxLevel2Peers, privilegedNodes, (this.server.conf.ws2p !== undefined && this.server.conf.ws2p.privilegedOnly))
- }, this.keyPriorityLevel, this.messageHandler)
+ }, this.messageHandler)
this.host = host
this.port = port
return this.ws2pServer
@@ -331,20 +330,13 @@ export class WS2PCluster {
}
async connectToWS2Peers() {
- const myUUID = (this.server.conf.ws2p && this.server.conf.ws2p.uuid) ? this.server.conf.ws2p.uuid:""
const potentials = await this.server.dal.getWS2Peers()
const peers:PeerDTO[] = potentials.map((p:any) => PeerDTO.fromJSONObject(p))
const prefered = ((this.server.conf.ws2p && this.server.conf.ws2p.preferedNodes) || []).slice() // Copy
// Our key is also a prefered one, so we connect to our siblings
+ prefered.push(this.server.conf.pair.pub)
const canReachTorEndpoint = ProxiesConf.canReachTorEndpoint(this.server.conf.proxiesConf)
peers.sort((a, b) => {
- // Top priority at our own nodes
- if (a.pubkey === this.server.conf.pair.pub && b.pubkey !== this.server.conf.pair.pub) {
- return -1
- } else if (a.pubkey !== this.server.conf.pair.pub && b.pubkey === this.server.conf.pair.pub) {
- return 1
- }
-
const aIsPrefered = prefered.indexOf(a.pubkey) !== -1
const bIsPrefered = prefered.indexOf(b.pubkey) !== -1
@@ -381,34 +373,20 @@ export class WS2PCluster {
const canReachClearEndpoint = ProxiesConf.canReachClearEndpoint(this.server.conf.proxiesConf)
while (i < peers.length && this.clientsCount() < this.maxLevel1Size) {
const p = peers[i]
- if (p.pubkey === this.server.conf.pair.pub) {
- const apis = p.getAllWS2PEndpoints(canReachTorEndpoint, canReachClearEndpoint, myUUID)
- for (const api of apis) {
- try {
- // We do not connect to local host
- if (api.uuid !== myUUID || api.uuid === '11111111') {
- await this.connectToRemoteWS(api.host, api.port, api.path, this.messageHandler, p.pubkey, api.uuid)
- }
- } catch (e) {
- this.server.logger.debug('WS2P: init: failed connection')
- }
- }
- } else {
- const api = p.getOnceWS2PEndpoint(canReachTorEndpoint, canReachClearEndpoint)
- if (api) {
- try {
- // We do not connect to local host
- if (api.uuid !== myUUID || api.uuid === '11111111') {
- await this.connectToRemoteWS(api.host, api.port, api.path, this.messageHandler, p.pubkey, api.uuid)
- }
- } catch (e) {
- this.server.logger.debug('WS2P: init: failed connection')
+ const api = p.getWS2P(canReachTorEndpoint, canReachClearEndpoint)
+ if (api) {
+ try {
+ // We do not connect to local host
+ if (!this.server.conf.ws2p || api.uuid !== this.server.conf.ws2p.uuid || p.pubkey !== this.server.conf.pair.pub || api.uuid === '11111111') {
+ await this.connectToRemoteWS(api.host, api.port, api.path, this.messageHandler, p.pubkey, api.uuid)
}
+ } catch (e) {
+ this.server.logger.debug('WS2P: init: failed connection')
}
}
i++
// Trim the eventual extra connections
- setTimeout(() => this.trimClientConnections(prefered), WS2PConstants.CONNEXION_TIMEOUT)
+ setTimeout(() => this.trimClientConnections(), WS2PConstants.CONNEXION_TIMEOUT)
}
}
@@ -422,16 +400,16 @@ export class WS2PCluster {
// New peer
if (data.endpoints) {
const peer = PeerDTO.fromJSONObject(data)
- const ws2pEnpoint = peer.getOnceWS2PEndpoint(ProxiesConf.canReachTorEndpoint(this.server.conf.proxiesConf), ProxiesConf.canReachClearEndpoint(this.server.conf.proxiesConf))
+ const ws2pEnpoint = peer.getWS2P(ProxiesConf.canReachTorEndpoint(this.server.conf.proxiesConf), ProxiesConf.canReachClearEndpoint(this.server.conf.proxiesConf))
if (ws2pEnpoint) {
// Check if already connected to the pubkey (in any way: server or client)
const connectedPubkeys = this.getConnectedPubkeys()
const connectedWS2PUID = this.getConnectedWS2PUID()
- const preferedKeys = (this.server.conf.ws2p && this.server.conf.ws2p.preferedNodes) ? this.server.conf.ws2p.preferedNodes:[]
- const shouldAccept = await this.acceptPubkey(peer.pubkey, connectedPubkeys, connectedWS2PUID, () => this.clientsCount(), this.maxLevel1Size, preferedKeys, (this.server.conf.ws2p && this.server.conf.ws2p.preferedOnly) || false, ws2pEnpoint.uuid)
+ const preferedNodes = (this.server.conf.ws2p && this.server.conf.ws2p.preferedNodes) ? this.server.conf.ws2p.preferedNodes:[]
+ const shouldAccept = await this.acceptPubkey(peer.pubkey, connectedPubkeys, connectedWS2PUID, () => this.clientsCount(), this.maxLevel1Size, preferedNodes, (this.server.conf.ws2p && this.server.conf.ws2p.preferedOnly) || false, ws2pEnpoint.uuid)
if (shouldAccept && (!this.server.conf.ws2p || ws2pEnpoint.uuid !== this.server.conf.ws2p.uuid || peer.pubkey !== this.server.conf.pair.pub || ws2pEnpoint.uuid === '11111111')) {
await this.connectToRemoteWS(ws2pEnpoint.host, ws2pEnpoint.port, ws2pEnpoint.path, this.messageHandler, peer.pubkey, ws2pEnpoint.uuid)
- await this.trimClientConnections(preferedKeys)
+ await this.trimClientConnections()
}
}
}
@@ -502,60 +480,7 @@ export class WS2PCluster {
return { sig, message, pub }
}
- async removeLowPriorityConnections(privilegedKeys:string[]) {
- let serverPubkeys:string[] = []
- if (this.ws2pServer) {
- serverPubkeys = this.ws2pServer.getConnexions().map(c => c.pubkey)
- }
- let disconnectedOne = true
- // Disconnect Private connexions already present under Public
- while (disconnectedOne) {
- disconnectedOne = false
- let uuids = Object.keys(this.ws2pClients)
- uuids = _.shuffle(uuids)
- for (const uuid of uuids) {
- const client = this.ws2pClients[uuid]
- const pub = client.connection.pubkey
- const isNotOurself = pub !== this.server.conf.pair.pub
- const isAlreadyInPublic = serverPubkeys.indexOf(pub) !== -1
- if (isNotOurself && isAlreadyInPublic) {
- client.connection.close()
- await client.connection.closed
- disconnectedOne = true
- if (this.ws2pClients[uuid]) {
- delete this.ws2pClients[uuid]
- }
- }
- }
- }
- // Disconnect Private connexions until the maximum size is respected
- while (disconnectedOne && this.clientsCount() > this.maxLevel1Size) {
- let uuids = Object.keys(this.ws2pClients)
- uuids = _.shuffle(uuids)
- let lowPriorityConnectionUUID:string = uuids[0]
- let minPriorityLevel = this.keyPriorityLevel(this.ws2pClients[lowPriorityConnectionUUID].connection.pubkey, privilegedKeys)
- for (const uuid of uuids) {
- const client = this.ws2pClients[uuid]
- if (uuid !== lowPriorityConnectionUUID) {
- let uuidPriorityLevel = this.keyPriorityLevel(client.connection.pubkey, privilegedKeys)
- if (uuidPriorityLevel < minPriorityLevel) {
- lowPriorityConnectionUUID = uuid
- minPriorityLevel = uuidPriorityLevel
- }
- }
- delete this.ws2pClients[lowPriorityConnectionUUID]
- }
- }
- }
-
- keyPriorityLevel(pubkey:string, preferedOrPrivilegedKeys:string[]) {
- let priorityLevel = (this.server.dal.isMember(pubkey)) ? WS2PConstants.CONNECTIONS_PRIORITY.MEMBER_KEY_LEVEL:0
- priorityLevel += (preferedOrPrivilegedKeys.indexOf(pubkey) !== -1) ? WS2PConstants.CONNECTIONS_PRIORITY.PREFERED_PRIVILEGED_KEY_LEVEL:0
- priorityLevel += (this.server.conf.pair.pub === pubkey) ? WS2PConstants.CONNECTIONS_PRIORITY.SELF_KEY_LEVEL:0
- return priorityLevel
- }
-
- async trimClientConnections(preferedKeys:string[]) {
+ async trimClientConnections() {
let serverPubkeys:string[] = []
if (this.ws2pServer) {
serverPubkeys = this.ws2pServer.getConnexions().map(c => c.pubkey)
@@ -662,19 +587,9 @@ export class WS2PCluster {
return false
}
- if (this.server.conf.pair.pub === pub) {
- // We do not accept oneself connetion
- if (this.server.conf.ws2p && this.server.conf.ws2p.uuid === targetWS2PUID) {
- return false
- } else {
- // We always accept self nodes, and they have a supreme priority (these are siblings)
- if (targetWS2PUID === "" || this.isNewSiblingNode(pub, targetWS2PUID, connectedWS2PUID) ) {
- return true
- } else {
- // We are already connected to this self node (same WS2PUID)
- return false
- }
- }
+ // We do not accept oneself connetion
+ if (this.server.conf.pair.pub === pub && this.server.conf.ws2p && this.server.conf.ws2p.uuid === targetWS2PUID) {
+ return false
}
// We do not accept banned keys
@@ -698,10 +613,17 @@ export class WS2PCluster {
if (getConcurrentConnexionsCount() < maxConcurrentConnexionsSize) {
// Yes: just connect to it
return true
+ } else if (this.server.conf.pair.pub === pub) {
+ // We always accept self nodes, and they have a supreme priority (these are siblings)
+ if (targetWS2PUID !== "") {
+ if (this.isNewSiblingNode(pub, targetWS2PUID, connectedWS2PUID)) {
+ return true
+ }
+ }
}
else if (connectedPubkeys.indexOf(pub) === -1)
{
- let minPriorityLevel = WS2PConstants.CONNECTIONS_PRIORITY.MAX_PRIORITY_LEVEL
+ let minPriorityLevel = WS2PConstants.MAX_PRIORITY_LEVEL
for (const connectedPubkey of connectedPubkeys) {
let connectedPubkeyPriorityLevel = this.ws2pServer.keyPriorityLevel(connectedPubkey, priorityKeys)
if (connectedPubkeyPriorityLevel < minPriorityLevel) {
diff --git a/app/modules/ws2p/lib/WS2PServer.ts b/app/modules/ws2p/lib/WS2PServer.ts
index 85bed3378f34e837cce71dc7746c7fd80372d4ce..d11c3298d1fee8cddb64a3812e20259fb7d5332d 100644
--- a/app/modules/ws2p/lib/WS2PServer.ts
+++ b/app/modules/ws2p/lib/WS2PServer.ts
@@ -7,7 +7,6 @@ import {WS2PConstants} from "./constants"
import {WS2PMessageHandler} from "./impl/WS2PMessageHandler"
import {WS2PStreamer} from "./WS2PStreamer"
import {WS2PSingleWriteStream} from "./WS2PSingleWriteStream"
-import { WS2PCluster } from './WS2PCluster';
const WebSocketServer = require('ws').Server
@@ -22,8 +21,7 @@ export class WS2PServer extends events.EventEmitter {
private host:string,
private port:number,
private fifo:GlobalFifoPromise,
- private shouldAcceptConnection:(pubkey:string, connectedPubkeys:string[])=>Promise<boolean>,
- public keyPriorityLevel:(pubkey:string, privilegedKeys:string[])=>number) {
+ private shouldAcceptConnection:(pubkey:string, connectedPubkeys:string[])=>Promise<boolean>) {
super()
// Conf: max public connections
if (this.server.conf.ws2p && this.server.conf.ws2p.maxPublic !== undefined) {
@@ -145,6 +143,13 @@ export class WS2PServer extends events.EventEmitter {
this.removeConnection(lowPriorityConnection)
}
+ keyPriorityLevel(pubkey:string, privilegedKeys:string[]) {
+ let priorityLevel = (this.server.dal.isMember(pubkey)) ? 1:0
+ priorityLevel += (privilegedKeys.indexOf(pubkey) !== -1) ? 2:0
+ priorityLevel += (this.server.conf.pair.pub === pubkey) ? 4:0
+ return priorityLevel
+ }
+
private removeConnection(c:WS2PConnection) {
const index = this.connections.indexOf(c)
if (index !== -1) {
@@ -178,8 +183,8 @@ export class WS2PServer extends events.EventEmitter {
}))
}
- static async bindOn(server:Server, host:string, port:number, fifo:GlobalFifoPromise, shouldAcceptConnection:(pubkey:string, connectedPubkeys:string[])=>Promise<boolean>, keyPriorityLevel:(pubkey:string, privilegedKeys:string[])=>number, messageHandler:WS2PMessageHandler) {
- const ws2ps = new WS2PServer(server, host, port, fifo, shouldAcceptConnection, keyPriorityLevel)
+ static async bindOn(server:Server, host:string, port:number, fifo:GlobalFifoPromise, shouldAcceptConnection:(pubkey:string, connectedPubkeys:string[])=>Promise<boolean>, messageHandler:WS2PMessageHandler) {
+ const ws2ps = new WS2PServer(server, host, port, fifo, shouldAcceptConnection)
await ws2ps.listenToWebSocketConnections(messageHandler)
server.logger.info('WS2P server %s listening on %s:%s', server.conf.pair.pub, host, port)
return ws2ps
diff --git a/app/modules/ws2p/lib/constants.ts b/app/modules/ws2p/lib/constants.ts
index 080db10c7be7766cf2f1e7fa28f2dc52d29ce341..cc75af0325e413ccdd5581caf9421332125f3e40 100644
--- a/app/modules/ws2p/lib/constants.ts
+++ b/app/modules/ws2p/lib/constants.ts
@@ -1,8 +1,6 @@
import {CommonConstants} from "../../../lib/common-libs/constants"
export const WS2PConstants = {
- WS2P_VERSION: 2,
-
WS2P_UPNP_TTL: 600,
WS2P_PORTS_START: 20900,
WS2P_PORTS_END: 20999,
@@ -21,13 +19,7 @@ export const WS2PConstants = {
MAX_LEVEL_1_PEERS: 10,
MAX_LEVEL_2_PEERS: 10,
CONNECTIONS_LOW_LEVEL: 3,
-
- CONNECTIONS_PRIORITY: {
- MEMBER_KEY_LEVEL: 1,
- PREFERED_PRIVILEGED_KEY_LEVEL: 2,
- SELF_KEY_LEVEL: 4,
- MAX_PRIORITY_LEVEL: 7,
- },
+ MAX_PRIORITY_LEVEL: 7,
BAN_DURATION_IN_SECONDS: 120,
BAN_ON_REPEAT_THRESHOLD: 5,