Comparing version 0.2.6 to 0.2.7
@@ -280,3 +280,3 @@ "use strict"; | ||
else { | ||
this.ssb.conn.remember(address, { key, type: 'internet' }); | ||
this.ssb.conn.remember(address, { key, type: 'pub' }); | ||
} | ||
@@ -283,0 +283,0 @@ } |
@@ -9,2 +9,3 @@ import { Callback, Peer } from './types'; | ||
private readonly connStaging; | ||
private latestWarning; | ||
constructor(ssb: any); | ||
@@ -11,0 +12,0 @@ private setupConnectionListeners; |
@@ -83,3 +83,6 @@ "use strict"; | ||
this.peers = () => { | ||
console.error('DEPRECATED gossip.peers() was called. Use ssb-conn instead'); | ||
if (this.latestWarning + 10e3 < Date.now()) { | ||
console.trace('DEPRECATED gossip.peers(), use ssb-conn instead'); | ||
this.latestWarning = Date.now(); | ||
} | ||
const peers = Array.from(this.connDB.entries()).map(([address, data]) => { | ||
@@ -200,2 +203,3 @@ return Object.assign({}, data, { address, state: this.connHub.getState(address) }); | ||
this.connStaging = this.conn.internalConnStaging(); | ||
this.latestWarning = 0; | ||
this.setupConnectionListeners(); | ||
@@ -202,0 +206,0 @@ this.conn.start(); |
{ | ||
"name": "ssb-conn", | ||
"description": "SSB plugin for establishing and managing peer connections", | ||
"version": "0.2.6", | ||
"version": "0.2.7", | ||
"homepage": "https://github.com/staltz/ssb-conn", | ||
@@ -52,2 +52,2 @@ "main": "lib/index.js", | ||
"license": "MIT" | ||
} | ||
} |
@@ -139,3 +139,3 @@ import ConnHub = require('ssb-conn-hub'); | ||
private isCurrentlyDownloading() { | ||
// don't schedule gossip if currently downloading messages | ||
// don't schedule new connections if currently downloading messages | ||
return this.lastMessageAt && this.lastMessageAt > Date.now() - 500; | ||
@@ -142,0 +142,0 @@ } |
@@ -94,2 +94,7 @@ import ConnDB = require('ssb-conn-db'); | ||
/** | ||
* Timestamp of the latest deprecation warning for gossip.peers() | ||
*/ | ||
private latestWarning: number; | ||
constructor(ssb: any) { | ||
@@ -102,2 +107,3 @@ this.ssb = ssb; | ||
this.connStaging = this.conn.internalConnStaging(); | ||
this.latestWarning = 0; | ||
@@ -160,3 +166,6 @@ this.setupConnectionListeners(); | ||
public peers: () => any = () => { | ||
console.error('DEPRECATED gossip.peers() was called. Use ssb-conn instead'); | ||
if (this.latestWarning + 10e3 < Date.now()) { | ||
console.trace('DEPRECATED gossip.peers(), use ssb-conn instead'); | ||
this.latestWarning = Date.now(); | ||
} | ||
const peers = Array.from(this.connDB.entries()).map(([address, data]) => { | ||
@@ -163,0 +172,0 @@ return { |
const CONN = require('../core'); | ||
const ConnScheduler = require('../scheduler'); | ||
const Gossip = require('../compat'); | ||
const os = require('os'); | ||
@@ -30,4 +31,5 @@ const fs = require('fs'); | ||
mockSSB.connScheduler = new ConnScheduler(mockSSB, mockConfig); | ||
mockSSB.gossip = new Gossip(mockSSB, mockConfig); | ||
return mockSSB; | ||
}; |
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
125087
44
2209