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

[bato...@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);
                        }