[freenet-cvs] r15799 - in trunk/plugins: . HelloFCP

[sa...@freenetproject.org]

Author: saces
Date: 2007-11-17 12:29:18 +0000 (Sat, 17 Nov 2007)
New Revision: 15799

Added:
   trunk/plugins/HelloFCP/
   trunk/plugins/HelloFCP/HelloFCP.java
   trunk/plugins/HelloFCP/PingMessage.java
   trunk/plugins/HelloFCP/PongMessage.java
Log:
hello world - fcp plugin

Added: trunk/plugins/HelloFCP/HelloFCP.java
===================================================================
--- trunk/plugins/HelloFCP/HelloFCP.java                                (rev 0)
+++ trunk/plugins/HelloFCP/HelloFCP.java        2007-11-17 12:29:18 UTC (rev 
15799)
@@ -0,0 +1,34 @@
+/**
+ * 
+ */
+package plugins.HelloFCP;
+
+import freenet.node.fcp.FCPMessage;
+import freenet.pluginmanager.FredPlugin;
+import freenet.pluginmanager.FredPluginFCP;
+import freenet.pluginmanager.FredPluginThreadless;
+import freenet.pluginmanager.PluginRespirator;
+import freenet.support.SimpleFieldSet;
+
+/**
+ * @author saces
+ *
+ */
+public class HelloFCP implements FredPlugin, FredPluginThreadless, 
FredPluginFCP {
+
+       public void runPlugin(PluginRespirator pr) {
+               
+       }
+
+       public void terminate() {
+               
+       }
+
+       public FCPMessage create(String name, SimpleFieldSet fs) {
+               if(name.equals(PingMessage.name))
+                       return new PingMessage(fs);
+               
+               return null;
+       }
+
+}

Added: trunk/plugins/HelloFCP/PingMessage.java
===================================================================
--- trunk/plugins/HelloFCP/PingMessage.java                             (rev 0)
+++ trunk/plugins/HelloFCP/PingMessage.java     2007-11-17 12:29:18 UTC (rev 
15799)
@@ -0,0 +1,35 @@
+/**
+ * 
+ */
+package plugins.HelloFCP;
+
+import freenet.node.Node;
+import freenet.node.fcp.FCPConnectionHandler;
+import freenet.node.fcp.FCPMessage;
+import freenet.node.fcp.MessageInvalidException;
+import freenet.support.SimpleFieldSet;
+
+/**
+ * @author saces
+ *
+ */
+public class PingMessage extends FCPMessage {
+       public static String name = "Ping";
+
+       public PingMessage(SimpleFieldSet fs) {
+               
+       }
+
+       public SimpleFieldSet getFieldSet() {
+               return null;
+       }
+
+       public String getName() {
+               return name;
+       }
+
+       public void run(FCPConnectionHandler handler, Node node) throws 
MessageInvalidException {
+               handler.outputHandler.queue(new PongMessage()); 
+       }
+
+}

Added: trunk/plugins/HelloFCP/PongMessage.java
===================================================================
--- trunk/plugins/HelloFCP/PongMessage.java                             (rev 0)
+++ trunk/plugins/HelloFCP/PongMessage.java     2007-11-17 12:29:18 UTC (rev 
15799)
@@ -0,0 +1,35 @@
+/**
+ * 
+ */
+package plugins.HelloFCP;
+
+import freenet.node.Node;
+import freenet.node.fcp.FCPConnectionHandler;
+import freenet.node.fcp.FCPMessage;
+import freenet.node.fcp.MessageInvalidException;
+import freenet.node.fcp.ProtocolErrorMessage;
+import freenet.support.SimpleFieldSet;
+
+/**
+ * @author saces
+ *
+ */
+public class PongMessage extends FCPMessage {
+       public static String name = "Pong";
+
+       public SimpleFieldSet getFieldSet() {
+               SimpleFieldSet sfs = new SimpleFieldSet(true);
+               sfs.putSingle("Hello", "FCP");
+               sfs.putSingle("World", "mine!!");
+               return sfs;
+       }
+
+       public String getName() {
+               return name;
+       }
+
+       public void run(FCPConnectionHandler handler, Node node) throws 
MessageInvalidException {
+               throw new 
MessageInvalidException(ProtocolErrorMessage.INVALID_MESSAGE, name + " goes 
from server to client not the other way around", name, false);
+       }
+
+}