idk/muwire
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

print reported version

Browse Source
This commit is contained in:
Zlatin Balevsky
2019-06-05 10:07:04 +01:00
parent 7b33a16fd8
commit e2f92c5c5e
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
update-server/src/main/groovy/com/muwire/update/UpdateServer.groovy
View File

@@ -2,6 +2,7 @@ package com.muwire.update
import java.util.logging.Level import java.util.logging.Level
import groovy.json.JsonSlurper
import groovy.util.logging.Log import groovy.util.logging.Log
import net.i2p.client.I2PClientFactory import net.i2p.client.I2PClientFactory
import net.i2p.client.I2PSession import net.i2p.client.I2PSession
@@ -55,7 +56,7 @@ class UpdateServer {
static class Listener implements I2PSessionMuxedListener { static class Listener implements I2PSessionMuxedListener {
private final File json private final File json
private final def slurper = new JsonSlurper()
Listener(File json) { Listener(File json) {
this.json = json this.json = json
} }
@@ -76,8 +77,9 @@ class UpdateServer {
try { try {
dissector.loadI2PDatagram(payload) dissector.loadI2PDatagram(payload)
def sender = dissector.getSender() def sender = dissector.getSender()
log.info("Got an update ping from "+sender.toBase32()) payload = slurper.parse(dissector.getPayload())
// I don't think we care about the payload at this point log.info("Got an update ping from "+sender.toBase32() + " reported version "+payload?.myVersion)
def maker = new I2PDatagramMaker(session) def maker = new I2PDatagramMaker(session)
def response = maker.makeI2PDatagram(json.bytes) def response = maker.makeI2PDatagram(json.bytes)
session.sendMessage(sender, response, I2PSession.PROTO_DATAGRAM, 0, 2) session.sendMessage(sender, response, I2PSession.PROTO_DATAGRAM, 0, 2)