[freenet-cvs] r20081 - trunk/apps/WoT/src/plugins/WoT

[batosai at freenetproject.org]

Author: batosai
Date: 2008-05-23 19:16:28 +0000 (Fri, 23 May 2008)
New Revision: 20081

Modified:
   trunk/apps/WoT/src/plugins/WoT/IdentityInserter.java
   trunk/apps/WoT/src/plugins/WoT/OwnIdentity.java
   trunk/apps/WoT/src/plugins/WoT/WoT.java
Log:
Pass the FCP connection to the insert thread so it can insert identities.

Modified: trunk/apps/WoT/src/plugins/WoT/IdentityInserter.java
===================================================================
--- trunk/apps/WoT/src/plugins/WoT/IdentityInserter.java	2008-05-23 18:18:25 UTC (rev 20080)
+++ trunk/apps/WoT/src/plugins/WoT/IdentityInserter.java	2008-05-23 19:16:28 UTC (rev 20081)
@@ -8,6 +8,8 @@
 import java.util.Iterator;
 import java.util.List;
 
+import net.pterodactylus.fcp.FcpConnection;
+
 import com.db4o.ObjectContainer;
 import com.db4o.query.Predicate;
 
@@ -19,6 +21,7 @@
 public class IdentityInserter implements Runnable{
 	
 	private ObjectContainer db;
+	private FcpConnection fcp;
 	private Thread inserter;
 	
 	/**
@@ -26,8 +29,9 @@
 	 * 
 	 * @param db Connection to the database
 	 */
-	public IdentityInserter(ObjectContainer db) {
+	public IdentityInserter(ObjectContainer db, FcpConnection fcp) {
 		this.db = db;
+		this.fcp = fcp;
 	}
 	
 	/**
@@ -47,7 +51,7 @@
 			
 			while(it.hasNext()) {
 				OwnIdentity identityToInsert = it.next();
-				//TODO Insert the identity
+				identityToInsert.insert(fcp);
 			}
 			
 			try {

Modified: trunk/apps/WoT/src/plugins/WoT/OwnIdentity.java
===================================================================
--- trunk/apps/WoT/src/plugins/WoT/OwnIdentity.java	2008-05-23 18:18:25 UTC (rev 20080)
+++ trunk/apps/WoT/src/plugins/WoT/OwnIdentity.java	2008-05-23 19:16:28 UTC (rev 20081)
@@ -141,6 +141,10 @@
 		fos.close();
 	}
 	
+	public void insert(FcpConnection fcp) {
+		//TODO Export and insert the identity
+	}
+	
 	/**
 	 *  
 	 * @return Whether the identity has been updated since the last insert

Modified: trunk/apps/WoT/src/plugins/WoT/WoT.java
===================================================================
--- trunk/apps/WoT/src/plugins/WoT/WoT.java	2008-05-23 18:18:25 UTC (rev 20080)
+++ trunk/apps/WoT/src/plugins/WoT/WoT.java	2008-05-23 19:16:28 UTC (rev 20081)
@@ -59,7 +59,7 @@
 		initFCPConnection(host, port);
 		db = Db4o.openFile("WoT.db4o");
 
-		identityInserter = new IdentityInserter(db);
+		identityInserter = new IdentityInserter(db, fcp);
 		identityInserter.start();
 		
 	}