ssb-conn - npm Package Compare versions

Comparing version 0.9.0 to 0.9.1

lib/interpool-glue.js

		@@ -20,8 +20,12 @@ "use strict";
		function onConnecting(ev) {
		const addr = ev.address;
		const stagedData = staging.get(addr);
		staging.unstage(addr);
		db.update(addr, { stateChange: Date.now() });
		const dbData = db.get(addr);
		hub.update(addr, Object.assign({}, dbData, stagedData));
		const address = ev.address;
		const stagedData = staging.get(address);
		staging.unstage(address);
		for (const [addr, data] of staging.entries()) {
		if (data.key && data.key === ev.key)
		staging.unstage(addr);
		}
		db.update(address, { stateChange: Date.now() });
		const dbData = db.get(address);
		hub.update(address, Object.assign({}, dbData, stagedData));
		}
		@@ -36,10 +40,14 @@ function onConnectingFailed(ev) {
		function onConnected(ev) {
		const addr = ev.address;
		const stagedData = staging.get(addr);
		staging.unstage(addr);
		db.update(addr, { stateChange: Date.now(), failure: 0 });
		const dbData = db.get(addr);
		hub.update(addr, Object.assign({}, dbData, stagedData));
		const address = ev.address;
		const stagedData = staging.get(address);
		staging.unstage(address);
		for (const [addr, data] of staging.entries()) {
		if (data.key && data.key === ev.key)
		staging.unstage(addr);
		}
		db.update(address, { stateChange: Date.now(), failure: 0 });
		const dbData = db.get(address);
		hub.update(address, Object.assign({}, dbData, stagedData));
		if (ev.details.isClient)
		setupPing(addr, ev.details.rpc);
		setupPing(address, ev.details.rpc);
		}
		@@ -46,0 +54,0 @@ function onDisconnecting(ev) {

package.json

		{
		"name": "ssb-conn",
		"description": "SSB plugin for establishing and managing peer connections",
		"version": "0.9.0",
		"version": "0.9.1",
		"homepage": "https://github.com/staltz/ssb-conn",
		@@ -24,4 +24,4 @@ "main": "lib/index.js",
		"ssb-conn-db": "~0.2.1",
		"ssb-conn-hub": "~0.2.2",
		"ssb-conn-query": "~0.4.0",
		"ssb-conn-hub": "~0.2.3",
		"ssb-conn-query": "~0.4.1",
		"ssb-conn-staging": "~0.1.0",
		@@ -28,0 +28,0 @@ "ssb-ref": "^2.13.9",

src/interpool-glue.ts

		@@ -28,8 +28,11 @@ import ConnDB = require('ssb-conn-db');
		function onConnecting(ev: HubEvent) {
		const addr = ev.address;
		const stagedData = staging.get(addr);
		staging.unstage(addr);
		db.update(addr, {stateChange: Date.now()});
		const dbData = db.get(addr);
		hub.update(addr, {...dbData, ...stagedData});
		const address = ev.address;
		const stagedData = staging.get(address);
		staging.unstage(address);
		for (const [addr, data] of staging.entries()) {
		if (data.key && data.key === ev.key) staging.unstage(addr);
		}
		db.update(address, {stateChange: Date.now()});
		const dbData = db.get(address);
		hub.update(address, {...dbData, ...stagedData});
		}
		@@ -46,9 +49,12 @@
		function onConnected(ev: HubEvent) {
		const addr = ev.address;
		const stagedData = staging.get(addr);
		staging.unstage(addr);
		db.update(addr, {stateChange: Date.now(), failure: 0});
		const dbData = db.get(addr);
		hub.update(addr, {...dbData, ...stagedData});
		if (ev.details.isClient) setupPing(addr, ev.details.rpc);
		const address = ev.address;
		const stagedData = staging.get(address);
		staging.unstage(address);
		for (const [addr, data] of staging.entries()) {
		if (data.key && data.key === ev.key) staging.unstage(addr);
		}
		db.update(address, {stateChange: Date.now(), failure: 0});
		const dbData = db.get(address);
		hub.update(address, {...dbData, ...stagedData});
		if (ev.details.isClient) setupPing(address, ev.details.rpc);
		}
		@@ -55,0 +61,0 @@

New alerts