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

[batosai at freenetproject.org]

Author: batosai
Date: 2008-05-23 15:10:19 +0000 (Fri, 23 May 2008)
New Revision: 20064

Modified:
   trunk/apps/WoT/src/plugins/WoT/IdentityInserter.java
Log:
Use of db4o's native requests.

Modified: trunk/apps/WoT/src/plugins/WoT/IdentityInserter.java
===================================================================
--- trunk/apps/WoT/src/plugins/WoT/IdentityInserter.java	2008-05-23 14:49:33 UTC (rev 20063)
+++ trunk/apps/WoT/src/plugins/WoT/IdentityInserter.java	2008-05-23 15:10:19 UTC (rev 20064)
@@ -5,10 +5,12 @@
  */
 package plugins.WoT;
 
-import java.util.Date;
+import java.util.Iterator;
+import java.util.List;
 
 import com.db4o.ObjectContainer;
 import com.db4o.ObjectSet;
+import com.db4o.query.Predicate;
 
 /**
  * @author Julien Cornuwel (batosai at batosai.net) 0x61917D90
@@ -37,13 +39,19 @@
 
 		while(Thread.currentThread() == inserter) {
 			
-			//TODO Rewrite this so we only get identities that need to be inserted
-			identities = db.query(OwnIdentity.class);
-			while(identities.hasNext()) {
-				OwnIdentity id = identities.next();
-				System.out.println(id.needsInsert());
-				id.setLastInsert(new Date());
+			List<OwnIdentity> identitiesToInsert = db.query(new Predicate<OwnIdentity> () {
+				public boolean match (OwnIdentity identity) {
+					return (identity.needsInsert());
+				}
+			});
+			
+			Iterator<OwnIdentity> it = identitiesToInsert.iterator();
+			
+			while(it.hasNext()) {
+				OwnIdentity identityToInsert = it.next();
+				//TODO Insert the identity
 			}
+			
 			try {
 				Thread.sleep(1000);
 			}