setField("File", file);
}
+ public AddPeer(String identifier, String file) {
+ this(file);
+ setField("Identifier", identifier);
+ }
+
/**
* Creates a new “AddPeer” request that reads the noderef of the peer from
* the given URL.
setField("URL", String.valueOf(url));
}
+ public AddPeer(String identifier, URL url) {
+ this(url);
+ setField("Identifier", identifier);
+ }
+
/**
* Creates a new “AddPeer” request that adds the peer given by the noderef.
*
setNodeRef(nodeRef);
}
+ public AddPeer(String identifier, NodeRef nodeRef) {
+ this(nodeRef);
+ setField("Identifier", identifier);
+ }
+
//
// PRIVATE METHODS
//
* @param payloadInputStream
* The payload
*/
- AllData(FcpMessage receivedMessage, InputStream payloadInputStream) {
+ public AllData(FcpMessage receivedMessage, InputStream payloadInputStream) {
super(receivedMessage);
this.payloadInputStream = payloadInputStream;
}
* @param receivedMessage
* The received message
*/
- CloseConnectionDuplicateClientName(FcpMessage receivedMessage) {
+ public CloseConnectionDuplicateClientName(FcpMessage receivedMessage) {
super(receivedMessage);
}
* @param receivedMessage
* The received message
*/
- ConfigData(FcpMessage receivedMessage) {
+ public ConfigData(FcpMessage receivedMessage) {
super(receivedMessage);
}
* @param receivedMessage
* The received message
*/
- DataFound(FcpMessage receivedMessage) {
+ public DataFound(FcpMessage receivedMessage) {
super(receivedMessage);
}
* @param fcpMessage
* The received message
*/
- EndListPeerNotes(FcpMessage fcpMessage) {
+ public EndListPeerNotes(FcpMessage fcpMessage) {
super(fcpMessage);
}
* @param receivedMessage
* The message that was received
*/
- EndListPeers(FcpMessage receivedMessage) {
+ public EndListPeers(FcpMessage receivedMessage) {
super(receivedMessage);
}
* @param receivedMessage
* The received message
*/
- EndListPersistentRequests(FcpMessage receivedMessage) {
+ public EndListPersistentRequests(FcpMessage receivedMessage) {
super(receivedMessage);
}
* @param payloadInputStream
* The optional input stream for the payload
*/
- FCPPluginReply(FcpMessage receivedMessage, InputStream payloadInputStream) {
+ public FCPPluginReply(FcpMessage receivedMessage, InputStream payloadInputStream) {
super(receivedMessage);
this.payloadInputStream = payloadInputStream;
}
* @param receivedMessage
* The message that was recevied
*/
- FinishedCompression(FcpMessage receivedMessage) {
+ public FinishedCompression(FcpMessage receivedMessage) {
super(receivedMessage);
}
super("GetConfig");
}
+ public GetConfig(String identifer) {
+ this();
+ setField("Identifier", identifer);
+ }
+
/**
* Sets whether the {@link ConfigData} result message shall include the
* current values.
* @param receivedMessage
* The received message
*/
- GetFailed(FcpMessage receivedMessage) {
+ public GetFailed(FcpMessage receivedMessage) {
super(receivedMessage);
}
* <code>true</code> to include volatile data in the noderef
*/
public GetNode(Boolean giveOpennetRef, Boolean withPrivate, Boolean withVolatile) {
+ this(null, giveOpennetRef, withPrivate, withVolatile);
+ }
+
+ public GetNode(String identifier, Boolean giveOpennetRef, Boolean withPrivate, Boolean withVolatile) {
super("GetNode");
+ if (identifier != null) {
+ setField("Identifier", identifier);
+ }
if (giveOpennetRef != null) {
setField("GiveOpennetRef", String.valueOf(giveOpennetRef));
}
*/
public class GetPluginInfo extends FcpMessage {
- /**
- * Creates a new “GetPluginInfo” message.
- *
- * @param pluginName
- * The name of the plugin
- * @param identifier
- * The identifier of the request
- */
- public GetPluginInfo(String pluginName, String identifier) {
+ public GetPluginInfo(String identifier) {
super("GetPluginInfo");
- setField("PluginName", pluginName);
setField("Identifier", identifier);
}
+ public GetPluginInfo(String pluginName, String identifier) {
+ this(identifier);
+ setField("PluginName", pluginName);
+ }
+
+ public void setPluginName(String pluginName) {
+ setField("PluginName", pluginName);
+ }
+
/**
* Sets whether detailed information about the plugin is wanted.
*
* @param receivedMessage
* The received message
*/
- IdentifierCollision(FcpMessage receivedMessage) {
+ public IdentifierCollision(FcpMessage receivedMessage) {
super(receivedMessage);
}
* The identifier of the node to get details about
*/
public ListPeer(String nodeIdentifier) {
+ this(null, nodeIdentifier);
+ }
+
+ public ListPeer(String identifier, String nodeIdentifier) {
super("ListPeer");
+ if (identifier != null) {
+ setField("Identifier", identifier);
+ }
setField("NodeIdentifier", nodeIdentifier);
}
setField("NodeIdentifier", nodeIdentifier);
}
+ public ListPeerNotes(String identifier, String nodeIdentifier) {
+ this(nodeIdentifier);
+ setField("Identifier", identifier);
+ }
+
}
super("ModifyConfig");
}
+ public ModifyConfig(String identifier) {
+ this();
+ setField("Identifier", identifier);
+ }
+
/**
* Sets the option with the given name to the given value.
*
*/
public class ModifyPeer extends FcpMessage {
- /**
- * Creates a new “ModifyPeer” request. All Boolean parameters may be null
- * to not influence the current setting.
- *
- * @param nodeIdentifier
- * The identifier of the node, i.e. name, identity, or IP
- * address and port
- * @param allowLocalAddresses
- * Whether to allow local addresses from this node
- * @param disabled
- * Whether the node is disabled
- * @param listenOnly
- * Whether your node should not try to connect the node
- */
+ public ModifyPeer(String identifier, String nodeIdentifier) {
+ super("ModifyPeer");
+ setField("Identifier", identifier);
+ setField("NodeIdentifier", nodeIdentifier);
+ }
+
+ @Deprecated
public ModifyPeer(String nodeIdentifier, Boolean allowLocalAddresses, Boolean disabled, Boolean listenOnly) {
super("ModifyPeer");
setField("NodeIdentifier", nodeIdentifier);
if (allowLocalAddresses != null) {
- setField("AllowLocalAddresses", String.valueOf(allowLocalAddresses));
+ setAllowLocalAddresses(allowLocalAddresses);
}
if (disabled != null) {
- setField("IsDisabled", String.valueOf(disabled));
+ setEnabled(!disabled);
}
if (listenOnly != null) {
- setField("IsListenOnly", String.valueOf(listenOnly));
+ setListenOnly(listenOnly);
}
}
+ public void setAllowLocalAddresses(boolean allowLocalAddresses) {
+ setField("AllowLocalAddresses", String.valueOf(allowLocalAddresses));
+ }
+
+ public void setEnabled(boolean enabled) {
+ setField("IsDisabled", String.valueOf(!enabled));
+ }
+
+ public void setListenOnly(boolean listenOnly) {
+ setField("IsListenOnly", String.valueOf(listenOnly));
+ }
+
+ public void setBurstOnly(boolean burstOnly) {
+ setField("IsBurstOnly", String.valueOf(burstOnly));
+ }
+
+ public void setIgnoreSource(boolean ignoreSource) {
+ setField("IgnoreSourcePort", String.valueOf(ignoreSource));
+ }
+
}
*/
public class ModifyPeerNote extends FcpMessage {
- /**
- * Creates a new “ModifyPeerNote” request that changes peer note of the
- * given type and node to the given text.
- *
- * @see PeerNote
- * @param nodeIdentifier
- * The identifier of the node, i.e. name, identity, or IP
- * address and port
- * @param noteText
- * The base64-encoded text
- * @param peerNoteType
- * The type of the note to change, possible values are only
- * {@link PeerNote#TYPE_PRIVATE_PEER_NOTE} at the moment
- */
+ public ModifyPeerNote(String identifier, String nodeIdentifier) {
+ super("ModifyPeerNote");
+ setField("Identifier", identifier);
+ setField("NodeIdentifier", nodeIdentifier);
+ }
+
+ @Deprecated
public ModifyPeerNote(String nodeIdentifier, String noteText, int peerNoteType) {
super("ModifyPeer");
setField("NodeIdentifier", nodeIdentifier);
setField("PeerNoteType", String.valueOf(peerNoteType));
}
+ public void setNoteText(String noteText) {
+ setField("NoteText", noteText);
+ }
+
+ public void setPeerNoteType(PeerNoteType peerNoteType) {
+ setField("PeerNoteType", peerNoteType.toString());
+ }
+
}
* @param receivedMessage
* The received message
*/
- NodeData(FcpMessage receivedMessage) {
+ public NodeData(FcpMessage receivedMessage) {
super(receivedMessage);
nodeRef = new NodeRef(receivedMessage);
}
* @param receivedMessage
* The received FCP message
*/
- NodeHello(FcpMessage receivedMessage) {
+ public NodeHello(FcpMessage receivedMessage) {
super(receivedMessage);
}
* @param receivedMessage
* The received message
*/
- Peer(FcpMessage receivedMessage) {
+ public Peer(FcpMessage receivedMessage) {
super(receivedMessage);
}
* @param receivedMessage
* The received message
*/
- PeerNote(FcpMessage receivedMessage) {
+ public PeerNote(FcpMessage receivedMessage) {
super(receivedMessage);
}
* @param receivedMessage
* The received message
*/
- PeerRemoved(FcpMessage receivedMessage) {
+ public PeerRemoved(FcpMessage receivedMessage) {
super(receivedMessage);
}
* @param receivedMessage
* The received message
*/
- PersistentGet(FcpMessage receivedMessage) {
+ public PersistentGet(FcpMessage receivedMessage) {
super(receivedMessage);
}
* @param receivedMessage
* The received message
*/
- PersistentPut(FcpMessage receivedMessage) {
+ public PersistentPut(FcpMessage receivedMessage) {
super(receivedMessage);
}
* @param receivedMessage
* The received message
*/
- PersistentPutDir(FcpMessage receivedMessage) {
+ public PersistentPutDir(FcpMessage receivedMessage) {
super(receivedMessage);
}
* @param receivedMessage
* The received message
*/
- PersistentRequestModified(FcpMessage receivedMessage) {
+ public PersistentRequestModified(FcpMessage receivedMessage) {
super(receivedMessage);
}
* @param receivedMessage
* The received message
*/
- PersistentRequestRemoved(FcpMessage receivedMessage) {
+ public PersistentRequestRemoved(FcpMessage receivedMessage) {
super(receivedMessage);
}
* @param receivedMessage
* The received message
*/
- PluginInfo(FcpMessage receivedMessage) {
+ public PluginInfo(FcpMessage receivedMessage) {
super(receivedMessage);
}
return Boolean.valueOf("Started");
}
+ public boolean isTalkable() {
+ return Boolean.valueOf(getField("IsTalkable"));
+ }
+
+ public String getVersion() {
+ return getField("Version");
+ }
+
+ public String getLongVersion() {
+ return getField("LongVersion");
+ }
}
* @param receivedMessage
* The received message
*/
- ProtocolError(FcpMessage receivedMessage) {
+ public ProtocolError(FcpMessage receivedMessage) {
super(receivedMessage);
}
* @param receivedMessage
* The received message
*/
- PutFailed(FcpMessage receivedMessage) {
+ public PutFailed(FcpMessage receivedMessage) {
super(receivedMessage);
}
* @param receivedMessage
* The received message
*/
- PutFetchable(FcpMessage receivedMessage) {
+ public PutFetchable(FcpMessage receivedMessage) {
super(receivedMessage);
}
* @param receivedMessage
* The received message
*/
- PutSuccessful(FcpMessage receivedMessage) {
+ public PutSuccessful(FcpMessage receivedMessage) {
super(receivedMessage);
}
*/
public class RemovePeer extends FcpMessage {
- /**
- * Creates a new “RemovePeer” command that removes the given peer.
- *
- * @param nodeIdentifier
- * The identifier of the node, i.e. its name, identity, or IP
- * address and port pair
- */
+ @Deprecated
public RemovePeer(String nodeIdentifier) {
super("RemovePeer");
setField("NodeIdentifier", nodeIdentifier);
}
+ public RemovePeer(String identifier, String nodeIdentifier) {
+ this(nodeIdentifier);
+ setField("Identifier", identifier);
+ }
+
}
* @param receivedMessage
* The received message
*/
- SSKKeypair(FcpMessage receivedMessage) {
+ public SSKKeypair(FcpMessage receivedMessage) {
super(receivedMessage);
}
* @param receivedMessage
* The received message
*/
- SimpleProgress(FcpMessage receivedMessage) {
+ public SimpleProgress(FcpMessage receivedMessage) {
super(receivedMessage);
}
return Boolean.valueOf(getField("FinalizedTotal"));
}
+ public long getLastProgress() {
+ return Long.valueOf(getField("LastProgress"));
+ }
+
+ public int getMinSuccessFetchBlocks() {
+ return Integer.valueOf(getField("MinSuccessFetchBlocks"));
+ }
+
/**
* Returns the identifier of the request.
*
* @param receivedMessage
* The received message
*/
- StartedCompression(FcpMessage receivedMessage) {
+ public StartedCompression(FcpMessage receivedMessage) {
super(receivedMessage);
}
*
* @author David ‘Bombe’ Roden <bombe@freenetproject.org>
*/
-public class SubscribeUSK extends FcpMessage {
+public class SubscribeUSK extends FcpMessage implements Identifiable {
- /**
- * Creates a new “SubscribeUSK” message.
- *
- * @param uri
- * The URI to watch for changes
- * @param identifier
- * The identifier of the request
- */
- public SubscribeUSK(String uri, String identifier) {
+ public SubscribeUSK(String identifier) {
super("SubscribeUSK");
- setField("URI", uri);
setField("Identifier", identifier);
}
+ public SubscribeUSK(String uri, String identifier) {
+ this(identifier);
+ setField("URI", uri);
+ }
+
+ @Override
+ public String getIdentifier() {
+ return getField("Identifier");
+ }
+
+ public String getUri() {
+ return getField("URI");
+ }
+
+ public void setUri(String uri) {
+ setField("URI", uri);
+ }
+
+ public boolean isActive() {
+ return !Boolean.parseBoolean(getField("DontPoll"));
+ }
+
/**
* Sets whether updates for the USK are actively searched.
*
setField("DontPoll", String.valueOf(!active));
}
+ public boolean isSparse() {
+ return Boolean.valueOf(getField("SparsePoll"));
+ }
+
+ public void setSparse(boolean sparse) {
+ setField("SparsePoll", String.valueOf(sparse));
+ }
+
+ public Priority getPriority() {
+ String priorityClass = getField("PriorityClass");
+ if (priorityClass != null) {
+ return Priority.valueOf(priorityClass);
+ }
+ return Priority.bulkSplitfile;
+ }
+
+ public void setPriority(Priority priority) {
+ setField("PriorityClass", priority.toString());
+ }
+
+ public Priority getActivePriority() {
+ String priorityClass = getField("PriorityClassProgress");
+ if (priorityClass != null) {
+ return Priority.valueOf(priorityClass);
+ }
+ return Priority.update;
+ }
+
+ public void setActivePriority(Priority activePriority) {
+ setField("PriorityClassProgress", activePriority.toString());
+ }
+
+ public boolean isRealTime() {
+ return Boolean.valueOf(getField("RealTimeFlag"));
+ }
+
+ public void setRealTime(boolean realTime) {
+ setField("RealTimeFlag", String.valueOf(realTime));
+ }
+
+ public boolean isIgnoreDateHints() {
+ return Boolean.valueOf(getField("IgnoreUSKDatehints"));
+ }
+
+ public void setIgnoreDateHints(boolean ignoreDateHints) {
+ setField("IgnoreUSKDatehints", String.valueOf(ignoreDateHints));
+ }
+
}
* @param receivedMessage
* The received message
*/
- SubscribedUSKUpdate(FcpMessage receivedMessage) {
+ public SubscribedUSKUpdate(FcpMessage receivedMessage) {
super(receivedMessage);
}
* @param receivedMessage
* The received message
*/
- TestDDAComplete(FcpMessage receivedMessage) {
+ public TestDDAComplete(FcpMessage receivedMessage) {
super(receivedMessage);
}
* @param receivedMessage
* The received message
*/
- TestDDAReply(FcpMessage receivedMessage) {
+ public TestDDAReply(FcpMessage receivedMessage) {
super(receivedMessage);
}
* @param receivedMessage
* The received message
*/
- URIGenerated(FcpMessage receivedMessage) {
+ public URIGenerated(FcpMessage receivedMessage) {
super(receivedMessage);
}
* @param receivedMessage
* The received message
*/
- UnknownNodeIdentifier(FcpMessage receivedMessage) {
+ public UnknownNodeIdentifier(FcpMessage receivedMessage) {
super(receivedMessage);
}
projects / jFCPlib.git / commitdiff