From 073ba9b9f33b093545a4046c66cb37fb84618e29 Mon Sep 17 00:00:00 2001 From: Zlatin Balevsky Date: Tue, 10 Jul 2018 20:26:51 +0100 Subject: [PATCH] Pinger utility --- .../groovy/com/muwire/hostcache/Pinger.groovy | 25 +++++++++++++++++++ 1 file changed, 25 insertions(+) create mode 100644 host-cache/src/main/groovy/com/muwire/hostcache/Pinger.groovy diff --git a/host-cache/src/main/groovy/com/muwire/hostcache/Pinger.groovy b/host-cache/src/main/groovy/com/muwire/hostcache/Pinger.groovy new file mode 100644 index 00000000..742f5d8f --- /dev/null +++ b/host-cache/src/main/groovy/com/muwire/hostcache/Pinger.groovy @@ -0,0 +1,25 @@ +package com.muwire.hostcache + +import groovy.json.JsonOutput +import net.i2p.client.I2PSession +import net.i2p.client.datagram.I2PDatagramMaker + +class Pinger { + + final def session + final def maker + Pinger(session) { + this.session = session + this.maker = new I2PDatagramMaker(session) + } + + def ping(host, uuid) { + def payload = new HashMap() + payload.type = "CrawlerPing" + payload.version = 1 + payload.uuid = uuid + payload = JsonOutput.toJson(payload) + payload = maker.makeI2PDatagram(payload.bytes) + session.sendMessage(host.destination, payload, I2PSession.PROTO_DATAGRAM, 0, 0) + } +}