313 lines
14 KiB
Java
313 lines
14 KiB
Java
|
package net.i2p.data.i2np;
|
||
|
|
/*
|
||
|
|
* free (adj.): unencumbered; not under the control of others
|
||
|
|
* Written by jrandom in 2003 and released into the public domain
|
||
|
|
* with no warranty of any kind, either expressed or implied.
|
||
|
|
* It probably won't make your computer catch on fire, or eat
|
||
|
|
* your children, but it might. Use at your own risk.
|
||
|
|
*
|
||
|
|
*/
|
||
|
|
|
||
|
|
import java.io.ByteArrayOutputStream;
|
||
|
|
import java.io.IOException;
|
||
|
|
import java.io.InputStream;
|
||
|
|
|
||
|
|
import net.i2p.data.Certificate;
|
||
|
|
import net.i2p.data.DataFormatException;
|
||
|
|
import net.i2p.data.DataHelper;
|
||
|
|
import net.i2p.data.Hash;
|
||
|
|
import net.i2p.data.TunnelId;
|
||
|
|
import net.i2p.util.Log;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Defines the message sent to a router to request that it participate in a
|
||
|
|
* tunnel using the included configuration settings.
|
||
|
|
*
|
||
|
|
* @author jrandom
|
||
|
|
*/
|
||
|
|
public class TunnelCreateMessage extends I2NPMessageImpl {
|
||
|
|
private final static Log _log = new Log(TunnelCreateMessage.class);
|
||
|
|
public final static int MESSAGE_TYPE = 6;
|
||
|
|
private int _participantType;
|
||
|
|
private Hash _nextRouter;
|
||
|
|
private TunnelId _tunnelId;
|
||
|
|
private long _tunnelDuration;
|
||
|
|
private TunnelConfigurationSessionKey _configKey;
|
||
|
|
private long _maxPeakMessagesPerMin;
|
||
|
|
private long _maxAvgMessagesPerMin;
|
||
|
|
private long _maxPeakBytesPerMin;
|
||
|
|
private long _maxAvgBytesPerMin;
|
||
|
|
private boolean _includeDummyTraffic;
|
||
|
|
private boolean _reorderMessages;
|
||
|
|
private TunnelSigningPublicKey _verificationPubKey;
|
||
|
|
private TunnelSigningPrivateKey _verificationPrivKey;
|
||
|
|
private TunnelSessionKey _tunnelKey;
|
||
|
|
private Certificate _certificate;
|
||
|
|
private SourceRouteBlock _replyBlock;
|
||
|
|
|
||
|
|
public static final int PARTICIPANT_TYPE_GATEWAY = 1;
|
||
|
|
public static final int PARTICIPANT_TYPE_ENDPOINT = 2;
|
||
|
|
public static final int PARTICIPANT_TYPE_OTHER = 3;
|
||
|
|
|
||
|
|
private final static long FLAG_DUMMY = 1 << 7;
|
||
|
|
private final static long FLAG_REORDER = 1 << 6;
|
||
|
|
|
||
|
|
public TunnelCreateMessage() {
|
||
|
|
setParticipantType(-1);
|
||
|
|
setNextRouter(null);
|
||
|
|
setTunnelId(null);
|
||
|
|
setTunnelDurationSeconds(-1);
|
||
|
|
setConfigurationKey(null);
|
||
|
|
setMaxPeakMessagesPerMin(-1);
|
||
|
|
setMaxAvgMessagesPerMin(-1);
|
||
|
|
setMaxPeakBytesPerMin(-1);
|
||
|
|
setMaxAvgBytesPerMin(-1);
|
||
|
|
setIncludeDummyTraffic(false);
|
||
|
|
setReorderMessages(false);
|
||
|
|
setVerificationPublicKey(null);
|
||
|
|
setVerificationPrivateKey(null);
|
||
|
|
setTunnelKey(null);
|
||
|
|
setCertificate(null);
|
||
|
|
setReplyBlock(null);
|
||
|
|
}
|
||
|
|
|
||
|
|
public void setParticipantType(int type) { _participantType = type; }
|
||
|
|
public int getParticipantType() { return _participantType; }
|
||
|
|
public void setNextRouter(Hash routerIdentityHash) { _nextRouter = routerIdentityHash; }
|
||
|
|
public Hash getNextRouter() { return _nextRouter; }
|
||
|
|
public void setTunnelId(TunnelId id) { _tunnelId = id; }
|
||
|
|
public TunnelId getTunnelId() { return _tunnelId; }
|
||
|
|
public void setTunnelDurationSeconds(long durationSeconds) { _tunnelDuration = durationSeconds; }
|
||
|
|
public long getTunnelDurationSeconds() { return _tunnelDuration; }
|
||
|
|
public void setConfigurationKey(TunnelConfigurationSessionKey key) { _configKey = key; }
|
||
|
|
public TunnelConfigurationSessionKey getConfigurationKey() { return _configKey; }
|
||
|
|
public void setMaxPeakMessagesPerMin(long msgs) { _maxPeakMessagesPerMin = msgs; }
|
||
|
|
public long getMaxPeakMessagesPerMin() { return _maxPeakMessagesPerMin; }
|
||
|
|
public void setMaxAvgMessagesPerMin(long msgs) { _maxAvgMessagesPerMin = msgs; }
|
||
|
|
public long getMaxAvgMessagesPerMin() { return _maxAvgMessagesPerMin; }
|
||
|
|
public void setMaxPeakBytesPerMin(long bytes) { _maxPeakBytesPerMin = bytes; }
|
||
|
|
public long getMaxPeakBytesPerMin() { return _maxPeakBytesPerMin; }
|
||
|
|
public void setMaxAvgBytesPerMin(long bytes) { _maxAvgBytesPerMin = bytes; }
|
||
|
|
public long getMaxAvgBytesPerMin() { return _maxAvgBytesPerMin; }
|
||
|
|
public void setIncludeDummyTraffic(boolean include) { _includeDummyTraffic = include; }
|
||
|
|
public boolean getIncludeDummyTraffic() { return _includeDummyTraffic; }
|
||
|
|
public void setReorderMessages(boolean reorder) { _reorderMessages = reorder; }
|
||
|
|
public boolean getReorderMessages() { return _reorderMessages; }
|
||
|
|
public void setVerificationPublicKey(TunnelSigningPublicKey key) { _verificationPubKey = key; }
|
||
|
|
public TunnelSigningPublicKey getVerificationPublicKey() { return _verificationPubKey; }
|
||
|
|
public void setVerificationPrivateKey(TunnelSigningPrivateKey key) { _verificationPrivKey = key; }
|
||
|
|
public TunnelSigningPrivateKey getVerificationPrivateKey() { return _verificationPrivKey; }
|
||
|
|
public void setTunnelKey(TunnelSessionKey key) { _tunnelKey = key; }
|
||
|
|
public TunnelSessionKey getTunnelKey() { return _tunnelKey; }
|
||
|
|
public void setCertificate(Certificate cert) { _certificate = cert; }
|
||
|
|
public Certificate getCertificate() { return _certificate; }
|
||
|
|
public void setReplyBlock(SourceRouteBlock block) { _replyBlock = block; }
|
||
|
|
public SourceRouteBlock getReplyBlock() { return _replyBlock; }
|
||
|
|
|
||
|
|
public void readMessage(InputStream in, int type) throws I2NPMessageException, IOException {
|
||
|
|
if (type != MESSAGE_TYPE) throw new I2NPMessageException("Message type is incorrect for this message");
|
||
|
|
try {
|
||
|
|
_participantType = (int)DataHelper.readLong(in, 1);
|
||
|
|
if (_participantType != PARTICIPANT_TYPE_ENDPOINT) {
|
||
|
|
_nextRouter = new Hash();
|
||
|
|
_nextRouter.readBytes(in);
|
||
|
|
}
|
||
|
|
_tunnelId = new TunnelId();
|
||
|
|
_tunnelId.readBytes(in);
|
||
|
|
_tunnelDuration = DataHelper.readLong(in, 4);
|
||
|
|
_configKey = new TunnelConfigurationSessionKey();
|
||
|
|
_configKey.readBytes(in);
|
||
|
|
_maxPeakMessagesPerMin = DataHelper.readLong(in, 4);
|
||
|
|
_maxAvgMessagesPerMin = DataHelper.readLong(in, 4);
|
||
|
|
_maxPeakBytesPerMin = DataHelper.readLong(in, 4);
|
||
|
|
_maxAvgBytesPerMin = DataHelper.readLong(in, 4);
|
||
|
|
|
||
|
|
int flags = (int)DataHelper.readLong(in, 1);
|
||
|
|
_includeDummyTraffic = flagsIncludeDummy(flags);
|
||
|
|
_reorderMessages = flagsReorder(flags);
|
||
|
|
|
||
|
|
_verificationPubKey = new TunnelSigningPublicKey();
|
||
|
|
_verificationPubKey.readBytes(in);
|
||
|
|
if (_participantType == PARTICIPANT_TYPE_GATEWAY) {
|
||
|
|
_verificationPrivKey = new TunnelSigningPrivateKey();
|
||
|
|
_verificationPrivKey.readBytes(in);
|
||
|
|
}
|
||
|
|
if ( (_participantType == PARTICIPANT_TYPE_ENDPOINT) || (_participantType == PARTICIPANT_TYPE_GATEWAY) ) {
|
||
|
|
_tunnelKey = new TunnelSessionKey();
|
||
|
|
_tunnelKey.readBytes(in);
|
||
|
|
}
|
||
|
|
_certificate = new Certificate();
|
||
|
|
_certificate.readBytes(in);
|
||
|
|
_replyBlock = new SourceRouteBlock();
|
||
|
|
_replyBlock.readBytes(in);
|
||
|
|
} catch (DataFormatException dfe) {
|
||
|
|
throw new I2NPMessageException("Unable to load the message data", dfe);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
protected byte[] writeMessage() throws I2NPMessageException, IOException {
|
||
|
|
ByteArrayOutputStream os = new ByteArrayOutputStream(32);
|
||
|
|
try {
|
||
|
|
DataHelper.writeLong(os, 1, _participantType);
|
||
|
|
if (_participantType != PARTICIPANT_TYPE_ENDPOINT) {
|
||
|
|
_nextRouter.writeBytes(os);
|
||
|
|
}
|
||
|
|
_tunnelId.writeBytes(os);
|
||
|
|
DataHelper.writeLong(os, 4, _tunnelDuration);
|
||
|
|
_configKey.writeBytes(os);
|
||
|
|
|
||
|
|
DataHelper.writeLong(os, 4, _maxPeakMessagesPerMin);
|
||
|
|
DataHelper.writeLong(os, 4, _maxAvgMessagesPerMin);
|
||
|
|
DataHelper.writeLong(os, 4, _maxPeakBytesPerMin);
|
||
|
|
DataHelper.writeLong(os, 4, _maxAvgBytesPerMin);
|
||
|
|
|
||
|
|
long flags = getFlags();
|
||
|
|
DataHelper.writeLong(os, 1, flags);
|
||
|
|
|
||
|
|
_verificationPubKey.writeBytes(os);
|
||
|
|
if (_participantType == PARTICIPANT_TYPE_GATEWAY) {
|
||
|
|
_verificationPrivKey.writeBytes(os);
|
||
|
|
}
|
||
|
|
if ( (_participantType == PARTICIPANT_TYPE_ENDPOINT) || (_participantType == PARTICIPANT_TYPE_GATEWAY) ) {
|
||
|
|
_tunnelKey.writeBytes(os);
|
||
|
|
}
|
||
|
|
_certificate.writeBytes(os);
|
||
|
|
_replyBlock.writeBytes(os);
|
||
|
|
} catch (Throwable t) {
|
||
|
|
throw new I2NPMessageException("Error writing out the message data", t);
|
||
|
|
}
|
||
|
|
/*
|
||
|
|
try {
|
||
|
|
DataHelper.writeLong(os, 1, _participantType);
|
||
|
|
if (_participantType != PARTICIPANT_TYPE_ENDPOINT) {
|
||
|
|
if (_nextRouter == null)
|
||
|
|
throw new I2NPMessageException("Next router is not defined");
|
||
|
|
_nextRouter.writeBytes(os);
|
||
|
|
}
|
||
|
|
if (_tunnelId == null)
|
||
|
|
throw new I2NPMessageException("Tunnel ID is not defined");
|
||
|
|
_tunnelId.writeBytes(os);
|
||
|
|
if (_tunnelDuration < 0)
|
||
|
|
throw new I2NPMessageException("Tunnel duration is negative");
|
||
|
|
DataHelper.writeLong(os, 4, _tunnelDuration);
|
||
|
|
if (_configKey == null)
|
||
|
|
throw new I2NPMessageException("Configuration key is not defined");
|
||
|
|
_configKey.writeBytes(os);
|
||
|
|
if ( (_maxPeakMessagesPerMin < 0) || (_maxAvgMessagesPerMin < 0) ||
|
||
|
|
(_maxAvgMessagesPerMin < 0) || (_maxAvgBytesPerMin < 0) )
|
||
|
|
throw new I2NPMessageException("Negative limits defined");
|
||
|
|
|
||
|
|
long flags = getFlags();
|
||
|
|
DataHelper.writeLong(os, 1, flags);
|
||
|
|
|
||
|
|
if (_verificationPubKey == null)
|
||
|
|
throw new I2NPMessageException("Verification public key is not defined");
|
||
|
|
_verificationPubKey.writeBytes(os);
|
||
|
|
if (_participantType == PARTICIPANT_TYPE_GATEWAY) {
|
||
|
|
if (_verificationPrivKey == null)
|
||
|
|
throw new I2NPMessageException("Verification private key is needed and not defined");
|
||
|
|
_verificationPrivKey.writeBytes(os);
|
||
|
|
}
|
||
|
|
if ( (_participantType == PARTICIPANT_TYPE_ENDPOINT) || (_participantType == PARTICIPANT_TYPE_GATEWAY) ) {
|
||
|
|
if (_tunnelKey == null)
|
||
|
|
throw new I2NPMessageException("Tunnel key is needed and not defined");
|
||
|
|
_tunnelKey.writeBytes(os);
|
||
|
|
}
|
||
|
|
if (_certificate == null)
|
||
|
|
throw new I2NPMessageException("Certificate is not defined");
|
||
|
|
_certificate.writeBytes(os);
|
||
|
|
if (_replyBlock == null)
|
||
|
|
throw new I2NPMessageException("Reply block not defined");
|
||
|
|
_replyBlock.writeBytes(os);
|
||
|
|
} catch (DataFormatException dfe) {
|
||
|
|
throw new I2NPMessageException("Error writing out the message data", dfe);
|
||
|
|
}
|
||
|
|
*/
|
||
|
|
return os.toByteArray();
|
||
|
|
}
|
||
|
|
|
||
|
|
private boolean flagsIncludeDummy(long flags) {
|
||
|
|
return (0 != (flags & FLAG_DUMMY));
|
||
|
|
}
|
||
|
|
private boolean flagsReorder(long flags) {
|
||
|
|
return (0 != (flags & FLAG_REORDER));
|
||
|
|
}
|
||
|
|
|
||
|
|
private long getFlags() {
|
||
|
|
long val = 0L;
|
||
|
|
if (getIncludeDummyTraffic())
|
||
|
|
val = val | FLAG_DUMMY;
|
||
|
|
if (getReorderMessages())
|
||
|
|
val = val | FLAG_REORDER;
|
||
|
|
return val;
|
||
|
|
}
|
||
|
|
|
||
|
|
public int getType() { return MESSAGE_TYPE; }
|
||
|
|
|
||
|
|
public int hashCode() {
|
||
|
|
return (int)(DataHelper.hashCode(getCertificate()) +
|
||
|
|
DataHelper.hashCode(getConfigurationKey()) +
|
||
|
|
DataHelper.hashCode(getNextRouter()) +
|
||
|
|
DataHelper.hashCode(getReplyBlock()) +
|
||
|
|
DataHelper.hashCode(getTunnelId()) +
|
||
|
|
DataHelper.hashCode(getTunnelKey()) +
|
||
|
|
DataHelper.hashCode(getVerificationPrivateKey()) +
|
||
|
|
DataHelper.hashCode(getVerificationPublicKey()) +
|
||
|
|
(getIncludeDummyTraffic() ? 1 : 0) +
|
||
|
|
getMaxAvgBytesPerMin() +
|
||
|
|
getMaxAvgMessagesPerMin() +
|
||
|
|
getMaxPeakBytesPerMin() +
|
||
|
|
getMaxPeakMessagesPerMin() +
|
||
|
|
getParticipantType() +
|
||
|
|
(getReorderMessages() ? 1 : 0) +
|
||
|
|
getTunnelDurationSeconds());
|
||
|
|
}
|
||
|
|
|
||
|
|
public boolean equals(Object object) {
|
||
|
|
if ( (object != null) && (object instanceof TunnelCreateMessage) ) {
|
||
|
|
TunnelCreateMessage msg = (TunnelCreateMessage)object;
|
||
|
|
return DataHelper.eq(getCertificate(), msg.getCertificate()) &&
|
||
|
|
DataHelper.eq(getConfigurationKey(), msg.getConfigurationKey()) &&
|
||
|
|
DataHelper.eq(getNextRouter(), msg.getNextRouter()) &&
|
||
|
|
DataHelper.eq(getReplyBlock(), msg.getReplyBlock()) &&
|
||
|
|
DataHelper.eq(getTunnelId(), msg.getTunnelId()) &&
|
||
|
|
DataHelper.eq(getTunnelKey(), msg.getTunnelKey()) &&
|
||
|
|
DataHelper.eq(getVerificationPrivateKey(), msg.getVerificationPrivateKey()) &&
|
||
|
|
DataHelper.eq(getVerificationPublicKey(), msg.getVerificationPublicKey()) &&
|
||
|
|
(getIncludeDummyTraffic() == msg.getIncludeDummyTraffic()) &&
|
||
|
|
(getMaxAvgBytesPerMin() == msg.getMaxAvgBytesPerMin()) &&
|
||
|
|
(getMaxAvgMessagesPerMin() == msg.getMaxAvgMessagesPerMin()) &&
|
||
|
|
(getMaxPeakBytesPerMin() == msg.getMaxPeakBytesPerMin()) &&
|
||
|
|
(getMaxPeakMessagesPerMin() == msg.getMaxPeakMessagesPerMin()) &&
|
||
|
|
(getParticipantType() == msg.getParticipantType()) &&
|
||
|
|
(getReorderMessages() == msg.getReorderMessages()) &&
|
||
|
|
(getTunnelDurationSeconds() == msg.getTunnelDurationSeconds());
|
||
|
|
} else {
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public String toString() {
|
||
|
|
StringBuffer buf = new StringBuffer();
|
||
|
|
buf.append("[TunnelCreateMessage: ");
|
||
|
|
buf.append("\n\tParticipant Type: ").append(getParticipantType());
|
||
|
|
buf.append("\n\tCertificate: ").append(getCertificate());
|
||
|
|
buf.append("\n\tConfiguration Key: ").append(getConfigurationKey());
|
||
|
|
buf.append("\n\tNext Router: ").append(getNextRouter());
|
||
|
|
buf.append("\n\tReply Block: ").append(getReplyBlock());
|
||
|
|
buf.append("\n\tTunnel ID: ").append(getTunnelId());
|
||
|
|
buf.append("\n\tTunnel Key: ").append(getTunnelKey());
|
||
|
|
buf.append("\n\tVerification Private Key: ").append(getVerificationPrivateKey());
|
||
|
|
buf.append("\n\tVerification Public Key: ").append(getVerificationPublicKey());
|
||
|
|
buf.append("\n\tInclude Dummy Traffic: ").append(getIncludeDummyTraffic());
|
||
|
|
buf.append("\n\tMax Avg Bytes / Minute: ").append(getMaxAvgBytesPerMin());
|
||
|
|
buf.append("\n\tMax Peak Bytes / Minute: ").append(getMaxPeakBytesPerMin());
|
||
|
|
buf.append("\n\tMax Avg Messages / Minute: ").append(getMaxAvgMessagesPerMin());
|
||
|
|
buf.append("\n\tMax Peak Messages / Minute: ").append(getMaxPeakMessagesPerMin());
|
||
|
|
buf.append("\n\tReorder Messages: ").append(getReorderMessages());
|
||
|
|
buf.append("\n\tTunnel Duration (seconds): ").append(getTunnelDurationSeconds());
|
||
|
|
buf.append("]");
|
||
|
|
return buf.toString();
|
||
|
|
}
|
||
|
|
}
|