@Test public void onUpdateFromUnknownPeer() { NodeInfo nodeInfo = NodeInfo.Builder.create() .withUrl("http: .build(); try { discovery.onUpdate(nodeInfo); failBecauseExceptionWasNotThrown(AutoDiscoveryDisabledException.class); } catch (AutoDiscoveryDisabledException exception) { assertThat(exception).isNotNull(); } }
@Override public void onUpdate(NodeInfo nodeInfo) { if(!knownPeers.contains(NodeUri.create(nodeInfo.getUrl()))) { throw new AutoDiscoveryDisabledException(String.format("%s is not a known peer", nodeInfo.getUrl())); } final NodeUri callerNodeUri = NodeUri.create(nodeInfo.getUrl()); final Set<PublicKey> keys = nodeInfo.getRecipients().stream() .filter(r -> NodeUri.create(r.getUrl()).equals(callerNodeUri)) .map(Recipient::getKey) .collect(Collectors.toSet()); final ActiveNode activeNode = ActiveNode.Builder.create() .withUri(callerNodeUri) .withSupportedVersions(nodeInfo.supportedApiVersions()) .withKeys(keys) .build(); networkStore.store(activeNode); }
DisabledAutoDiscovery implements Discovery { @Override public void onUpdate(NodeInfo nodeInfo) { if(!knownPeers.contains(NodeUri.create(nodeInfo.getUrl()))) { throw new AutoDiscoveryDisabledException(String.format("%s is not a known peer", nodeInfo.getUrl())); } final NodeUri callerNodeUri = NodeUri.create(nodeInfo.getUrl()); final Set<PublicKey> keys = nodeInfo.getRecipients().stream() .filter(r -> NodeUri.create(r.getUrl()).equals(callerNodeUri)) .map(Recipient::getKey) .collect(Collectors.toSet()); final ActiveNode activeNode = ActiveNode.Builder.create() .withUri(callerNodeUri) .withSupportedVersions(nodeInfo.supportedApiVersions()) .withKeys(keys) .build(); networkStore.store(activeNode); } }
DisabledAutoDiscovery implements Discovery { @Override public void onUpdate(NodeInfo nodeInfo) { if(!knownPeers.contains(NodeUri.create(nodeInfo.getUrl()))) { throw new AutoDiscoveryDisabledException(String.format("%s is not a known peer", nodeInfo.getUrl())); } final NodeUri callerNodeUri = NodeUri.create(nodeInfo.getUrl()); final Set<PublicKey> keys = nodeInfo.getRecipients().stream() .filter(r -> NodeUri.create(r.getUrl()).equals(callerNodeUri)) .map(Recipient::getKey) .collect(Collectors.toSet()); final ActiveNode activeNode = ActiveNode.Builder.create() .withUri(callerNodeUri) .withSupportedVersions(nodeInfo.supportedApiVersions()) .withKeys(keys) .build(); networkStore.store(activeNode); } DisabledAutoDiscovery(NetworkStore networkStore,Set<NodeUri> knownPeers); }
DisabledAutoDiscovery implements Discovery { @Override public void onUpdate(NodeInfo nodeInfo) { if(!knownPeers.contains(NodeUri.create(nodeInfo.getUrl()))) { throw new AutoDiscoveryDisabledException(String.format("%s is not a known peer", nodeInfo.getUrl())); } final NodeUri callerNodeUri = NodeUri.create(nodeInfo.getUrl()); final Set<PublicKey> keys = nodeInfo.getRecipients().stream() .filter(r -> NodeUri.create(r.getUrl()).equals(callerNodeUri)) .map(Recipient::getKey) .collect(Collectors.toSet()); final ActiveNode activeNode = ActiveNode.Builder.create() .withUri(callerNodeUri) .withSupportedVersions(nodeInfo.supportedApiVersions()) .withKeys(keys) .build(); networkStore.store(activeNode); } DisabledAutoDiscovery(NetworkStore networkStore,Set<NodeUri> knownPeers); @Override void onUpdate(NodeInfo nodeInfo); @Override void onDisconnect(URI nodeUri); }
DisabledAutoDiscovery implements Discovery { @Override public void onUpdate(NodeInfo nodeInfo) { if(!knownPeers.contains(NodeUri.create(nodeInfo.getUrl()))) { throw new AutoDiscoveryDisabledException(String.format("%s is not a known peer", nodeInfo.getUrl())); } final NodeUri callerNodeUri = NodeUri.create(nodeInfo.getUrl()); final Set<PublicKey> keys = nodeInfo.getRecipients().stream() .filter(r -> NodeUri.create(r.getUrl()).equals(callerNodeUri)) .map(Recipient::getKey) .collect(Collectors.toSet()); final ActiveNode activeNode = ActiveNode.Builder.create() .withUri(callerNodeUri) .withSupportedVersions(nodeInfo.supportedApiVersions()) .withKeys(keys) .build(); networkStore.store(activeNode); } DisabledAutoDiscovery(NetworkStore networkStore,Set<NodeUri> knownPeers); @Override void onUpdate(NodeInfo nodeInfo); @Override void onDisconnect(URI nodeUri);  }