ssb-conn-hub
Advanced tools
Comparing version 0.0.8 to 0.0.9
@@ -23,2 +23,4 @@ import { ConnectionData as Data, Address } from './types'; | ||
state: "connecting" | "connected" | "disconnecting"; | ||
hubBirth: number; | ||
hubUpdated: number; | ||
disconnect?: ((cb: (err?: any) => void) => void) | undefined; | ||
@@ -25,0 +27,0 @@ key?: string | undefined; |
@@ -167,2 +167,4 @@ "use strict"; | ||
ConnHub.prototype._setPeer = function (address, data) { | ||
var now = Date.now(); | ||
var hubUpdated = now; | ||
var previousData = this._peers.get(address); | ||
@@ -175,3 +177,3 @@ if (previousData) { | ||
}); | ||
this._peers.set(address, __assign({}, previousData, data)); | ||
this._peers.set(address, __assign({}, previousData, { hubUpdated: hubUpdated }, data)); | ||
} | ||
@@ -182,3 +184,4 @@ else if (!data.state) { | ||
else { | ||
this._peers.set(address, data); | ||
var hubBirth = now; | ||
this._peers.set(address, __assign({ hubBirth: hubBirth, hubUpdated: hubUpdated }, data)); | ||
} | ||
@@ -185,0 +188,0 @@ }; |
export declare type Address = string; | ||
export declare type ConnectionData = Readonly<{ | ||
state: 'connecting' | 'connected' | 'disconnecting'; | ||
hubBirth: number; | ||
hubUpdated: number; | ||
disconnect?: (cb: (err?: any) => void) => void; | ||
@@ -5,0 +7,0 @@ key?: string; |
{ | ||
"name": "ssb-conn-hub", | ||
"description": "Module that manages active connections to SSB peers", | ||
"version": "0.0.8", | ||
"version": "0.0.9", | ||
"homepage": "https://github.com/staltz/ssb-conn-hub", | ||
@@ -6,0 +6,0 @@ "main": "lib/index.js", |
@@ -79,2 +79,4 @@ import {ConnectionData as Data, ListenEvent, Address} from './types'; | ||
private _setPeer(address: Address, data: Partial<Data>) { | ||
const now = Date.now(); | ||
const hubUpdated = now; | ||
const previousData = this._peers.get(address); | ||
@@ -86,7 +88,8 @@ if (previousData) { | ||
}); | ||
this._peers.set(address, {...previousData, ...data}); | ||
this._peers.set(address, {...previousData, hubUpdated, ...data}); | ||
} else if (!data.state) { | ||
debug('unexpected control flow, we cannot add a peer without state'); | ||
} else { | ||
this._peers.set(address, data as Data); | ||
const hubBirth = now; | ||
this._peers.set(address, {hubBirth, hubUpdated, ...(data as Data)}); | ||
} | ||
@@ -93,0 +96,0 @@ } |
@@ -5,2 +5,4 @@ export type Address = string; | ||
state: 'connecting' | 'connected' | 'disconnecting'; | ||
hubBirth: number; | ||
hubUpdated: number; | ||
disconnect?: (cb: (err?: any) => void) => void; | ||
@@ -7,0 +9,0 @@ key?: string; |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
113858
912